A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
ipv6-queue-disc-item.cc
Go to the documentation of this file.
1/*
2 * Copyright (c) 2016 Universita' degli Studi di Napoli Federico II
3 *
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License version 2 as
6 * published by the Free Software Foundation;
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public License
14 * along with this program; if not, write to the Free Software
15 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16 */
17
19
20#include "tcp-header.h"
21#include "udp-header.h"
22
23#include "ns3/log.h"
24
25namespace ns3
26{
27
28NS_LOG_COMPONENT_DEFINE("Ipv6QueueDiscItem");
29
31 const Address& addr,
32 uint16_t protocol,
33 const Ipv6Header& header)
34 : QueueDiscItem(p, addr, protocol),
35 m_header(header),
36 m_headerAdded(false)
37{
38}
39
41{
42 NS_LOG_FUNCTION(this);
43}
44
47{
48 NS_LOG_FUNCTION(this);
50 NS_ASSERT(p);
51 uint32_t ret = p->GetSize();
52 if (!m_headerAdded)
53 {
55 }
56 return ret;
57}
58
59const Ipv6Header&
61{
62 return m_header;
63}
64
65void
67{
68 NS_LOG_FUNCTION(this);
69
70 NS_ASSERT_MSG(!m_headerAdded, "The header has been already added to the packet");
72 NS_ASSERT(p);
73 p->AddHeader(m_header);
74 m_headerAdded = true;
75}
76
77void
78Ipv6QueueDiscItem::Print(std::ostream& os) const
79{
80 if (!m_headerAdded)
81 {
82 os << m_header << " ";
83 }
84 os << GetPacket() << " "
85 << "Dst addr " << GetAddress() << " "
86 << "proto " << (uint16_t)GetProtocol() << " "
87 << "txq " << (uint16_t)GetTxQueueIndex();
88}
89
90bool
92{
93 NS_LOG_FUNCTION(this);
95 {
97 return true;
98 }
99 return false;
100}
101
102bool
104{
105 bool ret = false;
106
107 switch (field)
108 {
109 case IP_DSFIELD:
110 value = m_header.GetTrafficClass();
111 ret = true;
112 break;
113 }
114
115 return ret;
116}
117
120{
121 NS_LOG_FUNCTION(this << perturbation);
122
125 uint8_t prot = m_header.GetNextHeader();
126
127 TcpHeader tcpHdr;
128 UdpHeader udpHdr;
129 uint16_t srcPort = 0;
130 uint16_t destPort = 0;
131
132 if (prot == 6) // TCP
133 {
134 GetPacket()->PeekHeader(tcpHdr);
135 srcPort = tcpHdr.GetSourcePort();
136 destPort = tcpHdr.GetDestinationPort();
137 }
138 else if (prot == 17) // UDP
139 {
140 GetPacket()->PeekHeader(udpHdr);
141 srcPort = udpHdr.GetSourcePort();
142 destPort = udpHdr.GetDestinationPort();
143 }
144 if (prot != 6 && prot != 17)
145 {
146 NS_LOG_WARN("Unknown transport protocol, no port number included in hash computation");
147 }
148
149 /* serialize the 5-tuple and the perturbation in buf */
150 uint8_t buf[41];
151 src.Serialize(buf);
152 dest.Serialize(buf + 16);
153 buf[32] = prot;
154 buf[33] = (srcPort >> 8) & 0xff;
155 buf[34] = srcPort & 0xff;
156 buf[35] = (destPort >> 8) & 0xff;
157 buf[36] = destPort & 0xff;
158 buf[37] = (perturbation >> 24) & 0xff;
159 buf[38] = (perturbation >> 16) & 0xff;
160 buf[39] = (perturbation >> 8) & 0xff;
161 buf[40] = perturbation & 0xff;
162
163 // Linux calculates jhash2 (jenkins hash), we calculate murmur3 because it is
164 // already available in ns-3
165 uint32_t hash = Hash32((char*)buf, 41);
166
167 NS_LOG_DEBUG("Found Ipv6 packet; hash of the five tuple " << hash);
168
169 return hash;
170}
171
172} // namespace ns3
a polymophic address class
Definition: address.h:100
Describes an IPv6 address.
Definition: ipv6-address.h:49
void Serialize(uint8_t buf[16]) const
Serialize this address to a 16-byte buffer.
Packet header for IPv6.
Definition: ipv6-header.h:35
void SetEcn(EcnType ecn)
Set ECN field bits.
Definition: ipv6-header.cc:215
uint8_t GetNextHeader() const
Get the next header.
Definition: ipv6-header.cc:88
Ipv6Address GetDestination() const
Get the "Destination address" field.
Definition: ipv6-header.cc:124
uint8_t GetTrafficClass() const
Get the "Traffic class" field.
Definition: ipv6-header.cc:52
EcnType GetEcn() const
Definition: ipv6-header.cc:284
uint32_t GetSerializedSize() const override
Get the serialized size of the packet.
Definition: ipv6-header.cc:159
Ipv6Address GetSource() const
Get the "Source address" field.
Definition: ipv6-header.cc:112
const Ipv6Header & GetHeader() const
void AddHeader() override
Add the header to the packet.
bool Mark() override
Marks the packet by setting ECN_CE bits if the packet has ECN_ECT0 or ECN_ECT1 set.
bool GetUint8Value(Uint8Values field, uint8_t &value) const override
Retrieve the value of a given field from the packet, if present.
uint32_t GetSize() const override
Ipv6Header m_header
The IPv6 header.
void Print(std::ostream &os) const override
Print the item contents.
uint32_t Hash(uint32_t perturbation) const override
Computes the hash of the packet's 5-tuple.
bool m_headerAdded
True if the header has already been added to the packet.
uint32_t PeekHeader(Header &header) const
Deserialize but does not remove the header from the internal buffer.
Definition: packet.cc:305
Smart pointer class similar to boost::intrusive_ptr.
Definition: ptr.h:78
QueueDiscItem is the abstract base class for items that are stored in a queue disc.
Definition: queue-item.h:133
Address GetAddress() const
Get the MAC address included in this item.
Definition: queue-item.cc:92
uint8_t GetTxQueueIndex() const
Get the transmission queue index included in this item.
Definition: queue-item.cc:106
uint16_t GetProtocol() const
Get the L3 protocol included in this item.
Definition: queue-item.cc:99
Ptr< Packet > GetPacket() const
Definition: queue-item.cc:43
Uint8Values
1-byte fields of the packet whose value can be retrieved, if present
Definition: queue-item.h:82
Header for the Transmission Control Protocol.
Definition: tcp-header.h:46
uint16_t GetDestinationPort() const
Get the destination port.
Definition: tcp-header.cc:131
uint16_t GetSourcePort() const
Get the source port.
Definition: tcp-header.cc:125
Packet header for UDP packets.
Definition: udp-header.h:41
uint16_t GetDestinationPort() const
Definition: udp-header.cc:75
uint16_t GetSourcePort() const
Definition: udp-header.cc:69
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
Definition: assert.h:66
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
Definition: assert.h:86
uint32_t Hash32(const char *buffer, const std::size_t size)
Compute 32-bit hash of a byte buffer, using the default hash function.
Definition: hash.h:274
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition: log.h:202
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
Definition: log.h:268
#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.
Definition: log.h:261
Every class exported by the ns3 library is enclosed in the ns3 namespace.