F5/unison
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

packets cosmetics

Browse Source
This commit is contained in:
Pavel Boyko
2009-07-07 13:41:03 +04:00
parent 42a15f1229
commit f27ae1792b
2 changed files with 103 additions and 117 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/routing/aodv/aodv-packet.cc
View File

@@ -89,8 +89,7 @@ RreqHeader::Deserialize (Buffer::Iterator start)
void
RreqHeader::Print (std::ostream &os) const
{
os << "RREO ID " << rq_bcast_id << "\n"
os << "RREQ ID " << rq_bcast_id << "\n"
<< "destination: ipv4 " << rq_dst << " "
<< "sequence number " << rq_dst_seqno << "\n"
<< "source: ipv4 " << rq_src << " "
@@ -307,14 +306,6 @@ RrepHeader::SetHello(Ipv4Address src, uint32_t srcSeqNo)
rp_lifetime = HELLO_INTERVAL * ALLOWED_HELLO_LOSS;
}
bool
RrepHeader::IsHello(Ipv4Address src, uint32_t srcSeqNo)
{
return (rp_flags == 0 && prefixSize == 0 && rp_hop_count == 0 &&
rp_dst == src && rp_dst_seqno == srcSeqNo && rp_src == src &&
rp_lifetime == (HELLO_INTERVAL * ALLOWED_HELLO_LOSS));
}
std::ostream & operator<<(std::ostream & os, RrepHeader const & h)
{
h.Print (os);
@@ -348,9 +339,6 @@ bool RrepHeaderTest::RunTests ()
h.SetPrefixSize(2);
uint8_t sz = h.GetPrefixSize();
NS_TEST_ASSERT_EQUAL(2, sz);
NS_TEST_ASSERT(!h.IsHello(Ipv4Address("1.2.3.4"),10));
h.SetHello(Ipv4Address("1.2.3.4"),12);
NS_TEST_ASSERT(h.IsHello(Ipv4Address("1.2.3.4"),12));
Ptr<Packet> p = Create<Packet> ();
p->AddHeader (h);
@@ -451,7 +439,6 @@ bool RrepAckHeaderTest::RunTests ()
//-----------------------------------------------------------------------------
RerrHeader::RerrHeader() : er_flag(0), reserved(0)
{
destCount = unreachable_dst.size();
}
TypeId
@@ -463,7 +450,7 @@ RerrHeader::GetInstanceTypeId() const
uint32_t
RerrHeader::GetSerializedSize () const
{
return ( 4 + 8*destCount);
return ( 4 + 8*GetDestCount());
}
void
@@ -472,7 +459,7 @@ RerrHeader::Serialize (Buffer::Iterator i) const
i.WriteU8(type());
i.WriteU8(er_flag);
i.WriteU8(reserved);
i.WriteU8(destCount);
i.WriteU8(GetDestCount());
std::map<Ipv4Address, uint32_t>::const_iterator j;
for(j = unreachable_dst.begin(); j != unreachable_dst.end(); ++j)
{
@@ -490,15 +477,15 @@ RerrHeader::Deserialize (Buffer::Iterator start)
er_flag = i.ReadU8 ();
reserved = i.ReadU8 ();
destCount = i.ReadU8 ();
uint8_t dest = i.ReadU8 ();
unreachable_dst.clear();
Ipv4Address address;
uint32_t seqNo;
for(uint8_t k = 0; k < destCount; ++k)
for(uint8_t k = 0; k < dest; ++k)
{
ReadFrom (i, address);
seqNo = i.ReadNtohU32 ();
unreachable_dst[address] = seqNo;
unreachable_dst.insert(std::make_pair(address, seqNo));
}
uint32_t dist = i.GetDistanceFrom (start);
@@ -520,7 +507,7 @@ RerrHeader::SetNoDelete(bool f)
}
bool
RerrHeader::GetNoDelete()
RerrHeader::GetNoDelete() const
{
return (er_flag & (1 << 0));
}
@@ -530,29 +517,29 @@ RerrHeader::AddUnDestination(Ipv4Address dst, uint32_t seqNo)
{
if(unreachable_dst.find(dst) != unreachable_dst.end())
return false;
unreachable_dst[dst] = seqNo;
destCount = unreachable_dst.size();
NS_ASSERT (GetDestCount() < 255); // can't support more than 255 destinations in single RERR
unreachable_dst.insert(std::make_pair(dst, seqNo));
return true;
}
bool
RerrHeader::operator==(RerrHeader const & o) const
{
bool result = ( er_flag == o.er_flag && reserved == o.reserved &&
destCount == o.destCount );
if(!result)
if (er_flag != o.er_flag || reserved != o.reserved || GetDestCount() != o.GetDestCount())
return false;
std::map<Ipv4Address, uint32_t>::const_iterator j = unreachable_dst.begin();
std::map<Ipv4Address, uint32_t>::const_iterator k = o.unreachable_dst.begin();
for(uint8_t i = 0; i < destCount; ++i)
for(uint8_t i = 0; i < GetDestCount(); ++i)
{
result = result && ( (*j).first == (*k).first ) && ( (*j).second == (*k).second );
if(!result)
if ((j->first != k->first ) || (j->second != k->second))
return false;
j++;
k++;
}
return result;
return true;
}
std::ostream & operator<<(std::ostream & os, RerrHeader const & h)

175
src/routing/aodv/aodv-packet.h
View File

@@ -30,41 +30,44 @@
#include "ns3/ipv4-address.h"
#include <map>
namespace ns3 {
namespace aodv {
/// AODV message types
enum MessageType
{
AODVTYPE_RREQ = 0x02,
AODVTYPE_RREP = 0x04,
AODVTYPE_RERR = 0x08,
AODVTYPE_RREP_ACK = 0x10
};
// TODO avoid defines, use protocol attributes
#define HELLO_INTERVAL 1 // 1000 ms
#define ALLOWED_HELLO_LOSS 3 // packets
namespace ns3 {
namespace aodv {
/**
* \ingroup aodv
* \brief AODV control types
*/
enum MessageType
{
AODVTYPE_RREQ = 0x02, //!< AODVTYPE_RREQ
AODVTYPE_RREP = 0x04, //!< AODVTYPE_RREP
AODVTYPE_RERR = 0x08, //!< AODVTYPE_RERR
AODVTYPE_RREP_ACK = 0x10//!< AODVTYPE_RREP_ACK
};
/**
* \ingroup aodv
* \brief Route Request (RREQ) Message Format
\verbatim
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type |J|R|G|D|U| Reserved | Hop Count |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| RREQ ID |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination IP Address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination Sequence Number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Originator IP Address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Originator Sequence Number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
\endverbatim
\verbatim
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type |J|R|G|D|U| Reserved | Hop Count |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| RREQ ID |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination IP Address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination Sequence Number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Originator IP Address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Originator Sequence Number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
\endverbatim
*/
class RreqHeader : public Header
{
@@ -124,22 +127,22 @@ std::ostream & operator<<(std::ostream & os, RreqHeader const &);
/**
* \ingroup aodv
* \brief Route Reply (RREP) Message Format
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type |R|A| Reserved |Prefix Sz| Hop Count |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination IP address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination Sequence Number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Originator IP address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Lifetime |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
*
* \brief Route Reply (RREP) Message Format
\verbatim
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type |R|A| Reserved |Prefix Sz| Hop Count |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination IP address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Destination Sequence Number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Originator IP address |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Lifetime |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
\endverbatim
*/
class RrepHeader : public Header
{
@@ -176,22 +179,19 @@ public:
uint8_t GetPrefixSize() const;
//\}
///\name Hello massage
//\{
/// Configure RREP to be a Hello message
void SetHello(Ipv4Address src, uint32_t srcSeqNo);
bool IsHello(Ipv4Address src, uint32_t srcSeqNo);
//\}
bool operator==(RrepHeader const & o) const;
private:
static MessageType type() { return AODVTYPE_RREP; }
uint8_t rp_flags; ///< A - acknowledgment required flag
uint8_t prefixSize; ///< Prefix Size
uint8_t rp_hop_count; ///< Hop Count
Ipv4Address rp_dst; ///< Destination IP Address
uint32_t rp_dst_seqno; ///< Destination Sequence Number
Ipv4Address rp_src; ///< Source IP Address
uint32_t rp_lifetime; ///< Lifetime
uint8_t rp_flags; ///< A - acknowledgment required flag
uint8_t prefixSize; ///< Prefix Size
uint8_t rp_hop_count; ///< Hop Count
Ipv4Address rp_dst; ///< Destination IP Address
uint32_t rp_dst_seqno; ///< Destination Sequence Number
Ipv4Address rp_src; ///< Source IP Address
uint32_t rp_lifetime; ///< Lifetime
};
std::ostream & operator<<(std::ostream & os, RrepHeader const &);
@@ -199,11 +199,13 @@ std::ostream & operator<<(std::ostream & os, RrepHeader const &);
/**
* \ingroup aodv
* \brief Route Reply Acknowledgment (RREP-ACK) Message Format
* 0 1
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type | Reserved |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
\verbatim
0 1
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type | Reserved |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
\endverbatim
*/
class RrepAckHeader : public Header
{
@@ -222,7 +224,7 @@ public:
bool operator==(RrepAckHeader const & o) const;
private:
static MessageType type() { return AODVTYPE_RREP_ACK; }
uint8_t reserved;
uint8_t reserved;
};
std::ostream & operator<<(std::ostream & os, RrepAckHeader const &);
@@ -230,21 +232,21 @@ std::ostream & operator<<(std::ostream & os, RrepAckHeader const &);
/**
* \ingroup aodv
* \brief Route Error (RERR) Message Format
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type |N| Reserved | DestCount |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Unreachable Destination IP Address (1) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Unreachable Destination Sequence Number (1) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-|
| Additional Unreachable Destination IP Addresses (if needed) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|Additional Unreachable Destination Sequence Numbers (if needed)|
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
*
\verbatim
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type |N| Reserved | DestCount |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Unreachable Destination IP Address (1) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Unreachable Destination Sequence Number (1) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-|
| Additional Unreachable Destination IP Addresses (if needed) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|Additional Unreachable Destination Sequence Numbers (if needed)|
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
\endverbatim
*/
class RerrHeader : public Header
{
@@ -263,26 +265,23 @@ public:
///\name No delete flag
//\{
void SetNoDelete(bool f);
bool GetNoDelete();
bool GetNoDelete() const;
//\}
bool AddUnDestination(Ipv4Address dst, uint32_t seqNo);
uint8_t GetDestCount() const { return destCount; }
uint8_t GetDestCount() const { return (uint8_t)unreachable_dst.size(); }
bool operator==(RerrHeader const & o) const;
private:
static MessageType type() { return AODVTYPE_RERR; }
uint8_t er_flag; ///< No delete flag
uint8_t reserved; ///< Not used
uint8_t destCount; ///< DestCount
uint8_t er_flag; ///< No delete flag
uint8_t reserved; ///< Not used
/// List of Unreachable destination IP addresses and sequence numbers
std::map<Ipv4Address, uint32_t> unreachable_dst;
};
std::ostream & operator<<(std::ostream & os, RerrHeader const &);
}
}
#endif /* AODVPACKET_H_ */