28 #include <ndn-cxx/net/address-converter.hpp> 33 namespace ip = boost::asio::ip;
41 static std::string id(
"tcp");
65 if (!context.
isDryRun && !m_channels.empty()) {
66 NFD_LOG_WARN(
"Cannot disable tcp4 and tcp6 channels after initialization");
71 bool wantListen =
true;
76 for (
const auto& pair : *configSection) {
77 const std::string& key = pair.first;
79 if (key ==
"listen") {
82 else if (key ==
"port") {
83 port = ConfigFile::parseNumber<uint16_t>(pair,
"face_system.tcp");
85 else if (key ==
"enable_v4") {
88 else if (key ==
"enable_v6") {
92 BOOST_THROW_EXCEPTION(
ConfigFile::Error(
"Unrecognized option face_system.tcp." + key));
96 if (!enableV4 && !enableV6) {
98 "IPv4 and IPv6 TCP channels have been disabled. Remove face_system.tcp section to disable " 99 "TCP channels or enable at least one channel type."));
107 shared_ptr<TcpChannel> v4Channel = this->
createChannel(endpoint);
108 if (wantListen && !v4Channel->isListening()) {
109 v4Channel->listen(this->
addFace,
nullptr);
114 NFD_LOG_WARN(
"Cannot close tcp4 channel after its creation");
119 shared_ptr<TcpChannel> v6Channel = this->
createChannel(endpoint);
120 if (wantListen && !v6Channel->isListening()) {
121 v6Channel->listen(this->
addFace,
nullptr);
126 NFD_LOG_WARN(
"Cannot close tcp6 channel after its creation");
136 BOOST_ASSERT(req.
remoteUri.isCanonical());
139 NFD_LOG_TRACE(
"Cannot create unicast TCP face with LocalUri");
140 onFailure(406,
"Unicast TCP faces cannot be created with a LocalUri");
145 NFD_LOG_TRACE(
"createFace does not support FACE_PERSISTENCY_ON_DEMAND");
146 onFailure(406,
"Outgoing TCP faces do not support on-demand persistency");
151 boost::lexical_cast<uint16_t>(req.
remoteUri.getPort()));
154 BOOST_ASSERT(!endpoint.address().is_multicast());
157 NFD_LOG_TRACE(
"createFace cannot create non-local face with local fields enabled");
158 onFailure(406,
"Local fields can only be enabled on faces with local scope");
163 for (
const auto& i : m_channels) {
164 if ((i.first.address().is_v4() && endpoint.address().is_v4()) ||
165 (i.first.address().is_v6() && endpoint.address().is_v6())) {
166 i.second->connect(endpoint, req.
params, onCreated, onFailure);
171 NFD_LOG_TRACE(
"No channels available to connect to " << endpoint);
172 onFailure(504,
"No channels available to connect");
175 shared_ptr<TcpChannel>
178 auto it = m_channels.find(endpoint);
179 if (it != m_channels.end())
182 auto channel = make_shared<TcpChannel>(endpoint, m_wantCongestionMarking);
183 m_channels[endpoint] = channel;
187 std::vector<shared_ptr<const Channel>>
FaceCreatedCallback addFace
callback when a new face is created
shared_ptr< TcpChannel > createChannel(const tcp::Endpoint &localEndpoint)
Create TCP-based channel using tcp::Endpoint.
static const std::string & getId()
void createFace(const CreateFaceRequest &req, const FaceCreatedCallback &onCreated, const FaceCreationFailedCallback &onFailure) override
Try to create a unicast face using the supplied parameters.
function< void(const shared_ptr< Face > &face)> FaceCreatedCallback
Prototype for the callback that is invoked when a face is created (in response to an incoming connect...
std::set< std::string > providedSchemes
FaceUri schemes provided by this ProtocolFactory.
ndn::nfd::FacePersistency persistency
static bool parseYesNo(const ConfigSection &node, const std::string &key, const std::string §ionName)
parse a config option that can be either "yes" or "no"
#define NFD_REGISTER_PROTOCOL_FACTORY(PF)
registers a protocol factory
function< void(uint32_t status, const std::string &reason)> FaceCreationFailedCallback
Prototype for the callback that is invoked when a face fails to be created.
ndn::optional< FaceUri > localUri
TcpFactory(const CtorParams ¶ms)
#define NFD_LOG_WARN(expression)
context for processing a config section in ProtocolFactory
static std::vector< shared_ptr< const Channel > > getChannelsFromMap(const ChannelMap &channelMap)
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
boost::asio::ip::tcp::endpoint Endpoint
GeneralConfig generalConfig
void processConfig(OptionalConfigSection configSection, FaceSystem::ConfigContext &context) override
process face_system.tcp config section
boost::optional< const ConfigSection & > OptionalConfigSection
an optional config file section
std::vector< shared_ptr< const Channel > > getChannels() const override
Provides support for an underlying protocol.
Parameters to ProtocolFactory constructor.
#define NFD_LOG_INIT(name)
bool wantCongestionMarking
#define NFD_LOG_TRACE(expression)
Encapsulates a face creation request and all its parameters.