Attachment #2581 for bug #2493

View | Details | Raw Unified | Return to bug 2493
Collapse All | Expand All




   */
  bool IsAccessRequested (void) const;


private:
  friend class DcfManager;

  /**
   * Return the current number of backoff slots.
   *
   * \return the current number of backoff slots
   */
  uint32_t GetBackoffSlots (void) const;

private:
  friend class DcfManager;

  /**
   * Return the time when the backoff procedure started.
   *

   */
  void NotifyCtsTimeoutResetNow ();

  /**
   * Check if the device is busy sending or receiving,
   * or NAV busy.
   *
   * \return true if the device is busy,
   *         false otherwise
   */
  bool IsBusy (void) const;

private:
  /**

   * Grant access to DCF
   */
  void DoGrantAccess (void);
  /**
   * Check if the device is busy sending or receiving,
   * or NAV busy.
   *
   * \return true if the device is busy,
   *         false otherwise
   */
  bool IsBusy (void) const;

  /**
   * typedef for a vector of DcfStates




    {
      m_dcf->UpdateFailedCw ();
    }
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  RestartAccessIfNeeded ();
}


EdcaTxopN::NotifyCollision (void)
{
  NS_LOG_FUNCTION (this);
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  RestartAccessIfNeeded ();
}


      m_dcf->UpdateFailedCw ();
      m_cwTrace = m_dcf->GetCw ();
    }
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  RestartAccessIfNeeded ();
}


  NS_LOG_FUNCTION (this << packet << &hdr);
  m_stationManager->PrepareForQueue (hdr.GetAddr1 (), &hdr, packet);
  m_queue->Enqueue (packet, hdr);
  if (m_dcf->GetBackoffSlots () == 0 && m_manager->IsBusy () && !HasTxop ())
    {
      NS_LOG_DEBUG ("Starting backoff; slots=" << m_dcf->GetBackoffSlots () << " busy= " << m_manager->IsBusy ());
      m_backoffTrace = m_rng->GetNext (0, m_dcf->GetCw ());
      NS_LOG_DEBUG ("Drawing new backoff " << m_backoffTrace);
      m_dcf->StartBackoffNow (m_backoffTrace);
      RestartAccessIfNeeded ();
    }
  else
    {
      StartAccessIfNeeded ();
    }
}

void

        }
      m_currentPacket = 0;
      m_dcf->ResetCw ();
      m_cwTrace = m_dcf->GetCw ();
      if (HasPendingQosMpduWithSameTidAndAddress () && !HasTxop () && m_dcf->GetBackoffSlots () == 0)
        {
          StartBackoffIfNeeded ();
          m_backoffTrace = m_rng->GetNext (0, m_dcf->GetCw ());
          m_dcf->StartBackoffNow (m_backoffTrace);
          RestartAccessIfNeeded ();
        }
    }

      m_dcf->UpdateFailedCw ();
      m_cwTrace = m_dcf->GetCw ();
    }
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  RestartAccessIfNeeded ();
}


      m_dcf->ResetCw ();
      m_cwTrace = m_dcf->GetCw ();
    }
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  RestartAccessIfNeeded ();
}


                                                                 &tstamp);
  if (peekedPacket == 0)
    {
      NS_LOG_DEBUG ("No pending packet; returning");
      return;
    }
  if (!HasTxop () && m_dcf->GetBackoffSlots () == 0)
    {
      NS_LOG_DEBUG ("No TXOP left; start backoff again");
      m_backoffTrace = m_rng->GetNext (0, m_dcf->GetCw ());
      NS_LOG_DEBUG ("Drawing new backoff " << m_backoffTrace);
      m_dcf->StartBackoffNow (m_backoffTrace);
      RestartAccessIfNeeded ();
    }
    
  MacLowTransmissionParameters params;
  params.DisableOverrideDurationId ();

    }
}

void
EdcaTxopN::StartBackoffIfNeeded (void)
{
  NS_LOG_FUNCTION (this);
  if (m_dcf->GetBackoffSlots () == 0)
    {
      m_backoffTrace = m_rng->GetNext (0, m_dcf->GetCw ());
      NS_LOG_DEBUG ("Drawing new backoff " << m_backoffTrace);
      m_dcf->StartBackoffNow (m_backoffTrace);
    }
}

Time
EdcaTxopN::GetTxopRemaining (void)
{

  return (GetTxopRemaining () >= Low ()->CalculateOverallTxTime (peekedPacket, &hdr, params));
}

bool
EdcaTxopN::HasPendingQosMpduWithSameTidAndAddress (void) const
{
  NS_LOG_FUNCTION (this);
  WifiMacHeader hdr;
  Time tstamp;
  if (!m_currentHdr.IsQosData ())
    {
      NS_LOG_DEBUG ("Current header is not QoS data; returning false");
      return false;
    }

  Ptr<const Packet> peekedPacket = m_queue->PeekByTidAndAddress (&hdr,
                                                                 m_currentHdr.GetQosTid (),
                                                                 WifiMacHeader::ADDR1,
                                                                 m_currentHdr.GetAddr1 (),
                                                                 &tstamp);
  if (peekedPacket == 0)
    {
      NS_LOG_DEBUG ("No pending MPDU matching current header TID and address; returning false");
      return false;
    }
  else
    {
      NS_LOG_DEBUG ("Pending MPDU found; returning true");
      return true;
    }
}

void
EdcaTxopN::Cancel (void)
{

  m_currentPacket = 0;
  m_dcf->ResetCw ();
  m_cwTrace = m_dcf->GetCw ();
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  StartAccessIfNeeded ();
}


  m_currentPacket = 0;
  m_dcf->ResetCw ();
  m_cwTrace = m_dcf->GetCw ();
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  RestartAccessIfNeeded ();
}


  NS_LOG_FUNCTION (this);
  m_dcf->ResetCw ();
  m_cwTrace = m_dcf->GetCw ();
  StartBackoffIfNeeded ();
  m_dcf->StartBackoffNow (m_backoffTrace);
  ns3::Dcf::DoInitialize ();
}





  /*
   * Check if the station has TXOP granted for the next MPDU.
   *
   * \return true if the station has another MPDU ready and TXOP granted for it,
   *         false otherwise
   */
  bool HasTxop (void);
  /*
   * Check if the station has a MPDU pending with the same TID and address
   * as the current packet.
   *
   * \return true if the station has a MPDU pending with the same TID and
   *         address as the current packet, false otherwise 
   */
  bool HasPendingQosMpduWithSameTidAndAddress (void) const;

  void StartBackoffIfNeeded (void);

  AcIndex m_ac;
  class Dcf;

Return to bug 2493