Attachment #2406 for bug #2307

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

(-)a/src/test/traced/traced-callback-typedef-test-suite.cc (-2 / +2 lines)

Lines 610-617	Link Here

610

         empty, empty, empty, empty);

610

         empty, empty, empty, empty);

611

612

  CHECK (WifiPhyStateHelper::RxEndErrorTracedCallback,

612

  CHECK (WifiPhyStateHelper::RxEndErrorTracedCallback,

613

         Ptr<const Packet>, double, bool,

613

         Ptr<const Packet>, double,

614

         empty, empty);

614

         empty, empty, empty);

615

616

  CHECK (WifiPhyStateHelper::RxOkTracedCallback,

616

  CHECK (WifiPhyStateHelper::RxOkTracedCallback,

617

         Ptr<const Packet>, double, WifiMode, WifiPreamble,

617

         Ptr<const Packet>, double, WifiMode, WifiPreamble,




}

AmpduTag::AmpduTag ()
  : m_ampdu (0),
    m_duration (0)
{
}


  m_noOfMpdus = noofmpdus;
}

void
AmpduTag::SetRemainingAmpduDurationNs (uint32_t durationNanoSeconds)
{
  NS_ASSERT (m_duration <= 10000000);
  m_duration = durationNanoSeconds;
}

uint32_t
AmpduTag::GetSerializedSize (void) const
{
  return 6;
}

void

{
  i.WriteU8 (m_ampdu);
  i.WriteU8 (m_noOfMpdus);
  i.WriteU32 (m_duration);
}

void

{
  m_ampdu = i.ReadU8 ();
  m_noOfMpdus = i.ReadU8 ();
  m_duration = i.ReadU32 ();
}

bool

  return m_noOfMpdus;
}

uint32_t
AmpduTag::GetRemainingAmpduDurationNs () const
{
  return m_duration;
}

void
AmpduTag::Print (std::ostream &os) const
{

(-)a/src/wifi/model/ampdu-tag.h (-1 / +14 lines)

Lines 53-58	Link Here

   * Set the number of MPDUs in the A-MPDU.

   * Set the number of MPDUs in the A-MPDU.

*/

*/

  void SetNoOfMpdus (uint8_t noofmpdus);

  void SetNoOfMpdus (uint8_t noofmpdus);

/**

   * \param durationNanoSeconds duration of the A-MPDU in nanoseconds

   * Set the duration of the A-MPDU in nanoseconds.

*/

  void SetRemainingAmpduDurationNs (uint32_t durationNanoSeconds);

  virtual void Serialize (TagBuffer i) const;

  virtual void Serialize (TagBuffer i) const;

  virtual void Deserialize (TagBuffer i);

  virtual void Deserialize (TagBuffer i);

Lines 72-81	Link Here

   * Returns the number of MPDUs in an A-MPDU

   * Returns the number of MPDUs in an A-MPDU

*/

*/

  uint8_t GetNoOfMpdus (void) const;

  uint8_t GetNoOfMpdus (void) const;

/**

   * \return the duration of an A-MPDU in nanoseconds

   * Returns the duration of an A-MPDU in nanoseconds

*/

  uint32_t GetRemainingAmpduDurationNs (void) const;

private:

private:

  uint8_t m_ampdu;     //!< Flag whether it is an A-MPDU

  uint8_t m_ampdu;     //!< Flag whether it is an A-MPDU

  uint8_t m_noOfMpdus; //!< number of MPDUs in the A-MPDU

  uint8_t m_noOfMpdus; //!< Number of MPDUs in the A-MPDU

  uint32_t m_duration; //!< Remaining duration of the A-MPDU in nanoseconds

};

};

} //namespace ns3

} //namespace ns3




    m_listener (0),
    m_phyMacLowListener (0),
    m_ctsToSelfSupported (false),
    m_receivedAtLeastOneMpdu (false),
    m_nTxMpdus (0)
{
  NS_LOG_FUNCTION (this);

MacLow::ResetPhy (void)
{
  m_phy->SetReceiveOkCallback (MakeNullCallback<void, Ptr<Packet>, double, WifiTxVector, enum WifiPreamble> ());
  m_phy->SetReceiveErrorCallback (MakeNullCallback<void, Ptr<Packet>, double> ());
  RemovePhyMacLowListener (m_phy);
  m_phy = 0;
}

}

void
MacLow::ReceiveError (Ptr<Packet> packet, double rxSnr)
{
  NS_LOG_FUNCTION (this << packet << rxSnr);
  NS_LOG_DEBUG ("rx failed ");
  if (isEndOfFrame == true && m_receivedAtLeastOneMpdu == true)
    {
      WifiMacHeader hdr;
      AmpduTag ampdu;
      if (packet->RemovePacketTag (ampdu))
        {
          MpduAggregator::DeaggregatedMpdus mpdu = MpduAggregator::Deaggregate (packet);
          mpdu.begin ()->first->PeekHeader (hdr);
        }
      else
        {
          packet->PeekHeader (hdr);
        }
      if (hdr.GetAddr1 () != m_self)
        {
          NS_LOG_DEBUG ("hdr addr1 " << hdr.GetAddr1 () << "not for me (" << m_self << "); returning");
          return;
        }
      NS_ASSERT (m_lastReceivedHdr.IsQosData ());
      NS_LOG_DEBUG ("last a-mpdu subframe detected/sendImmediateBlockAck from=" << m_lastReceivedHdr.GetAddr2 ());
      m_sendAckEvent = Simulator::Schedule (GetSifs (),
                                            &MacLow::SendBlockAckAfterAmpdu, this,
                                            m_lastReceivedHdr.GetQosTid (),
                                            m_lastReceivedHdr.GetAddr2 (),
                                            m_lastReceivedHdr.GetDuration (),
                                            m_currentTxVector,
                                            rxSnr);
      m_receivedAtLeastOneMpdu = false;
    }
  if (m_txParams.MustWaitFastAck ())
    {
      NS_ASSERT (m_fastAckFailedTimeoutEvent.IsExpired ());

              NS_ASSERT (i != m_bAckCaches.end ());
              (*i).second.UpdateWithBlockAckReq (blockAckReq.GetStartingSequence ());

              //NS_ASSERT (m_sendAckEvent.IsExpired ());
              m_sendAckEvent.Cancel ();
              /* See section 11.5.3 in IEEE 802.11 for mean of this timer */
              ResetBlockAckInactivityTimerIfNeeded (it->second.first);
              if ((*it).second.first.IsImmediateBlockAck ())

                {
                  NS_FATAL_ERROR ("Delayed block ack not supported.");
                }
              m_receivedAtLeastOneMpdu = false;
            }
          else
            {

  else if (hdr.IsCtl ())
    {
      NS_LOG_DEBUG ("rx drop " << hdr.GetTypeString ());
      m_receivedAtLeastOneMpdu = false;
    }
  else if (hdr.GetAddr1 () == m_self)
    {

                                                    hdr.GetDuration (),
                                                    txVector.GetMode (),
                                                    rxSnr);
              m_receivedAtLeastOneMpdu = false;
            }
          else if (hdr.IsQosBlockAck ())
            {

                                                    hdr.GetDuration (),
                                                    txVector.GetMode (),
                                                    rxSnr);
              m_receivedAtLeastOneMpdu = false;
            }
        }
      goto rxPacket;

          if (hdr.IsData () || hdr.IsMgt ())
            {
              NS_LOG_DEBUG ("rx group from=" << hdr.GetAddr2 ());
              m_receivedAtLeastOneMpdu = false;
              goto rxPacket;
            }
          else

      AmpduTag ampdutag;
      ampdutag.SetAmpdu (true);
      Time delay = Seconds (0);
      Time remainingAmpduDuration = m_phy->CalculateTxDuration (packet->GetSize (), txVector, preamble, m_phy->GetFrequency ());
      if (queueSize > 1 || vhtSingleMpdu)
        {
          txVector.SetAggregation (true);

            }

          listenerIt->second->GetMpduAggregator ()->AddHeaderAndPad (newPacket, last, vhtSingleMpdu);
          
          ampdutag.SetNoOfMpdus (queueSize);
          newPacket->AddPacketTag (ampdutag);

          if (delay == Seconds (0))
            {
              if (!vhtSingleMpdu)

                {
                  mpdutype = NORMAL_MPDU;
                }
            }
          
          Time mpduDuration = m_phy->CalculateTxDuration (newPacket->GetSize (), txVector, preamble, m_phy->GetFrequency (), mpdutype, 0);
          remainingAmpduDuration -= mpduDuration;

          ampdutag.SetNoOfMpdus (queueSize);
          ampdutag.SetRemainingAmpduDurationNs (remainingAmpduDuration.GetNanoSeconds());
          newPacket->AddPacketTag (ampdutag);

          if (delay == Seconds (0))
            {
              m_phy->SendPacket (newPacket, txVector, preamble, mpdutype);
            }
          else

            }
          if (queueSize > 1)
            {
              delay = delay + mpduDuration;
            }

          preamble = WIFI_PREAMBLE_NONE;
        }
    }

  if (aggregatedPacket->RemovePacketTag (ampdu))
    {
      ampduSubframe = true;
      m_currentTxVector = txVector;
      MpduAggregator::DeaggregatedMpdus packets = MpduAggregator::Deaggregate (aggregatedPacket);
      MpduAggregator::DeaggregatedMpdusCI n = packets.begin ();


          NS_LOG_DEBUG ("Receive VHT single MPDU");
          ampduSubframe = false;
        }
      else if (preamble != WIFI_PREAMBLE_NONE || !m_sendAckEvent.IsRunning ())
        {
          m_sendAckEvent = Simulator::Schedule (NanoSeconds (ampdu.GetRemainingAmpduDurationNs ()) + GetSifs (),
                                                &MacLow::SendBlockAckAfterAmpdu, this,
                                                firsthdr.GetQosTid (),
                                                firsthdr.GetAddr2 (),
                                                firsthdr.GetDuration (),
                                                txVector,
                                                rxSnr);
        }

      if (firsthdr.GetAddr1 () == m_self)
        {
          if (!vhtSingleMpdu)
            {
              m_receivedAtLeastOneMpdu = true;
            }
          if (firsthdr.IsAck () || firsthdr.IsBlockAck () || firsthdr.IsBlockAckReq ())
            {
              ReceiveOk ((*n).first, rxSnr, txVector, preamble, ampduSubframe);

              AgreementsI it = m_bAckAgreements.find (std::make_pair (firsthdr.GetAddr2 (), tid));
              if (it != m_bAckAgreements.end ())
                {
                  NS_ASSERT (m_sendAckEvent.IsExpired ());
                  /* See section 11.5.3 in IEEE 802.11 for mean of this timer */
                  ResetBlockAckInactivityTimerIfNeeded (it->second.first);
                  NS_LOG_DEBUG ("rx A-MPDU/sendImmediateBlockAck from=" << firsthdr.GetAddr2 ());
                  NS_ASSERT (m_sendAckEvent.IsRunning ());
                                                        &MacLow::SendBlockAckAfterAmpdu, this,
                                                        firsthdr.GetQosTid (),
                                                        firsthdr.GetAddr2 (),
                                                        firsthdr.GetDuration (),
                                                        txVector,
                                                        rxSnr);
                }
              else
                {
                  NS_LOG_DEBUG ("There's not a valid agreement for this block ack request.");
                }
            }
          m_receivedAtLeastOneMpdu = false;
        }
    }
  else

(-)a/src/wifi/model/mac-low.h (-2 / +1 lines)

Lines 736-742	Link Here

736

   * This method is typically invoked by the lower PHY layer to notify

736

   * This method is typically invoked by the lower PHY layer to notify

737

   * the MAC layer that a packet was unsuccessfully received.

737

   * the MAC layer that a packet was unsuccessfully received.

738

*/

738

*/

739

  void ReceiveError (Ptr<Packet> packet, double rxSnr, bool isEndOfFrame);

739

  void ReceiveError (Ptr<Packet> packet, double rxSnr);

740

/**

740

/**

741

   * \param duration switching delay duration.

741

   * \param duration switching delay duration.

742

Lines 1378-1384	Link Here

1378

  uint8_t m_sentMpdus;                //!< Number of transmitted MPDUs in an A-MPDU that have not been acknowledged yet

1378

  uint8_t m_sentMpdus;                //!< Number of transmitted MPDUs in an A-MPDU that have not been acknowledged yet

1379

  Ptr<WifiMacQueue> m_aggregateQueue; //!< Queue used for MPDU aggregation

1379

  Ptr<WifiMacQueue> m_aggregateQueue; //!< Queue used for MPDU aggregation

1380

  WifiTxVector m_currentTxVector;     //!< TXVECTOR used for the current packet transmission

1380

  WifiTxVector m_currentTxVector;     //!< TXVECTOR used for the current packet transmission

1381

  bool m_receivedAtLeastOneMpdu;      //!< Flag whether an MPDU has already been successfully received while receiving an A-MPDU

1382

  std::vector<Item> m_txPackets;      //!< Contain temporary items to be sent with the next A-MPDU transmission, once RTS/CTS exchange has succeeded. It is not used in other cases.

1381

  std::vector<Item> m_txPackets;      //!< Contain temporary items to be sent with the next A-MPDU transmission, once RTS/CTS exchange has succeeded. It is not used in other cases.

1383

  uint32_t m_nTxMpdus;                //!<Holds the number of transmitted MPDUs in the last A-MPDU transmission

1382

  uint32_t m_nTxMpdus;                //!<Holds the number of transmitted MPDUs in the last A-MPDU transmission

1384

};

1383

};




}

void
WifiPhyStateHelper::SwitchFromRxEndError (Ptr<Packet> packet, double snr)
{
  m_rxErrorTrace (packet, snr);
  NotifyRxEndError ();
  DoSwitchFromRx ();
  if (!m_rxErrorCallback.IsNull ())
    {
      m_rxErrorCallback (packet, snr);
    }
}





   *
   * \param packet the packet that we failed to received
   * \param snr the SNR of the received packet
   * \param isEndOfFrame PHY-RXEND indication.
   */
  void SwitchFromRxEndError (Ptr<Packet> packet, double snr);
  /**
   * Switch to CCA busy.
   *

   *
   * \param [in] packet       The received packet.
   * \param [in] snr          The SNR of the received packet.
   * \param [in] isEndOfFrame PHY-RXEND indication..
   */
  typedef void (* RxEndErrorTracedCallback)
    (Ptr<const Packet> packet, double snr);

  /**
   * TracedCallback signature for transmit event.

(-)a/src/wifi/model/wifi-phy.h (-2 / +1 lines)

Lines 192-200	Link Here

192

/**

192

/**

193

   * arg1: packet received unsuccessfully

193

   * arg1: packet received unsuccessfully

194

   * arg2: snr of packet

194

   * arg2: snr of packet

195

   * arg3: PHY-RXEND flag

196

*/

195

*/

197

  typedef Callback<void, Ptr<Packet>, double, bool> RxErrorCallback;

196

  typedef Callback<void, Ptr<Packet>, double> RxErrorCallback;

198

197

199

  static TypeId GetTypeId (void);

198

  static TypeId GetTypeId (void);

200

199




        {
          /* failure. */
          NotifyRxDrop (packet);
          m_state->SwitchFromRxEndError (packet, snrPer.snr);
          m_state->SwitchFromRxEndError (packet, snrPer.snr, isEndOfFrame);
        }
    }
  else
    {
      m_state->SwitchFromRxEndError (packet, snrPer.snr);
      m_state->SwitchFromRxEndError (packet, snrPer.snr, isEndOfFrame);
    }

  if (preamble == WIFI_PREAMBLE_NONE && mpdutype == LAST_MPDU_IN_AGGREGATE)

Return to bug 2307