diff -r eb380b33ae24 -r 082ffdd8fbd7 src/internet-node/arp-cache.cc --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/internet-node/arp-cache.cc Fri May 04 15:04:07 2007 +0200 @@ -0,0 +1,229 @@ +/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil; -*- */ +/* + * Copyright (c) 2006 INRIA + * All rights reserved. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 as + * published by the Free Software Foundation; + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + * + * Author: Mathieu Lacage + */ +#include "ns3/assert.h" + +#include "ns3/packet.h" +#include "ns3/simulator.h" + +#include "arp-cache.h" +#include "arp-header.h" + +namespace ns3 { + +ArpCache::ArpCache (NetDevice *device, Ipv4Interface *interface) + : m_device (device), + m_interface (interface), + m_aliveTimeout (Seconds (120)), + m_deadTimeout (Seconds (100)), + m_waitReplyTimeout (Seconds (1)) +{ + m_device->Ref (); +} + +ArpCache::~ArpCache () +{ + m_device->Unref (); + Flush (); +} + +NetDevice * +ArpCache::PeekDevice (void) const +{ + return m_device; +} + +Ipv4Interface * +ArpCache::GetInterface (void) const +{ + return m_interface; +} + +void +ArpCache::SetAliveTimeout (Time aliveTimeout) +{ + m_aliveTimeout = aliveTimeout; +} +void +ArpCache::SetDeadTimeout (Time deadTimeout) +{ + m_deadTimeout = deadTimeout; +} +void +ArpCache::SetWaitReplyTimeout (Time waitReplyTimeout) +{ + m_waitReplyTimeout = waitReplyTimeout; +} + +Time +ArpCache::GetAliveTimeout (void) const +{ + return m_aliveTimeout; +} +Time +ArpCache::GetDeadTimeout (void) const +{ + return m_deadTimeout; +} +Time +ArpCache::GetWaitReplyTimeout (void) const +{ + return m_waitReplyTimeout; +} + +void +ArpCache::Flush (void) +{ + for (CacheI i = m_arpCache.begin (); i != m_arpCache.end (); i++) + { + delete (*i).second; + } + m_arpCache.erase (m_arpCache.begin (), m_arpCache.end ()); +} + +ArpCache::Entry * +ArpCache::Lookup (Ipv4Address to) +{ + if (m_arpCache.find (to) != m_arpCache.end ()) + { + ArpCache::Entry *entry = m_arpCache[to]; + return entry; + } + return 0; +} + +ArpCache::Entry * +ArpCache::Add (Ipv4Address to) +{ + ArpCache::Entry *entry = new ArpCache::Entry (this); + m_arpCache[to] = entry; + return entry; +} + +ArpCache::Entry::Entry (ArpCache *arp) + : m_arp (arp), + m_state (ALIVE), + m_waiting () +{} + + +bool +ArpCache::Entry::IsDead (void) +{ + return (m_state == DEAD)?true:false; +} +bool +ArpCache::Entry::IsAlive (void) +{ + return (m_state == ALIVE)?true:false; +} +bool +ArpCache::Entry::IsWaitReply (void) +{ + return (m_state == WAIT_REPLY)?true:false; +} + + +void +ArpCache::Entry::MarkDead (void) +{ + m_state = DEAD; + //NS_ASSERT (m_waiting != 0); + UpdateSeen (); +} +Packet +ArpCache::Entry::MarkAlive (MacAddress macAddress) +{ + NS_ASSERT (m_state == WAIT_REPLY); + //NS_ASSERT (m_waiting != 0); + m_macAddress = macAddress; + m_state = ALIVE; + UpdateSeen (); + Packet waiting = m_waiting; + //m_waiting = 0; + return waiting; +} + +Packet +ArpCache::Entry::UpdateWaitReply (Packet waiting) +{ + NS_ASSERT (m_state == WAIT_REPLY); + /* We are already waiting for an answer so + * we dump the previously waiting packet and + * replace it with this one. + */ + Packet old = m_waiting; + m_waiting = waiting; + return old; +} +void +ArpCache::Entry::MarkWaitReply (Packet waiting) +{ + NS_ASSERT (m_state == ALIVE || m_state == DEAD); + //NS_ASSERT (m_waiting == 0); + m_state = WAIT_REPLY; + m_waiting = waiting; + UpdateSeen (); +} + +MacAddress +ArpCache::Entry::GetMacAddress (void) +{ + NS_ASSERT (m_state == ALIVE); + return m_macAddress; +} +bool +ArpCache::Entry::IsExpired (void) +{ + Time timeout; + switch (m_state) { + case ArpCache::Entry::WAIT_REPLY: + timeout = m_arp->GetWaitReplyTimeout (); + break; + case ArpCache::Entry::DEAD: + timeout = m_arp->GetDeadTimeout (); + break; + case ArpCache::Entry::ALIVE: + timeout = m_arp->GetAliveTimeout (); + break; + default: + NS_ASSERT (false); + timeout = Seconds (0); + /* NOTREACHED */ + break; + } + Time delta = Simulator::Now () - m_lastSeen; + if (delta >= timeout) + { + return true; + } + else + { + return false; + } +} +void +ArpCache::Entry::UpdateSeen (void) +{ + m_lastSeen = Simulator::Now (); +} + +} // namespace ns3 +