NS-3 based Named Data Networking (NDN) simulator
ndnSIM 2.5: NDN, CCN, CCNx, content centric networks
API Documentation
ndn-net-device-transport.cpp
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2 /*
3  * Copyright (c) 2011-2018 Regents of the University of California.
4  *
5  * This file is part of ndnSIM. See AUTHORS for complete list of ndnSIM authors and
6  * contributors.
7  *
8  * ndnSIM is free software: you can redistribute it and/or modify it under the terms
9  * of the GNU General Public License as published by the Free Software Foundation,
10  * either version 3 of the License, or (at your option) any later version.
11  *
12  * ndnSIM is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
13  * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
14  * PURPOSE. See the GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License along with
17  * ndnSIM, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
18  **/
19 
21 
22 #include "../helper/ndn-stack-helper.hpp"
23 #include "ndn-block-header.hpp"
24 #include "../utils/ndn-ns3-packet-tag.hpp"
25 
27 #include <ndn-cxx/interest.hpp>
28 #include <ndn-cxx/data.hpp>
29 
30 #include "ns3/queue.h"
31 
32 NS_LOG_COMPONENT_DEFINE("ndn.NetDeviceTransport");
33 
34 namespace ns3 {
35 namespace ndn {
36 
38  const Ptr<NetDevice>& netDevice,
39  const std::string& localUri,
40  const std::string& remoteUri,
41  ::ndn::nfd::FaceScope scope,
42  ::ndn::nfd::FacePersistency persistency,
43  ::ndn::nfd::LinkType linkType)
44  : m_netDevice(netDevice)
45  , m_node(node)
46 {
47  this->setLocalUri(FaceUri(localUri));
48  this->setRemoteUri(FaceUri(remoteUri));
49  this->setScope(scope);
50  this->setPersistency(persistency);
51  this->setLinkType(linkType);
52  this->setMtu(m_netDevice->GetMtu()); // Use the MTU of the netDevice
53 
54  // Get send queue capacity for congestion marking
55  PointerValue txQueueAttribute;
56  if (m_netDevice->GetAttributeFailSafe("TxQueue", txQueueAttribute)) {
57  Ptr<ns3::QueueBase> txQueue = txQueueAttribute.Get<ns3::QueueBase>();
58  // must be put into bytes mode queue
59 
60  auto size = txQueue->GetMaxSize();
61  if (size.GetUnit() == BYTES) {
62  this->setSendQueueCapacity(size.GetValue());
63  }
64  else {
65  // don't know the exact size in bytes, guessing based on "standard" packet size
66  this->setSendQueueCapacity(size.GetValue() * 1500);
67  }
68  }
69 
70  NS_LOG_FUNCTION(this << "Creating an ndnSIM transport instance for netDevice with URI"
71  << this->getLocalUri());
72 
73  NS_ASSERT_MSG(m_netDevice != 0, "NetDeviceFace needs to be assigned a valid NetDevice");
74 
75  m_node->RegisterProtocolHandler(MakeCallback(&NetDeviceTransport::receiveFromNetDevice, this),
77  true /*promiscuous mode*/);
78 }
79 
81 {
82  NS_LOG_FUNCTION_NOARGS();
83 }
84 
85 ssize_t
87 {
88  PointerValue txQueueAttribute;
89  if (m_netDevice->GetAttributeFailSafe("TxQueue", txQueueAttribute)) {
90  Ptr<ns3::QueueBase> txQueue = txQueueAttribute.Get<ns3::QueueBase>();
91  return txQueue->GetNBytes();
92  }
93  else {
95  }
96 }
97 
98 void
99 NetDeviceTransport::doClose()
100 {
101  NS_LOG_FUNCTION(this << "Closing transport for netDevice with URI"
102  << this->getLocalUri());
103 
104  // set the state of the transport to "CLOSED"
106 }
107 
108 void
109 NetDeviceTransport::doSend(const Block& packet, const nfd::EndpointId& endpoint)
110 {
111  NS_LOG_FUNCTION(this << "Sending packet from netDevice with URI"
112  << this->getLocalUri());
113 
114  // convert NFD packet to NS3 packet
115  BlockHeader header(packet);
116 
117  Ptr<ns3::Packet> ns3Packet = Create<ns3::Packet>();
118  ns3Packet->AddHeader(header);
119 
120  // send the NS3 packet
121  m_netDevice->Send(ns3Packet, m_netDevice->GetBroadcast(),
123 }
124 
125 // callback
126 void
127 NetDeviceTransport::receiveFromNetDevice(Ptr<NetDevice> device,
128  Ptr<const ns3::Packet> p,
129  uint16_t protocol,
130  const Address& from, const Address& to,
131  NetDevice::PacketType packetType)
132 {
133  NS_LOG_FUNCTION(device << p << protocol << from << to << packetType);
134 
135  // Convert NS3 packet to NFD packet
136  Ptr<ns3::Packet> packet = p->Copy();
137 
138  BlockHeader header;
139  packet->RemoveHeader(header);
140 
141  this->receive(std::move(header.getBlock()));
142 }
143 
144 Ptr<NetDevice>
146 {
147  return m_netDevice;
148 }
149 
150 } // namespace ndn
151 } // namespace ns3
nfd::face::Transport::setSendQueueCapacity
void setSendQueueCapacity(ssize_t sendQueueCapacity)
Definition: transport.hpp:461
nfd::face::TransportState::CLOSED
@ CLOSED
the transport is closed, and can be safely deallocated
nfd::face::Transport::setMtu
void setMtu(ssize_t mtu)
Definition: transport.hpp:448
nonstd::optional_lite::std11::move
T & move(T &t)
Definition: optional.hpp:421
nfd::face::Transport::setRemoteUri
void setRemoteUri(const FaceUri &uri)
Definition: transport.hpp:406
ns3
Copyright (c) 2011-2015 Regents of the University of California.
Definition: ndn-app-link-service.cpp:32
nfd::face::Transport::setScope
void setScope(ndn::nfd::FaceScope scope)
Definition: transport.hpp:418
block.hpp
nfd::face::Transport::setState
void setState(TransportState newState)
set transport state
Definition: transport.cpp:173
ns3::ndn::NetDeviceTransport::~NetDeviceTransport
~NetDeviceTransport()
Definition: ndn-net-device-transport.cpp:80
ndn::nfd::LinkType
LinkType
Definition: nfd-constants.hpp:57
ndn-block-header.hpp
ndn-net-device-transport.hpp
ndn::nfd::FacePersistency
FacePersistency
Definition: nfd-constants.hpp:45
ns3::ndn::NetDeviceTransport::NetDeviceTransport
NetDeviceTransport(Ptr< Node > node, const Ptr< NetDevice > &netDevice, const std::string &localUri, const std::string &remoteUri, ::ndn::nfd::FaceScope scope=::ndn::nfd::FACE_SCOPE_NON_LOCAL, ::ndn::nfd::FacePersistency persistency=::ndn::nfd::FACE_PERSISTENCY_PERSISTENT, ::ndn::nfd::LinkType linkType=::ndn::nfd::LINK_TYPE_POINT_TO_POINT)
Definition: ndn-net-device-transport.cpp:37
nfd::face::QUEUE_UNSUPPORTED
const ssize_t QUEUE_UNSUPPORTED
indicates that the transport does not support reading the queue capacity/length
Definition: transport.hpp:99
ns3::ndn::NetDeviceTransport::getSendQueueLength
virtual ssize_t getSendQueueLength() final
Definition: ndn-net-device-transport.cpp:86
nfd::face::Transport::setLinkType
void setLinkType(ndn::nfd::LinkType linkType)
Definition: transport.hpp:436
interest.hpp
data.hpp
nfd::face::Transport::getLocalUri
FaceUri getLocalUri() const
Definition: transport.hpp:388
nfd::face::Transport::setPersistency
void setPersistency(ndn::nfd::FacePersistency newPersistency)
changes face persistency setting
Definition: transport.cpp:150
ns3::ndn::NetDeviceTransport::GetNetDevice
Ptr< NetDevice > GetNetDevice() const
Definition: ndn-net-device-transport.cpp:145
ns3::ndn::L3Protocol::ETHERNET_FRAME_TYPE
static const uint16_t ETHERNET_FRAME_TYPE
Ethernet Frame Type of Ndn.
Definition: ndn-l3-protocol.hpp:91
nfd::face::EndpointId
uint64_t EndpointId
Identifies a remote endpoint on the link.
Definition: face-common.hpp:65
nfd::face::Transport::receive
void receive(const Block &packet, const EndpointId &endpoint=0)
Pass a received link-layer packet to the upper layer for further processing.
Definition: transport.cpp:115
ndn::nfd::FaceScope
FaceScope
Definition: nfd-constants.hpp:34
ndn
Copyright (c) 2011-2015 Regents of the University of California.
Definition: ndn-strategy-choice-helper.hpp:34
nfd::face::Transport::setLocalUri
void setLocalUri(const FaceUri &uri)
Definition: transport.hpp:394