| /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */ |
| /** |
| * Copyright (c) 2013-2014, Regents of the University of California. |
| * All rights reserved. |
| * |
| * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions). |
| * See AUTHORS.md for complete list of ndn-cxx authors and contributors. |
| * |
| * This file licensed under New BSD License. See COPYING for detailed information about |
| * ndn-cxx library copyright, permissions, and redistribution restrictions. |
| */ |
| |
| #include "common.hpp" |
| |
| #include "tcp-transport.hpp" |
| #include "stream-transport.hpp" |
| |
| namespace ndn { |
| |
| TcpTransport::TcpTransport(const std::string& host, const std::string& port/* = "6363"*/) |
| : m_host(host) |
| , m_port(port) |
| { |
| } |
| |
| TcpTransport::~TcpTransport() |
| { |
| } |
| |
| void |
| TcpTransport::connect(boost::asio::io_service& ioService, |
| const ReceiveCallback& receiveCallback) |
| { |
| if (!static_cast<bool>(m_impl)) { |
| Transport::connect(ioService, receiveCallback); |
| |
| m_impl = make_shared<Impl>(ref(*this), ref(ioService)); |
| } |
| |
| boost::asio::ip::tcp::resolver::query query(m_host, m_port); |
| m_impl->connect(query); |
| } |
| |
| void |
| TcpTransport::send(const Block& wire) |
| { |
| m_impl->send(wire); |
| } |
| |
| void |
| TcpTransport::send(const Block& header, const Block& payload) |
| { |
| m_impl->send(header, payload); |
| } |
| |
| void |
| TcpTransport::close() |
| { |
| m_impl->close(); |
| } |
| |
| void |
| TcpTransport::pause() |
| { |
| m_impl->pause(); |
| } |
| |
| void |
| TcpTransport::resume() |
| { |
| m_impl->resume(); |
| } |
| |
| } // namespace ndn |