12#include "ns3/packet.h"
13#include "ns3/tcp-header.h"
14#include "ns3/udp-header.h"
110 if (ipPayload->GetSize() < 4)
122 ipPayload->CopyData(
data, 4);
124 uint16_t srcPort = 0;
129 uint16_t dstPort = 0;
138 auto insert =
m_flowMap.insert(std::pair<FiveTuple, FlowId>(tuple, 0));
144 insert.first->second = newFlowId;
155 auto dscpInserter =
m_flowDscpMap[insert.first->second].insert(
156 std::pair<Ipv6Header::DscpType, uint32_t>(dscp, 1));
159 if (!dscpInserter.second)
164 *out_flowId = insert.first->second;
175 if (iter->second == flowId)
187 std::pair<Ipv6Header::DscpType, uint32_t> right)
189 return left.second > right.second;
192std::vector<std::pair<Ipv6Header::DscpType, uint32_t>>
202 std::vector<std::pair<Ipv6Header::DscpType, uint32_t>> v(flow->second.begin(),
212 os <<
"<Ipv6FlowClassifier>\n";
218 os <<
"<Flow flowId=\"" << iter->second <<
"\""
219 <<
" sourceAddress=\"" << iter->first.sourceAddress <<
"\""
220 <<
" destinationAddress=\"" << iter->first.destinationAddress <<
"\""
221 <<
" protocol=\"" << int(iter->first.protocol) <<
"\""
222 <<
" sourcePort=\"" << iter->first.sourcePort <<
"\""
223 <<
" destinationPort=\"" << iter->first.destinationPort <<
"\">\n";
230 for (
auto i = flow->second.begin(); i != flow->second.end(); i++)
233 os <<
"<Dscp value=\"0x" << std::hex << static_cast<uint32_t>(i->first) <<
"\""
234 <<
" packets=\"" << std::dec << i->second <<
"\" />\n";
245 os <<
"</Ipv6FlowClassifier>\n";
void Indent(std::ostream &os, uint16_t level) const
Add a number of spaces for indentation purposes.
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.
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.