27#include "ns3/ap-wifi-mac.h"
28#include "ns3/erp-ofdm-phy.h"
30#include "ns3/recipient-block-ack-agreement.h"
31#include "ns3/snr-tag.h"
32#include "ns3/sta-wifi-mac.h"
33#include "ns3/wifi-mac-queue.h"
34#include "ns3/wifi-mac-trailer.h"
39#undef NS_LOG_APPEND_CONTEXT
40#define NS_LOG_APPEND_CONTEXT WIFI_FEM_NS_LOG_APPEND_CONTEXT
52 return psduMap.size() == 1 && psduMap.cbegin()->first ==
SU_STA_ID &&
53 psduMap.cbegin()->second->GetNMpdus() == 1 &&
54 psduMap.cbegin()->second->GetHeader(0).IsTrigger();
60 return psduMap.size() == 1 && psduMap.cbegin()->first ==
SU_STA_ID &&
61 psduMap.cbegin()->second->GetNMpdus() == 1 &&
62 psduMap.cbegin()->second->GetHeader(0).IsTrigger();
68 static TypeId tid =
TypeId(
"ns3::HeFrameExchangeManager")
70 .AddConstructor<HeFrameExchangeManager>()
71 .SetGroupName(
"Wifi");
76 : m_intraBssNavEnd(0),
77 m_triggerFrameInAmpdu(false)
102 m_apMac = DynamicCast<ApWifiMac>(mac);
103 m_staMac = DynamicCast<StaWifiMac>(mac);
135 "A Multi-User Scheduler can only be aggregated to an HE AP");
156 (!(mpdu = edca->PeekNextMpdu(
m_linkId)) ||
157 (mpdu->GetHeader().IsQosData() && !mpdu->GetHeader().GetAddr1().IsGroup() &&
159 mpdu->GetHeader().GetQosTid()))))
178 "The Multi-user Scheduler returned DL_MU_TX with empty psduMap, do not transmit");
189 auto packet = Create<Packet>();
229 <<
") incompatible with Basic Trigger Frame");
233 <<
") incompatible with BSRP Trigger Frame");
235 auto txVector = trigger.GetHeTbTxVector(trigger.begin()->GetAid12());
252 if (mpdu->IsQueued())
269 "Cannot use RTS/CTS with MU PPDUs");
294 for (
const auto& userInfo : protection->muRts)
296 const auto addressIt = aidAddrMap.find(userInfo.GetAid12());
297 NS_ASSERT_MSG(addressIt != aidAddrMap.end(),
"AID not found");
322 NS_LOG_FUNCTION(
this << muRtsSize << muRtsTxVector << txDuration << response);
357 protection->muRts.SetCsRequired(
true);
359 payload->AddHeader(protection->muRts);
361 auto mpdu = Create<WifiMpdu>(payload, hdr);
365 mpdu->GetHeader().SetDuration(
367 protection->muRtsTxVector,
380 protection->muRtsTxVector,
392 protection->muRtsTxVector);
416 if (mpdu->IsQueued())
424 const auto& hdr =
m_psduMap.cbegin()->second->GetHeader(0);
425 if (!hdr.GetAddr1().IsGroup())
430 if (!hdr.GetAddr1().IsGroup() &&
455 for (
const auto& [staId, psdu] :
m_psduMap)
466 auto it = std::find_if(
469 [&to](std::pair<uint16_t,
Ptr<WifiPsdu>> psdu) { return psdu.second->GetAddr1() == to; });
470 if (it != psduMap.end())
505 NS_LOG_DEBUG(address <<
" did not respond, hence it is no longer protected");
525 std::set<Mac48Address> staExpectResponseFrom;
534 auto acknowledgment =
540 if (acknowledgment->stationsSendBlockAckReqTo.contains(psdu.second->GetAddr1()))
543 std::set<uint8_t> tids = psdu.second->GetTids();
545 "Acknowledgment method incompatible with a Multi-TID A-MPDU");
546 uint8_t tid = *tids.begin();
555 if (!acknowledgment->stationsReplyingWithNormalAck.empty())
560 &acknowledgment->stationsReplyingWithNormalAck.begin()->second.ackTxVector;
561 auto from = acknowledgment->stationsReplyingWithNormalAck.begin()->first;
564 mpdu = *psdu->begin();
565 staExpectResponseFrom.insert(from);
567 else if (!acknowledgment->stationsReplyingWithBlockAck.empty())
572 &acknowledgment->stationsReplyingWithBlockAck.begin()->second.blockAckTxVector;
573 auto from = acknowledgment->stationsReplyingWithBlockAck.begin()->first;
575 staExpectResponseFrom.insert(from);
591 std::map<uint16_t, CtrlBAckRequestHeader> recipients;
593 NS_ASSERT(!acknowledgment->stationsReplyingWithBlockAck.empty());
594 auto staIt = acknowledgment->stationsReplyingWithBlockAck.begin();
596 while (staIt != acknowledgment->stationsReplyingWithBlockAck.end())
602 staIt->second.blockAckTxVector.GetHeMuUserInfo(staId));
603 recipients.emplace(staId, staIt->second.barHeader);
618 for (
auto& station : acknowledgment->stationsReplyingWithBlockAck)
620 staExpectResponseFrom.insert(station.first);
625 acknowledgment->muBarTxVector,
628 *acknowledgment->acknowledgmentTime -= (
m_phy->
GetSifs() + txDuration);
632 &acknowledgment->stationsReplyingWithBlockAck.begin()->second.blockAckTxVector;
638 staExpectResponseFrom,
642 staExpectResponseFrom.size());
663 acknowledgment->stationsReplyingWithBlockAck.begin()->second.blockAckTxVector;
666 for (
auto& station : acknowledgment->stationsReplyingWithBlockAck)
668 staExpectResponseFrom.insert(station.first);
671 auto psduMapIt = std::find_if(
m_psduMap.begin(),
674 return psdu.second->GetAddr1() == station.first;
679 std::vector<Ptr<WifiMpdu>> mpduList(psduMapIt->second->begin(),
680 psduMapIt->second->end());
681 NS_ASSERT(mpduList.size() == psduMapIt->second->GetNMpdus());
684 station.second.blockAckTxVector.SetLength(acknowledgment->ulLength);
685 mpduList.push_back(
PrepareMuBar(station.second.blockAckTxVector,
686 {{psduMapIt->first, station.second.barHeader}}));
687 psduMapIt->second = Create<WifiPsdu>(std::move(mpduList));
690 station.second.blockAckTxVector.GetHeMuUserInfo(psduMapIt->first));
695 &acknowledgment->stationsReplyingWithBlockAck.begin()->second.blockAckTxVector;
705 mpdu = *m_psduMap.begin()->second->begin();
707 auto acknowledgment =
static_cast<WifiUlMuMultiStaBa*
>(m_txParams.m_acknowledgment.get());
710 for (
const auto& station : acknowledgment->stationsReceivingMultiStaBa)
712 staExpectResponseFrom.insert(station.first.first);
718 acknowledgment->baType.m_bitmapLen.clear();
721 responseTxVector = &acknowledgment->tbPpduTxVector;
722 m_trigVector = GetTrigVector(m_muScheduler->GetUlMuInfo(m_linkId).trigger);
728 !m_txParams.m_txVector.IsUlMu() &&
IsTrigger(m_psduMap))
730 CtrlTriggerHeader& trigger = m_muScheduler->GetUlMuInfo(m_linkId).trigger;
735 for (
const auto& userInfo : trigger)
737 auto staIt = m_apMac->GetStaList(m_linkId).find(userInfo.GetAid12());
738 NS_ASSERT(staIt != m_apMac->GetStaList(m_linkId).end());
739 staExpectResponseFrom.insert(staIt->second);
743 txVector = trigger.GetHeTbTxVector(trigger.begin()->GetAid12());
744 responseTxVector = &txVector;
745 m_trigVector = GetTrigVector(m_muScheduler->GetUlMuInfo(m_linkId).trigger);
750 else if (m_txParams.m_txVector.IsUlMu() &&
755 NS_ASSERT(m_staMac && m_staMac->IsAssociated());
756 auto recv = m_psduMap.begin()->second->GetAddr1();
757 txVector = GetWifiRemoteStationManager()->GetBlockAckTxVector(recv, m_txParams.m_txVector);
758 responseTxVector = &txVector;
759 staExpectResponseFrom.insert(recv);
764 else if (m_txParams.m_txVector.IsUlMu() &&
771 NS_ABORT_MSG(
"Unable to handle the selected acknowledgment method ("
772 << m_txParams.m_acknowledgment.get() <<
")");
777 for (
const auto& psdu : m_psduMap)
779 psduMap.emplace(psdu.first, psdu.second);
783 if (m_txParams.m_txVector.IsUlMu())
786 m_txParams.m_txVector,
787 m_phy->GetPhyBand());
792 m_phy->CalculateTxDuration(psduMap, m_txParams.m_txVector, m_phy->GetPhyBand());
795 Time durationId = GetPsduDurationId(txDuration, m_txParams);
796 for (
auto& psdu : m_psduMap)
798 psdu.second->SetDuration(durationId);
811 else if (!m_txParams.m_txVector.IsUlMu())
818 Time timeout = txDuration + m_phy->GetSifs() + m_phy->GetSlot() +
819 m_phy->CalculatePhyPreambleAndHeaderDuration(*responseTxVector);
820 m_channelAccessManager->NotifyAckTimeoutStartNow(
timeout);
827 m_txTimer.Set(timerType,
829 staExpectResponseFrom,
833 m_txParams.m_txVector);
837 m_txTimer.Set(timerType,
839 staExpectResponseFrom,
843 m_txParams.m_txVector);
846 m_txTimer.Set(timerType,
848 staExpectResponseFrom,
852 staExpectResponseFrom.size());
856 m_txTimer.Set(timerType,
858 staExpectResponseFrom,
862 staExpectResponseFrom.size());
865 m_txTimer.Set(timerType,
867 staExpectResponseFrom,
870 m_psduMap.begin()->second,
871 m_txParams.m_txVector);
880 ForwardPsduMapDown(psduMap, m_txParams.m_txVector);
887 auto hePhy = StaticCast<HePhy>(m_phy->GetPhyEntity(responseTxVector->GetModulationClass()));
888 hePhy->SetTrigVector(m_trigVector, m_txTimer.GetDelayLeft());
905 auto sigBMode = hePhy->GetSigBMode(txVector);
909 for (
const auto& psdu : psduMap)
911 NS_LOG_DEBUG(
"Transmitting: [STAID=" << psdu.first <<
", " << *psdu.second <<
"]");
914 for (
const auto& [staId, psdu] : psduMap)
916 FinalizeMacHeader(psdu);
917 NotifyTxToEdca(psdu);
921 if (psduMap.size() > 1 || psduMap.begin()->second->IsAggregate() ||
922 psduMap.begin()->second->IsSingle())
927 m_phy->Send(psduMap, txVector);
931HeFrameExchangeManager::PrepareMuBar(
const WifiTxVector& responseTxVector,
932 std::map<uint16_t, CtrlBAckRequestHeader> recipients)
const
939 SetTargetRssi(muBar);
945 for (
auto& userInfo : muBar)
947 auto recipientIt = recipients.find(userInfo.GetAid12());
948 NS_ASSERT(recipientIt != recipients.end());
951 userInfo.SetMuBarTriggerDepUserInfo(recipientIt->second);
955 bar->AddHeader(muBar);
963 rxAddress = Mac48Address::GetBroadcast();
968 rxAddress = m_apMac->GetStaList(m_linkId).at(recipients.begin()->first);
980 return Create<WifiMpdu>(bar, hdr);
989 if (protection->
method == WifiProtection::MU_RTS_CTS)
996 GetCtsTxVectorAfterMuRts(muRtsCtsProtection->muRts,
997 muRtsCtsProtection->muRts.begin()->GetAid12());
1000 muRtsCtsProtection->muRts.GetSerializedSize() + WIFI_MAC_FCS_LENGTH;
1001 muRtsCtsProtection->protectionTime =
1002 m_phy->CalculateTxDuration(muRtsSize,
1003 muRtsCtsProtection->muRtsTxVector,
1004 m_phy->GetPhyBand()) +
1005 m_phy->CalculateTxDuration(
GetCtsSize(), ctsTxVector, m_phy->GetPhyBand()) +
1006 2 * m_phy->GetSifs();
1010 VhtFrameExchangeManager::CalculateProtectionTime(protection);
1023 if (acknowledgment->
method == WifiAcknowledgment::DL_MU_BAR_BA_SEQUENCE)
1030 NS_ABORT_IF(dlMuBarBaAcknowledgment->stationsReplyingWithNormalAck.size() +
1031 dlMuBarBaAcknowledgment->stationsReplyingWithBlockAck.size() >
1034 if (!dlMuBarBaAcknowledgment->stationsReplyingWithNormalAck.empty())
1037 dlMuBarBaAcknowledgment->stationsReplyingWithNormalAck.begin()->second;
1040 m_phy->CalculateTxDuration(
GetAckSize(), info.ackTxVector, m_phy->GetPhyBand());
1043 if (!dlMuBarBaAcknowledgment->stationsReplyingWithBlockAck.empty())
1046 dlMuBarBaAcknowledgment->stationsReplyingWithBlockAck.begin()->second;
1047 duration += m_phy->GetSifs() + m_phy->CalculateTxDuration(
GetBlockAckSize(info.baType),
1048 info.blockAckTxVector,
1049 m_phy->GetPhyBand());
1052 for (
const auto& stations : dlMuBarBaAcknowledgment->stationsSendBlockAckReqTo)
1054 const auto& info = stations.second;
1055 duration += m_phy->GetSifs() +
1057 info.blockAckReqTxVector,
1058 m_phy->GetPhyBand()) +
1061 info.blockAckTxVector,
1062 m_phy->GetPhyBand());
1065 dlMuBarBaAcknowledgment->acknowledgmentTime = duration;
1070 else if (acknowledgment->
method == WifiAcknowledgment::DL_MU_TF_MU_BAR)
1072 auto dlMuTfMuBarAcknowledgment =
static_cast<WifiDlMuTfMuBar*
>(acknowledgment);
1076 for (
const auto& stations : dlMuTfMuBarAcknowledgment->stationsReplyingWithBlockAck)
1079 const auto& info = stations.second;
1080 NS_ASSERT(info.blockAckTxVector.GetHeMuUserInfoMap().size() == 1);
1081 uint16_t staId = info.blockAckTxVector.GetHeMuUserInfoMap().begin()->first;
1083 info.blockAckTxVector,
1084 m_phy->GetPhyBand(),
1087 if (currBlockAckDuration > duration)
1089 duration = currBlockAckDuration;
1095 WifiTxVector& txVector = dlMuTfMuBarAcknowledgment->stationsReplyingWithBlockAck.begin()
1096 ->second.blockAckTxVector;
1097 std::tie(dlMuTfMuBarAcknowledgment->ulLength, duration) =
1098 HePhy::ConvertHeTbPpduDurationToLSigLength(duration, txVector, m_phy->GetPhyBand());
1101 if (dlMuTfMuBarAcknowledgment->muBarTxVector.GetModulationClass() >=
WIFI_MOD_CLASS_VHT)
1104 muBarSize = MpduAggregator::GetSizeIfAggregated(muBarSize, 0);
1106 dlMuTfMuBarAcknowledgment->acknowledgmentTime =
1108 m_phy->CalculateTxDuration(muBarSize,
1109 dlMuTfMuBarAcknowledgment->muBarTxVector,
1110 m_phy->GetPhyBand()) +
1111 m_phy->GetSifs() + duration;
1116 else if (acknowledgment->
method == WifiAcknowledgment::DL_MU_AGGREGATE_TF)
1122 for (
const auto& stations : dlMuAggrTfAcknowledgment->stationsReplyingWithBlockAck)
1125 const auto& info = stations.second;
1126 NS_ASSERT(info.blockAckTxVector.GetHeMuUserInfoMap().size() == 1);
1127 uint16_t staId = info.blockAckTxVector.GetHeMuUserInfoMap().begin()->first;
1129 info.blockAckTxVector,
1130 m_phy->GetPhyBand(),
1133 if (currBlockAckDuration > duration)
1135 duration = currBlockAckDuration;
1142 dlMuAggrTfAcknowledgment->stationsReplyingWithBlockAck.begin()->second.blockAckTxVector;
1143 std::tie(dlMuAggrTfAcknowledgment->ulLength, duration) =
1144 HePhy::ConvertHeTbPpduDurationToLSigLength(duration, txVector, m_phy->GetPhyBand());
1145 dlMuAggrTfAcknowledgment->acknowledgmentTime = m_phy->GetSifs() + duration;
1150 else if (acknowledgment->
method == WifiAcknowledgment::UL_MU_MULTI_STA_BA)
1155 ulMuMultiStaBa->multiStaBaTxVector,
1156 m_phy->GetPhyBand());
1157 ulMuMultiStaBa->acknowledgmentTime = m_phy->GetSifs() + duration;
1162 else if (acknowledgment->
method == WifiAcknowledgment::ACK_AFTER_TB_PPDU)
1171 VhtFrameExchangeManager::CalculateAcknowledgmentTime(acknowledgment);
1176HeFrameExchangeManager::GetCtsModeAfterMuRts()
const
1181 : OfdmPhy::GetOfdmRate6Mbps();
1186 uint16_t staId)
const
1191 NS_ASSERT_MSG(userInfoIt != trigger.
end(),
"User Info field for AID=" << staId <<
" not found");
1194 if (uint8_t ru = userInfoIt->GetMuRtsRuAllocation(); ru < 65)
1212 auto txVector = GetWifiRemoteStationManager()->GetCtsTxVector(m_bssid, GetCtsModeAfterMuRts());
1214 txVector.SetChannelWidth(bw);
1220HeFrameExchangeManager::GetTxDuration(
uint32_t ppduPayloadSize,
1226 return VhtFrameExchangeManager::GetTxDuration(ppduPayloadSize, receiver, txParams);
1233 txParams.
m_acknowledgment->method == WifiAcknowledgment::DL_MU_AGGREGATE_TF)
1237 NS_ASSERT_MSG(psduInfo,
"No information for " << receiver <<
" in TX params");
1238 NS_ASSERT_MSG(!psduInfo->seqNumbers.empty(),
"No sequence number for " << receiver);
1239 const auto tid = psduInfo->seqNumbers.cbegin()->first;
1241 ppduPayloadSize = MpduAggregator::GetSizeIfAggregated(
1242 GetMuBarSize({m_mac->GetBarTypeAsOriginator(receiver, tid)}),
1246 uint16_t staId = (txParams.
m_txVector.
IsDlMu() ? m_apMac->GetAssociationId(receiver, m_linkId)
1247 : m_staMac->GetAssociationId());
1248 Time psduDuration = m_phy->CalculateTxDuration(ppduPayloadSize,
1250 m_phy->GetPhyBand(),
1257HeFrameExchangeManager::TbPpduTimeout(
WifiPsduMap* psduMap, std::size_t nSolicitedStations)
1259 const auto& staMissedTbPpduFrom = m_txTimer.GetStasExpectedToRespond();
1260 NS_LOG_FUNCTION(
this << psduMap << staMissedTbPpduFrom.size() << nSolicitedStations);
1266 NS_ASSERT(!staMissedTbPpduFrom.empty());
1269 if (staMissedTbPpduFrom.size() == nSolicitedStations)
1272 m_edca->UpdateFailedCw(m_linkId);
1274 TransmissionFailed();
1276 else if (!m_multiStaBaEvent.IsRunning())
1278 m_edca->ResetCw(m_linkId);
1279 TransmissionSucceeded();
1287 std::size_t nSolicitedStations)
1292 NS_ASSERT(m_txParams.m_acknowledgment &&
1293 (m_txParams.m_acknowledgment->method == WifiAcknowledgment::DL_MU_AGGREGATE_TF ||
1294 m_txParams.m_acknowledgment->method == WifiAcknowledgment::DL_MU_TF_MU_BAR));
1297 const auto& staMissedBlockAckFrom = m_txTimer.GetStasExpectedToRespond();
1298 NS_ASSERT(!staMissedBlockAckFrom.empty());
1302 if (staMissedBlockAckFrom.size() == nSolicitedStations)
1306 GetWifiRemoteStationManager()->ReportDataFailed(*psduMap->begin()->second->begin());
1318 m_triggerFrame =
nullptr;
1321 for (
const auto& sta : staMissedBlockAckFrom)
1330 MissedBlockAck(psdu, m_txParams.m_txVector, psduResetCw);
1331 resetCw = resetCw || psduResetCw;
1338 m_edca->ResetCw(m_linkId);
1342 m_edca->UpdateFailedCw(m_linkId);
1345 if (staMissedBlockAckFrom.size() == nSolicitedStations)
1348 TransmissionFailed();
1352 TransmissionSucceeded();
1365 GetWifiRemoteStationManager()->ReportDataFailed(*psdu->begin());
1367 MissedBlockAck(psdu, m_txParams.m_txVector, resetCw);
1382 VhtFrameExchangeManager::NormalAckTimeout(mpdu, txVector);
1387 for (
auto& psdu : m_psduMap)
1391 if (mpdu->IsQueued())
1393 m_mac->GetTxopQueue(mpdu->GetQueueAc())->GetOriginal(mpdu)->GetHeader().SetRetry();
1394 mpdu->ResetInFlight(m_linkId);
1406 VhtFrameExchangeManager::BlockAckTimeout(psdu, txVector);
1411 for (
auto& psdu : m_psduMap)
1415 if (mpdu->IsQueued())
1417 mpdu->GetHeader().SetRetry();
1433 for (
const auto& userInfoField : trigger)
1436 userInfoField.GetAid12(),
1437 {userInfoField.GetRuAllocation(), userInfoField.GetUlMcs(), userInfoField.GetNss()});
1449 uint16_t staId = m_staMac->GetAssociationId();
1456 NS_ASSERT_MSG(heConfiguration,
"This STA has to be an HE station to send an HE TB PPDU");
1459 if (userInfoIt->IsUlTargetRssiMaxTxPower())
1461 NS_LOG_LOGIC(
"AP requested using the max transmit power (" << m_phy->GetTxPowerEnd()
1467 uint8_t powerLevel = GetWifiRemoteStationManager()->GetDefaultTxPowerLevel();
1485 auto optRssi = GetMostRecentRssi(triggerSender);
1491 auto reqTxPowerDbm =
static_cast<double>(userInfoIt->GetUlTargetRssi() + pathLossDb);
1494 uint8_t numPowerLevels = m_phy->GetNTxPower();
1495 if (numPowerLevels > 1)
1497 double stepDbm = (m_phy->GetTxPowerEnd() - m_phy->GetTxPowerStart()) / (numPowerLevels - 1);
1498 powerLevel =
static_cast<uint8_t
>(
1499 ceil((reqTxPowerDbm - m_phy->GetTxPowerStart()) /
1501 if (powerLevel > numPowerLevels)
1503 powerLevel = numPowerLevels;
1506 if (reqTxPowerDbm > m_phy->GetPowerDbm(powerLevel))
1509 << reqTxPowerDbm <<
"dBm) cannot be satisfied (max: " << m_phy->GetTxPowerEnd()
1514 <<
"input {pathLoss=" << pathLossDb <<
"dB, reqTxPower=" << reqTxPowerDbm <<
"dBm}"
1515 <<
" output {powerLevel=" << +powerLevel <<
" -> "
1516 << m_phy->GetPowerDbm(powerLevel) <<
"dBm}"
1517 <<
" PHY power capa {min=" << m_phy->GetTxPowerStart() <<
"dBm, max="
1518 << m_phy->GetTxPowerEnd() <<
"dBm, levels:" << +numPowerLevels <<
"}");
1523std::optional<double>
1524HeFrameExchangeManager::GetMostRecentRssi(
const Mac48Address& address)
const
1526 return GetWifiRemoteStationManager()->GetMostRecentRssi(address);
1536 m_phy->GetPowerDbm(GetWifiRemoteStationManager()->GetDefaultTxPowerLevel())));
1537 for (
auto& userInfo : trigger)
1539 const auto staList = m_apMac->GetStaList(m_linkId);
1540 auto itAidAddr = staList.find(userInfo.GetAid12());
1542 auto optRssi = GetMostRecentRssi(itAidAddr->second);
1544 auto rssi =
static_cast<int8_t>(*optRssi);
1545 rssi = (rssi >= -20)
1547 : ((rssi <= -110) ? -110 : rssi);
1548 userInfo.SetUlTargetRssi(rssi);
1557 auto txVectorCopy = txVector;
1559 if (psdu->GetNMpdus() == 1 && psdu->GetHeader(0).IsTrigger())
1562 psdu->GetPayload(0)->PeekHeader(trigger);
1576 if (m_staMac !=
nullptr && m_staMac->IsAssociated() &&
1587 psdu = Create<const WifiPsdu>(Create<Packet>(), rts);
1591 GetWifiRemoteStationManager()->GetCtsTxVector(m_bssid, GetCtsModeAfterMuRts());
1594 VhtFrameExchangeManager::PostProcessFrame(psdu, txVectorCopy);
1604 if (!UlMuCsMediumIdle(trigger))
1606 NS_LOG_DEBUG(
"UL MU CS indicated medium busy, cannot send CTS");
1610 NS_ASSERT(m_staMac !=
nullptr && m_staMac->IsAssociated());
1611 WifiTxVector ctsTxVector = GetCtsTxVectorAfterMuRts(trigger, m_staMac->GetAssociationId());
1614 DoSendCtsAfterRts(muRtsHdr, ctsTxVector, muRtsSnr);
1624 txParams.
m_acknowledgment->method == WifiAcknowledgment::UL_MU_MULTI_STA_BA);
1627 NS_ASSERT(!acknowledgment->stationsReceivingMultiStaBa.empty());
1630 blockAck.
SetType(acknowledgment->baType);
1634 for (
const auto& staInfo : acknowledgment->stationsReceivingMultiStaBa)
1636 receiver = staInfo.first.first;
1637 uint8_t tid = staInfo.first.second;
1638 std::size_t index = staInfo.second;
1640 blockAck.
SetAid11(m_apMac->GetAssociationId(receiver, m_linkId), index);
1646 NS_LOG_DEBUG(
"Multi-STA Block Ack: Sending All-ack to=" << receiver);
1651 if (acknowledgment->baType.m_bitmapLen.at(index) == 0)
1654 NS_LOG_DEBUG(
"Multi-STA Block Ack: Sending Ack to=" << receiver);
1662 auto agreement = m_mac->GetBaAgreementEstablishedAsRecipient(receiver, tid);
1664 agreement->get().FillBlockAckBitmap(&blockAck, index);
1665 NS_LOG_DEBUG(
"Multi-STA Block Ack: Sending Block Ack with seq="
1667 <<
" tid=" << +tid);
1673 hdr.
SetAddr1(acknowledgment->stationsReceivingMultiStaBa.size() == 1
1675 : Mac48Address::GetBroadcast());
1681 packet->AddHeader(blockAck);
1683 GetWifiPsdu(Create<WifiMpdu>(packet, hdr), acknowledgment->multiStaBaTxVector);
1686 acknowledgment->multiStaBaTxVector,
1687 m_phy->GetPhyBand());
1699 if (m_edca->GetTxopLimit(m_linkId).IsZero())
1702 psdu->SetDuration(
Max(durationId - m_phy->GetSifs() - txDuration,
Seconds(0)));
1707 psdu->SetDuration(
Max(m_edca->GetRemainingTxop(m_linkId) - txDuration,
Seconds(0)));
1710 psdu->GetPayload(0)->AddPacketTag(m_muSnrTag);
1712 ForwardPsduDown(psdu, acknowledgment->multiStaBaTxVector);
1716 m_edca->ResetCw(m_linkId);
1718 Simulator::Schedule(txDuration, &HeFrameExchangeManager::TransmissionSucceeded,
this);
1727 NS_ASSERT(m_staMac && m_staMac->IsAssociated());
1729 NS_LOG_DEBUG(
"Received a Trigger Frame (basic variant) soliciting a transmission");
1731 if (!UlMuCsMediumIdle(trigger))
1742 std::vector<uint8_t> tids;
1743 uint16_t staId = m_staMac->GetAssociationId();
1746 for (uint8_t i = 0; i < 4; i++)
1749 tids.push_back(acIt->second.GetHighTid());
1750 tids.push_back(acIt->second.GetLowTid());
1762 Time ppduDuration = HePhy::ConvertLSigLengthToHeTbPpduDuration(trigger.
GetUlLength(),
1764 m_phy->GetPhyBand());
1766 for (
const auto& tid : tids)
1770 if (!m_mac->GetBaAgreementEstablishedAsOriginator(hdr.
GetAddr2(), tid))
1780 if (
auto mpdu = GetBar(edca->GetAccessCategory(), tid, hdr.
GetAddr2());
1781 mpdu && TryAddMpdu(mpdu, txParams, ppduDuration))
1784 psdu = Create<WifiPsdu>(mpdu,
true);
1790 GetWifiRemoteStationManager()->GetMldAddress(hdr.
GetAddr2()).value_or(hdr.
GetAddr2());
1791 if (
auto mpdu = edca->PeekNextMpdu(m_linkId, tid, receiver))
1793 mpdu = CreateAliasIfNeeded(mpdu);
1794 if (
auto item = edca->GetNextMpdu(m_linkId, mpdu, txParams, ppduDuration,
false))
1797 std::vector<Ptr<WifiMpdu>> mpduList =
1798 m_mpduAggregator->GetNextAmpdu(item, txParams, ppduDuration);
1799 psdu = (mpduList.size() > 1 ? Create<WifiPsdu>(std::move(mpduList))
1800 : Create<WifiPsdu>(item,
true));
1808 psdu->SetDuration(hdr.
GetDuration() - m_phy->GetSifs() - ppduDuration);
1809 SendPsduMapWithProtection(
WifiPsduMap{{staId, psdu}}, txParams);
1814 SendQosNullFramesInTbPpdu(trigger, hdr);
1824 NS_ASSERT(m_staMac && m_staMac->IsAssociated());
1828 if (!UlMuCsMediumIdle(trigger))
1850 Time ppduDuration = HePhy::ConvertLSigLengthToHeTbPpduDuration(trigger.
GetUlLength(),
1852 m_phy->GetPhyBand());
1855 std::vector<Ptr<WifiMpdu>> mpduList;
1857 for (uint8_t tid = 0; tid < 8; ++tid)
1859 if (!m_mac->GetBaAgreementEstablishedAsOriginator(hdr.
GetAddr2(), tid))
1861 NS_LOG_DEBUG(
"Skipping tid=" << +tid <<
" because no agreement established");
1871 auto mpdu = Create<WifiMpdu>(Create<Packet>(), header);
1873 UpdateTxDuration(header.
GetAddr1(), txParams);
1884 NS_LOG_DEBUG(
"Aggregating a QoS Null frame with tid=" << +tid);
1886 mpduList.push_back(mpdu);
1889 if (mpduList.empty())
1891 NS_LOG_DEBUG(
"Not enough time to send a QoS Null frame");
1895 Ptr<WifiPsdu> psdu = (mpduList.size() > 1 ? Create<WifiPsdu>(std::move(mpduList))
1896 : Create<WifiPsdu>(mpduList.front(),
true));
1897 uint16_t staId = m_staMac->GetAssociationId();
1898 SendPsduMapWithProtection(
WifiPsduMap{{staId, psdu}}, txParams);
1909 auto agreement = m_mac->GetBaAgreementEstablishedAsRecipient(m_bssid, tid);
1913 NS_LOG_DEBUG(
"There's not a valid agreement for this BlockAckReq");
1917 if (!UlMuCsMediumIdle(trigger))
1923 auto txVector = GetHeTbTxVector(trigger, m_bssid);
1924 SendBlockAck(*agreement, durationId, txVector, snr);
1938 const auto ra = psdu->GetAddr1();
1939 const auto ta = psdu->GetAddr2();
1940 const auto bssid = psdu->GetHeader(0).GetAddr3();
1943 if (ra == m_bssid || ta == m_bssid || bssid == m_bssid)
1951 if (psdu->GetHeader(0).IsCtl() && ta == empty && ra == m_txopHolder)
1965 if (bssid != empty && bssid != m_bssid)
1973 if (bssid == empty && ta != empty && ra != empty && ta != m_bssid && ra != m_bssid)
1986 const auto bssColor = m_mac->GetHeConfiguration()->GetBssColor();
1989 return bssColor != 0 && bssColor == txVector.
GetBssColor();
1997 if (!psdu->HasNav())
2002 if (psdu->GetAddr1() == m_self)
2012 if (!IsIntraBssPpdu(psdu, txVector))
2014 NS_LOG_DEBUG(
"PPDU not classified as intra-BSS, update the basic NAV");
2015 VhtFrameExchangeManager::UpdateNav(psdu, txVector);
2019 NS_LOG_DEBUG(
"PPDU classified as intra-BSS, update the intra-BSS NAV");
2020 Time duration = psdu->GetDuration();
2023 if (psdu->GetHeader(0).IsCfEnd())
2029 NS_LOG_DEBUG(
"Received CF-End, resetting the intra-BSS NAV");
2030 IntraBssNavResetTimeout();
2036 auto intraBssNavEnd = Simulator::Now() + duration;
2037 if (intraBssNavEnd > m_intraBssNavEnd)
2039 m_intraBssNavEnd = intraBssNavEnd;
2040 NS_LOG_DEBUG(
"Updated intra-BSS NAV=" << m_intraBssNavEnd);
2051 if (psdu->GetHeader(0).IsRts())
2054 GetWifiRemoteStationManager()->GetCtsTxVector(psdu->GetAddr2(), txVector.
GetMode());
2055 auto navResetDelay =
2056 2 * m_phy->GetSifs() +
2057 WifiPhy::CalculateTxDuration(
GetCtsSize(), ctsTxVector, m_phy->GetPhyBand()) +
2058 m_phy->CalculatePhyPreambleAndHeaderDuration(ctsTxVector) + 2 * m_phy->GetSlot();
2059 m_intraBssNavResetEvent =
2060 Simulator::Schedule(navResetDelay,
2061 &HeFrameExchangeManager::IntraBssNavResetTimeout,
2065 NS_LOG_DEBUG(
"Current intra-BSS NAV=" << m_intraBssNavEnd);
2067 m_channelAccessManager->NotifyNavStartNow(duration);
2071HeFrameExchangeManager::ClearTxopHolderIfNeeded()
2074 if (m_intraBssNavEnd <= Simulator::Now())
2076 m_txopHolder.reset();
2081HeFrameExchangeManager::NavResetTimeout()
2084 m_navEnd = Simulator::Now();
2087 Time intraBssNav = Simulator::GetDelayLeft(m_intraBssNavResetEvent);
2088 m_channelAccessManager->NotifyNavResetNow(intraBssNav);
2092HeFrameExchangeManager::IntraBssNavResetTimeout()
2095 m_intraBssNavEnd = Simulator::Now();
2096 ClearTxopHolderIfNeeded();
2098 Time basicNav = Simulator::GetDelayLeft(m_navResetEvent);
2099 m_channelAccessManager->NotifyNavResetNow(basicNav);
2107 if (psdu->GetHeader(0).IsTrigger() && psdu->GetAddr2() == m_bssid)
2109 m_txopHolder = m_bssid;
2111 else if (!txVector.
IsUlMu())
2113 VhtFrameExchangeManager::SetTxopHolder(psdu, txVector);
2118HeFrameExchangeManager::VirtualCsMediumIdle()
const
2123 return m_navEnd <= Simulator::Now() && m_intraBssNavEnd <= Simulator::Now();
2139 const Time now = Simulator::Now();
2146 NS_ASSERT_MSG(m_staMac,
"UL MU CS is only performed by non-AP STAs");
2149 "No User Info field for STA (" << m_self
2150 <<
") AID=" << m_staMac->GetAssociationId());
2152 std::set<uint8_t> indices;
2156 auto ctsTxVector = GetCtsTxVectorAfterMuRts(trigger, m_staMac->GetAssociationId());
2157 auto bw = ctsTxVector.GetChannelWidth();
2158 indices = m_phy->GetOperatingChannel().GetAll20MHzChannelIndicesInPrimary(bw);
2163 m_phy->GetOperatingChannel().Get20MHzIndicesCoveringRu(userInfoIt->GetRuAllocation(),
2166 return !m_channelAccessManager->GetPer20MHzBusy(indices);
2176 NS_ASSERT(mpdu->GetHeader().GetAddr1().IsGroup() || mpdu->GetHeader().GetAddr1() == m_self);
2180 if (txVector.
IsUlMu() && m_txTimer.IsRunning() &&
2181 m_txTimer.GetReason() == WifiTxTimer::WAIT_TB_PPDU_AFTER_BASIC_TF)
2184 NS_ASSERT(m_txParams.m_acknowledgment &&
2185 m_txParams.m_acknowledgment->method == WifiAcknowledgment::UL_MU_MULTI_STA_BA);
2186 auto acknowledgment =
static_cast<WifiUlMuMultiStaBa*
>(m_txParams.m_acknowledgment.get());
2189 if (!m_txTimer.GetStasExpectedToRespond().contains(sender))
2191 NS_LOG_WARN(
"Received a TB PPDU from an unexpected station: " << sender);
2197 NS_LOG_DEBUG(
"Received a BlockAckReq in a TB PPDU from " << sender);
2200 mpdu->GetPacket()->PeekHeader(blockAckReq);
2203 GetBaManager(tid)->NotifyGotBlockAckRequest(
2204 m_mac->GetMldAddress(sender).value_or(sender),
2209 acknowledgment->stationsReceivingMultiStaBa.emplace(std::make_pair(sender, tid), index);
2210 acknowledgment->baType.m_bitmapLen.push_back(
2211 m_mac->GetBaTypeAsRecipient(sender, tid).m_bitmapLen.at(0));
2213 m_muSnrTag.Set(staId, rxSignalInfo.
snr);
2217 NS_LOG_DEBUG(
"Received an S-MPDU in a TB PPDU from " << sender <<
" (" << *mpdu <<
")");
2220 GetBaManager(tid)->NotifyGotMpdu(mpdu);
2223 acknowledgment->stationsReceivingMultiStaBa.emplace(std::make_pair(sender, tid), index);
2224 acknowledgment->baType.m_bitmapLen.push_back(0);
2226 m_muSnrTag.Set(staId, rxSignalInfo.
snr);
2235 VhtFrameExchangeManager::ReceiveMpdu(mpdu, rxSignalInfo, txVector, inAmpdu);
2240 if (!acknowledgment->stationsReceivingMultiStaBa.empty() && !m_multiStaBaEvent.IsRunning())
2242 m_multiStaBaEvent = Simulator::Schedule(m_phy->GetSifs(),
2243 &HeFrameExchangeManager::SendMultiStaBlockAck,
2245 std::cref(m_txParams),
2246 mpdu->GetHeader().GetDuration());
2250 m_txTimer.GotResponseFrom(sender);
2252 if (m_txTimer.GetStasExpectedToRespond().empty())
2256 m_channelAccessManager->NotifyAckTimeoutResetNow();
2258 if (!m_multiStaBaEvent.IsRunning())
2263 m_edca->ResetCw(m_linkId);
2264 TransmissionSucceeded();
2272 if (txVector.
IsUlMu() && m_txTimer.IsRunning() &&
2273 m_txTimer.GetReason() == WifiTxTimer::WAIT_QOS_NULL_AFTER_BSRP_TF &&
2276 const auto& sender = hdr.
GetAddr2();
2278 if (!m_txTimer.GetStasExpectedToRespond().contains(sender))
2280 NS_LOG_WARN(
"Received a TB PPDU from an unexpected station: " << sender);
2285 NS_LOG_WARN(
"No QoS Null frame in the received MPDU");
2289 NS_LOG_DEBUG(
"Received a QoS Null frame in a TB PPDU from " << sender);
2292 m_txTimer.GotResponseFrom(sender);
2294 if (m_txTimer.GetStasExpectedToRespond().empty())
2298 m_channelAccessManager->NotifyAckTimeoutResetNow();
2302 m_edca->ResetCw(m_linkId);
2303 TransmissionSucceeded();
2312 if (hdr.
IsCts() && m_txTimer.IsRunning() &&
2313 m_txTimer.GetReason() == WifiTxTimer::WAIT_CTS && m_psduMap.size() == 1)
2318 Mac48Address sender = m_psduMap.begin()->second->GetAddr1();
2322 mpdu->GetPacket()->PeekPacketTag(tag);
2323 GetWifiRemoteStationManager()->ReportRxOk(sender, rxSignalInfo, txVector);
2324 GetWifiRemoteStationManager()->ReportRtsOk(m_psduMap.begin()->second->GetHeader(0),
2330 m_channelAccessManager->NotifyCtsTimeoutResetNow();
2331 Simulator::Schedule(m_phy->GetSifs(),
2332 &HeFrameExchangeManager::ProtectionCompleted,
2335 else if (hdr.
IsCts() && m_txTimer.IsRunning() &&
2336 m_txTimer.GetReason() == WifiTxTimer::WAIT_CTS_AFTER_MU_RTS)
2341 NS_LOG_DEBUG(
"Received a CTS frame in response to an MU-RTS");
2344 m_channelAccessManager->NotifyCtsTimeoutResetNow();
2345 Simulator::Schedule(m_phy->GetSifs(),
2346 &HeFrameExchangeManager::ProtectionCompleted,
2349 else if (hdr.
IsAck() && m_txTimer.IsRunning() &&
2350 m_txTimer.GetReason() == WifiTxTimer::WAIT_NORMAL_ACK_AFTER_DL_MU_PPDU)
2354 NS_ASSERT(m_txParams.m_acknowledgment->method ==
2355 WifiAcknowledgment::DL_MU_BAR_BA_SEQUENCE);
2357 auto acknowledgment =
2359 NS_ASSERT(acknowledgment->stationsReplyingWithNormalAck.size() == 1);
2361 uint16_t staId = m_apMac->GetAssociationId(
2362 acknowledgment->stationsReplyingWithNormalAck.begin()->first,
2364 auto it = m_psduMap.find(staId);
2367 acknowledgment->stationsReplyingWithNormalAck.begin()->first);
2369 mpdu->GetPacket()->PeekPacketTag(tag);
2370 ReceivedNormalAck(*it->second->begin(),
2371 m_txParams.m_txVector,
2384 m_txTimer.GetReason() == WifiTxTimer::WAIT_BLOCK_ACKS_IN_TB_PPDU)
2387 NS_LOG_DEBUG(
"Received BlockAck in TB PPDU from=" << sender);
2390 mpdu->GetPacket()->PeekPacketTag(tag);
2394 mpdu->GetPacket()->PeekHeader(blockAck);
2396 std::pair<uint16_t, uint16_t> ret =
2397 GetBaManager(tid)->NotifyGotBlockAck(m_linkId,
2399 m_mac->GetMldAddress(sender).value_or(sender),
2401 GetWifiRemoteStationManager()->ReportAmpduTxStatus(sender,
2406 m_txParams.m_txVector);
2409 if (!m_txTimer.GetStasExpectedToRespond().contains(sender))
2411 NS_LOG_WARN(
"Received a BlockAck from an unexpected stations: " << sender);
2415 m_txTimer.GotResponseFrom(sender);
2417 if (m_txTimer.GetStasExpectedToRespond().empty())
2421 m_channelAccessManager->NotifyAckTimeoutResetNow();
2425 m_triggerFrame =
nullptr;
2428 m_edca->ResetCw(m_linkId);
2430 TransmissionSucceeded();
2433 else if (hdr.
IsBlockAck() && m_txTimer.IsRunning() &&
2434 m_txTimer.GetReason() == WifiTxTimer::WAIT_BLOCK_ACK_AFTER_TB_PPDU)
2437 mpdu->GetPacket()->PeekHeader(blockAck);
2440 "A Multi-STA BlockAck is expected after a TB PPDU");
2443 NS_ASSERT(m_staMac && m_staMac->IsAssociated());
2446 NS_LOG_DEBUG(
"The sender is not the AP we are associated with");
2450 uint16_t staId = m_staMac->GetAssociationId();
2453 if (indices.empty())
2455 NS_LOG_DEBUG(
"No Per AID TID Info subfield intended for me");
2460 mpdu->GetPacket()->PeekPacketTag(tag);
2463 for (
const auto& index : indices)
2470 NS_ABORT_IF(m_psduMap.empty() || m_psduMap.begin()->first != staId);
2471 GetBaManager(tid)->NotifyGotAck(m_linkId, *m_psduMap.at(staId)->begin());
2480 NS_ABORT_IF(m_psduMap.empty() || m_psduMap.begin()->first != staId);
2481 std::set<uint8_t> tids = m_psduMap.at(staId)->GetTids();
2482 NS_ABORT_MSG_IF(tids.size() > 1,
"Multi-TID A-MPDUs not supported yet");
2483 tid = *tids.begin();
2486 std::pair<uint16_t, uint16_t> ret = GetBaManager(tid)->NotifyGotBlockAck(
2492 GetWifiRemoteStationManager()->ReportAmpduTxStatus(hdr.
GetAddr2(),
2497 m_txParams.m_txVector);
2500 if (m_psduMap.at(staId)->GetHeader(0).IsQosData() &&
2502 || std::any_of(blockAck.
GetBitmap(index).begin(),
2504 [](uint8_t b) { return b != 0; })))
2506 NS_ASSERT(m_psduMap.at(staId)->GetHeader(0).HasData());
2507 NS_ASSERT(m_psduMap.at(staId)->GetHeader(0).GetQosTid() == tid);
2512 m_mac->GetQosTxop(tid)->StartMuEdcaTimerNow(m_linkId);
2518 m_channelAccessManager->NotifyAckTimeoutResetNow();
2520 for (
const auto& [staId, psdu] : m_psduMap)
2522 if (psdu->GetNMpdus() == 1 && psdu->GetHeader(0).IsBlockAckReq())
2529 else if (hdr.
IsBlockAck() && m_txTimer.IsRunning() &&
2530 m_txTimer.GetReason() == WifiTxTimer::WAIT_BLOCK_ACK)
2536 VhtFrameExchangeManager::ReceiveMpdu(mpdu, rxSignalInfo, txVector, inAmpdu);
2549 m_triggerFrameInAmpdu =
true;
2554 mpdu->GetPacket()->PeekHeader(trigger);
2565 uint16_t staId = m_staMac->GetAssociationId();
2570 NS_LOG_DEBUG(
"Received MU-RTS Trigger Frame from=" << sender);
2571 GetWifiRemoteStationManager()->ReportRxOk(sender, rxSignalInfo, txVector);
2581 Simulator::Schedule(m_phy->GetSifs(),
2582 &HeFrameExchangeManager::SendCtsAfterMuRts,
2591 NS_LOG_DEBUG(
"Received MU-BAR Trigger Frame from=" << sender);
2592 GetWifiRemoteStationManager()->ReportRxOk(sender, rxSignalInfo, txVector);
2600 GetBaManager(tid)->NotifyGotBlockAckRequest(
2601 m_mac->GetMldAddress(sender).value_or(sender),
2605 Simulator::Schedule(m_phy->GetSifs(),
2606 &HeFrameExchangeManager::ReceiveMuBarTrigger,
2615 Simulator::Schedule(m_phy->GetSifs(),
2616 &HeFrameExchangeManager::ReceiveBasicTrigger,
2621 else if (trigger.
IsBsrp())
2623 Simulator::Schedule(m_phy->GetSifs(),
2624 &HeFrameExchangeManager::SendQosNullFramesInTbPpdu,
2633 VhtFrameExchangeManager::ReceiveMpdu(mpdu, rxSignalInfo, txVector, inAmpdu);
2641 VhtFrameExchangeManager::ReceiveMpdu(mpdu, rxSignalInfo, txVector, inAmpdu);
2649 const std::vector<bool>& perMpduStatus)
2651 std::set<uint8_t> tids = psdu->GetTids();
2653 if (txVector.
IsUlMu() && m_txTimer.IsRunning() &&
2654 m_txTimer.GetReason() == WifiTxTimer::WAIT_TB_PPDU_AFTER_BASIC_TF)
2657 NS_ASSERT(m_txParams.m_acknowledgment &&
2658 m_txParams.m_acknowledgment->method == WifiAcknowledgment::UL_MU_MULTI_STA_BA);
2659 auto acknowledgment =
static_cast<WifiUlMuMultiStaBa*
>(m_txParams.m_acknowledgment.get());
2662 if (!m_txTimer.GetStasExpectedToRespond().contains(sender))
2664 NS_LOG_WARN(
"Received a TB PPDU from an unexpected station: " << sender);
2668 NS_LOG_DEBUG(
"Received an A-MPDU in a TB PPDU from " << sender <<
" (" << *psdu <<
")");
2670 if (std::any_of(tids.begin(), tids.end(), [&psdu](uint8_t tid) {
2671 return psdu->GetAckPolicyForTid(tid) == WifiMacHeader::NORMAL_ACK;
2674 if (std::all_of(perMpduStatus.cbegin(), perMpduStatus.cend(), [](
bool v) { return v; }))
2677 acknowledgment->stationsReceivingMultiStaBa.emplace(std::make_pair(sender, 14),
2679 acknowledgment->baType.m_bitmapLen.push_back(0);
2685 for (
const auto& tid : tids)
2687 acknowledgment->stationsReceivingMultiStaBa.emplace(std::make_pair(sender, tid),
2689 acknowledgment->baType.m_bitmapLen.push_back(
2690 m_mac->GetBaTypeAsRecipient(sender, tid).m_bitmapLen.at(0));
2694 m_muSnrTag.Set(staId, rxSignalInfo.
snr);
2698 if (!acknowledgment->stationsReceivingMultiStaBa.empty() && !m_multiStaBaEvent.IsRunning())
2700 m_multiStaBaEvent = Simulator::Schedule(m_phy->GetSifs(),
2701 &HeFrameExchangeManager::SendMultiStaBlockAck,
2703 std::cref(m_txParams),
2704 psdu->GetDuration());
2708 m_txTimer.GotResponseFrom(sender);
2710 if (m_txTimer.GetStasExpectedToRespond().empty())
2714 m_channelAccessManager->NotifyAckTimeoutResetNow();
2716 if (!m_multiStaBaEvent.IsRunning())
2721 m_edca->ResetCw(m_linkId);
2722 TransmissionSucceeded();
2730 if (txVector.
IsUlMu() && m_txTimer.IsRunning() &&
2731 m_txTimer.GetReason() == WifiTxTimer::WAIT_QOS_NULL_AFTER_BSRP_TF)
2735 if (!m_txTimer.GetStasExpectedToRespond().contains(sender))
2737 NS_LOG_WARN(
"Received a TB PPDU from an unexpected station: " << sender);
2740 if (std::none_of(psdu->begin(), psdu->end(), [](
Ptr<WifiMpdu> mpdu) {
2741 return mpdu->GetHeader().IsQosData() && !mpdu->GetHeader().HasData();
2744 NS_LOG_WARN(
"No QoS Null frame in the received PSDU");
2748 NS_LOG_DEBUG(
"Received QoS Null frames in a TB PPDU from " << sender);
2751 m_txTimer.GotResponseFrom(sender);
2753 if (m_txTimer.GetStasExpectedToRespond().empty())
2757 m_channelAccessManager->NotifyAckTimeoutResetNow();
2761 m_edca->ResetCw(m_linkId);
2762 TransmissionSucceeded();
2769 if (m_triggerFrameInAmpdu)
2772 auto psduIt = psdu->begin();
2773 while (psduIt != psdu->end())
2775 if ((*psduIt)->GetHeader().IsTrigger())
2777 ReceiveMpdu(*psduIt, rxSignalInfo, txVector,
false);
2782 m_triggerFrameInAmpdu =
false;
2787 VhtFrameExchangeManager::EndReceiveAmpdu(psdu, rxSignalInfo, txVector, perMpduStatus);
uint16_t GetAssociationId(Mac48Address addr, uint8_t linkId) const
const std::map< uint16_t, Mac48Address > & GetStaList(uint8_t linkId) const
Get a const reference to the map of associated stations on the given link.
void NotifyAckTimeoutStartNow(Time duration)
Notify that ack timer has started for the given duration.
void NotifyCtsTimeoutStartNow(Time duration)
Notify that CTS timer has started for the given duration.
void Cancel()
This method is syntactic sugar for the ns3::Simulator::Cancel method.
bool IsRunning() const
This method is syntactic sugar for !IsExpired().
std::set< Mac48Address > m_sentRtsTo
the STA(s) which we sent an RTS to (waiting for CTS)
void DoCtsTimeout(Ptr< WifiPsdu > psdu)
Take required actions when the CTS timer fired after sending an RTS to protect the given PSDU expires...
uint8_t m_linkId
the ID of the link this object is associated with
Ptr< WifiMac > m_mac
the MAC layer on this station
virtual void SetWifiMac(const Ptr< WifiMac > mac)
Set the MAC layer to use.
Ptr< WifiRemoteStationManager > GetWifiRemoteStationManager() const
virtual void Reset()
Reset this frame exchange manager.
Mac48Address m_self
the MAC address of this device
virtual void StartProtection(const WifiTxParameters &txParams)
Start the protection mechanism indicated by the given TX parameters.
uint16_t m_allowedWidth
the allowed width in MHz for the current transmission
WifiTxTimer m_txTimer
the timer set upon frame transmission
std::set< Mac48Address > m_protectedStas
STAs that have replied to an RTS in this TXOP.
virtual Time GetRtsDurationId(const WifiTxVector &rtsTxVector, Time txDuration, Time response) const
Compute how to set the Duration/ID field of an RTS frame to send to protect a frame transmitted with ...
virtual void ProtectionCompleted()
Transmit prepared frame upon successful protection mechanism.
virtual void CtsTimeout(Ptr< WifiMpdu > rts, const WifiTxVector &txVector)
Called when the CTS timeout expires.
virtual void TransmissionSucceeded()
Take necessary actions upon a transmission success.
Ptr< WifiPhy > m_phy
the PHY layer on this station
Ptr< ChannelAccessManager > m_channelAccessManager
the channel access manager
virtual void RxStartIndication(WifiTxVector txVector, Time psduDuration)
virtual Time GetMuRtsDurationId(uint32_t muRtsSize, const WifiTxVector &muRtsTxVector, Time txDuration, Time response) const
Compute how to set the Duration/ID field of an MU-RTS Trigger Frame to send to protect a frame transm...
Ptr< ApWifiMac > m_apMac
MAC pointer (null if not an AP)
void DoDispose() override
Destructor implementation.
void Reset() override
Reset this frame exchange manager.
WifiMode GetCtsModeAfterMuRts() const
Ptr< WifiMpdu > PrepareMuBar(const WifiTxVector &responseTxVector, std::map< uint16_t, CtrlBAckRequestHeader > recipients) const
Build a MU-BAR Trigger Frame starting from the TXVECTOR used to respond to the MU-BAR (in case of mul...
virtual void SendMuRts(const WifiTxParameters &txParams)
Send an MU-RTS to begin an MU-RTS/CTS frame exchange protecting an MU PPDU.
WifiTxParameters m_txParams
the TX parameters for the current PPDU
void BlockAckTimeout(Ptr< WifiPsdu > psdu, const WifiTxVector &txVector) override
Called when the BlockAck timeout expires.
void RxStartIndication(WifiTxVector txVector, Time psduDuration) override
void CalculateAcknowledgmentTime(WifiAcknowledgment *acknowledgment) const override
Calculate the time required to acknowledge a frame according to the given acknowledgment method.
Ptr< WifiMpdu > m_triggerFrame
Trigger Frame being sent.
void SetMultiUserScheduler(const Ptr< MultiUserScheduler > muScheduler)
Set the Multi-user Scheduler associated with this Frame Exchange Manager.
WifiTxVector GetCtsTxVectorAfterMuRts(const CtrlTriggerHeader &trigger, uint16_t staId) const
Get the TXVECTOR that the station having the given station ID has to use to send a CTS frame after re...
void SetWifiMac(const Ptr< WifiMac > mac) override
Set the MAC layer to use.
Ptr< MultiUserScheduler > m_muScheduler
Multi-user Scheduler (HE APs only)
virtual void CtsAfterMuRtsTimeout(Ptr< WifiMpdu > muRts, const WifiTxVector &txVector)
Called when no CTS frame is received after an MU-RTS.
WifiTxVector m_trigVector
the TRIGVECTOR
void ProtectionCompleted() override
Transmit prepared frame upon successful protection mechanism.
static Ptr< WifiPsdu > GetPsduTo(Mac48Address to, const WifiPsduMap &psduMap)
Get the PSDU in the given PSDU map that is addressed to the given MAC address, if any,...
Ptr< StaWifiMac > m_staMac
MAC pointer (null if not a STA)
void CtsTimeout(Ptr< WifiMpdu > rts, const WifiTxVector &txVector) override
Called when the CTS timeout expires.
virtual void BlockAcksInTbPpduTimeout(WifiPsduMap *psduMap, std::size_t nSolicitedStations)
Take the necessary actions after that some BlockAck frames are missing in response to a DL MU PPDU.
EventId m_intraBssNavResetEvent
the event to reset the intra-BSS NAV after an RTS
bool StartFrameExchange(Ptr< QosTxop > edca, Time availableTime, bool initialFrame) override
Start a frame exchange (including protection frames and acknowledgment frames as needed) that fits wi...
void NormalAckTimeout(Ptr< WifiMpdu > mpdu, const WifiTxVector &txVector) override
Called when the Ack timeout expires.
virtual void BlockAckAfterTbPpduTimeout(Ptr< WifiPsdu > psdu, const WifiTxVector &txVector)
Take the necessary actions after that a Block Ack is missing after a TB PPDU solicited through a Trig...
virtual void TbPpduTimeout(WifiPsduMap *psduMap, std::size_t nSolicitedStations)
Take the necessary actions after that some TB PPDUs are missing in response to Trigger Frame.
void SendPsduMap()
Send the current PSDU map as a DL MU PPDU.
WifiPsduMap m_psduMap
the A-MPDU being transmitted
void RecordSentMuRtsTo(const WifiTxParameters &txParams)
Record the stations being solicited by an MU-RTS TF.
static TypeId GetTypeId()
Get the type ID.
Time m_intraBssNavEnd
intra-BSS NAV expiration time
EventId m_multiStaBaEvent
Sending a Multi-STA BlockAck event.
void SendPsduMapWithProtection(WifiPsduMap psduMap, WifiTxParameters &txParams)
Send a map of PSDUs as a DL MU PPDU.
void StartProtection(const WifiTxParameters &txParams) override
Start the protection mechanism indicated by the given TX parameters.
~HeFrameExchangeManager() override
void TransmissionSucceeded() override
Take necessary actions upon a transmission success.
static Time ConvertLSigLengthToHeTbPpduDuration(uint16_t length, const WifiTxVector &txVector, WifiPhyBand band)
Ptr< WifiMpdu > GetBar(AcIndex ac, std::optional< uint8_t > optTid=std::nullopt, std::optional< Mac48Address > optAddress=std::nullopt)
Get the next BlockAckRequest or MU-BAR Trigger Frame to send, if any.
virtual Time GetPsduDurationId(Time txDuration, const WifiTxParameters &txParams) const
Compute how to set the Duration/ID field of PSDUs that do not include fragments.
void ForwardMpduDown(Ptr< WifiMpdu > mpdu, WifiTxVector &txVector) override
Forward an MPDU down to the PHY layer.
bool StartFrameExchange(Ptr< QosTxop > edca, Time availableTime, bool initialFrame) override
Start a frame exchange (including protection frames and acknowledgment frames as needed) that fits wi...
void NotifyPacketDiscarded(Ptr< const WifiMpdu > mpdu) override
Pass the given MPDU, discarded because of the max retry limit was reached, to the MPDU dropped callba...
virtual void ForwardPsduDown(Ptr< const WifiPsdu > psdu, WifiTxVector &txVector)
Forward a PSDU down to the PHY layer.
void DequeuePsdu(Ptr< const WifiPsdu > psdu)
Dequeue the MPDUs of the given PSDU from the queue in which they are stored.
void ReleaseSequenceNumbers(Ptr< const WifiPsdu > psdu) const override
Make the sequence numbers of MPDUs included in the given PSDU available again if the MPDUs have never...
static Mac48Address GetBroadcast()
A tag to be attached to a response to a multi-user UL frame, that carries the SNR values with which t...
double Get(uint16_t staId) const
Return the SNR value for the given sender.
TxFormat
Enumeration of the possible transmission formats.
virtual void DoDispose()
Destructor implementation.
Smart pointer class similar to boost::intrusive_ptr.
void TransmissionFailed() override
Take necessary actions upon a transmission failure.
Ptr< QosTxop > m_edca
the EDCAF that gained channel access
Ptr< BlockAckManager > GetBaManager()
Get the Block Ack Manager associated with this QosTxop.
virtual Time GetRemainingTxop(uint8_t linkId) const
Return the remaining duration in the current TXOP on the given link.
std::pair< CtrlBAckRequestHeader, WifiMacHeader > PrepareBlockAckRequest(Mac48Address recipient, uint8_t tid) const
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
static Time Now()
Return the current simulation virtual time.
Introspection did not find any typical Config paths.
double Get() const
Return the SNR value.
Simulation virtual time values and global simulation resolution.
TimeWithUnit As(const Unit unit=Time::AUTO) const
Attach a unit to a Time, to facilitate output in a specific unit.
bool IsZero() const
Exactly equivalent to t == 0.
Time GetTxopLimit() const
Return the TXOP limit.
void UpdateFailedCw(uint8_t linkId)
Update the value of the CW variable for the given link to take into account a transmission failure.
void ResetCw(uint8_t linkId)
Update the value of the CW variable for the given link to take into account a transmission success or...
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
VhtFrameExchangeManager handles the frame exchange sequences for VHT stations.
Ptr< WifiPsdu > GetWifiPsdu(Ptr< WifiMpdu > mpdu, const WifiTxVector &txVector) const override
Get a PSDU containing the given MPDU.
static void SetQosAckPolicy(Ptr< WifiMpdu > item, const WifiAcknowledgment *acknowledgment)
Set the QoS Ack policy for the given MPDU, which must be a QoS data frame.
Ptr< HeConfiguration > GetHeConfiguration() const
OriginatorAgreementOptConstRef GetBaAgreementEstablishedAsOriginator(Mac48Address recipient, uint8_t tid) const
Ptr< QosTxop > GetQosTxop(AcIndex ac) const
Accessor for a specified EDCA object.
represent a single transmission mode
Time GetSlot() const
Return the slot duration for this PHY.
Time GetSifs() const
Return the Short Interframe Space (SIFS) for this PHY.
static Time CalculateTxDuration(uint32_t size, const WifiTxVector &txVector, WifiPhyBand band, uint16_t staId=SU_STA_ID)
WifiPhyBand GetPhyBand() const
Get the configured Wi-Fi band.
Ptr< PhyEntity > GetPhyEntity(WifiModulationClass modulation) const
Get the supported PHY entity corresponding to the modulation class.
static Time CalculatePhyPreambleAndHeaderDuration(const WifiTxVector &txVector)
This class stores the TX parameters (TX vector, protection mechanism, acknowledgment mechanism,...
std::optional< Time > m_txDuration
TX duration of the frame.
std::unique_ptr< WifiProtection > m_protection
protection method
uint32_t GetSize(Mac48Address receiver) const
Get the size in bytes of the (A-)MPDU addressed to the given receiver.
std::unique_ptr< WifiAcknowledgment > m_acknowledgment
acknowledgment method
const PsduInfo * GetPsduInfo(Mac48Address receiver) const
Get a pointer to the information about the PSDU addressed to the given receiver, if present,...
void UndoAddMpdu()
Undo the addition of the last MPDU added by calling AddMpdu().
WifiTxVector m_txVector
TXVECTOR of the frame being prepared.
void AddMpdu(Ptr< const WifiMpdu > mpdu)
Record that an MPDU is being added to the current frame.
void Clear()
Reset the TX parameters.
bool IsRunning() const
Return true if the timer is running.
Reason
The reason why the timer was started.
@ WAIT_BLOCK_ACK_AFTER_TB_PPDU
@ WAIT_NORMAL_ACK_AFTER_DL_MU_PPDU
@ WAIT_QOS_NULL_AFTER_BSRP_TF
@ WAIT_TB_PPDU_AFTER_BASIC_TF
@ WAIT_BLOCK_ACKS_IN_TB_PPDU
const std::set< Mac48Address > & GetStasExpectedToRespond() const
void Set(Reason reason, const Time &delay, const std::set< Mac48Address > &from, MEM mem_ptr, OBJ obj, Args... args)
This method is called when a frame soliciting a response is transmitted.
This class mimics the TXVECTOR which is to be passed to the PHY in order to define the parameters whi...
void SetTxPowerLevel(uint8_t powerlevel)
Sets the selected transmission power level.
void SetChannelWidth(uint16_t channelWidth)
Sets the selected channelWidth (in MHz)
uint8_t GetBssColor() const
Get the BSS color.
void SetGuardInterval(uint16_t guardInterval)
Sets the guard interval duration (in nanoseconds)
void SetTriggerResponding(bool triggerResponding)
Set the Trigger Responding parameter to the given value.
WifiMode GetMode(uint16_t staId=SU_STA_ID) const
If this TX vector is associated with an SU PPDU, return the selected payload transmission mode.
void SetHeMuUserInfo(uint16_t staId, HeMuUserInfo userInfo)
Set the HE MU user-specific transmission information for the given STA-ID.
WifiPreamble GetPreambleType() const
void SetAggregation(bool aggregation)
Sets if PSDU contains A-MPDU.
const HeMuUserInfoMap & GetHeMuUserInfoMap() const
Get a const reference to the map HE MU user-specific transmission information indexed by STA-ID.
WifiModulationClass GetModulationClass() const
Get the modulation class specified by this TXVECTOR.
void SetLength(uint16_t length)
Set the LENGTH field of the L-SIG.
void SetSigBMode(const WifiMode &mode)
Set the MCS used for SIG-B.
void SetBssColor(uint8_t color)
Set the BSS color.
uint16_t GetChannelWidth() const
void SetMode(WifiMode mode)
Sets the selected payload transmission mode.
void SetPreambleType(WifiPreamble preamble)
Sets the preamble type.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
#define NS_ABORT_MSG(msg)
Unconditional abnormal program termination with a message.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
#define NS_ABORT_IF(cond)
Abnormal program termination if a condition is true.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
#define NS_LOG_FUNCTION_NOARGS()
Output the name of the function.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Time Seconds(double value)
Construct a Time in the indicated unit.
AcIndex
This enumeration defines the Access Categories as an enumeration with values corresponding to the AC ...
@ WIFI_PHY_BAND_2_4GHZ
The 2.4 GHz band.
@ WIFI_MOD_CLASS_VHT
VHT (Clause 22)
Declaration of ns3::HePhy class and ns3::HeSigAParameters struct.
void(* Time)(Time oldValue, Time newValue)
TracedValue callback signature for Time.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
U * PeekPointer(const Ptr< U > &p)
std::unordered_map< uint16_t, Ptr< const WifiPsdu > > WifiConstPsduMap
Map of const PSDUs indexed by STA-ID.
bool IsTrigger(const WifiPsduMap &psduMap)
uint32_t GetBlockAckRequestSize(BlockAckReqType type)
Return the total BlockAckRequest size (including FCS trailer).
uint32_t GetMuBarSize(std::list< BlockAckReqType > types)
Return the total MU-BAR size (including FCS trailer).
const std::map< AcIndex, WifiAc > wifiAcList
Map containing the four ACs in increasing order of priority (according to Table 10-1 "UP-to-AC Mappin...
uint32_t GetBlockAckSize(BlockAckType type)
Return the total BlockAck size (including FCS trailer).
bool IsDlMu(WifiPreamble preamble)
Return true if a preamble corresponds to a downlink multi-user transmission.
uint32_t GetAckSize()
Return the total Ack size (including FCS trailer).
static constexpr uint16_t SU_STA_ID
STA_ID to identify a single user (SU)
uint32_t GetCtsSize()
Return the total CTS size (including FCS trailer).
std::unordered_map< uint16_t, Ptr< WifiPsdu > > WifiPsduMap
Map of PSDUs indexed by STA-ID.
std::vector< uint8_t > m_bitmapLen
Length (bytes) of included bitmaps.
RxSignalInfo structure containing info on the received signal.
double snr
SNR in linear scale.
WifiAcknowledgment is an abstract base struct.
const Method method
acknowledgment method
std::optional< Time > acknowledgmentTime
time required by the acknowledgment method
WifiDlMuAggregateTf specifies that a DL MU PPDU made of PSDUs including each a MU-BAR Trigger Frame i...
WifiDlMuBarBaSequence specifies that a DL MU PPDU is acknowledged through a sequence of BlockAckReq a...
WifiDlMuTfMuBar specifies that a DL MU PPDU is followed after a SIFS duration by a MU-BAR Trigger Fra...
WifiMuRtsCtsProtection specifies that MU-RTS/CTS protection method is used.
WifiNoAck specifies that no acknowledgment is required.
WifiNoProtection specifies that no protection method is used.
WifiProtection is an abstract base struct.
const Method method
protection method
WifiUlMuMultiStaBa specifies that a Basic Trigger Frame is being sent to solicit TB PPDUs that will b...
BlockAckType baType
BlockAck type.
std::map< std::pair< Mac48Address, uint8_t >, std::size_t > stationsReceivingMultiStaBa
Map (originator, tid) pairs to the their index in baType.