channel switching support for wifi

src/devices/wifi/mac-low.cc

 /* -*-  Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil; -*- */
 /*
  * Copyright (c) 2005,2006 INRIA
  *
  * 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
@@ skipping 225 matching lines @@
   case MacLowTransmissionParameters::ACK_FAST:
     os << "fast";
     break;
   case MacLowTransmissionParameters::ACK_SUPER_FAST:
     os << "super-fast";
     break;
   }
   os << "]";
   return os;
 }
+
+
+/***************************************************************
+ *         Listener for PHY events. Forwards to MacLow
+ ***************************************************************/
+
+
+class PhyMacLowListener : public ns3::WifiPhyListener {
+public:
+  PhyMacLowListener (ns3::MacLow *macLow)
+    : m_macLow (macLow) {}
+  virtual ~PhyMacLowListener () {}
+  virtual void NotifyRxStart (Time duration) {}
+  virtual void NotifyRxEndOk (void) {}
+  virtual void NotifyRxEndError (void) {}
+  virtual void NotifyTxStart (Time duration) {}
+  virtual void NotifyMaybeCcaBusyStart (Time duration) {}
+  virtual void NotifySwitchingStart (Time duration) { 
+    m_macLow->NotifySwitchingStartNow (duration);
+  }
+private:
+  ns3::MacLow *m_macLow;
+};
+
 
 MacLow::MacLow ()
   : m_normalAckTimeoutEvent (),
     m_fastAckTimeoutEvent (),
     m_superFastAckTimeoutEvent (),
     m_fastAckFailedTimeoutEvent (),
     m_ctsTimeoutEvent (),
     m_sendCtsEvent (),
     m_sendAckEvent (),
     m_sendDataEvent (),
     m_waitSifsEvent (),
     m_currentPacket (0),
     m_listener (0)
 {
   NS_LOG_FUNCTION (this);
   m_lastNavDuration = Seconds (0);
   m_lastNavStart = Seconds (0);
 }
 
 MacLow::~MacLow ()
 {
   NS_LOG_FUNCTION (this);
 }
 
 void 
+MacLow::SetupPhyMacLowListener (Ptr<WifiPhy> phy)
+{
+  m_phyMacLowListener = new PhyMacLowListener (this);

[Mathieu Lacage, 2009/08/19 08:19:12]

delete in DoDispose ?

[Ramon Bauza, 2009/09/08 11:36:08]

On 2009/08/19 08:19:12, Mathieu Lacage wrote:
> delete in DoDispose ?

Not before. done.

+  phy->RegisterListener (m_phyMacLowListener);
+}
+
+
+void 
 MacLow::DoDispose (void)
 {
   NS_LOG_FUNCTION (this);
   CancelAllEvents ();
   m_phy = 0;
   m_stationManager = 0;
 }
 
 void
 MacLow::CancelAllEvents (void)
@@ skipping 51 matching lines @@
       m_listener = 0;
     }
 }
 
 void
 MacLow::SetPhy (Ptr<WifiPhy> phy)
 {
   m_phy = phy;
   m_phy->SetReceiveOkCallback (MakeCallback (&MacLow::ReceiveOk, this));
   m_phy->SetReceiveErrorCallback (MakeCallback (&MacLow::ReceiveError, this));
+  SetupPhyMacLowListener(phy); 
 }
 void 
 MacLow::SetWifiRemoteStationManager (Ptr<WifiRemoteStationManager> manager)
 {
   m_stationManager = manager;
 }
 
 void 
 MacLow::SetAddress (Mac48Address ad)
 {
@@ skipping 130 matching lines @@
   if (m_txParams.MustWaitFastAck ()) 
     {
       NS_ASSERT (m_fastAckFailedTimeoutEvent.IsExpired ());
       m_fastAckFailedTimeoutEvent = Simulator::Schedule (GetSifs (), 
                                                          &MacLow::FastAckFailedTimeout, this);
     }
   return;
 }
 
 void 
+MacLow::NotifySwitchingStartNow (Time duration)
+{
+  NS_LOG_DEBUG ("switching channel. Cancelling MAC pending events"); 
+  m_stationManager->Reset();
+  CancelAllEvents(); 
+  if (m_navCounterResetCtsMissed.IsRunning ())
+    {
+      m_navCounterResetCtsMissed.Cancel();
+    }
+  m_lastNavStart = Simulator::Now (); 
+  m_lastNavDuration = Seconds (0);
+  m_currentPacket = 0;
+  m_listener = 0;
+}
+
+void 
 MacLow::ReceiveOk (Ptr<Packet> packet, double rxSnr, WifiMode txMode, WifiPreamble preamble)
 {
   NS_LOG_FUNCTION (this << packet << rxSnr << txMode << preamble);
   /* A packet is received from the PHY.
    * When we have handled this packet,
    * we handle any packet present in the
    * packet queue.
    */
   WifiMacHeader hdr;
   packet->RemoveHeader (hdr);
@@ skipping 688 matching lines @@
   packet->AddTrailer (fcs);
 
   struct SnrTag tag;
   tag.Set (dataSnr);
   packet->AddPacketTag (tag);
 
   ForwardDown (packet, &ack, ackTxMode);
 }
 
 } // namespace ns3