udp-channel.hpp

Go to the documentation of this file.

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

#include "channel.hpp"

namespace nfd {

namespace udp {
typedef boost::asio::ip::udp::endpoint Endpoint;
} // namespace udp

class UdpFace;

class UdpChannel : public Channel
{
public:
  UdpChannel(const udp::Endpoint& localEndpoint,
             const time::seconds& timeout);

  void
  listen(const FaceCreatedCallback& onFaceCreated,
         const ConnectFailedCallback& onReceiveFailed);

  void
  connect(const udp::Endpoint& remoteEndpoint,
          ndn::nfd::FacePersistency persistency,
          const FaceCreatedCallback& onFaceCreated,
          const ConnectFailedCallback& onConnectFailed);

  size_t
  size() const;

  bool
  isListening() const;

private:
  std::pair<bool, shared_ptr<UdpFace>>
  createFace(const udp::Endpoint& remoteEndpoint, ndn::nfd::FacePersistency persistency);

  void
  handleNewPeer(const boost::system::error_code& error,
                size_t nBytesReceived,
                const FaceCreatedCallback& onFaceCreated,
                const ConnectFailedCallback& onReceiveFailed);

private:
  std::map<udp::Endpoint, shared_ptr<UdpFace>> m_channelFaces;

  udp::Endpoint m_localEndpoint;

  udp::Endpoint m_remoteEndpoint;

  boost::asio::ip::udp::socket m_socket;

  time::seconds m_idleFaceTimeout;

  uint8_t m_inputBuffer[ndn::MAX_NDN_PACKET_SIZE];
};

inline bool
UdpChannel::isListening() const
{
  return m_socket.is_open();
}

} // namespace nfd

#endif // NFD_DAEMON_FACE_UDP_CHANNEL_HPP