async-tcp-transport.hpp

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

#include <string>
#include "../common.hpp"
#include "../c/encoding/element-reader-types.h"
#include "transport.hpp"

namespace boost { namespace asio { class io_service; }}

namespace ndn {

class AsyncTcpTransport : public Transport {
public:
  class ConnectionInfo : public Transport::ConnectionInfo {
  public:
    ConnectionInfo(const char *host, unsigned short port = 6363)
    : host_(host), port_(port)
    {
    }

    const std::string&
    getHost() const { return host_; }

    unsigned short
    getPort() const { return port_; }

    virtual
    ~ConnectionInfo();

  private:
    std::string host_;
    unsigned short port_;
  };

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

  virtual bool
  isLocal(const Transport::ConnectionInfo& connectionInfo);

  virtual bool
  isAsync();

  virtual void
  connect
    (const Transport::ConnectionInfo& connectionInfo,
     ElementListener& elementListener, const OnConnected& onConnected);

  virtual void
  send(const uint8_t *data, size_t dataLength);

  virtual void
  processEvents();

  virtual bool
  getIsConnected();

  virtual void
  close();

  virtual ~AsyncTcpTransport();

private:
  boost::asio::io_service& ioService_;
  // We define SocketTransport in the source file so that we don't have to
  // include the Boost headers for boost::asio::ip::tcp in this header file.
  // (We cannot forward declare ip::tcp itself because it is an inner class.)
  class SocketTransport;
  ptr_lib::shared_ptr<SocketTransport> socketTransport_;
  ConnectionInfo connectionInfo_;
  bool isLocal_;
};

}

#endif