14#include "ns3/config.h"
15#include "ns3/ethernet-header.h"
17#include "ns3/node-list.h"
18#include "ns3/ppp-header.h"
19#include "ns3/simulator.h"
20#include "ns3/wifi-mac-header.h"
21#include "ns3/wifi-net-device.h"
28#define NUM_LAST_PACKETS 10
30static std::vector<std::string>
33 std::vector<std::string> results;
35 while ((cutAt = str.find_first_of(
'/')) != std::string::npos)
39 results.push_back(str.substr(0, cutAt));
41 str = str.substr(cutAt + 1);
45 results.push_back(str);
65 void Print(std::ostream& os)
const override;
80 .SetGroupName(
"Visualizer")
170 std::ostringstream sstream;
171 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/MacTx";
175 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Rx";
179 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/PromiscRx";
188 std::ostringstream sstream;
189 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Tx";
193 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Rx";
202 std::ostringstream sstream;
203 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/TxQueue/Dequeue";
207 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Rx";
215 << nodeId <<
" PacketCaptureOptions (headers size = " << options.
headers.size()
241 <<
": Have " <<
g_visualizer->m_pauseMessages.size() <<
" pause messages");
251std::vector<std::string>
255 <<
": GetPauseMessages: have " <<
g_visualizer->m_pauseMessages.size()
256 <<
" pause messages");
285 if (iter->second.time < expirationTime)
298 if (iter->second < expirationTime)
327 visualImpl->RunRealSimulator();
369 std::vector<NetDeviceStatistics>* stats;
377 stats = &(nodeStatsIter->second);
393 *outOptions = &iter->second;
401 switch (options.
mode)
408 while (metadataIterator.
HasNext())
420 std::set<TypeId> missingHeaders(options.
headers);
422 while (metadataIterator.
HasNext())
425 auto missingIter = missingHeaders.find(item.
tid);
426 if (missingIter != missingHeaders.end())
428 missingHeaders.erase(missingIter);
431 return missingHeaders.empty();
444 std::vector<std::string> splitPath =
PathSplit(context);
445 int nodeIndex = std::stoi(splitPath[1]);
454 NS_LOG_DEBUG(
"Packet " << packet->GetUid() <<
" is not of interest");
467 lastPacket.
packet = packet->Copy();
468 lastPacket.
device =
nullptr;
483 iter->second += packet->GetSize();
496 packetCopy->AddHeader(hdr);
509 std::vector<std::string> splitPath =
PathSplit(context);
510 int nodeIndex = std::stoi(splitPath[1]);
511 int devIndex = std::stoi(splitPath[3]);
528 lastPacket.
packet = packet->Copy();
529 lastPacket.
device = device;
530 lastPacket.
to = destinationAddress;
546 NS_LOG_DEBUG(
"Packet " << packet->GetUid() <<
" is not of interest");
557 if (destinationAddress == device->GetBroadcast())
567 packet->AddByteTag(tag);
588 destinationAddress = hdr.
GetAddr3();
592 destinationAddress = hdr.
GetAddr1();
601 NS_ABORT_IF(packet->PeekHeader(ethernetHeader) == 0);
620 if (packet->FindFirstMatchingByteTag(tag))
628 uid = packet->GetUid();
632 std::vector<std::string> splitPath =
PathSplit(context);
633 int nodeIndex = std::stoi(splitPath[1]);
634 int devIndex = std::stoi(splitPath[3]);
652 lastPacket.
packet = packet->Copy();
653 lastPacket.
device = device;
654 lastPacket.
from = from;
665 NS_LOG_DEBUG(
"RX Packet " << uid <<
" is not of interest");
675 NS_LOG_DEBUG(
"RX Packet " << uid <<
" was not transmitted?!");
683 NS_LOG_WARN(
"Node " << node->GetId() <<
" receiving back the same packet (UID=" << uid
684 <<
") it had previously transmitted, on the same channel!");
697 <<
"/" << iter->first.transmitter->GetId() <<
", " << iter->first.receiver
698 <<
"/" << iter->first.receiver->GetId() <<
", " << iter->first.channel
699 <<
" => " << iter->second.bytes <<
" (@ " << &iter->second <<
")");
712 << channel <<
": " << packet->GetSize()
713 <<
" bytes more. => new sample with " << packet->GetSize()
722 << channel <<
": " << packet->GetSize()
723 <<
" bytes more. => sample " << &sample <<
" with bytes "
726 sample.
bytes += packet->GetSize();
766 NS_ABORT_IF(packet->PeekHeader(ethernetHeader) == 0);
780 NS_ABORT_IF(packet->PeekHeader(ethernetHeader) == 0);
819 sample.
receiver = iter->first.receiver;
820 sample.
channel = iter->first.channel;
821 sample.
bytes = iter->second.bytes;
823 <<
": " << sample.
bytes <<
" bytes.");
824 list.push_back(sample);
839 sample.
bytes = iter->second;
841 <<
" bytes dropped.");
842 list.push_back(sample);
854std::vector<PyViz::NodeStatistics>
857 std::vector<PyViz::NodeStatistics> retval;
861 retval.push_back(stats);
1008 uint8_t lineCode = 0;
1565 FastClipping::Vector2 clipMin = {boundsX1, boundsY1};
1566 FastClipping::Vector2 clipMax = {boundsX2, boundsY2};
1567 FastClipping::Line line = {{lineX1, lineY1},
1572 FastClipping clipper(clipMin, clipMax);
1573 clipper.ClipLine(line);
1574 lineX1 = line.start.x;
1575 lineX2 = line.end.x;
1576 lineY1 = line.start.y;
1577 lineY2 = line.end.y;
DropReason
Reason why a packet has been dropped.
PacketType
Packet types are used as they are in Linux.
@ PACKET_OTHERHOST
Packet addressed to someone else.
static Ptr< Node > GetNode(uint32_t n)
Smart pointer class similar to boost::intrusive_ptr.
helper class to be used by the visualizer
void RegisterCsmaLikeDevice(const std::string &deviceTypeName)
Register CSMA like device function.
void TraceNetDevRxCsma(std::string context, Ptr< const Packet > packet)
CSMA receive trace callback function.
void SetPacketCaptureOptions(uint32_t nodeId, PacketCaptureOptions options)
Set packet capture options function.
void TraceNetDevRxPointToPoint(std::string context, Ptr< const Packet > packet)
Point to point receive trace callback function.
void RegisterDropTracePath(const std::string &tracePath)
Register drop trace path function.
void RegisterWifiLikeDevice(const std::string &deviceTypeName)
Register WIFI like device function.
std::map< uint32_t, PacketCaptureOptions > m_packetCaptureOptions
packet capture options
void TraceNetDevTxLte(std::string context, Ptr< const Packet > packet, const Mac48Address &destination)
LTE transmit trace callback function.
std::map< uint32_t, LastPacketsSample > m_lastPackets
last packets
void SimulatorRunUntil(Time time)
Run simulation until a given (simulated, absolute) time is reached.
PacketDropSampleList GetPacketDropSamples() const
Get packet drop samples.
void SetNodesOfInterest(std::set< uint32_t > nodes)
Set nodes of interest function.
std::map< uint32_t, std::vector< NetDeviceStatistics > > m_nodesStatistics
node statistics
void TraceNetDevTxCsma(std::string context, Ptr< const Packet > packet)
CSMA transmit trace callback function.
void TraceNetDevTxCommon(const std::string &context, Ptr< const Packet > packet, const Mac48Address &destination)
Network transmit common trace callback function.
void DoPause(const std::string &message)
Do pause function.
std::vector< NodeStatistics > GetNodesStatistics() const
Get node statistics.
std::set< uint32_t > m_nodesOfInterest
list of node IDs whose transmissions will be monitored
void TraceNetDevPromiscRxCsma(std::string context, Ptr< const Packet > packet)
CSMA promiscuous receive function.
static void Pause(const std::string &message)
Pause function.
std::vector< std::string > m_pauseMessages
pause message
void TraceNetDevRxLte(std::string context, Ptr< const Packet > packet, const Mac48Address &source)
LTE receive trace callback function.
void TraceIpv4Drop(std::string context, const ns3::Ipv4Header &hdr, Ptr< const Packet > packet, ns3::Ipv4L3Protocol::DropReason reason, Ptr< Ipv4 > dummy_ipv4, uint32_t interface)
Ipv4 drop trace callback function.
void TraceNetDevRxCommon(const std::string &context, Ptr< const Packet > packet, const Mac48Address &source)
Network receive common trace callback function.
TransmissionSampleList GetTransmissionSamples() const
Get transmission samples.
static void LineClipping(double boundsX1, double boundsY1, double boundsX2, double boundsY2, double &lineX1, double &lineY1, double &lineX2, double &lineY2)
Utility function - clips a line to a bounding box.
std::map< TransmissionSampleKey, TransmissionSampleValue > m_transmissionSamples
transmission samples
void TraceNetDevTxPointToPoint(std::string context, Ptr< const Packet > packet)
Point to point transmit trace callback function.
void TraceNetDevRxWifi(std::string context, Ptr< const Packet > packet)
Wi-Fi receive trace callback function.
NetDeviceStatistics & FindNetDeviceStatistics(int node, int interface)
Find net device statistics function.
void TraceDevQueueDrop(std::string context, Ptr< const Packet > packet)
Queue drop trace callback function.
std::map< TxRecordKey, TxRecordValue > m_txRecords
transmit records
std::vector< std::string > GetPauseMessages() const
Get pause message function.
std::vector< PacketDropSample > PacketDropSampleList
PacketDropSampleList typedef.
static bool FilterPacket(Ptr< const Packet > packet, const PacketCaptureOptions &options)
Filter packet function.
void CallbackStopSimulation()
Stop simulation callback function.
void RegisterPointToPointLikeDevice(const std::string &deviceTypeName)
Register point to point like device function.
std::map< Ptr< Node >, uint32_t > m_packetDrops
packet drops
LastPacketsSample GetLastPackets(uint32_t nodeId) const
Get last packets function.
void TraceNetDevTxWifi(std::string context, Ptr< const Packet > packet)
Wi-Fi transmit trace callback function.
bool GetPacketCaptureOptions(uint32_t nodeId, const PacketCaptureOptions **outOptions) const
Get packet capture options function.
Time m_runUntil
run until time
std::map< uint32_t, Time > m_packetsOfInterest
list of packet UIDs that will be monitored
std::pair< Ptr< Channel >, uint32_t > TxRecordKey
TxRecordKey typedef.
std::vector< TransmissionSample > TransmissionSampleList
TransmissionSampleList typedef.
@ PACKET_CAPTURE_FILTER_HEADERS_OR
@ PACKET_CAPTURE_DISABLED
@ PACKET_CAPTURE_FILTER_HEADERS_AND
static Ptr< SimulatorImpl > GetImplementation()
Get the SimulatorImpl singleton.
static void ScheduleWithContext(uint32_t context, const Time &delay, FUNC f, Ts &&... args)
Schedule an event with the given context.
static Time Now()
Return the current simulation virtual time.
@ NO_CONTEXT
Flag for events not associated with any particular context.
static void Stop()
Tell the Simulator the calling event should be the last one executed.
TAG_BUFFER_INLINE uint32_t ReadU32()
TAG_BUFFER_INLINE void WriteU32(uint32_t v)
tag a set of bytes in a packet
Simulation virtual time values and global simulation resolution.
a unique identifier for an interface.
static TypeId LookupByName(std::string name)
Get a TypeId by name.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
bool ClipLine(Line &line)
Clip line function.
Vector2 m_clipMin
clip minimum
void ClipEndRight(Line &line) const
Clip end right function.
Vector2 m_clipMax
clip maximum
void ClipEndBottom(Line &line) const
Clip end bottom function.
void ClipStartLeft(Line &line) const
Clip start left function.
void ClipStartTop(Line &line) const
Clip start top function.
void ClipStartBottom(Line &line) const
Clip start bottom function.
void ClipStartRight(Line &line) const
Clip start right function.
FastClipping(Vector2 clipMin, Vector2 clipMax)
Constructor.
void ClipEndLeft(Line &line) const
Clip end left function.
void ClipEndTop(Line &line) const
Clip end top function.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
void Connect(std::string path, const CallbackBase &cb)
bool ConnectFailSafe(std::string path, const CallbackBase &cb)
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_IF(cond)
Abnormal program termination if a condition is true.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
#define NS_LOG_FUNCTION_NOARGS()
Output the name of the function.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
Time Seconds(double value)
Construct a Time in the indicated unit.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Callback< R, Args... > MakeCallback(R(T::*memPtr)(Args...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
Ptr< T1 > DynamicCast(const Ptr< T2 > &p)
Cast a Ptr.
@ LOG_DEBUG
Full voluminous logging to support debugging.
static PyViz * g_visualizer
the visualizer
static std::vector< std::string > PathSplit(std::string str)
LastPacketsSample structure.
std::vector< PacketSample > lastDroppedPackets
last dropped packets
std::vector< TxPacketSample > lastTransmittedPackets
last transmitted packets
std::vector< RxPacketSample > lastReceivedPackets
last received packets
NetDeviceStatistics structure.
uint64_t receivedBytes
received bytes
uint64_t transmittedBytes
transmitted bytes
uint32_t receivedPackets
received packets
uint32_t transmittedPackets
transmitted packets
NodeStatistics structure.
PacketCaptureOptions structure.
PacketCaptureMode mode
mode
uint32_t numLastPackets
num last packets
std::set< TypeId > headers
headers
PacketDropSample structure.
Ptr< Node > transmitter
transmitter
Ptr< Packet > packet
packet
Ptr< NetDevice > device
device
RxPacketSample structure.
TransmissionSample structure.
Ptr< Node > transmitter
transmitter
Ptr< Channel > channel
channel
Ptr< Node > receiver
NULL if broadcast.
TransmissionSampleKey structure.
Ptr< Channel > channel
channel
bool operator==(const TransmissionSampleKey &other) const
Equality operator.
bool operator<(const TransmissionSampleKey &other) const
Less than operator.
Ptr< Node > transmitter
transmitter
Ptr< Node > receiver
NULL if broadcast.
TransmissionSampleValue structure.
TxPacketSample structure.
Ptr< Node > srcNode
source node
bool isBroadcast
is broadcast?
PyVizPacketTag structure.
TypeId GetInstanceTypeId() const override
Get the most derived TypeId for this Object.
void Deserialize(TagBuffer buf) override
void Serialize(TagBuffer buf) const override
static TypeId GetTypeId()
Get the type ID.
uint32_t m_packetId
packet id
void Print(std::ostream &os) const override
uint32_t GetSerializedSize() const override