32 #define NS_LOG_APPEND_CONTEXT \
33 if (GetObject<Node> ()) { std::clog << "[node " << GetObject<Node> ()->GetId () << "] "; }
42 #include "ns3/config.h"
44 #include "ns3/string.h"
47 #include "ns3/assert.h"
48 #include "ns3/uinteger.h"
49 #include "ns3/net-device.h"
50 #include "ns3/packet.h"
51 #include "ns3/boolean.h"
52 #include "ns3/node-list.h"
53 #include "ns3/double.h"
54 #include "ns3/pointer.h"
55 #include "ns3/timer.h"
56 #include "ns3/object-vector.h"
57 #include "ns3/ipv4-address.h"
58 #include "ns3/ipv4-header.h"
59 #include "ns3/ipv4-l3-protocol.h"
60 #include "ns3/ipv4-route.h"
61 #include "ns3/trace-source-accessor.h"
62 #include "ns3/icmpv4-l4-protocol.h"
63 #include "ns3/adhoc-wifi-mac.h"
64 #include "ns3/wifi-net-device.h"
65 #include "ns3/inet-socket-address.h"
66 #include "ns3/udp-l4-protocol.h"
67 #include "ns3/udp-socket-factory.h"
68 #include "ns3/tcp-socket-factory.h"
69 #include "ns3/llc-snap-header.h"
70 #include "ns3/arp-header.h"
71 #include "ns3/ipv6-interface.h"
112 .SetGroupName (
"Dsr")
114 .AddAttribute (
"RouteCache",
115 "The route cache for saving routes from "
116 "route discovery process.",
120 MakePointerChecker<DsrRouteCache> ())
121 .AddAttribute (
"RreqTable",
122 "The request table to manage route requests.",
126 MakePointerChecker<DsrRreqTable> ())
127 .AddAttribute (
"PassiveBuffer",
128 "The passive buffer to manage "
129 "promisucously received passive ack.",
133 MakePointerChecker<DsrPassiveBuffer> ())
134 .AddAttribute (
"MaxSendBuffLen",
135 "Maximum number of packets that can be stored "
139 MakeUintegerChecker<uint32_t> ())
140 .AddAttribute (
"MaxSendBuffTime",
141 "Maximum time packets can be queued in the send buffer .",
145 .AddAttribute (
"MaxMaintLen",
146 "Maximum number of packets that can be stored "
147 "in maintenance buffer.",
150 MakeUintegerChecker<uint32_t> ())
151 .AddAttribute (
"MaxMaintTime",
152 "Maximum time packets can be queued in maintenance buffer.",
156 .AddAttribute (
"MaxCacheLen",
157 "Maximum number of route entries that can be stored "
161 MakeUintegerChecker<uint32_t> ())
162 .AddAttribute (
"RouteCacheTimeout",
163 "Maximum time the route cache can be queued in "
168 .AddAttribute (
"MaxEntriesEachDst",
169 "Maximum number of route entries for a "
170 "single destination to respond.",
173 MakeUintegerChecker<uint32_t> ())
174 .AddAttribute (
"SendBuffInterval",
175 "How often to check send buffer for packet with route.",
179 .AddAttribute (
"NodeTraversalTime",
180 "The time it takes to traverse two neighboring nodes.",
184 .AddAttribute (
"RreqRetries",
185 "Maximum number of retransmissions for "
186 "request discovery of a route.",
189 MakeUintegerChecker<uint32_t> ())
190 .AddAttribute (
"MaintenanceRetries",
191 "Maximum number of retransmissions for "
192 "data packets from maintenance buffer.",
195 MakeUintegerChecker<uint32_t> ())
196 .AddAttribute (
"RequestTableSize",
197 "Maximum number of request entries in the request table, "
198 "set this as the number of nodes in the simulation.",
201 MakeUintegerChecker<uint32_t> ())
202 .AddAttribute (
"RequestIdSize",
203 "Maximum number of request source Ids in "
204 "the request table.",
207 MakeUintegerChecker<uint32_t> ())
208 .AddAttribute (
"UniqueRequestIdSize",
209 "Maximum number of request Ids in "
210 "the request table for a single destination.",
213 MakeUintegerChecker<uint32_t> ())
214 .AddAttribute (
"NonPropRequestTimeout",
215 "The timeout value for non-propagation request.",
219 .AddAttribute (
"DiscoveryHopLimit",
220 "The max discovery hop limit for route requests.",
223 MakeUintegerChecker<uint32_t> ())
224 .AddAttribute (
"MaxSalvageCount",
225 "The max salvage count for a single data packet.",
228 MakeUintegerChecker<uint8_t> ())
229 .AddAttribute (
"BlacklistTimeout",
230 "The time for a neighbor to stay in blacklist.",
234 .AddAttribute (
"GratReplyHoldoff",
235 "The time for gratuitous reply entry to expire.",
239 .AddAttribute (
"BroadcastJitter",
240 "The jitter time to avoid collision for broadcast packets.",
243 MakeUintegerChecker<uint32_t> ())
244 .AddAttribute (
"LinkAckTimeout",
245 "The time a packet in maintenance buffer wait for "
246 "link acknowledgment.",
250 .AddAttribute (
"TryLinkAcks",
251 "The number of link acknowledgment to use.",
254 MakeUintegerChecker<uint32_t> ())
255 .AddAttribute (
"PassiveAckTimeout",
256 "The time a packet in maintenance buffer wait for "
257 "passive acknowledgment.",
261 .AddAttribute (
"TryPassiveAcks",
262 "The number of passive acknowledgment to use.",
265 MakeUintegerChecker<uint32_t> ())
266 .AddAttribute (
"RequestPeriod",
267 "The base time interval between route requests.",
271 .AddAttribute (
"MaxRequestPeriod",
272 "The max time interval between route requests.",
276 .AddAttribute (
"GraReplyTableSize",
277 "The gratuitous reply table size.",
280 MakeUintegerChecker<uint32_t> ())
281 .AddAttribute (
"CacheType",
282 "Use Link Cache or use Path Cache",
286 .AddAttribute (
"StabilityDecrFactor",
287 "The stability decrease factor for link cache",
290 MakeUintegerChecker<uint32_t> ())
291 .AddAttribute (
"StabilityIncrFactor",
292 "The stability increase factor for link cache",
295 MakeUintegerChecker<uint32_t> ())
296 .AddAttribute (
"InitStability",
297 "The initial stability factor for link cache",
301 .AddAttribute (
"MinLifeTime",
302 "The minimal life time for link cache",
306 .AddAttribute (
"UseExtends",
307 "The extension time for link cache",
311 .AddAttribute (
"EnableSubRoute",
312 "Enables saving of sub route when receiving "
313 "route error messages, only available when "
314 "using path route cache",
318 .AddAttribute (
"RetransIncr",
319 "The increase time for retransmission timer "
320 "when facing network congestion",
324 .AddAttribute (
"MaxNetworkQueueSize",
325 "The max number of packet to save in the network queue.",
328 MakeUintegerChecker<uint32_t> ())
329 .AddAttribute (
"MaxNetworkQueueDelay",
330 "The max time for a packet to stay in the network queue.",
334 .AddAttribute (
"NumPriorityQueues",
335 "The max number of packet to save in the network queue.",
338 MakeUintegerChecker<uint32_t> ())
339 .AddAttribute (
"LinkAcknowledgment",
340 "Enable Link layer acknowledgment mechanism",
344 .AddTraceSource (
"Tx",
347 "ns3::dsr::DsrOptionSRHeader::TracedCallback")
348 .AddTraceSource (
"Drop",
351 "ns3::Packet::TracedCallback")
402 Ptr<Node> node = this->GetObject<Node> ();
405 m_ipv4 = this->GetObject<Ipv4L3Protocol> ();
434 std::pair<std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator,
bool> result_i =
m_priorityQueue.insert (std::make_pair (i, queue_i));
466 for (uint32_t i = 0; i <
m_ipv4->GetNInterfaces (); i++)
471 if (addr != loopback)
489 routeCache->ScheduleTimer ();
512 routeCache->AddArpCache (
m_ipv4->GetInterface (i)->GetArpCache ());
530 return n->
GetDevice (atoi (elements[3].c_str ()));
533 std::vector<std::string>
536 std::vector <std::string> elements;
538 while (pos1 != context.npos)
540 pos1 = context.find (
"/",pos1);
541 pos2 = context.find (
"/",pos1+1);
542 elements.push_back (context.substr (pos1+1,pos2-(pos1+1)));
554 for (uint32_t i = 0; i <
m_ipv4->GetNInterfaces (); i++)
564 mac->TraceDisconnectWithoutContext (
"TxErrHeader",
630 for (int32_t i = 0; i < nNodes; ++i)
634 int32_t ifIndex = ipv4->GetInterfaceForAddress (ipv4Address);
667 std::vector<Ipv4Address> nodelist = rt.
GetVector ();
675 m_routeCache->DeleteAllRoutesIncludeLink (errorSrc, unreachNode, node);
685 return m_rreqTable->FindSourceEntry (src, dst,
id);
693 for (int32_t i = 0; i < nNodes; ++i)
699 if (netDevice->GetAddress () ==
address)
701 return ipv4->GetAddress (1, 0).GetLocal ();
720 for (std::vector<Ipv4Address>::const_iterator i = vec.begin (); i != vec.end (); ++i)
732 if (vec.size () == 2)
740 if (ipv4Address == vec.back ())
742 NS_LOG_DEBUG (
"We have reached to the final destination " << ipv4Address <<
" " << vec.back ());
745 for (std::vector<Ipv4Address>::const_iterator i = vec.begin (); i != vec.end (); ++i)
747 if (ipv4Address == (*i))
781 for (int32_t i = 0; i < nNodes; ++i)
785 if (ipv4->GetAddress (1, 0).GetLocal () ==
address)
805 return ipv4->GetAddress (1, 0).GetLocal ();
839 NS_LOG_DEBUG (
"Here we try to find the data packet in the send buffer");
842 bool findRoute =
m_routeCache->LookupRoute (destination, toDst);
845 NS_LOG_INFO (
"We have found a route for the packet");
848 uint8_t protocol = i->GetProtocol ();
863 uint32_t size = copyP->
GetSize ();
864 uint8_t *
data =
new uint8_t[size];
867 uint8_t optionType = 0;
868 optionType = *(
data);
874 uint8_t errorType = *(data + 2);
890 std::vector<Ipv4Address> errorRoute = toDst.
GetVector ();
902 if (nextHop ==
"0.0.0.0")
909 uint8_t length = (sourceRoute.
GetLength () + newUnreach.GetLength ());
924 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
926 NS_LOG_LOGIC (
"Will be inserting into priority queue number: " << priority);
933 if (dsrNetworkQueue->Enqueue (newEntry))
939 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
951 std::vector<Ipv4Address> nodeList = toDst.
GetVector ();
953 if (nextHop ==
"0.0.0.0")
967 uint8_t length = sourceRoute.
GetLength ();
980 networkKey.
m_ackId = newEntry.GetAckId ();
981 networkKey.
m_ourAdd = newEntry.GetOurAdd ();
982 networkKey.
m_nextHop = newEntry.GetNextHop ();
983 networkKey.
m_source = newEntry.GetSrc ();
988 passiveKey.
m_source = newEntry.GetSrc ();
990 passiveKey.
m_segsLeft = newEntry.GetSegsLeft ();
993 linkKey.
m_source = newEntry.GetSrc ();
995 linkKey.
m_ourAdd = newEntry.GetOurAdd ();
996 linkKey.
m_nextHop = newEntry.GetNextHop ();
1009 if (nextHop != destination)
1086 newEntry.SetSrc (sourceIp);
1087 newEntry.SetDst (destinationIp);
1089 newEntry.SetOurAdd (previousHop);
1090 newEntry.SetNextHop (ourAddress);
1096 dsr->CancelLinkPacketTimer (newEntry);
1103 NS_LOG_INFO (
this << from << to << packetType << *pktMinusIpHdr);
1115 uint32_t size = pktMinusIpHdr->
GetSize ();
1116 uint8_t *
data =
new uint8_t[size];
1117 pktMinusIpHdr->
CopyData (data, size);
1118 uint8_t optionType = 0;
1119 optionType = *(
data);
1123 if (optionType == 96)
1129 " overhearing packet PID: " << pktMinusIpHdr->
GetUid () <<
1130 " from " << promiscSource <<
1132 " with source IP " << ipv4Header.
GetSource () <<
1134 " and packet : " << *pktMinusDsrHdr);
1136 bool isPromisc =
true;
1137 dsrOption->Process (pktMinusIpHdr, pktMinusDsrHdr,
m_mainAddress, source, ipv4Header, nextHeader, isPromisc, promiscSource);
1151 NS_LOG_FUNCTION (
this << packet << source << destination << (uint32_t)protocol);
1154 bool findRoute =
m_routeCache->LookupRoute (destination, toDst);
1159 <<
"s " <<
m_mainAddress <<
" there is no route for this packet, queue the packet");
1167 <<
"s Add packet PID: " << packet->
GetUid () <<
" to queue. Packet: " << *packet);
1189 std::vector<Ipv4Address> nodeList = toDst.
GetVector ();
1191 if (nextHop ==
"0.0.0.0")
1196 uint8_t salvage = 0;
1206 uint8_t length = sourceRoute.
GetLength ();
1214 source, destination, 0,
1221 networkKey.
m_ackId = newEntry.GetAckId ();
1222 networkKey.
m_ourAdd = newEntry.GetOurAdd ();
1223 networkKey.
m_nextHop = newEntry.GetNextHop ();
1224 networkKey.
m_source = newEntry.GetSrc ();
1229 passiveKey.
m_source = newEntry.GetSrc ();
1231 passiveKey.
m_segsLeft = newEntry.GetSegsLeft ();
1234 linkKey.
m_source = newEntry.GetSrc ();
1236 linkKey.
m_ourAdd = newEntry.GetOurAdd ();
1237 linkKey.
m_nextHop = newEntry.GetNextHop ();
1250 if (nextHop != destination)
1267 NS_LOG_FUNCTION (
this << unreachNode << destination << originalDst << (uint32_t)salvage << (uint32_t)protocol);
1281 uint8_t rerrLength = rerrUnreachHeader.
GetLength ();
1285 bool findRoute =
m_routeCache->LookupRoute (destination, toDst);
1292 NS_LOG_INFO (
"We are the error source, send request to original dst " << originalDst);
1299 <<
"s " <<
m_mainAddress <<
" there is no route for this packet, queue the packet");
1303 newPacket->
AddHeader (dsrRoutingHeader);
1311 <<
"s Add packet PID: " << p->
GetUid () <<
" to queue. Packet: " << *p);
1315 NS_LOG_DEBUG (
"When there is no existing route request for " << destination <<
", initialize one");
1326 std::vector<Ipv4Address> nodeList = toDst.
GetVector ();
1328 if (nextHop ==
"0.0.0.0")
1342 uint8_t srLength = sourceRoute.
GetLength ();
1343 uint8_t length = (srLength + rerrLength);
1348 newPacket->
AddHeader (dsrRoutingHeader);
1356 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
1358 NS_LOG_DEBUG (
"Will be inserting into priority queue " << dsrNetworkQueue <<
" number: " << priority);
1365 if (dsrNetworkQueue->Enqueue (newEntry))
1371 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
1383 NS_LOG_FUNCTION (
this << rerr << sourceRoute << nextHop << (uint32_t)protocol << route);
1387 dsrRoutingHeader.SetMessageType (1);
1392 dsrRoutingHeader.SetPayloadLength (uint16_t (length) + 4);
1393 dsrRoutingHeader.AddDsrOption (rerr);
1394 dsrRoutingHeader.AddDsrOption (sourceRoute);
1401 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
1403 NS_LOG_DEBUG (
"Will be inserting into priority queue " << dsrNetworkQueue <<
" number: " << priority);
1410 if (dsrNetworkQueue->Enqueue (newEntry))
1416 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
1427 NS_LOG_FUNCTION (
this << packet << source << destination << (uint32_t)protocol << route);
1432 NS_LOG_INFO (
"Drop packet. Not handling ICMP packet for now");
1438 bool findRoute =
m_routeCache->LookupRoute (destination, toDst);
1443 <<
"s " <<
m_mainAddress <<
" there is no route for this packet, queue the packet");
1451 <<
"s Add packet PID: " << packet->
GetUid () <<
" to send buffer. Packet: " << *packet);
1463 NS_LOG_LOGIC (
"There is existing route request timer with request count " <<
m_rreqTable->GetRreqCnt (destination));
1477 std::vector<Ipv4Address> nodeList = toDst.
GetVector ();
1479 if (nextHop ==
"0.0.0.0")
1484 uint8_t salvage = 0;
1494 uint8_t length = sourceRoute.
GetLength ();
1504 source, destination, 0,
1510 networkKey.
m_ackId = newEntry.GetAckId ();
1511 networkKey.
m_ourAdd = newEntry.GetOurAdd ();
1512 networkKey.
m_nextHop = newEntry.GetNextHop ();
1513 networkKey.
m_source = newEntry.GetSrc ();
1518 passiveKey.
m_source = newEntry.GetSrc ();
1520 passiveKey.
m_segsLeft = newEntry.GetSegsLeft ();
1523 linkKey.
m_source = newEntry.GetSrc ();
1525 linkKey.
m_ourAdd = newEntry.GetOurAdd ();
1526 linkKey.
m_nextHop = newEntry.GetNextHop ();
1539 if (nextHop != destination)
1572 uint32_t sourceId = dsrRoutingHeader.
GetSourceId ();
1573 uint32_t destinationId = dsrRoutingHeader.
GetDestId ();
1580 uint8_t numberAddress = (buf[1] - 2) / 4;
1593 newDsrRoutingHeader.
SetDestId (destinationId);
1606 NS_LOG_FUNCTION (
this << packet << source << nextHop << (uint32_t)protocol);
1613 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
1615 NS_LOG_INFO (
"Will be inserting into priority queue number: " << priority);
1622 if (dsrNetworkQueue->Enqueue (newEntry))
1628 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
1643 uint32_t numPriorities;
1644 if (continueWithFirst)
1650 numPriorities = priority;
1655 std::map<uint32_t, Ptr<DsrNetworkQueue> >::iterator q =
m_priorityQueue.find (i);
1657 uint32_t queueSize = dsrNetworkQueue->GetSize ();
1660 if ((i == (m_numPriorityQueues - 1)) && continueWithFirst)
1671 uint32_t totalQueueSize = 0;
1674 NS_LOG_INFO (
"The size of the network queue for " << j->first <<
" is " << j->second->GetSize ());
1675 totalQueueSize += j->second->GetSize ();
1676 NS_LOG_INFO (
"The total network queue size is " << totalQueueSize);
1678 if (totalQueueSize > 5)
1684 dsrNetworkQueue->Dequeue (newEntry);
1687 NS_LOG_LOGIC (
"Packet sent by Dsr. Calling PriorityScheduler after some time");
1696 NS_LOG_LOGIC (
"Packet dropped by Dsr. Calling PriorityScheduler immediately");
1700 if ((i == (m_numPriorityQueues - 1)) && continueWithFirst)
1718 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
1721 std::vector<DsrNetworkQueueEntry> newNetworkQueue = dsrNetworkQueue->GetQueue ();
1722 for (std::vector<DsrNetworkQueueEntry>::iterator i = newNetworkQueue.begin (); i != newNetworkQueue.end (); i++)
1727 if (nextHop == j->first.m_nextHop)
1729 NS_LOG_DEBUG (
"The network delay left is " << j->second.GetDelayLeft ());
1730 j->second.SetDelay (j->second.GetDelayLeft () +
m_retransIncr);
1758 NS_LOG_INFO (
"The nexthop address " << nextHop <<
" the source " << source <<
" the destination " << destination);
1764 NS_LOG_DEBUG (
"destination over here " << destination);
1783 uint8_t length = sourceRoute.
GetLength ();
1792 source, destination, 0,
1799 networkKey.
m_ackId = newEntry.GetAckId ();
1800 networkKey.
m_ourAdd = newEntry.GetOurAdd ();
1801 networkKey.
m_nextHop = newEntry.GetNextHop ();
1802 networkKey.
m_source = newEntry.GetSrc ();
1807 passiveKey.
m_source = newEntry.GetSrc ();
1809 passiveKey.
m_segsLeft = newEntry.GetSegsLeft ();
1812 linkKey.
m_source = newEntry.GetSrc ();
1814 linkKey.
m_ourAdd = newEntry.GetOurAdd ();
1815 linkKey.
m_nextHop = newEntry.GetNextHop ();
1828 if (nextHop != destination)
1843 NS_LOG_LOGIC (
"Schedule sending the next packet in send buffer");
1850 NS_LOG_LOGIC (
"All queued packets are out-dated for the destination in send buffer");
1868 uint32_t offset = dsrRoutingHeader.GetDsrOptionsOffset ();
1873 uint32_t size = copyP->
GetSize ();
1874 uint8_t *
data =
new uint8_t[size];
1877 uint8_t optionType = 0;
1878 optionType = *(
data);
1879 NS_LOG_DEBUG (
"The option type value in send packet " << (uint32_t)optionType);
1880 if (optionType == 3)
1886 uint8_t errorType = *(data + 2);
1890 NS_LOG_DEBUG (
"The packet is route error unreach packet");
1920 newPacket->
AddHeader (newRoutingHeader);
1925 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
1927 NS_LOG_DEBUG (
"Will be inserting into priority queue " << dsrNetworkQueue <<
" number: " << priority);
1934 if (dsrNetworkQueue->Enqueue (newEntry))
1940 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
1947 NS_LOG_LOGIC (
"Schedule sending the next packet in error buffer");
1955 NS_LOG_DEBUG (
"Packet not found in either the send or error buffer");
1961 uint16_t fragmentOffset, uint16_t identification,
bool saveEntry)
1963 NS_LOG_FUNCTION (
this << packet << source << destination << (uint32_t)segsLeft);
1982 NS_LOG_DEBUG (
"We get the all equal for passive buffer here");
1987 mbEntry.
SetDst (destination);
2006 NS_LOG_FUNCTION (
this << packet << source << destination << (uint32_t)segsLeft);
2014 newEntry.
SetSrc (source);
2015 newEntry.
SetDst (destination);
2032 NS_LOG_FUNCTION (
this << (uint32_t)ackId << ipv4Header << realSrc << realDst);
2041 realSrc, realDst, ackId,
2074 std::map<LinkKey, Timer>::const_iterator i =
2101 NS_LOG_INFO (
"Link acknowledgment received, remove same maintenance buffer entry");
2122 <<
" source " << mb.
GetSrc () <<
" destination " << mb.
GetDst ()
2126 std::map<NetworkKey, Timer>::const_iterator i =
2151 NS_LOG_INFO (
"Remove same maintenance buffer entry based on network acknowledgment");
2169 std::map<PassiveKey, Timer>::const_iterator j =
2197 std::vector<Ipv4Address> previousErrorDst;
2214 uint8_t numberAddress = (buf[1] - 2) / 4;
2215 NS_LOG_DEBUG (
"The number of addresses " << (uint32_t)numberAddress);
2231 errorDst = address1;
2238 if (std::find(previousErrorDst.begin(), previousErrorDst.end(), destination)==previousErrorDst.end())
2240 NS_LOG_DEBUG (
"have not seen this dst before " << errorDst <<
" in " << previousErrorDst.size());
2242 previousErrorDst.push_back(errorDst);
2254 NS_LOG_INFO (
"Cancel the packet timer for next maintenance entry");
2261 NS_LOG_INFO (
"Maintenance buffer entry not found");
2269 NS_LOG_FUNCTION (
this << packet << source << dst << (uint32_t)protocol);
2282 newPacket->
CopyData (buf,
sizeof(buf));
2283 uint8_t numberAddress = (buf[1] - 2) / 4;
2293 bool findRoute =
m_routeCache->LookupRoute (dst, toDst);
2303 std::vector<Ipv4Address> nodeList = toDst.
GetVector ();
2305 if (nextHop ==
"0.0.0.0")
2321 uint8_t length = sourceRoute.
GetLength ();
2333 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
2335 NS_LOG_DEBUG (
"Will be inserting into priority queue " << dsrNetworkQueue <<
" number: " << priority);
2342 if (dsrNetworkQueue->Enqueue (newEntry))
2348 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
2359 NS_LOG_DEBUG (
"Will not salvage this packet, silently drop");
2417 NS_LOG_DEBUG (
"The passive acknowledgment option for data packet");
2434 NS_LOG_DEBUG (
"is the first retry or not " << isFirst);
2455 networkKey.m_ackId = newEntry.
GetAckId ();
2456 networkKey.m_ourAdd = newEntry.
GetOurAdd ();
2457 networkKey.m_nextHop = newEntry.
GetNextHop ();
2458 networkKey.m_source = newEntry.
GetSrc ();
2459 networkKey.m_destination = newEntry.
GetDst ();
2484 networkKey.m_ackId = mb.
GetAckId ();
2487 networkKey.m_source = mb.
GetSrc ();
2488 networkKey.m_destination = mb.
GetDst ();
2503 NS_LOG_DEBUG (
"The packet with dsr header " << dsrP->GetSize ());
2504 networkKey.m_ackId = mb.
GetAckId ();
2507 networkKey.m_source = mb.
GetSrc ();
2508 networkKey.m_destination = mb.
GetDst ();
2566 NS_LOG_INFO (
"We need to send error messages now");
2674 NS_LOG_FUNCTION (
this << packet << sourceRoute << source << nextHop << targetAddress << (uint32_t)protocol << route);
2679 dsrRoutingHeader.SetMessageType (2);
2680 dsrRoutingHeader.SetSourceId (
GetIDfromIP (source));
2681 dsrRoutingHeader.SetDestId (
GetIDfromIP (targetAddress));
2685 uint8_t length = sourceRoute.
GetLength ();
2686 dsrRoutingHeader.SetPayloadLength (uint16_t (length) + 2);
2687 dsrRoutingHeader.AddDsrOption (sourceRoute);
2693 source, targetAddress,
m_ackId,
2700 networkKey.
m_ackId = newEntry.GetAckId ();
2701 networkKey.
m_ourAdd = newEntry.GetOurAdd ();
2702 networkKey.
m_nextHop = newEntry.GetNextHop ();
2703 networkKey.
m_source = newEntry.GetSrc ();
2708 passiveKey.
m_source = newEntry.GetSrc ();
2710 passiveKey.
m_segsLeft = newEntry.GetSegsLeft ();
2713 linkKey.
m_source = newEntry.GetSrc ();
2715 linkKey.
m_ourAdd = newEntry.GetOurAdd ();
2716 linkKey.
m_nextHop = newEntry.GetNextHop ();
2729 if (nextHop != targetAddress)
2747 NS_LOG_FUNCTION (
this << source << destination << (uint32_t)protocol);
2768 uint8_t length = rreqHeader.
GetLength ();
2770 packet->AddHeader (dsrRoutingHeader);
2773 bool nonProp =
true;
2774 std::vector<Ipv4Address>
address;
2775 address.push_back (source);
2776 address.push_back (destination);
2808 std::vector<Ipv4Address> ip = toDst.GetVector ();
2820 if (nextHop ==
"0.0.0.0")
2838 NS_LOG_INFO (
"No route found, initiate route error request");
2855 rreqHeader.SetTarget (originalDst);
2861 uint8_t length = rreqHeader.GetLength () + rerr.
GetLength ();
2865 bool nonProp =
false;
2866 std::vector<Ipv4Address>
address;
2868 address.push_back (originalDst);
2879 NS_LOG_INFO (
"Only when there is no existing route request time when the initial route request is scheduled");
2885 NS_LOG_INFO (
"There is existing route request, find the existing route request entry");
2903 NS_LOG_DEBUG (
"Did not find the non-propagation timer");
2948 NS_LOG_FUNCTION (
this << packet << nonProp << requestId << (uint32_t)protocol);
2959 std::vector<Ipv4Address>
address;
2960 address.push_back (source);
2961 address.push_back (dst);
2983 std::vector<Ipv4Address>
address;
2984 address.push_back (source);
2985 address.push_back (dst);
3035 std::vector<Ipv4Address> ip = toDst.
GetVector ();
3046 NS_LOG_INFO (
"The nextHop address is " << nextHop);
3047 if (nextHop ==
"0.0.0.0")
3073 NS_LOG_DEBUG (
"Route not found. Drop packet with dst " << dst);
3085 NS_LOG_DEBUG (
"Check the route request entry " << source <<
" " << dst);
3102 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
3104 NS_LOG_LOGIC (
"Inserting into priority queue number: " << priority);
3110 if (dsrNetworkQueue->Enqueue (newEntry))
3116 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
3148 std::vector<Ipv4Address>::iterator before = find (nodeList.begin (), nodeList.end (), srcAddress);
3149 for (std::vector<Ipv4Address>::iterator i = nodeList.begin (); i != before; ++i)
3154 std::vector<Ipv4Address>::iterator after = find (nodeList.begin (), nodeList.end (),
m_mainAddress);
3155 for (std::vector<Ipv4Address>::iterator j = after; j != nodeList.end (); ++j)
3181 newPacket->
AddHeader (dsrRoutingHeader);
3190 NS_LOG_INFO (
"The same gratuitous route reply has already sent");
3205 NS_LOG_INFO (
"The output device " << dev <<
" packet is: " << *packet);
3208 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
3210 NS_LOG_INFO (
"Inserting into priority queue number: " << priority);
3216 if (dsrNetworkQueue->Enqueue (newEntry))
3222 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
3234 packet, source, nextHop, route);
3256 NS_LOG_FUNCTION (
this << ackId << destination << realSrc << realDst << (uint32_t)protocol << route);
3262 dsrRoutingHeader.SetMessageType (1);
3264 dsrRoutingHeader.SetDestId (
GetIDfromIP (destination));
3275 dsrRoutingHeader.SetPayloadLength (uint16_t (length) + 2);
3276 dsrRoutingHeader.AddDsrOption (ack);
3284 std::map<uint32_t, Ptr<dsr::DsrNetworkQueue> >::iterator i =
m_priorityQueue.find (priority);
3287 NS_LOG_LOGIC (
"Will be inserting into priority queue " << dsrNetworkQueue <<
" number: " << priority);
3293 if (dsrNetworkQueue->Enqueue (newEntry))
3299 NS_LOG_INFO (
"Packet dropped as dsr network queue is full");
3321 uint32_t sourceId = dsrRoutingHeader.
GetSourceId ();
3323 NS_LOG_INFO (
"The source address " << source <<
" with source id " << sourceId);
3329 bool isPromisc =
false;
3340 uint32_t size = p->
GetSize ();
3341 uint8_t *
data =
new uint8_t[size];
3344 uint8_t optionType = 0;
3345 uint8_t optionLength = 0;
3346 uint8_t segmentsLeft = 0;
3348 optionType = *(
data);
3349 NS_LOG_LOGIC (
"The option type value " << (uint32_t)optionType <<
" with packet id " << p->
GetUid());
3352 if (optionType == 1)
3357 NS_LOG_INFO (
"Discard this packet due to unidirectional link");
3362 optionLength = dsrOption->Process (p, packet,
m_mainAddress, source, ip, protocol, isPromisc, promiscSource);
3364 if (optionLength == 0)
3370 else if (optionType == 2)
3373 optionLength = dsrOption->Process (p, packet,
m_mainAddress, source, ip, protocol, isPromisc, promiscSource);
3375 if (optionLength == 0)
3382 else if (optionType == 32)
3386 optionLength = dsrOption->Process (p, packet,
m_mainAddress, source, ip, protocol, isPromisc, promiscSource);
3388 if (optionLength == 0)
3395 else if (optionType == 3)
3398 NS_LOG_INFO (
"The option type value " << (uint32_t)optionType);
3401 optionLength = dsrOption->Process (p, packet,
m_mainAddress, source, ip, protocol, isPromisc, promiscSource);
3403 if (optionLength == 0)
3408 NS_LOG_INFO (
"The option Length " << (uint32_t)optionLength);
3411 else if (optionType == 96)
3414 optionLength = dsrOption->Process (p, packet,
m_mainAddress, source, ip, protocol, isPromisc, promiscSource);
3415 segmentsLeft = *(data + 3);
3416 if (optionLength == 0)
3423 if (segmentsLeft == 0)
3435 nextProto->Receive (copy, ip, incomingInterface);
3462 NS_LOG_INFO (
"This is not the final destination, the packet has already been forward to next hop");
3472 uint8_t salvage = 0;
3534 if ((*i)->GetOptionNumber () == optionNumber)
uint32_t m_sendRetries
of retries have been sent for network acknowledgment
uint32_t m_stabilityDecrFactor
The initial decrease factor for link cache.
uint32_t RemoveHeader(Header &header)
Deserialize and remove the header from the internal buffer.
uint32_t GetSize()
Number of entries.
Ptr< const AttributeChecker > MakeStringChecker(void)
void SetDownTarget(IpL4Protocol::DownTargetCallback callback)
This method allows a caller to set the current down target callback set for this L4 protocol (IPv4 ca...
uint32_t GetSize()
Number of entries.
void UseExtends(DsrRouteCacheEntry::IP_VECTOR rt)
functions used to direct to route cache
void SetRequestTable(Ptr< dsr::DsrRreqTable > r)
Set the node.
std::string m_cacheType
The type of route cache.
Ptr< dsr::DsrPassiveBuffer > GetPassiveBuffer() const
Get the passive buffer.
Simulation virtual time values and global simulation resolution.
Smart pointer class similar to boost::intrusive_ptr.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
void SetStream(int64_t stream)
Specifies the stream number for this RNG stream.
Ipv4Address GetDst() const
bool PassiveEntryCheck(Ptr< Packet > packet, Ipv4Address source, Ipv4Address destination, uint8_t segsLeft, uint16_t fragmentOffset, uint16_t identification, bool saveEntry)
Find the same passive entry.
static uint32_t GetNNodes(void)
AttributeValue implementation for Boolean.
uint8_t GetSegsLeft() const
virtual void DoDispose(void)
Drop trace callback.
uint32_t m_maxSendBuffLen
The maximum number of packets that we allow a routing protocol to buffer.
Ipv4Address GetOurAdd() const
void ScheduleInterRequest(Ptr< Packet > packet)
Schedule the intermediate route request.
uint32_t m_stabilityIncrFactor
The initial increase factor for link cache.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
bool LookupRoute(Ipv4Address id, DsrRouteCacheEntry &rt)
functions used to direct to route cache
void SetMaxQueueLen(uint32_t len)
void SendInitialRequest(Ipv4Address source, Ipv4Address destination, uint8_t protocol)
Broadcast the route request packet in subnet.
Ptr< const Packet > GetPacket() const
Ptr< T > GetObject(void) const
Get a pointer to the requested aggregated Object.
bool FindAndUpdate(Ipv4Address replyTo, Ipv4Address replyFrom, Time gratReplyHoldoff)
Update the route entry if found, create a new one if not.
Hold variables of type string.
void SendBuffTimerExpire()
The send buffer timer expire.
static Ptr< Node > GetNode(uint32_t n)
void Scheduler(uint32_t priority)
This function is called to schedule sending packets from the network queue.
bool NetworkEqual(DsrMaintainBuffEntry &entry)
Verify if the maintain buffer entry is the same in every field for network ack.
DSR Maintain Buffer Entry.
Ipv4Address m_destination
void SalvagePacket(Ptr< const Packet > packet, Ipv4Address source, Ipv4Address dst, uint8_t protocol)
Salvage the packet which has been transmitted for 3 times.
Time m_sendBuffInterval
how often to check send buffer
Time m_passiveAckTimeout
The timeout value for passive acknowledge.
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
Ipv4Address GetSrc() const
uint32_t m_discoveryHopLimit
Maximum hops to go for route request.
uint32_t GetPriority(DsrMessageType messageType)
Set the priority of the packet in network queue.
Ptr< Ipv4 > m_ip
The ip ptr.
bool Find(Ipv4Address dst)
Finds whether a packet with destination dst exists in the queue.
void AddPacketTag(const Tag &tag) const
Add a packet tag.
uint32_t m_linkRetries
of retries have been sent for link acknowledgment
TracedCallback< const DsrOptionSRHeader & > m_txPacketTrace
uint64_t GetUid(void) const
Returns the packet's Uid.
void SetDst(Ipv4Address n)
bool IsNull(void) const
Check for null implementation.
void DeleteAllRoutesIncludeLink(Ipv4Address errorSrc, Ipv4Address unreachNode, Ipv4Address node)
functions used to direct to route cache
Time m_maxRequestPeriod
The max request period.
void PrintVector(std::vector< Ipv4Address > &vec)
Print the route vector.
std::vector< DsrSendBuffEntry > & GetBuffer()
Return a pointer to the internal queue.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
PacketType
Packet types are used as they are in Linux.
Ptr< dsr::DsrRreqTable > GetRequestTable() const
Get the request table.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
IP_VECTOR GetVector() const
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
uint32_t m_maxEntriesEachDst
Max number of route entries to save for each destination.
uint32_t GetSize(void) const
Returns the the size in bytes of the packet (including the zero-filled initial payload).
void IncreaseRetransTimer()
This function is called to increase the retransmission timer for data packet in the network queue...
bool IsMulticast(void) const
Ipv4Address m_mainAddress
Our own Ip address.
bool AllEqual(DsrMaintainBuffEntry &entry)
Verify if all the elements in the maintainence buffer entry is the same.
Ipv4Address SearchNextHop(Ipv4Address ipv4Address, std::vector< Ipv4Address > &vec)
Get the next hop of the route.
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
uint16_t GetAckId() const
void CancelPacketAllTimer(DsrMaintainBuffEntry &mb)
Cancel all the packet timers.
void(* Time)(Time oldValue, Time newValue)
TracedValue callback signature for Time.
bool IsLinkCache()
functions used to direct to route cache
virtual void DoDispose(void)
Destructor implementation.
Time m_linkAckTimeout
The timeout value for link acknowledge.
#define NS_LOG_FUNCTION_NOARGS()
Output the name of the function.
Ipv4Address GetNextHop() const
bool PromiscReceive(Ptr< NetDevice > device, Ptr< const Packet > packet, uint16_t protocol, const Address &from, const Address &to, NetDevice::PacketType packetType)
Promiscuous receive data packets destined to some other node.
This class implements a tag that carries the socket-specific TTL of a packet to the IP layer...
void SetSegsLeft(uint8_t segs)
uint32_t m_requestTableSize
The max size of the request table size.
void ScheduleCachedReply(Ptr< Packet > packet, Ipv4Address source, Ipv4Address destination, Ptr< Ipv4Route > route, double hops)
Schedule the cached reply to a random start time to avoid possible route reply storm.
uint32_t m_tryLinkAcks
Maximum number of packet transmission using link acknowledgment.
Ipv4Address m_destination
void ForwardErrPacket(DsrOptionRerrUnreachHeader &rerr, DsrOptionSRHeader &sourceRoute, Ipv4Address nextHop, uint8_t protocol, Ptr< Ipv4Route > route)
This function is responsible for forwarding error packets along the route.
Time m_maxCacheTime
Max time for caching the route cache entry.
Time m_gratReplyHoldoff
The max gratuitous reply hold off time.
a polymophic address class
Ptr< const Packet > GetPacket() const
uint32_t m_maxMaintainLen
Max # of entries for maintainance buffer.
void SendRequest(Ptr< Packet > packet, Ipv4Address source)
Forward the route request if the node is not the destination.
Ipv4Address GetIPfromID(uint16_t id)
Get the ip address from id.
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
Create a TraceSourceAccessor which will control access to the underlying trace source.
bool IsRunning(void) const
Ptr< const AttributeChecker > MakeTimeChecker(const Time min, const Time max)
Helper to make a Time checker with bounded range.
std::vector< Ipv4Address > m_finalRoute
The route cache.
static TypeId GetTypeId()
Get the type identificator.
void SetSource(Ipv4Address src)
int64_t AssignStreams(int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model...
bool Dequeue(Ipv4Address dst, DsrErrorBuffEntry &entry)
Return first found (the earliest) entry for given destination.
uint32_t m_graReplyTableSize
Set the gratuitous reply table size.
bool AddRoute(DsrRouteCacheEntry &rt)
functions used to direct to route cache
DsrMaintainBuffer m_maintainBuffer
The declaration of maintain buffer.
void SetDestination(Ipv4Address d)
Ipv4Address m_destination
Time m_maxNetworkDelay
Maximum network delay.
double GetSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
uint16_t m_ackId
The ack id assigned to each acknowledge.
uint32_t GetDsrOptionsOffset()
Get the offset where the options begin, measured from the start of the extension header.
virtual uint32_t GetInteger(void)=0
Get the next random value as an integer drawn from the distribution.
void DropPacketWithDst(Ipv4Address dst)
Remove all packets with destination IP address dst.
void RemoveAtStart(uint32_t size)
Remove size bytes from the start of the current packet.
Ptr< const AttributeAccessor > MakePointerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
static EventId Schedule(Time const &delay, MEM mem_ptr, OBJ obj)
Schedule an event to expire after delay.
DsrGraReply m_graReply
The gratuitous route reply.
void DropPacketForErrLink(Ipv4Address source, Ipv4Address nextHop)
Remove all packets with the error link.
void SetTtl(uint8_t ttl)
Set the tag's TTL.
AttributeValue implementation for Time.
void Schedule(void)
Schedule a new event using the currently-configured delay, function, and arguments.
void CancelPassivePacketTimer(DsrMaintainBuffEntry &mb)
Cancel the passive packet retransmission timer for a specific maintenance entry.
void SetGateway(Ipv4Address gw)
void SendUnreachError(Ipv4Address unreachNode, Ipv4Address destination, Ipv4Address originalDst, uint8_t salvage, uint8_t protocol)
This function is responsible for sending error packets in case of break link to next hop...
void SetErrorBufferTimeout(Time t)
Hold an unsigned integer type.
Time m_sendBufferTimeout
The maximum period of time that a routing protocol is allowed to buffer a packet for.
int GetProtocolNumber(void) const
Get the dsr protocol number.
Ipv4Address m_broadcast
The broadcast IP address.
uint32_t GetSize()
Number of entries.
void SetSendBufferTimeout(Time t)
Set the entry lifetime in the queue.
bool IsBroadcast(void) const
uint32_t m_numPriorityQueues
The number of priority queues used.
uint32_t m_broadcastJitter
The max time to delay route request broadcast.
void ScheduleLinkPacketRetry(DsrMaintainBuffEntry &mb, uint8_t protocol)
Schedule the packet retransmission based on link-layer acknowledgment.
void SetNode(Ptr< Node > node)
Set the node.
static const uint8_t PROT_NUMBER
Define the dsr protocol number.
uint32_t m_requestId
The id assigned to each route request.
DsrErrorBuffer m_errorBuffer
The error buffer to save the error messages.
Ptr< NetDevice > GetDevice(uint32_t index) const
Retrieve the index-th NetDevice associated to this node.
Hold together all Wifi-related objects.
void NetworkScheduleTimerExpire(DsrMaintainBuffEntry &mb, uint8_t protocol)
This function deals with packet retransmission timer expire using network acknowledgment.
bool Find(Ipv4Address nextHop)
Finds whether a packet with destination dst exists in the queue.
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
void SetDownTarget6(IpL4Protocol::DownTargetCallback6 callback)
This method allows a caller to set the current down target callback set for this L4 protocol (IPv6 ca...
Ptr< Ipv4L3Protocol > m_ipv4
Ipv4l3Protocol.
void Send(Ptr< Packet > packet, Ipv4Address source, Ipv4Address destination, uint8_t protocol, Ptr< Ipv4Route > route)
uint32_t m_requestTableIds
The request table identifiers.
bool AddRoute_Link(DsrRouteCacheEntry::IP_VECTOR nodelist, Ipv4Address source)
functions used to direct to route cache
void SendReply(Ptr< Packet > packet, Ipv4Address source, Ipv4Address nextHop, Ptr< Ipv4Route > route)
Send the route reply back to the request originator with the cumulated route.
Ptr< const Packet > GetPacket() const
bool UpdateRouteEntry(Ipv4Address dst)
functions used to direct to route cache
Time m_minLifeTime
The min life time.
void SetFragmentOffset(uint16_t f)
std::vector< Ipv4Address > IP_VECTOR
Define the vector to hold Ip address.
Time m_useExtends
The use extension of the life time for link cache.
DSR Passive Buffer Entry.
void SetMaxQueueLen(uint32_t len)
void SchedulePassivePacketRetry(DsrMaintainBuffEntry &mb, uint8_t protocol)
Schedule the packet retransmission based on passive acknowledgment.
bool Find(Ipv4Address dst)
Check if a packet with destination dst exists in the queue.
void ScheduleInitialReply(Ptr< Packet > packet, Ipv4Address source, Ipv4Address nextHop, Ptr< Ipv4Route > route)
this is a generating the initial route reply from the destination address, a random delay time [0...
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
Time m_blacklistTimeout
The black list time out.
bool Enqueue(DsrErrorBuffEntry &entry)
Push entry in queue, if there is no entry with the same packet and destination address in queue...
std::map< NetworkKey, Timer > m_addressForwardTimer
Map network key + forward timer.
static Mac48Address ConvertFrom(const Address &address)
std::map< Ipv4Address, Timer > m_addressReqTimer
Map IP address + RREQ timer.
void SetPassiveBuffer(Ptr< dsr::DsrPassiveBuffer > r)
Set the node.
Access to the IPv4 forwarding table, interfaces, and configuration.
bool PromiscEqual(DsrMaintainBuffEntry &entry)
Verify if the maintain buffer entry is the same in every field for promiscuous ack.
Ptr< Packet > Copy(void) const
performs a COW copy of the packet.
void LinkScheduleTimerExpire(DsrMaintainBuffEntry &mb, uint8_t protocol)
This function deals with packet retransmission timer expire using link acknowledgment.
void SendPacketFromBuffer(DsrOptionSRHeader const &sourceRoute, Ipv4Address nextHop, uint8_t protocol)
This function is responsible for sending out data packets when have route, if no route found...
uint8_t m_maxSalvageCount
Maximum # times to salvage a packet.
Ipv4Address GetNextHopAddress() const
Time m_initStability
The initial stability value for link cache.
void SetExpireTime(Time exp)
The maintenance buffer is responsible for maintaining packet next hop delivery The data packet is sav...
Time m_requestPeriod
The base time interval between route requests.
Implement the IPv4 layer.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< dsr::DsrOptions > GetOption(int optionNumber)
Get the option corresponding to optionNumber.
uint16_t GetIDfromIP(Ipv4Address address)
Get the node id from ip address.
Hold objects of type Ptr.
Ptr< Node > m_node
The node ptr.
void CallCancelPacketTimer(uint16_t ackId, Ipv4Header const &ipv4Header, Ipv4Address realSrc, Ipv4Address realDst)
Call the cancel packet retransmission timer function.
bool Enqueue(DsrSendBuffEntry &entry)
Push entry in queue, if there is no entry with the same packet and destination address in queue...
Ptr< const AttributeChecker > MakeBooleanChecker(void)
uint32_t m_passiveRetries
of retries have been sent for passive acknowledgment
uint32_t m_maxNetworkSize
Maximum network queue size.
Packet addressed to someone else.
void SetMaintainBufferTimeout(Time t)
Ptr< Ipv4Route > SetRoute(Ipv4Address nextHop, Ipv4Address srcAddress)
Set the route to use for data packets, used by the option headers when sending data/control packets...
void Send(Ptr< Packet > packet, Ipv4Address source, Ipv4Address destination, uint8_t protocol, Ptr< Ipv4Route > route)
This function is called by higher layer protocol when sending packets.
uint32_t m_tryPassiveAcks
Maximum number of packet transmission using passive acknowledgment.
Ptr< NetDevice > GetNetDeviceFromContext(std::string context)
Get the netdevice from the context.
void SetAckId(uint16_t ackId)
uint32_t m_maxMaintRexmt
Maximum number of retransmissions of data packets.
void CancelLinkPacketTimer(DsrMaintainBuffEntry &mb)
Cancel the link packet retransmission timer for a specific maintenance entry.
void Resume(void)
Restart the timer to expire within the amount of time left saved during Suspend.
uint16_t AddAckReqHeader(Ptr< Packet > &packet, Ipv4Address nextHop)
This function is called to add ack request header for network acknowledgement.
void PacketNewRoute(Ptr< Packet > packet, Ipv4Address source, Ipv4Address destination, uint8_t protocol)
When route vector corrupted, originate a new packet, normally not happening.
Time m_retransIncr
the increase time for retransmission timer when face network congestion
void ForwardPacket(Ptr< const Packet > packet, DsrOptionSRHeader &sourceRoute, Ipv4Header const &ipv4Header, Ipv4Address source, Ipv4Address destination, Ipv4Address targetAddress, uint8_t protocol, Ptr< Ipv4Route > route)
Forward the packet using the route saved in the source route option header.
std::map< LinkKey, Timer > m_linkAckTimer
The timer for link acknowledgment.
static EventId ScheduleNow(MEM mem_ptr, OBJ obj)
Schedule an event to expire Now.
Ptr< const AttributeAccessor > MakeTimeAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
L4 Protocol abstract base class.
static Time Now(void)
Return the current simulation virtual time.
void SetOutputDevice(Ptr< NetDevice > outputDevice)
Equivalent in Linux to dst_entry.dev.
void SendPacket(Ptr< Packet > packet, Ipv4Address source, Ipv4Address nextHop, uint8_t protocol)
This function is called by when really sending out the packet.
void SetSegsLeft(uint8_t seg)
void ScheduleRreqRetry(Ptr< Packet > packet, std::vector< Ipv4Address > address, bool nonProp, uint32_t requestId, uint8_t protocol)
Schedule the route request retry.
IpL4Protocol::DownTargetCallback GetDownTarget(void) const
This method allows a caller to get the current down target callback set for this L4 protocol (IPv4 ca...
uint32_t m_maxRreqId
The max number of request ids for a single destination.
virtual enum IpL4Protocol::RxStatus Receive(Ptr< Packet > p, Ipv4Header const &header, Ptr< Ipv4Interface > incomingInterface)
Ptr< dsr::DsrRouteCache > m_routeCache
A "drop-front" queue used by the routing layer to cache routes found.
uint32_t m_maxCacheLen
Max # of cache entries for route cache.
void SetSource(Ipv4Address s)
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
void PassiveScheduleTimerExpire(DsrMaintainBuffEntry &mb, uint8_t protocol)
This function deals with packet retransmission timer expire using passive acknowledgment.
bool Dequeue(Ipv4Address dst, DsrMaintainBuffEntry &entry)
Return first found (the earliest) entry for given destination.
void SetPacket(Ptr< const Packet > p)
void CheckSendBuffer()
Check the send buffer of packets with route when send buffer timer expire.
std::map< uint32_t, Ptr< dsr::DsrNetworkQueue > > m_priorityQueue
priority queues
Ipv4Address GetSourceAddress() const
Describes an IPv6 address.
std::map< PassiveKey, uint32_t > m_passiveCnt
Map packet key + passive forward counts.
Ptr< Ipv4Route > GetIpv4Route() const
Ipv4 addresses are stored in host order in this class.
virtual void NotifyNewAggregate()
Notify all Objects aggregated to this one of a new Object being aggregated.
TracedCallback< Ptr< const Packet > > m_dropTrace
The trace for drop, receive and send data packets.
void SetMaxQueueLen(uint32_t len)
Set the maximum queue length.
Ptr< const Packet > GetPacket() const
std::map< PassiveKey, Timer > m_passiveAckTimer
The timer for passive acknowledgment.
void AddDsrOption(DsrOptionHeader const &option)
Serialize the option, prepending pad1 or padn option as necessary.
bool AddEntry(GraReplyEntry &graTableEntry)
Add a new gratuitous reply entry.
Ptr< dsr::DsrRouteCache > GetRouteCache() const
Get the route cache.
void CancelPacketTimerNextHop(Ipv4Address nextHop, uint8_t protocol)
Cancel the packet retransmission timer for a all maintenance entries with nextHop address...
Ptr< Ipv4Route > m_ipv4Route
Ipv4 Route.
void SendAck(uint16_t ackId, Ipv4Address destination, Ipv4Address realSrc, Ipv4Address realDst, uint8_t protocol, Ptr< Ipv4Route > route)
Send network layer acknowledgment back to the earlier hop to notify the receipt of data packet...
Time m_nodeTraversalTime
Time estimated for packet to travel between two nodes.
void SetPacket(Ptr< const Packet > p)
void SetRouteCache(Ptr< dsr::DsrRouteCache > r)
Set the route cache.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
bool m_subRoute
Whether to save sub route or not.
Time Seconds(double value)
Construct a Time in the indicated unit.
void Cancel(void)
Cancel the currently-running event if there is one.
void ScheduleNetworkPacketRetry(DsrMaintainBuffEntry &mb, bool isFirst, uint8_t protocol)
Schedule the packet retransmission based on network layer acknowledgment.
bool CancelPassiveTimer(Ptr< Packet > packet, Ipv4Address source, Ipv4Address destination, uint8_t segsLeft)
Cancel the passive timer.
void Insert(Ptr< dsr::DsrOptions > option)
Insert a new Dsr Option.
Ipv4Address GetIPfromMAC(Mac48Address address)
Get the Ip address from mac address.
bool SendRealDown(DsrNetworkQueueEntry &newEntry)
This function is called to send packets down stack.
void RouteRequestTimerExpire(Ptr< Packet > packet, std::vector< Ipv4Address > address, uint32_t requestId, uint8_t protocol)
Handle route discovery timer.
bool Enqueue(DsrMaintainBuffEntry &entry)
Push entry in queue, if there is no entry with the same packet and destination address in queue...
void CancelNetworkPacketTimer(DsrMaintainBuffEntry &mb)
Cancel the network packet retransmission timer for a specific maintenance entry.
uint32_t m_rreqRetries
Maximum number of retransmissions of RREQ with TTL = NetDiameter to discover a route.
void Suspend(void)
Cancel the timer and save the amount of time left until it was set to expire.
void SetGraTableSize(uint32_t g)
Set the gratuitous reply table size.
void PriorityScheduler(uint32_t priority, bool continueWithFirst)
This function is called to schedule sending packets from the network queue by priority.
Timer m_sendBuffTimer
The send buffer timer.
bool LinkEqual(DsrMaintainBuffEntry &entry)
Verify if the maintain buffer entry is the same in every field for link ack.
bool FindSourceEntry(Ipv4Address src, Ipv4Address dst, uint16_t id)
functions used to direct to route cache
uint32_t CopyData(uint8_t *buffer, uint32_t size) const
Copy the packet contents to a byte buffer.
Ptr< UniformRandomVariable > m_uniformRandomVariable
Provides uniform random variables.
Time MicroSeconds(uint64_t value)
Construct a Time in the indicated unit.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
Ptr< Node > GetNodeWithAddress(Ipv4Address ipv4Address)
Get the node with give ip address.
DsrOptionList_t m_options
List of DSR Options supported.
void SendGratuitousReply(Ipv4Address replyTo, Ipv4Address replyFrom, std::vector< Ipv4Address > &nodeList, uint8_t protocol)
Send the gratuitous reply.
void SendErrorRequest(DsrOptionRerrUnreachHeader &rerr, uint8_t protocol)
Send the error request packet.
virtual void NotifyNewAggregate(void)
Notify all Objects aggregated to this one of a new Object being aggregated.
Ptr< const AttributeAccessor > MakeStringAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
Ptr< Node > GetNode() const
Get the node.
std::map< LinkKey, uint32_t > m_linkCnt
Map packet key + link forward counts.
bool IsSuspended(void) const
void SetIdentification(uint16_t i)
This policy cancels the event from the destructor of the Timer to verify that the event has already e...
IpL4Protocol::DownTargetCallback6 GetDownTarget6(void) const
This method allows a caller to get the current down target callback set for this L4 protocol (IPv6 ca...
std::map< NetworkKey, uint32_t > m_addressForwardCnt
Map network key + forward counts.
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
a unique identifier for an interface.
Time m_nonpropRequestTimeout
The non-propagation request timeout.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
std::map< Ipv4Address, Timer > m_nonPropReqTimer
Map IP address + RREQ timer.
bool Dequeue(Ipv4Address dst, DsrSendBuffEntry &entry)
Return first found (the earliest) entry for the given destination.
bool m_linkAck
define if we use link acknowledgement or not
std::vector< std::string > GetElementsFromContext(std::string context)
Get the elements from the tracing context.
void AddHeader(const Header &header)
Add header to this packet.
Ptr< dsr::DsrRreqTable > m_rreqTable
A "drop-front" queue used by the routing layer to cache route request sent.
Ptr< dsr::DsrPassiveBuffer > m_passiveBuffer
A "drop-front" queue used by the routing layer to cache route request sent.
static const uint16_t PROT_NUMBER
Protocol number (0x0800)
void SetDestination(Ipv4Address dest)
IpL4Protocol::DownTargetCallback m_downTarget
The callback for down layer.
DsrSendBuffer m_sendBuffer
The send buffer.
void SetSrc(Ipv4Address s)
Time m_maxMaintainTime
Time out for maintainance buffer.
void CancelRreqTimer(Ipv4Address dst, bool isRemove)
Cancel the route request timer.
virtual ~DsrRouting()
Destructor.