/* -*-  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

 * 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 <mathieu.lacage@sophia.inria.fr>

 */

#include "ns3/assert.h"

#include "ns3/packet.h"

#include "ns3/simulator.h"

#include "ns3/tag.h"

#include "ns3/log.h"

#include "ns3/node.h"

#include "mac-low.h"

#include "wifi-phy.h"

#include "wifi-mac-trailer.h"

#include "wifi-mac.h"

#include "mac-stations.h"

#include "wifi-mac-parameters.h"

#include "ns3/composite-trace-resolver.h"

NS_LOG_COMPONENT_DEFINE ("MacLow");

#define MY_DEBUG(x) \

  NS_LOG_DEBUG (Simulator::Now () << " " << m_mac->GetAddress () << " " << x)

namespace ns3 {

class SnrTag : public Tag

{

public:

  SnrTag ();

  SnrTag (const SnrTag &o);

  ~SnrTag ();

  static uint32_t GetUid (void);

  void Print (std::ostream &os) const;

  uint32_t GetSerializedSize (void) const;

  void Serialize (Buffer::Iterator i) const;

  uint32_t Deserialize (Buffer::Iterator i);

  void Set (double snr);

  double Get (void) const;

private:

  double m_snr;

};

SnrTag::SnrTag ()

  : m_snr (0.0)

{}

SnrTag::SnrTag (const SnrTag &o)

  : m_snr (o.m_snr)

{}

SnrTag::~SnrTag ()

{}

uint32_t 

SnrTag::GetUid (void)

{

  static uint32_t uid = AllocateUid<SnrTag> ("SnrTag.ns3.inria.fr");

  return uid;

}

void 

SnrTag::Print (std::ostream &os) const

{

  os << "snr="<<m_snr;

}

uint32_t 

SnrTag::GetSerializedSize (void) const

{

  return 0;

}

void 

SnrTag::Serialize (Buffer::Iterator i) const

{

  // would need to serialize double to platform-independent format.

}

uint32_t 

SnrTag::Deserialize (Buffer::Iterator i)

{

  // would need to deserialize double from platform-independent format.

  return 0;

}

void 

SnrTag::Set (double snr)

{

  m_snr = snr;

}

double 

SnrTag::Get (void) const

{

  return m_snr;

}

MacLowTransmissionListener::MacLowTransmissionListener ()

{}

MacLowTransmissionListener::~MacLowTransmissionListener ()

{}

MacLowNavListener::MacLowNavListener ()

{}

MacLowNavListener::~MacLowNavListener ()

{}

MacLowTransmissionParameters::MacLowTransmissionParameters ()

  : m_nextSize (0),

    m_waitAck (ACK_NONE),

    m_sendRts (false),

    m_overrideDurationId (Seconds (0))

{}

void 

MacLowTransmissionParameters::EnableNextData (uint32_t size)

{

  m_nextSize = size;

}

void 

MacLowTransmissionParameters::DisableNextData (void)

{

  m_nextSize = 0;

}

void 

MacLowTransmissionParameters::EnableOverrideDurationId (Time durationId)

{

  m_overrideDurationId = durationId;

}

void 

MacLowTransmissionParameters::DisableOverrideDurationId (void)

{

  m_overrideDurationId = Seconds (0);

}

void 

MacLowTransmissionParameters::EnableSuperFastAck (void)

{

  m_waitAck = ACK_SUPER_FAST;

}

void 

MacLowTransmissionParameters::EnableFastAck (void)

{

  m_waitAck = ACK_FAST;

}

void 

MacLowTransmissionParameters::EnableAck (void)

{

  m_waitAck = ACK_NORMAL;

}

void 

MacLowTransmissionParameters::DisableAck (void)

{

  m_waitAck = ACK_NONE;

}

void 

MacLowTransmissionParameters::EnableRts (void)

{

  m_sendRts = true;

}

void 

MacLowTransmissionParameters::DisableRts (void)

{

  m_sendRts = false;

}

bool 

MacLowTransmissionParameters::MustWaitAck (void) const

{

  return (m_waitAck != ACK_NONE)?true:false;

}

bool 

MacLowTransmissionParameters::MustWaitNormalAck (void) const

{

  return (m_waitAck == ACK_NORMAL)?true:false;

}

bool 

MacLowTransmissionParameters::MustWaitFastAck (void) const

{

  return (m_waitAck == ACK_FAST)?true:false;

}

bool 

MacLowTransmissionParameters::MustWaitSuperFastAck (void) const

{

  return (m_waitAck == ACK_SUPER_FAST)?true:false;

}

bool 

MacLowTransmissionParameters::MustSendRts (void) const

{

  return m_sendRts;

}

bool 

MacLowTransmissionParameters::HasDurationId (void) const

{

  return (m_overrideDurationId != Seconds (0))?true:false;

}

Time

MacLowTransmissionParameters::GetDurationId (void) const

{

  NS_ASSERT (m_overrideDurationId != Seconds (0));

  return m_overrideDurationId;

}

bool 

MacLowTransmissionParameters::HasNextPacket (void) const

{

  return (m_nextSize != 0)?true:false;

}

uint32_t 

MacLowTransmissionParameters::GetNextPacketSize (void) const

{

  NS_ASSERT (HasNextPacket ());

  return m_nextSize;

}

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)

{

  m_lastNavDuration = Seconds (0);

  m_lastNavStart = Seconds (0);

}

MacLow::~MacLow ()

{

  CancelAllEvents ();

  m_phy = 0;

}

void

MacLow::CancelAllEvents (void)

{

  bool oneRunning = false;

  if (m_normalAckTimeoutEvent.IsRunning ()) 

    {

      m_normalAckTimeoutEvent.Cancel ();

      oneRunning = true;

    }

  if (m_fastAckTimeoutEvent.IsRunning ()) 

    {

      m_fastAckTimeoutEvent.Cancel ();

      oneRunning = true;

    }

  if (m_superFastAckTimeoutEvent.IsRunning ()) 

    {

      m_superFastAckTimeoutEvent.Cancel ();

      oneRunning = true;

    }

  if (m_fastAckFailedTimeoutEvent.IsRunning ()) 

    {

      m_fastAckFailedTimeoutEvent.Cancel ();

      oneRunning = true;

    }

  if (m_ctsTimeoutEvent.IsRunning ()) 

    {

      m_ctsTimeoutEvent.Cancel ();

      oneRunning = true;

    }

  if (m_sendCtsEvent.IsRunning ()) 

    {

      m_sendCtsEvent.Cancel ();

      oneRunning = true;

    }

  if (m_sendAckEvent.IsRunning ()) 

    {

      m_sendAckEvent.Cancel ();

      oneRunning = true;

    }

  if (m_sendDataEvent.IsRunning ()) 

    {

      m_sendDataEvent.Cancel ();

      oneRunning = true;

    }

  if (m_waitSifsEvent.IsRunning ()) 

    {

      m_waitSifsEvent.Cancel ();

      oneRunning = true;

    }

  if (oneRunning && m_listener != 0) 

    {

      m_listener->Cancel ();

      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));

}

void

MacLow::SetMac (Ptr<WifiMac> mac)

{

  m_mac = mac;

}

void 

MacLow::SetWifiRemoteStationManager (Ptr<WifiRemoteStationManager> manager)

{

  m_stationManager = manager;

}

Ptr<WifiMac> 

MacLow::GetMac (void)

{

  return m_mac;

}

void 

MacLow::SetRxCallback (Callback<void,Ptr<Packet>,const WifiMacHeader *> callback)

{

  m_rxCallback = callback;

}

void 

MacLow::RegisterNavListener (MacLowNavListener *listener)

{

  m_navListeners.push_back (listener);

}

void 

MacLow::StartTransmission (Ptr<const Packet> packet, 

                           WifiMacHeader const*hdr, 

                           MacLowTransmissionParameters parameters,

                           MacLowTransmissionListener *listener)

{

  /* m_currentPacket is not NULL because someone started

   * a transmission and was interrupted before one of:

   *   - ctsTimeout

   *   - sendDataAfterCTS

   * expired. This means that one of these timers is still

   * running. They are all cancelled below anyway by the 

   * call to CancelAllEvents (because of at least one

   * of these two timer) which will trigger a call to the

   * previous listener's cancel method.

   *

   * This typically happens because the high-priority 

   * QapScheduler has taken access to the channel from

   * one of the Edca of the QAP.

   */

  m_currentPacket = packet->Copy ();

  m_currentHdr = *hdr;

  CancelAllEvents ();

  m_listener = listener;

  m_txParams = parameters;

  //NS_ASSERT (m_phy->IsStateIdle ());

  MY_DEBUG ("startTx size="<< GetSize (m_currentPacket, &m_currentHdr) << 

            ", to=" << m_currentHdr.GetAddr1()<<", listener="<<m_listener);

  if (m_txParams.MustSendRts ()) 

    {

      SendRtsForPacket ();

    } 

  else 

    {

      SendDataPacket ();

    }

  /* When this method completes, we have taken ownership of the medium. */

  NS_ASSERT (m_phy->IsStateTx ());  

}

void

MacLow::ReceiveError (Ptr<Packet> packet, double rxSnr)

{

  MY_DEBUG ("rx failed ");

  if (m_txParams.MustWaitFastAck ()) 

    {

      NS_ASSERT (m_fastAckFailedTimeoutEvent.IsExpired ());

      m_fastAckFailedTimeoutEvent = Simulator::Schedule (GetSifs (), 

                                                         &MacLow::FastAckFailedTimeout, this);

    }

  return;

}

void 

MacLow::ReceiveOk (Ptr<Packet> packet, double rxSnr, WifiMode txMode, WifiPreamble 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);

  bool isPrevNavZero = IsNavZero ();

  MY_DEBUG ("duration/id=" << hdr.GetDuration ());

  NotifyNav (hdr, txMode, preamble);

  if (hdr.IsRts ()) 

    {

      /* see section 9.2.5.7 802.11-1999

       * A STA that is addressed by an RTS frame shall transmit a CTS frame after a SIFS 

       * period if the NAV at the STA receiving the RTS frame indicates that the medium is 

       * idle. If the NAV at the STA receiving the RTS indicates the medium is not idle, 

       * that STA shall not respond to the RTS frame.

       */

      if (isPrevNavZero &&

          hdr.GetAddr1 () == m_mac->GetAddress ()) 

        {

          MY_DEBUG ("rx RTS from=" << hdr.GetAddr2 () << ", schedule CTS");

          NS_ASSERT (m_sendCtsEvent.IsExpired ());

          WifiRemoteStation *station = GetStation (hdr.GetAddr2 ());

          station->ReportRxOk (rxSnr, txMode);

          m_sendCtsEvent = Simulator::Schedule (GetSifs (),

                                                &MacLow::SendCtsAfterRts, this,

                                                hdr.GetAddr2 (), 

                                                hdr.GetDuration (),

                                                txMode,

                                                rxSnr);

        } 

      else 

        {

          MY_DEBUG ("rx RTS from=" << hdr.GetAddr2 () << ", cannot schedule CTS");

        }

    } 

  else if (hdr.IsCts () &&

           hdr.GetAddr1 () == m_mac->GetAddress () &&

           m_ctsTimeoutEvent.IsRunning () &&

           m_currentPacket != 0) 

    {

      MY_DEBUG ("receive cts from="<<m_currentHdr.GetAddr1 ());

      SnrTag tag;

      packet->PeekTag (tag);

      WifiRemoteStation *station = GetStation (m_currentHdr.GetAddr1 ());

      station->ReportRxOk (rxSnr, txMode);

      station->ReportRtsOk (rxSnr, txMode, tag.Get ());

      m_ctsTimeoutEvent.Cancel ();

      m_listener->GotCts (rxSnr, txMode);

      NS_ASSERT (m_sendDataEvent.IsExpired ());

      m_sendDataEvent = Simulator::Schedule (GetSifs (), 

                                             &MacLow::SendDataAfterCts, this, 

                                             hdr.GetAddr1 (),

                                             hdr.GetDuration (),

                                             txMode);

    } 

  else if (hdr.IsAck () &&

           hdr.GetAddr1 () == m_mac->GetAddress () &&

           (m_normalAckTimeoutEvent.IsRunning () || 

            m_fastAckTimeoutEvent.IsRunning () ||

            m_superFastAckTimeoutEvent.IsRunning ()) &&

           m_txParams.MustWaitAck ()) 

    {

      MY_DEBUG ("receive ack from="<<m_currentHdr.GetAddr1 ());

      SnrTag tag;

      packet->PeekTag (tag);

      WifiRemoteStation *station = GetStation (m_currentHdr.GetAddr1 ());

      station->ReportRxOk (rxSnr, txMode);

      station->ReportDataOk (rxSnr, txMode, tag.Get ());

      bool gotAck = false;

      if (m_txParams.MustWaitNormalAck () &&

          m_normalAckTimeoutEvent.IsRunning ()) 

        {

          m_normalAckTimeoutEvent.Cancel ();

          gotAck = true;

        }

      if (m_txParams.MustWaitFastAck () &&

          m_fastAckTimeoutEvent.IsRunning ()) 

        {

          m_fastAckTimeoutEvent.Cancel ();

          gotAck = true;

        }

      if (gotAck) 

        {

          m_listener->GotAck (rxSnr, txMode);

        }

    if (m_txParams.HasNextPacket ()) 

      {

        m_waitSifsEvent = Simulator::Schedule (GetSifs (), 

                                               &MacLow::WaitSifsAfterEndTx, this);

      }

    } 

  else if (hdr.IsCtl ()) 

    {

      MY_DEBUG ("rx drop " << hdr.GetTypeString ());

    } 

  else if (hdr.GetAddr1 () == m_mac->GetAddress ()) 

    {

      WifiRemoteStation *station = GetStation (hdr.GetAddr2 ());

      station->ReportRxOk (rxSnr, txMode);

      if (hdr.IsQosData () && hdr.IsQosNoAck ()) 

        {

          MY_DEBUG ("rx unicast/noAck from="<<hdr.GetAddr2 ());

        } 

      else if (hdr.IsData () || hdr.IsMgt ()) 

        {

          MY_DEBUG ("rx unicast/sendAck from=" << hdr.GetAddr2 ());

          NS_ASSERT (m_sendAckEvent.IsExpired ());

          m_sendAckEvent = Simulator::Schedule (GetSifs (),

                                                &MacLow::SendAckAfterData, this,

                                                hdr.GetAddr2 (),