mac-low.h

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
 * Copyright (c) 2005, 2006 INRIA
 * Copyright (c) 2009 MIRKO BANCHI
 *
 * 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
 *
 * Authors: Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
 *          Mirko Banchi <mk.banchi@gmail.com>
 */

#ifndef MAC_LOW_H
#define MAC_LOW_H

#include <map>
#include "ns3/object.h"
#include "ns3/nstime.h"
#include "channel-access-manager.h"
#include "block-ack-cache.h"
#include "mac-low-transmission-parameters.h"
#include "qos-utils.h"
#include "wifi-mac-header.h"
#include "wifi-tx-vector.h"
#include "block-ack-type.h"
#include "wifi-mpdu-type.h"

namespace ns3 {

class WifiMac;
class WifiPhy;
class Txop;
class QosTxop;
class WifiMacQueueItem;
class WifiMacQueue;
class WifiPsdu;
class BlockAckAgreement;
class MgtAddBaResponseHeader;
class WifiRemoteStationManager;
class CtrlBAckRequestHeader;
class CtrlBAckResponseHeader;
class MsduAggregator;
class MpduAggregator;

class MacLow : public Object
{
public:

  typedef Callback<void, Ptr<WifiMacQueueItem>> MacLowRxCallback;

  MacLow ();
  virtual ~MacLow ();

  static TypeId GetTypeId (void);

  void SetPhy (const Ptr<WifiPhy> phy);
  Ptr<WifiPhy> GetPhy (void) const;
  void ResetPhy (void);
  Ptr<QosTxop> GetEdca (uint8_t tid) const;
  void SetMac (const Ptr<WifiMac> mac);
  void SetWifiRemoteStationManager (const Ptr<WifiRemoteStationManager> manager);
  void SetAddress (Mac48Address ad);
  void SetCtsToSelfSupported (bool enable);
  void SetBeaconInterval (Time interval);
  void SetCfpMaxDuration (Time duration);
  void SetBssid (Mac48Address ad);
  void SetPromisc (void);
  bool GetCtsToSelfSupported (void) const;
  Mac48Address GetAddress (void) const;
  Time GetSifs (void) const;
  Time GetSlotTime (void) const;
  Time GetPifs (void) const;
  Time GetBeaconInterval (void) const;
  Time GetCfpMaxDuration (void) const;
  Time GetRemainingCfpDuration (void) const;
  Mac48Address GetBssid (void) const;
  bool IsPromisc (void) const;

  void SetRxCallback (Callback<void, Ptr<WifiMacQueueItem>> callback);
  void RegisterChannelAccessManager (Ptr<ChannelAccessManager> channelAccessManager);

  bool IsWithinSizeAndTimeLimits (Ptr<const WifiMacQueueItem> mpdu, WifiTxVector txVector,
                                  uint32_t ampduSize, Time ppduDurationLimit);
  bool IsWithinSizeAndTimeLimits (uint32_t mpduSize, Mac48Address receiver, uint8_t tid,
                                  WifiTxVector txVector, uint32_t ampduSize, Time ppduDurationLimit);
  Time CalculateTransmissionTime (Ptr<const Packet> packet,
                                  const WifiMacHeader* hdr,
                                  const MacLowTransmissionParameters& parameters) const;

  Time CalculateOverallTxTime (Ptr<const Packet> packet,
                               const WifiMacHeader* hdr,
                               const MacLowTransmissionParameters& params,
                               uint32_t fragmentSize = 0) const;

  Time CalculateOverheadTxTime (Ptr<const WifiMacQueueItem> item,
                               const MacLowTransmissionParameters& params) const;

  virtual void StartTransmission (Ptr<WifiMacQueueItem> mpdu,
                                  MacLowTransmissionParameters parameters,
                                  Ptr<Txop> txop);

  void RxStartIndication (WifiTxVector txVector, Time psduDuration);

  void ReceiveOk (Ptr<WifiMacQueueItem> mpdu, double rxSnr, WifiTxVector txVector, bool ampduSubframe);
  void ReceiveError (Ptr<WifiPsdu> psdu);
  void NotifySwitchingStartNow (Time duration);
  void NotifySleepNow (void);
  void NotifyOffNow (void);
  void CreateBlockAckAgreement (const MgtAddBaResponseHeader *respHdr,
                                Mac48Address originator,
                                uint16_t startingSeq);
  void DestroyBlockAckAgreement (Mac48Address originator, uint8_t tid);
  void RegisterEdcaForAc (AcIndex ac, Ptr<QosTxop> edca);
  void DeaggregateAmpduAndReceive (Ptr<WifiPsdu> aggregatedPacket, double rxSnr, WifiTxVector txVector,
                                   std::vector<bool> statusPerMpdu);

  virtual WifiTxVector GetDataTxVector (Ptr<const WifiMacQueueItem> item) const;
  bool DoNavStartNow (Time duration);
  virtual bool IsCfPeriod (void) const;
  bool CanTransmitNextCfFrame (void) const;

  Ptr<MsduAggregator> GetMsduAggregator (void) const;
  Ptr<MpduAggregator> GetMpduAggregator (void) const;

  void SetMsduAggregator (const Ptr<MsduAggregator> aggr);
  void SetMpduAggregator (const Ptr<MpduAggregator> aggr);


private:
  void CancelAllEvents (void);
  uint32_t GetCfEndSize (void) const;
  void ForwardDown (Ptr<const WifiPsdu> psdu, WifiTxVector txVector);
  WifiTxVector GetRtsTxVector (Ptr<const WifiMacQueueItem> item) const;
  WifiTxVector GetCtsTxVector (Mac48Address to, WifiMode rtsTxMode) const;
  WifiTxVector GetAckTxVector (Mac48Address to, WifiMode dataTxMode) const;
  WifiTxVector GetBlockAckTxVector (Mac48Address to, WifiMode dataTxMode) const;
  WifiTxVector GetCtsTxVectorForRts (Mac48Address to, WifiMode rtsTxMode) const;
  WifiTxVector GetAckTxVectorForData (Mac48Address to, WifiMode dataTxMode) const;
  WifiMode GetControlAnswerMode (WifiMode reqMode) const;
  Time GetCtsDuration (WifiTxVector ctsTxVector) const;
  Time GetCtsDuration (Mac48Address to, WifiTxVector rtsTxVector) const;
  Time GetAckDuration (WifiTxVector ackTxVector) const;
  Time GetAckDuration (Mac48Address to, WifiTxVector dataTxVector) const;
  Time GetBlockAckDuration (WifiTxVector blockAckReqTxVector, BlockAckType type) const;
  Time GetBlockAckRequestDuration (WifiTxVector blockAckReqTxVector, BlockAckType type) const;
  Time GetResponseDuration (const MacLowTransmissionParameters& params,
                            WifiTxVector dataTxVector, Mac48Address receiver) const;
  bool NeedCtsToSelf (void) const;

  void NotifyNav (Ptr<const Packet> packet,const WifiMacHeader &hdr);
  void DoNavResetNow (Time duration);
  bool IsNavZero (void) const;
  void NotifyAckTimeoutStartNow (Time duration);
  void NotifyAckTimeoutResetNow (void);
  void NotifyCtsTimeoutStartNow (Time duration);
  void NotifyCtsTimeoutResetNow (void);
  /* Event handlers */
  void NormalAckTimeout (void);
  void BlockAckTimeout (void);
  void CtsTimeout (void);
  void CfPollTimeout (void);
  void SendCtsToSelf (void);
  void SendCtsAfterRts (Mac48Address source, Time duration, WifiTxVector rtsTxVector, double rtsSnr);
  void SendAckAfterData (Mac48Address source, Time duration, WifiMode dataTxMode, double dataSnr);
  void SendDataAfterCts (Time duration);

  void WaitIfsAfterEndTxFragment (void);
  void WaitIfsAfterEndTxPacket (void);

  void EndTxNoAck (void);
  void SendRtsForPacket (void);
  void SendDataPacket (void);
  void StartDataTxTimers (WifiTxVector dataTxVector);

  void DoDispose (void);

  void RxCompleteBufferedPacketsWithSmallerSequence (uint16_t seq, Mac48Address originator, uint8_t tid);
  void RxCompleteBufferedPacketsUntilFirstLost (Mac48Address originator, uint8_t tid);
  bool ReceiveMpdu (Ptr<WifiMacQueueItem> mpdu);
  bool StoreMpduIfNeeded (Ptr<WifiMacQueueItem> mpdu);
  void SendBlockAckAfterBlockAckRequest (const CtrlBAckRequestHeader reqHdr, Mac48Address originator,
                                         Time duration, WifiMode blockAckReqTxMode, double rxSnr);
  void SendBlockAckAfterAmpdu (uint8_t tid, Mac48Address originator, Time duration,
                               WifiTxVector blockAckReqTxVector, double rxSnr);
  void SendBlockAckResponse (const CtrlBAckResponseHeader* blockAck, Mac48Address originator, bool immediate,
                             Time duration, WifiMode blockAckReqTxMode, double rxSnr);
  void ResetBlockAckInactivityTimerIfNeeded (BlockAckAgreement &agreement);

  void SetupPhyMacLowListener (const Ptr<WifiPhy> phy);
  void RemovePhyMacLowListener (Ptr<WifiPhy> phy);

  Ptr<WifiPhy> m_phy; 
  Ptr<WifiMac> m_mac; 
  Ptr<WifiRemoteStationManager> m_stationManager; 
  MacLowRxCallback m_rxCallback; 

  struct CfAckInfo
  {
    bool appendCfAck;     
    bool expectCfAck;     
    Mac48Address address; 
  };

  typedef std::vector<Ptr<ChannelAccessManager> >::const_iterator ChannelAccessManagersCI;
  typedef std::vector<Ptr<ChannelAccessManager> > ChannelAccessManagers;
  ChannelAccessManagers m_channelAccessManagers; 

  Ptr<MsduAggregator> m_msduAggregator;             
  Ptr<MpduAggregator> m_mpduAggregator;             

  EventId m_normalAckTimeoutEvent;      
  EventId m_blockAckTimeoutEvent;       
  EventId m_ctsTimeoutEvent;            
  EventId m_sendCtsEvent;               
  EventId m_sendAckEvent;               
  EventId m_sendDataEvent;              
  EventId m_waitIfsEvent;               
  EventId m_endTxNoAckEvent;            
  EventId m_navCounterResetCtsMissed;   

  Ptr<WifiPsdu> m_currentPacket;            
  Ptr<Txop> m_currentTxop;                  
  MacLowTransmissionParameters m_txParams;  
  Mac48Address m_self;                      
  Mac48Address m_bssid;                     

  Time m_beaconInterval;   
  Time m_cfpMaxDuration;   

  Time m_lastNavStart;     
  Time m_lastNavDuration;  

  Time m_cfpStart;          
  Time m_lastBeacon;        
  Time m_cfpForeshortening; 

  bool m_promisc;  

  class PhyMacLowListener * m_phyMacLowListener; 

  /*
   * BlockAck data structures.
   */
  typedef std::list<Ptr<WifiMacQueueItem>>::iterator BufferedPacketI; 

  typedef std::pair<Mac48Address, uint8_t> AgreementKey; 
  typedef std::pair<BlockAckAgreement, std::list<Ptr<WifiMacQueueItem>> > AgreementValue; 

  typedef std::map<AgreementKey, AgreementValue> Agreements; 
  typedef std::map<AgreementKey, AgreementValue>::iterator AgreementsI; 

  typedef std::map<AgreementKey, BlockAckCache> BlockAckCaches; 
  typedef std::map<AgreementKey, BlockAckCache>::iterator BlockAckCachesI; 

  Agreements m_bAckAgreements; 
  BlockAckCaches m_bAckCaches; 

  typedef std::map<AcIndex, Ptr<QosTxop> > QueueEdcas; 
  QueueEdcas m_edca; 

  bool m_ctsToSelfSupported;             
  WifiTxVector m_currentTxVector;        

  CfAckInfo m_cfAckInfo; 
};

} //namespace ns3

#endif /* MAC_LOW_H */