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"
28static std::vector<std::string>
31 std::vector<std::string> results;
33 while ((cutAt = str.find_first_of(
'/')) != std::string::npos)
37 results.push_back(str.substr(0, cutAt));
39 str = str.substr(cutAt + 1);
43 results.push_back(str);
63 void Print(std::ostream& os)
const override;
78 .SetGroupName(
"Visualizer")
168 std::ostringstream sstream;
169 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/MacTx";
173 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Rx";
177 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/PromiscRx";
186 std::ostringstream sstream;
187 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Tx";
191 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Rx";
200 std::ostringstream sstream;
201 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/TxQueue/Dequeue";
205 sstream <<
"/NodeList/*/DeviceList/*/$" << deviceTypeName <<
"/Rx";
213 << nodeId <<
" PacketCaptureOptions (headers size = " << options.
headers.size()
239 <<
": Have " <<
g_visualizer->m_pauseMessages.size() <<
" pause messages");
249std::vector<std::string>
253 <<
": GetPauseMessages: have " <<
g_visualizer->m_pauseMessages.size()
254 <<
" pause messages");
283 if (iter->second.time < expirationTime)
296 if (iter->second < expirationTime)
325 visualImpl->RunRealSimulator();
367 std::vector<NetDeviceStatistics>* stats;
375 stats = &(nodeStatsIter->second);
391 *outOptions = &iter->second;
399 switch (options.
mode)
406 while (metadataIterator.
HasNext())
418 std::set<TypeId> missingHeaders(options.
headers);
420 while (metadataIterator.
HasNext())
423 auto missingIter = missingHeaders.find(item.
tid);
424 if (missingIter != missingHeaders.end())
426 missingHeaders.erase(missingIter);
429 return missingHeaders.empty();
442 std::vector<std::string> splitPath =
PathSplit(context);
443 int nodeIndex = std::stoi(splitPath[1]);
452 NS_LOG_DEBUG(
"Packet " << packet->GetUid() <<
" is not of interest");
465 lastPacket.
packet = packet->Copy();
466 lastPacket.
device =
nullptr;
481 iter->second += packet->GetSize();
494 packetCopy->AddHeader(hdr);
507 std::vector<std::string> splitPath =
PathSplit(context);
508 int nodeIndex = std::stoi(splitPath[1]);
509 int devIndex = std::stoi(splitPath[3]);
526 lastPacket.
packet = packet->Copy();
527 lastPacket.
device = device;
528 lastPacket.
to = destinationAddress;
544 NS_LOG_DEBUG(
"Packet " << packet->GetUid() <<
" is not of interest");
555 if (destinationAddress == device->GetBroadcast())
565 packet->AddByteTag(tag);
586 destinationAddress = hdr.
GetAddr3();
590 destinationAddress = hdr.
GetAddr1();
599 NS_ABORT_IF(packet->PeekHeader(ethernetHeader) == 0);
618 if (packet->FindFirstMatchingByteTag(tag))
626 uid = packet->GetUid();
630 std::vector<std::string> splitPath =
PathSplit(context);
631 int nodeIndex = std::stoi(splitPath[1]);
632 int devIndex = std::stoi(splitPath[3]);
650 lastPacket.
packet = packet->Copy();
651 lastPacket.
device = device;
652 lastPacket.
from = from;
663 NS_LOG_DEBUG(
"RX Packet " << uid <<
" is not of interest");
673 NS_LOG_DEBUG(
"RX Packet " << uid <<
" was not transmitted?!");
681 NS_LOG_WARN(
"Node " << node->GetId() <<
" receiving back the same packet (UID=" << uid
682 <<
") it had previously transmitted, on the same channel!");
695 <<
"/" << iter->first.transmitter->GetId() <<
", " << iter->first.receiver
696 <<
"/" << iter->first.receiver->GetId() <<
", " << iter->first.channel
697 <<
" => " << iter->second.bytes <<
" (@ " << &iter->second <<
")");
710 << channel <<
": " << packet->GetSize()
711 <<
" bytes more. => new sample with " << packet->GetSize()
720 << channel <<
": " << packet->GetSize()
721 <<
" bytes more. => sample " << &sample <<
" with bytes "
724 sample.
bytes += packet->GetSize();
764 NS_ABORT_IF(packet->PeekHeader(ethernetHeader) == 0);
778 NS_ABORT_IF(packet->PeekHeader(ethernetHeader) == 0);
817 sample.
receiver = iter->first.receiver;
818 sample.
channel = iter->first.channel;
819 sample.
bytes = iter->second.bytes;
821 <<
": " << sample.
bytes <<
" bytes.");
822 list.push_back(sample);
837 sample.
bytes = iter->second;
839 <<
" bytes dropped.");
840 list.push_back(sample);
852std::vector<PyViz::NodeStatistics>
855 std::vector<PyViz::NodeStatistics> retval;
859 retval.push_back(stats);
1006 uint8_t lineCode = 0;
1563 FastClipping::Vector2 clipMin = {boundsX1, boundsY1};
1564 FastClipping::Vector2 clipMax = {boundsX2, boundsY2};
1565 FastClipping::Line line = {{lineX1, lineY1},
1570 FastClipping clipper(clipMin, clipMax);
1571 clipper.ClipLine(line);
1572 lineX1 = line.start.x;
1573 lineX2 = line.end.x;
1574 lineY1 = line.start.y;
1575 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