23#include "ns3/packet.h"
24#include "ns3/tcp-header.h"
25#include "ns3/udp-header.h"
121 if (ipPayload->GetSize() < 4)
133 ipPayload->CopyData(
data, 4);
135 uint16_t srcPort = 0;
140 uint16_t dstPort = 0;
149 auto insert =
m_flowMap.insert(std::pair<FiveTuple, FlowId>(tuple, 0));
155 insert.first->second = newFlowId;
166 auto dscpInserter =
m_flowDscpMap[insert.first->second].insert(
167 std::pair<Ipv6Header::DscpType, uint32_t>(dscp, 1));
170 if (!dscpInserter.second)
175 *out_flowId = insert.first->second;
186 if (iter->second == flowId)
198 std::pair<Ipv6Header::DscpType, uint32_t> right)
200 return left.second > right.second;
203std::vector<std::pair<Ipv6Header::DscpType, uint32_t>>
213 std::vector<std::pair<Ipv6Header::DscpType, uint32_t>> v(flow->second.begin(),
223 os <<
"<Ipv6FlowClassifier>\n";
229 os <<
"<Flow flowId=\"" << iter->second <<
"\""
230 <<
" sourceAddress=\"" << iter->first.sourceAddress <<
"\""
231 <<
" destinationAddress=\"" << iter->first.destinationAddress <<
"\""
232 <<
" protocol=\"" << int(iter->first.protocol) <<
"\""
233 <<
" sourcePort=\"" << iter->first.sourcePort <<
"\""
234 <<
" destinationPort=\"" << iter->first.destinationPort <<
"\">\n";
241 for (
auto i = flow->second.begin(); i != flow->second.end(); i++)
244 os <<
"<Dscp value=\"0x" << std::hex << static_cast<uint32_t>(i->first) <<
"\""
245 <<
" packets=\"" << std::dec << i->second <<
"\" />\n";
256 os <<
"</Ipv6FlowClassifier>\n";
FlowId GetNewFlowId()
Returns a new, unique Flow Identifier.
static Ipv6Address GetZero()
Get the 0 (::) Ipv6Address.
bool IsMulticast() const
If the IPv6 address is multicast (ff00::/8).
Comparator used to sort the vector of DSCP values.
bool operator()(std::pair< Ipv6Header::DscpType, uint32_t > left, std::pair< Ipv6Header::DscpType, uint32_t > right)
Comparator function.
std::map< FiveTuple, FlowId > m_flowMap
Map to Flows Identifiers to FlowIds.
void SerializeToXmlStream(std::ostream &os, uint16_t indent) const override
Serializes the results to an std::ostream in XML format.
std::vector< std::pair< Ipv6Header::DscpType, uint32_t > > GetDscpCounts(FlowId flowId) const
get the DSCP values of the packets belonging to the flow with the given FlowId, sorted in decreasing ...
FiveTuple FindFlow(FlowId flowId) const
Searches for the FiveTuple corresponding to the given flowId.
bool Classify(const Ipv6Header &ipHeader, Ptr< const Packet > ipPayload, uint32_t *out_flowId, uint32_t *out_packetId)
try to classify the packet into flow-id and packet-id
std::map< FlowId, FlowPacketId > m_flowPktIdMap
Map to FlowIds to FlowPacketId.
std::map< FlowId, std::map< Ipv6Header::DscpType, uint32_t > > m_flowDscpMap
Map FlowIds to (DSCP value, packet count) pairs.
Smart pointer class similar to boost::intrusive_ptr.
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
const uint8_t TCP_PROT_NUMBER
TCP Protocol number.
bool operator==(const EventId &a, const EventId &b)
bool operator<(const EventId &a, const EventId &b)
const uint8_t UDP_PROT_NUMBER
UDP Protocol number.
Helper to indent output a specified number of steps.
Structure to classify a packet.
uint16_t destinationPort
Destination port.
Ipv6Address destinationAddress
Destination address.
uint16_t sourcePort
Source port.
uint8_t protocol
Protocol.
Ipv6Address sourceAddress
Source address.