arp-queue-disc-item.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2018 Universita' degli Studi di Napoli Federico II
 *
 * SPDX-License-Identifier: GPL-2.0-only
 */
 
#include "arp-queue-disc-item.h"
 
#include "ns3/log.h"
 
#include <vector>
 
namespace ns3
{
 
NS_LOG_COMPONENT_DEFINE("ArpQueueDiscItem");
 
ArpQueueDiscItem::ArpQueueDiscItem(Ptr<Packet> p,
                                   const Address& addr,
                                   uint16_t protocol,
                                   const ArpHeader& header)
    : QueueDiscItem(p, addr, protocol),
      m_header(header),
      m_headerAdded(false)
{
}
 
ArpQueueDiscItem::~ArpQueueDiscItem()
{
    NS_LOG_FUNCTION(this);
}
 
uint32_t
ArpQueueDiscItem::GetSize() const
{
    NS_LOG_FUNCTION(this);
    Ptr<Packet> p = GetPacket();
    NS_ASSERT(p);
    uint32_t ret = p->GetSize();
    if (!m_headerAdded)
    {
        ret += m_header.GetSerializedSize();
    }
    return ret;
}
 
const ArpHeader&
ArpQueueDiscItem::GetHeader() const
{
    return m_header;
}
 
void
ArpQueueDiscItem::AddHeader()
{
    NS_LOG_FUNCTION(this);
 
    NS_ASSERT_MSG(!m_headerAdded, "The header has been already added to the packet");
    Ptr<Packet> p = GetPacket();
    NS_ASSERT(p);
    p->AddHeader(m_header);
    m_headerAdded = true;
}
 
void
ArpQueueDiscItem::Print(std::ostream& os) const
{
    if (!m_headerAdded)
    {
        os << m_header << " ";
    }
    os << GetPacket() << " "
       << "Dst addr " << GetAddress() << " "
       << "proto " << (uint16_t)GetProtocol() << " "
       << "txq " << (uint8_t)GetTxQueueIndex();
}
 
bool
ArpQueueDiscItem::Mark()
{
    NS_LOG_FUNCTION(this);
    return false;
}
 
uint32_t
ArpQueueDiscItem::Hash(uint32_t perturbation) const
{
    NS_LOG_FUNCTION(this << perturbation);
 
    Ipv4Address ipv4Src = m_header.GetSourceIpv4Address();
    Ipv4Address ipv4Dst = m_header.GetDestinationIpv4Address();
    Address macSrc = m_header.GetSourceHardwareAddress();
    Address macDst = m_header.GetDestinationHardwareAddress();
    uint8_t type = m_header.IsRequest() ? ArpHeader::ARP_TYPE_REQUEST : ArpHeader::ARP_TYPE_REPLY;
 
    /* serialize the addresses and the perturbation in buf */
    uint8_t tmp = 8 + macSrc.GetLength() + macDst.GetLength();
    std::vector<uint8_t> buf(tmp + 5);
    ipv4Src.Serialize(buf.data());
    ipv4Dst.Serialize(buf.data() + 4);
    macSrc.CopyTo(buf.data() + 8);
    macDst.CopyTo(buf.data() + 8 + macSrc.GetLength());
    buf[tmp] = type;
    buf[tmp + 1] = (perturbation >> 24) & 0xff;
    buf[tmp + 2] = (perturbation >> 16) & 0xff;
    buf[tmp + 3] = (perturbation >> 8) & 0xff;
    buf[tmp + 4] = perturbation & 0xff;
 
    // Linux calculates jhash2 (jenkins hash), we calculate murmur3 because it is
    // already available in ns-3
 
    uint32_t hash = Hash32((char*)buf.data(), tmp + 5);
 
    NS_LOG_DEBUG("Hash value " << hash);
 
    return hash;
}
 
} // namespace ns3