Attachment #3119 for bug #2926

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




          m_stationManager->ReportRxOk (m_currentHdr.GetAddr1 (), &m_currentHdr,
                                        rxSnr, txVector.GetMode ());
          m_stationManager->ReportDataOk (m_currentHdr.GetAddr1 (), &m_currentHdr,
                                          rxSnr, txVector.GetMode (), tag.Get (),
                                          m_currentPacket);
        }
      bool gotAck = false;
      if (m_txParams.MustWaitNormalAck ()

  /// \todo should check that there was no rx start before now.
  /// we should restart a new ack timeout now until the expected
  /// end of rx if there was a rx start before now.
  m_stationManager->ReportDataFailed (m_currentHdr.GetAddr1 (), &m_currentHdr,
                                      m_currentPacket);
  Ptr<Txop> txop = m_currentTxop;
  m_currentTxop = 0;
  m_ampdu = false;




          if (!NeedDataRetransmission (packet, header))
            {
              resetDcf = true;
              m_stationManager->ReportFinalDataFailed (header.GetAddr1 (), &header, packet);
            }
          else
            {
              m_stationManager->ReportDataFailed (header.GetAddr1 (), &header, packet);
            }
        }
      if (resetDcf)

  if (!NeedDataRetransmission (m_currentPacket, m_currentHdr))
    {
      NS_LOG_DEBUG ("Ack Fail");
      m_stationManager->ReportFinalDataFailed (m_currentHdr.GetAddr1 (), &m_currentHdr, m_currentPacket);
      bool resetCurrentPacket = true;
      if (!m_txFailedCallback.IsNull ())
        {




  if (!NeedDataRetransmission (m_currentPacket, m_currentHdr))
    {
      NS_LOG_DEBUG ("Ack Fail");
      m_stationManager->ReportFinalDataFailed (m_currentHdr.GetAddr1 (), &m_currentHdr,
                                               m_currentPacket);
      if (!m_txFailedCallback.IsNull ())
        {
          m_txFailedCallback (m_currentHdr);

      if (!NeedDataRetransmission (m_currentPacket, m_currentHdr))
        {
          NS_LOG_DEBUG ("Ack Fail");
          m_stationManager->ReportFinalDataFailed (m_currentHdr.GetAddr1 (), &m_currentHdr,
                                                   m_currentPacket);
          m_currentPacket = 0;
        }
      else

    {
      if (!NeedDataRetransmission (m_currentPacket, m_currentHdr))
        {
          m_stationManager->ReportFinalDataFailed (m_currentHdr.GetAddr1 (), &m_currentHdr,
                                                   m_currentPacket);
          m_currentPacket = 0;
        }
      else




}

void
WifiRemoteStationManager::ReportDataFailed (Mac48Address address, const WifiMacHeader *header,
                                            Ptr<const Packet> packet)
{
  NS_LOG_FUNCTION (this << address << *header);
  NS_ASSERT (!address.IsGroup ());
  WifiRemoteStation *station = Lookup (address, header);
  bool longMpdu = (packet->GetSize () + header->GetSize () + WIFI_MAC_FCS_LENGTH) > m_rtsCtsThreshold;
  if (longMpdu)
    {
      station->m_slrc++;
    }
  else
    {
      station->m_ssrc++;
    }
  m_macTxDataFailed (address);
  DoReportDataFailed (station);
}


void
WifiRemoteStationManager::ReportDataOk (Mac48Address address, const WifiMacHeader *header,
                                        double ackSnr, WifiMode ackMode, double dataSnr,
                                        Ptr<const Packet> packet)
{
  NS_LOG_FUNCTION (this << address << *header << ackSnr << ackMode << dataSnr);
  NS_ASSERT (!address.IsGroup ());
  WifiRemoteStation *station = Lookup (address, header);
  bool longMpdu = (packet->GetSize () + header->GetSize () + WIFI_MAC_FCS_LENGTH) > m_rtsCtsThreshold;
  if (longMpdu)
    {
      station->m_state->m_info.NotifyTxSuccess (station->m_slrc);
      station->m_slrc = 0;
    }
  else
    {
      station->m_state->m_info.NotifyTxSuccess (station->m_ssrc);
      station->m_ssrc = 0;
    }
  DoReportDataOk (station, ackSnr, ackMode, dataSnr);
}


}

void
WifiRemoteStationManager::ReportFinalDataFailed (Mac48Address address, const WifiMacHeader *header,
                                                 Ptr<const Packet> packet)
{
  NS_LOG_FUNCTION (this << address << *header);
  NS_ASSERT (!address.IsGroup ());
  WifiRemoteStation *station = Lookup (address, header);
  station->m_state->m_info.NotifyTxFailed ();
  bool longMpdu = (packet->GetSize () + header->GetSize () + WIFI_MAC_FCS_LENGTH) > m_rtsCtsThreshold;
  if (longMpdu)
    {
      station->m_slrc = 0;
    }
  else
    {
      station->m_ssrc = 0;
    }
  m_macTxFinalDataFailed (address);
  DoReportFinalDataFailed (station);
}




   *
   * \param address the address of the receiver
   * \param header MAC header of the DATA packet
   * \param packet the DATA packet
   */
  void ReportDataFailed (Mac48Address address, const WifiMacHeader *header,
                         Ptr<const Packet> packet);
  /**
   * Should be invoked whenever we receive the Cts associated to an RTS
   * we just sent. Note that we also get the SNR of the RTS we sent since

   * \param ackSnr the SNR of the ACK we received
   * \param ackMode the WifiMode the receiver used to send the ACK
   * \param dataSnr the SNR of the DATA we sent
   * \param packet the DATA packet
   */
  void ReportDataOk (Mac48Address address, const WifiMacHeader *header,
                     double ackSnr, WifiMode ackMode, double dataSnr,
                     Ptr<const Packet> packet);
  /**
   * Should be invoked after calling ReportRtsFailed if
   * NeedRetransmission returns false

   *
   * \param address the address of the receiver
   * \param header MAC header of the DATA packet
   * \param packet the DATA packet
   */
  void ReportFinalDataFailed (Mac48Address address, const WifiMacHeader *header,
                              Ptr<const Packet> packet);
  /**
   * Typically called per A-MPDU, either when a Block ACK was successfully
   * received or when a BlockAckTimeout has elapsed.




   */
  for (int i = 0; i < 10; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   * As we are using recovery power, one failure make power increase.
   *
   */
  manager->ReportDataFailed (remoteAddress, &packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 7; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
      manager->ReportDataFailed (remoteAddress, &packetHeader, packet);
    }
  manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   * As we are using recovery power, one failure make power increase. recoveryPower=false.
   */

  manager->ReportDataFailed (remoteAddress, &packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   * After two consecutive fails the rate is decreased or the power increased.
   * As we are at maximal power, the rate should be decreased.
   */
  manager->ReportDataFailed (remoteAddress, &packetHeader, packet);
  manager->ReportDataFailed (remoteAddress, &packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 10; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   * As we are using recovery rate, one failure make rate decrease. recoveryRate=false.
   */

  manager->ReportDataFailed (remoteAddress, &packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 10; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   */
  for (int i = 0; i < 10; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   * One successful transmissions after a power decrease make recoverPower=false.
   * So we need two consecutive failures to increase power again.
   */
  manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);

  for (int i = 0; i < 2; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   */
  for (int i = 0; i < 3; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   * One failure make the power to be increased again.
   * Change to state Low.
   */
  manager->ReportDataFailed (remoteAddress, &packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 10; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 3; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   */
  for (int i = 0; i < 16 * 3; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   * After one fail the rate is decreased or the power increased.
   * As we are at minimal power, the power should be increased.
   */
  manager->ReportDataFailed (remoteAddress,&packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 16; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   * As we are at maximal power, the rate should be decreased.
   * Set critical rate to 54 Mbps.
   */
  manager->ReportDataFailed (remoteAddress,&packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 3; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   */
  for (int i = 0; i < 9 * 3; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 3; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

   */
  for (int i = 0; i < 6; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

  /**
   * Test that 7 is enough.
   */
  manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();

   */
  for (int i = 0; i < 4; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

  NS_TEST_ASSERT_MSG_EQ (mode.GetDataRate (txVector.GetChannelWidth (), txVector.GetGuardInterval (), 1), 9000000, "RRPAA: Incorrect vale of data rate");
  NS_TEST_ASSERT_MSG_EQ (power, 17, "RRPAA: Incorrect value of power level");

  manager->ReportDataFailed (remoteAddress,&packetHeader, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();


  for (int i = 0; i < 7; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 10; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 13; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 19; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 23; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 33; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 43; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 49; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

  NS_TEST_ASSERT_MSG_EQ (mode.GetDataRate (txVector.GetChannelWidth (), txVector.GetGuardInterval (), 1), 54000000, "RRPAA: Incorrect vale of data rate");
  NS_TEST_ASSERT_MSG_EQ (power, 17, "RRPAA: Incorrect value of power level");

  manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);
  mode = txVector.GetMode ();


  for (int i = 0; i < 16 * 50; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 6; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 16 * 6; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 6; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 11; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 25; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 5; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 5; i++)
    {
      manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);


  for (int i = 0; i < 25; i++)
    {
      manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
    }

  txVector = manager->GetDataTxVector (remoteAddress, &packetHeader, packet);

    {
      for (int j = 0; j < 25; j++)
        {
          manager->ReportDataOk (remoteAddress, &packetHeader, 0, ackMode, 0, packet);
        }

      for (int j = 0; j < 5; j++)
        {
          manager->ReportDataFailed (remoteAddress,&packetHeader, packet);
        }
    }


Return to bug 2926