NS-3 based Named Data Networking (NDN) simulator
ndnSIM 2.0: NDN, CCN, CCNx, content centric networks
API Documentation
unix-stream-factory.cpp
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
26 #include "unix-stream-factory.hpp"
27 
28 #include <boost/filesystem.hpp> // for canonical()
29 
30 namespace nfd {
31 
32 shared_ptr<UnixStreamChannel>
33 UnixStreamFactory::createChannel(const std::string& unixSocketPath)
34 {
35  boost::filesystem::path p(unixSocketPath);
36  p = boost::filesystem::canonical(p.parent_path()) / p.filename();
37  unix_stream::Endpoint endpoint(p.string());
38 
39  auto channel = findChannel(endpoint);
40  if (channel)
41  return channel;
42 
43  channel = make_shared<UnixStreamChannel>(endpoint);
44  m_channels[endpoint] = channel;
45  return channel;
46 }
47 
48 void
50  ndn::nfd::FacePersistency persistency,
51  const FaceCreatedCallback& onCreated,
52  const FaceCreationFailedCallback& onConnectFailed)
53 {
54  BOOST_THROW_EXCEPTION(Error("UnixStreamFactory does not support 'createFace' operation"));
55 }
56 
57 std::vector<shared_ptr<const Channel>>
59 {
60  std::vector<shared_ptr<const Channel>> channels;
61  channels.reserve(m_channels.size());
62 
63  for (const auto& i : m_channels)
64  channels.push_back(i.second);
65 
66  return channels;
67 }
68 
69 shared_ptr<UnixStreamChannel>
70 UnixStreamFactory::findChannel(const unix_stream::Endpoint& endpoint) const
71 {
72  auto i = m_channels.find(endpoint);
73  if (i != m_channels.end())
74  return i->second;
75  else
76  return nullptr;
77 }
78 
79 } // namespace nfd
function< void(const std::string &reason)> FaceCreationFailedCallback
Prototype for the callback that is invoked when the face fails to be created.
Definition: channel.hpp:44
represents the underlying protocol and address used by a Face
Definition: face-uri.hpp:44
Exception of UnixStreamFactory.
Copyright (c) 2011-2015 Regents of the University of California.
Definition: ndn-common.hpp:40
shared_ptr< UnixStreamChannel > createChannel(const std::string &unixSocketPath)
Create stream-oriented Unix channel using specified socket path.
virtual std::vector< shared_ptr< const Channel > > getChannels() const 1
function< void(const shared_ptr< Face > &newFace)> FaceCreatedCallback
Prototype for the callback that is invoked when the face is created (as a response to incoming connec...
Definition: channel.hpp:38
boost::asio::local::stream_protocol::endpoint Endpoint
virtual void createFace(const FaceUri &uri, ndn::nfd::FacePersistency persistency, const FaceCreatedCallback &onCreated, const FaceCreationFailedCallback &onConnectFailed) 1
Try to create Face using the supplied FaceUri.