threadsafe-face.hpp

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */
#ifndef NDN_THREADSAFE_FACE_HPP
#define NDN_THREADSAFE_FACE_HPP

#include "face.hpp"

namespace boost { namespace asio { class io_service; }}

namespace ndn {

class ThreadsafeFace : public Face {
public:
  ThreadsafeFace
    (boost::asio::io_service& ioService,
     const ptr_lib::shared_ptr<Transport>& transport,
     const ptr_lib::shared_ptr<const Transport::ConnectionInfo>& connectionInfo);

  ThreadsafeFace
    (boost::asio::io_service& ioService, const char *host,
     unsigned short port = 6363);

  ThreadsafeFace(boost::asio::io_service& ioService);

  virtual uint64_t
  expressInterest
    (const Interest& interest, const OnData& onData,
     const OnTimeout& onTimeout, const OnNetworkNack& onNetworkNack,
     WireFormat& wireFormat = *WireFormat::getDefaultWireFormat());

  virtual uint64_t
  expressInterest
    (const Name& name, const Interest *interestTemplate, const OnData& onData,
     const OnTimeout& onTimeout, const OnNetworkNack& onNetworkNack,
     WireFormat& wireFormat = *WireFormat::getDefaultWireFormat());

  uint64_t
  expressInterest
    (const Name& name, const OnData& onData, const OnTimeout& onTimeout = OnTimeout(),
     WireFormat& wireFormat = *WireFormat::getDefaultWireFormat())
  {
    // This is needed, otherwise C++ will use the signature with
    // const Interest& by automatically converting the Name to an Interest
    // using the constructor Interest(const Name& name). Just call the Face
    // method with the same signature as this.
    return Face::expressInterest(name, onData, onTimeout, wireFormat);
  }

  virtual void
  removePendingInterest(uint64_t pendingInterestId);

  virtual uint64_t
  registerPrefix
    (const Name& prefix, const OnInterestCallback& onInterest,
     const OnRegisterFailed& onRegisterFailed,
     const OnRegisterSuccess& onRegisterSuccess,
     const ForwardingFlags& flags = ForwardingFlags(),
     WireFormat& wireFormat = *WireFormat::getDefaultWireFormat());

  uint64_t
  registerPrefix
    (const Name& prefix, const OnInterestCallback& onInterest,
     const OnRegisterFailed& onRegisterFailed,
     const ForwardingFlags& flags,
     WireFormat& wireFormat = *WireFormat::getDefaultWireFormat())
  {
    // This is needed, otherwise C++ will try to use the signature with
    // const OnRegisterSuccess&. Just call the Face method with the same
    // signature as this.
    return Face::registerPrefix
      (prefix, onInterest, onRegisterFailed, flags, wireFormat);
  }

  uint64_t
  registerPrefix
    (const Name& prefix, const OnInterestCallback& onInterest,
     const OnRegisterFailed& onRegisterFailed)
  {
    // This is needed, otherwise C++ will try to use the signature with
    // const OnRegisterSuccess&. Just call the Face method with the same
    // signature as this.
    return Face::registerPrefix(prefix, onInterest, onRegisterFailed);
  }

  virtual void
  removeRegisteredPrefix(uint64_t registeredPrefixId);

  virtual uint64_t
  setInterestFilter
    (const InterestFilter& filter, const OnInterestCallback& onInterest);

  virtual uint64_t
  setInterestFilter(const Name& prefix, const OnInterestCallback& onInterest);

  virtual void
  unsetInterestFilter(uint64_t interestFilterId);

  virtual void
  send(const uint8_t *encoding, size_t encodingLength);

  virtual void
  shutdown();

  virtual void
  callLater(Milliseconds delayMilliseconds, const Callback& callback);

private:
  static ptr_lib::shared_ptr<Transport>
  getDefaultTransport(boost::asio::io_service& ioService);

  static ptr_lib::shared_ptr<Transport::ConnectionInfo>
  getDefaultConnectionInfo();

  boost::asio::io_service& ioService_;
};

}

#endif