socket_producer.h

/*
 * Copyright (c) 2017-2019 Cisco and/or its affiliates.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at:
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#pragma once
 
#include <hicn/transport/auth/signer.h>
#include <hicn/transport/config.h>
#include <hicn/transport/core/asio_wrapper.h>
#include <hicn/transport/core/name.h>
#include <hicn/transport/core/prefix.h>
#include <hicn/transport/interfaces/callbacks.h>
#include <hicn/transport/interfaces/socket_options_default_values.h>
#include <hicn/transport/interfaces/socket_options_keys.h>
 
namespace transport {
 
namespace implementation {
class ProducerSocket;
}
 
namespace interface {
 
using namespace core;
 
class ProducerSocket {
 public:
  explicit ProducerSocket(
      int protocol = ProductionProtocolAlgorithms::BYTE_STREAM);
 
  explicit ProducerSocket(int protocol, asio::io_service &io_service);
 
  virtual ~ProducerSocket();
 
  void connect();
 
  bool isRunning();
 
  void registerPrefix(const Prefix &producer_namespace);
 
  uint32_t produceStream(const Name &content_name, const uint8_t *buffer,
                         size_t buffer_size, bool is_last = true,
                         uint32_t start_offset = 0);
 
  uint32_t produceStream(const Name &content_name,
                         std::unique_ptr<utils::MemBuf> &&buffer,
                         bool is_last = true, uint32_t start_offset = 0);
 
  uint32_t produceDatagram(const Name &content_name, const uint8_t *buffer,
                           size_t buffer_size);
 
  uint32_t produceDatagram(const Name &content_name,
                           std::unique_ptr<utils::MemBuf> &&buffer);
 
  void asyncProduce(const Name &suffix, const uint8_t *buf, size_t buffer_size,
                    bool is_last = true, uint32_t *start_offset = nullptr);
 
  void asyncProduce(Name content_name, std::unique_ptr<utils::MemBuf> &&buffer,
                    bool is_last, uint32_t offset,
                    uint32_t **last_segment = nullptr);
 
  void produce(ContentObject &content_object);
 
  void serveForever();
 
  void stop();
 
  asio::io_service &getIoService();
 
  int setSocketOption(int socket_option_key, uint32_t socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      std::nullptr_t socket_option_value);
 
  int setSocketOption(int socket_option_key, bool socket_option_value);
 
  int setSocketOption(int socket_option_key, Name *socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      std::list<Prefix> socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      ProducerContentObjectCallback socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      ProducerInterestCallback socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      ProducerContentCallback socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      auth::CryptoHashType socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      auth::CryptoSuite socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      const std::shared_ptr<auth::Signer> &socket_option_value);
 
  int setSocketOption(int socket_option_key,
                      const std::string &socket_option_value);
 
  int getSocketOption(int socket_option_key, uint32_t &socket_option_value);
 
  int getSocketOption(int socket_option_key, bool &socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      std::list<Prefix> &socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      ProducerContentObjectCallback **socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      ProducerContentCallback **socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      ProducerInterestCallback **socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      auth::CryptoHashType &socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      auth::CryptoSuite &socket_option_value);
 
  int getSocketOption(int socket_option_key,
                      std::shared_ptr<auth::Signer> &socket_option_value);
 
  int getSocketOption(int socket_option_key, std::string &socket_option_value);
 
 protected:
  ProducerSocket(bool);
  std::unique_ptr<implementation::ProducerSocket> socket_;
};
 
}  // namespace interface
 
}  // namespace transport