tcp-transport.cpp
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2 /*
3  * Copyright (c) 2013-2022 Regents of the University of California.
4  *
5  * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
6  *
7  * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8  * terms of the GNU Lesser General Public License as published by the Free Software
9  * Foundation, either version 3 of the License, or (at your option) any later version.
10  *
11  * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13  * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14  *
15  * You should have received copies of the GNU General Public License and GNU Lesser
16  * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17  * <http://www.gnu.org/licenses/>.
18  *
19  * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
20  */
21 
24 #include "ndn-cxx/net/face-uri.hpp"
25 #include "ndn-cxx/util/logger.hpp"
26 
28 // DEBUG level: connect, close, pause, resume.
29 
30 namespace ndn {
31 
32 TcpTransport::TcpTransport(const std::string& host, const std::string& port/* = "6363"*/)
33  : m_host(host)
34  , m_port(port)
35 {
36 }
37 
38 TcpTransport::~TcpTransport() = default;
39 
40 shared_ptr<TcpTransport>
41 TcpTransport::create(const std::string& uri)
42 {
43  const auto hostAndPort(getSocketHostAndPortFromUri(uri));
44  return make_shared<TcpTransport>(hostAndPort.first, hostAndPort.second);
45 }
46 
47 std::pair<std::string, std::string>
48 TcpTransport::getSocketHostAndPortFromUri(const std::string& uriString)
49 {
50  std::string host = "localhost";
51  std::string port = "6363";
52 
53  if (uriString.empty()) {
54  return {host, port};
55  }
56 
57  try {
58  const FaceUri uri(uriString);
59 
60  const std::string scheme = uri.getScheme();
61  if (scheme != "tcp" && scheme != "tcp4" && scheme != "tcp6") {
62  NDN_THROW(Error("Cannot create TcpTransport from \"" + scheme + "\" URI"));
63  }
64 
65  if (!uri.getHost().empty()) {
66  host = uri.getHost();
67  }
68 
69  if (!uri.getPort().empty()) {
70  port = uri.getPort();
71  }
72  }
73  catch (const FaceUri::Error& error) {
74  NDN_THROW_NESTED(Error(error.what()));
75  }
76 
77  return {host, port};
78 }
79 
80 void
81 TcpTransport::connect(boost::asio::io_service& ioService, ReceiveCallback receiveCallback)
82 {
83  NDN_LOG_DEBUG("connect host=" << m_host << " port=" << m_port);
84 
85  if (m_impl == nullptr) {
86  Transport::connect(ioService, std::move(receiveCallback));
87  m_impl = make_shared<Impl>(*this, ioService);
88  }
89 
90  boost::asio::ip::tcp::resolver::query query(m_host, m_port);
91  m_impl->connect(query);
92 }
93 
94 void
96 {
97  BOOST_ASSERT(m_impl != nullptr);
98  m_impl->send(wire);
99 }
100 
101 void
103 {
104  BOOST_ASSERT(m_impl != nullptr);
105  NDN_LOG_DEBUG("close");
106  m_impl->close();
107  m_impl.reset();
108 }
109 
110 void
112 {
113  if (m_impl != nullptr) {
114  NDN_LOG_DEBUG("pause");
115  m_impl->pause();
116  }
117 }
118 
119 void
121 {
122  BOOST_ASSERT(m_impl != nullptr);
123  NDN_LOG_DEBUG("resume");
124  m_impl->resume();
125 }
126 
127 } // namespace ndn
Represents a TLV element of the NDN packet format.
Definition: block.hpp:45
A transport using TCP socket.
TcpTransport(const std::string &host, const std::string &port="6363")
void send(const Block &wire) override
Send a TLV block through the transport.
void pause() override
Pause the transport, canceling all pending operations.
static shared_ptr< TcpTransport > create(const std::string &uri)
Create transport with parameters defined in URI.
~TcpTransport() override
void close() override
Close the connection.
void resume() override
Resume the transport.
void connect(boost::asio::io_service &ioService, ReceiveCallback receiveCallback) override
Asynchronously open the connection.
std::function< void(const Block &)> ReceiveCallback
Definition: transport.hpp:54
virtual void connect(boost::asio::io_service &ioService, ReceiveCallback receiveCallback)
Asynchronously open the connection.
Definition: transport.cpp:32
#define NDN_THROW_NESTED(e)
Definition: exception.hpp:71
#define NDN_THROW(e)
Definition: exception.hpp:61
#define NDN_LOG_DEBUG(expression)
Log at DEBUG level.
Definition: logger.hpp:254
#define NDN_LOG_INIT(name)
Define a non-member log module.
Definition: logger.hpp:163
Definition: data.cpp:25