/* -*-  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/packet.h"

#include "ns3/llc-snap-header.h"

#include "ns3/node.h"

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

#include "wifi-net-device.h"

#include "wifi-phy.h"

#include "wifi-channel.h"

#include "mac-stations.h"

#include "mac-low.h"

#include "mac-parameters.h"

#include "mac-rx-middle.h"

#include "mac-tx-middle.h"

#include "mac-high-adhoc.h"

#include "mac-high-nqsta.h"

#include "mac-high-nqap.h"

#include "dca-txop.h"

#include "dcf-manager.h"

#include "wifi-default-parameters.h"

#include "arf-mac-stations.h"

#include "aarf-mac-stations.h"

#include "ideal-mac-stations.h"

#include "cr-mac-stations.h"

namespace ns3 {

/***************************************************************

 *         hold an enumeration of the trace types

 ***************************************************************/

WifiNetDeviceTraceType::WifiNetDeviceTraceType ()

  : m_type (RX)

{}

WifiNetDeviceTraceType::WifiNetDeviceTraceType (enum Type type)

  : m_type (type)

{}

enum WifiNetDeviceTraceType::Type 

WifiNetDeviceTraceType::Get (void) const

{

  return m_type;

}

uint16_t 

WifiNetDeviceTraceType::GetUid (void)

{

  static uint16_t uid = AllocateUid<WifiNetDeviceTraceType> ("ns3::WifiNetDeviceTraceType");

  return uid;

}

void 

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

{

  os << "event=";

  switch (m_type) {

  case RX: 

    os << "rx"; 

    break;

  case TX: 

    os << "tx";

    break;

  }

}

std::string 

WifiNetDeviceTraceType::GetTypeName (void) const

{

   return "ns3::WifiNetDeviceTraceType";

}

/***************************************************************

 *         a static helper

 ***************************************************************/

static WifiMode 

GetWifiModeForPhyMode (Ptr<WifiPhy> phy, enum WifiDefaultParameters::PhyModeParameter mode)

{

  uint32_t phyRate = (uint32_t)mode;

  for (uint32_t i= 0; i < phy->GetNModes (); i++)

    {

      WifiMode mode = phy->GetMode (i);

      if (mode.GetPhyRate () == phyRate)

        {

          return mode;

        }

    }

  NS_ASSERT (false);

  return WifiMode ();

}

/***************************************************************

 *         Listener for Nav events. Forwards to DcfManager

 ***************************************************************/

class WifiNetDevice::NavListener : public ns3::MacLowNavListener {

public:

  NavListener (ns3::DcfManager *dcf)

    : m_dcf (dcf) {}

  virtual ~NavListener () {}

  virtual void NavStart (Time duration) {

    m_dcf->NotifyNavStartNow (duration);

  }

  virtual void NavReset (Time duration) {

    m_dcf->NotifyNavResetNow (duration);

  }

private:

  ns3::DcfManager *m_dcf;

};

/***************************************************************

 *         Listener for PHY events. Forwards to DcfManager

 ***************************************************************/

class WifiNetDevice::PhyListener : public ns3::WifiPhyListener {

public:

  PhyListener (ns3::DcfManager *dcf)

    : m_dcf (dcf) {}

  virtual ~PhyListener () {}

  virtual void NotifyRxStart (Time duration) {

    m_dcf->NotifyRxStartNow (duration);

  }

  virtual void NotifyRxEndOk (void) {

    m_dcf->NotifyRxEndOkNow ();

  }

  virtual void NotifyRxEndError (void) {

    m_dcf->NotifyRxEndErrorNow ();

  }

  virtual void NotifyTxStart (Time duration) {

    m_dcf->NotifyTxStartNow (duration);

  }

  virtual void NotifyCcaBusyStart (Time duration) {

    m_dcf->NotifyCcaBusyStartNow (duration);

  }

private:

  ns3::DcfManager *m_dcf;

};

/***************************************************************

 *              The NetDevice itself

 ***************************************************************/

WifiNetDevice::WifiNetDevice (Ptr<Node> node)

  : NetDevice (node, Mac48Address::Allocate ())

{

  Construct ();

}

WifiNetDevice::WifiNetDevice (Ptr<Node> node, Mac48Address self)

  : NetDevice (node, self)

{

  Construct ();

}

WifiNetDevice::~WifiNetDevice ()

{}

void

WifiNetDevice::Construct (void)

{

  SetMtu (2300);

  EnableBroadcast (Mac48Address ("ff:ff:ff:ff:ff:ff"));

  // the physical layer.

  m_phy = Create<WifiPhy> (this);

  // the rate control algorithm

  switch (WifiDefaultParameters::GetRateControlAlgorithm ()) {

  case WifiDefaultParameters::ARF:

    m_stations = new ArfMacStations (m_phy->GetMode (0), 

                                     WifiDefaultParameters::GetArfRateControlTimerThreshold (),

                                     WifiDefaultParameters::GetArfRateControlSuccessThreshold ());

    break;

  case WifiDefaultParameters::AARF:

    m_stations = new AarfMacStations (m_phy->GetMode (0),

                                      WifiDefaultParameters::GetAarfRateControlMinTimerThreshold (),

                                      WifiDefaultParameters::GetAarfRateControlMinSuccessThreshold (),

                                      WifiDefaultParameters::GetAarfRateControlSuccessK (),

                                      WifiDefaultParameters::GetAarfRateControlMaxSuccessThreshold (),

                                      WifiDefaultParameters::GetAarfRateControlTimerK ());

    break;

  case WifiDefaultParameters::CONSTANT_RATE: {

    WifiMode dataRate = GetWifiModeForPhyMode (m_phy, WifiDefaultParameters::GetConstantDataRate ());

    WifiMode ctlRate = GetWifiModeForPhyMode (m_phy, WifiDefaultParameters::GetConstantCtlRate ());

    m_stations = new CrMacStations (dataRate, ctlRate);

  } break;

  case WifiDefaultParameters::IDEAL: {

    double ber = WifiDefaultParameters::GetIdealRateControlBer ();

    IdealMacStations *ideal = new IdealMacStations (m_phy->GetMode (0));

    uint32_t nModes = m_phy->GetNModes ();

    for (uint32_t i = 0; i < nModes; i++) 

      {

        WifiMode mode = m_phy->GetMode (i);

        ideal->AddModeSnrThreshold (mode, m_phy->CalculateSnr (mode, ber));

      }

    m_stations = ideal;

  } break;

  default:

    // NOTREACHED

    NS_ASSERT (false);

    break;

  }

  // MacParameters

  MacParameters *parameters = new MacParameters ();

  WifiMacHeader hdr;

  hdr.SetType (WIFI_MAC_CTL_CTS);

  Time ctsDelay = m_phy->CalculateTxDuration (hdr.GetSize () + 4, m_phy->GetMode (0), WIFI_PREAMBLE_LONG);

  hdr.SetType (WIFI_MAC_CTL_ACK);

  Time ackDelay = m_phy->CalculateTxDuration (hdr.GetSize () + 4, m_phy->GetMode (0), WIFI_PREAMBLE_LONG);

  parameters->Initialize (ctsDelay, ackDelay);

  m_parameters = parameters;

  // the MacLow

  MacLow *low = new MacLow ();

  low->SetDevice (this);

  low->SetPhy (m_phy);

  low->SetStations (m_stations);

  low->SetParameters (m_parameters);

  m_phy->SetReceiveOkCallback (MakeCallback (&MacLow::ReceiveOk, low));

  m_phy->SetReceiveErrorCallback (MakeCallback (&MacLow::ReceiveError, low));

  m_low = low;

  // the 'middle' rx

  MacRxMiddle *rxMiddle = new MacRxMiddle ();

  low->SetRxCallback (MakeCallback (&MacRxMiddle::Receive, rxMiddle));

  m_rxMiddle = rxMiddle;

  // the 'middle' tx

  MacTxMiddle *txMiddle = new MacTxMiddle ();

  m_txMiddle = txMiddle;

  m_manager = new DcfManager ();

  Time ackTxDuration = m_phy->CalculateTxDuration (8 * (2+2+6+4), m_phy->GetMode (0), WIFI_PREAMBLE_LONG);

  m_manager->SetAckTxDuration (ackTxDuration);

  m_manager->SetSlotTime (m_parameters->GetSlotTime ());

  m_manager->SetSifs (m_parameters->GetSifs ());

  m_phyListener = new WifiNetDevice::PhyListener (m_manager);

  m_phy->RegisterListener (m_phyListener);

  m_navListener = new WifiNetDevice::NavListener (m_manager);

  m_low->RegisterNavListener (m_navListener);

}

DcaTxop *

WifiNetDevice::CreateDca (uint32_t minCw, uint32_t maxCw, uint32_t aifsn) const

{

  DcaTxop *dca = new DcaTxop (minCw, maxCw, aifsn, m_manager);

  dca->SetParameters (m_parameters);

  dca->SetTxMiddle (m_txMiddle);

  dca->SetLow (m_low);

  dca->SetMaxQueueSize (400);

  dca->SetMaxQueueDelay (Seconds (10));

  return dca;

}

Ptr<TraceResolver> 

WifiNetDevice::GetTraceResolver (void) const

{

  Ptr<CompositeTraceResolver> resolver = 

    Create<CompositeTraceResolver> ();

  resolver->AddSource ("rx", 

                       TraceDoc ("Receive a packet",

                                 "Packet", "the packet received",

                                 "Mac48Address", "the sender of the packet"),

                       m_rxLogger,

                       WifiNetDeviceTraceType (WifiNetDeviceTraceType::RX));

  resolver->AddSource ("tx", 

                       TraceDoc ("Send a packet",

                                 "Packet", "the packet to send",

                                 "Mac48Address", "the destination of the packet"),

                       m_txLogger,

                       WifiNetDeviceTraceType (WifiNetDeviceTraceType::TX));

  resolver->AddComposite ("phy", m_phy);

  resolver->SetParentResolver (NetDevice::GetTraceResolver ());

  return resolver;

}

void 

WifiNetDevice::ConnectTo (Ptr<WifiChannel> channel)

{

  m_channel = channel;

  m_phy->SetChannel (channel);

  NotifyConnected ();

}

bool

{

  NS_ASSERT (Mac48Address::IsMatchingType (to));

  Mac48Address realTo = Mac48Address::ConvertFrom (to);

  LlcSnapHeader llc;

  llc.SetType (protocolNumber);

}

void 

{

  m_rxLogger (packet, from);

  LlcSnapHeader llc;

  NetDevice::ForwardUp (packet, llc.GetType (), from);

}

Mac48Address 

WifiNetDevice::GetSelfAddress (void) const

{

  NS_ASSERT (Mac48Address::IsMatchingType (GetAddress ()));

  Mac48Address self = Mac48Address::ConvertFrom (GetAddress ());

  return self;

}

bool 

WifiNetDevice::DoNeedsArp (void) const

{

  return true;

}

Ptr<Channel> 

WifiNetDevice::DoGetChannel (void) const

{

  return m_channel;

}

void 

WifiNetDevice::DoDispose (void)

{

  // chain up.

  NetDevice::DoDispose ();

  // cleanup local

  m_channel = 0;

  delete m_stations;

  delete m_low;

  delete m_rxMiddle;

  delete m_txMiddle;

  delete m_parameters;

  delete m_manager;

  delete m_phyListener;

  delete m_navListener;

  m_phy = 0;

  m_stations = 0;

  m_low = 0;

  m_rxMiddle = 0;

  m_txMiddle = 0;

  m_parameters = 0;

}

/*****************************************************

 *            Adhoc code

 *****************************************************/

AdhocWifiNetDevice::AdhocWifiNetDevice (Ptr<Node> node)

  : WifiNetDevice (node)

{

  DoConstruct ();

}

AdhocWifiNetDevice::AdhocWifiNetDevice (Ptr<Node> node, Mac48Address self)

  : WifiNetDevice (node, self)

{

  DoConstruct ();

}

void

AdhocWifiNetDevice::DoConstruct (void)

{

  m_ssid = WifiDefaultParameters::GetSsid ();

  m_dca = CreateDca (15, 1023, 2);

  MacHighAdhoc *high = new MacHighAdhoc ();

  high->SetDevice (this);

  high->SetDcaTxop (m_dca);

  high->SetForwardCallback (MakeCallback (&AdhocWifiNetDevice::DoForwardUp, 

                                          static_cast<WifiNetDevice *> (this)));

  high->SetPhy (m_phy);

  high->SetStations (m_stations);

  m_rxMiddle->SetForwardCallback (MakeCallback (&MacHighAdhoc::Receive, high));

  m_high = high;

}

AdhocWifiNetDevice::~AdhocWifiNetDevice ()

{}

Mac48Address 

AdhocWifiNetDevice::GetBssid (void) const

{

  return m_high->GetBssid ();

}

Ssid 

AdhocWifiNetDevice::GetSsid (void) const

{

  return m_ssid;

}

void 

AdhocWifiNetDevice::SetSsid (Ssid ssid)

{

  // XXX restart adhoc network join.

  m_ssid = ssid;

}

bool

{

  m_high->Enqueue (packet, to);

  return true;

}

void

AdhocWifiNetDevice::NotifyConnected (void)

{

  NotifyLinkUp ();

}

void 

AdhocWifiNetDevice::DoDispose (void)

{

  // chain up.

  WifiNetDevice::DoDispose ();

  // local cleanup

  delete m_dca;

  delete m_high;

  m_dca = 0;

  m_high = 0;

}

/*****************************************************

 *            STA code

 *****************************************************/

NqstaWifiNetDevice::NqstaWifiNetDevice (Ptr<Node> node)

  : WifiNetDevice (node)

{

  DoConstruct ();

}

NqstaWifiNetDevice::NqstaWifiNetDevice (Ptr<Node> node, Mac48Address self)

  : WifiNetDevice (node, self)

{

  DoConstruct ();

}

void

NqstaWifiNetDevice::DoConstruct (void)

{

  m_ssid = WifiDefaultParameters::GetSsid ();

  m_dca = CreateDca (15, 1023, 2);

  MacHighNqsta *high = new MacHighNqsta ();

  high->SetDevice (this);

  high->SetDcaTxop (m_dca);

  high->SetForwardCallback (MakeCallback (&NqstaWifiNetDevice::DoForwardUp, 

                                          this));

  high->SetAssociatedCallback (MakeCallback (&NqstaWifiNetDevice::Associated, 

                                             this));

  high->SetDisAssociatedCallback (MakeCallback (&NqstaWifiNetDevice::DisAssociated, 

                                                this));

  high->SetStations (m_stations);

  high->SetPhy (m_phy);

  m_rxMiddle->SetForwardCallback (MakeCallback (&MacHighNqsta::Receive, high));

  m_high = high;

}

NqstaWifiNetDevice::~NqstaWifiNetDevice ()

{}

Mac48Address 

NqstaWifiNetDevice::GetBssid (void) const

{

  return m_high->GetBssid ();

}

Ssid 

NqstaWifiNetDevice::GetSsid (void) const

{

  return m_ssid;

}

void 

NqstaWifiNetDevice::StartActiveAssociation (Ssid ssid)

{

  m_ssid = ssid;

  m_high->StartActiveAssociation ();

}

bool

{

  m_high->Queue (packet, to);

  return true;

}

void