cyp0633
/
ns3-datacenter
mirror of https://github.com/cyp0633/ns3-datacenter.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

swift minor fix

This commit is contained in:
cyp0633 2024-04-04 11:18:48 +08:00
parent 307a26ffa4
commit 58b9e3bf22
Signed by: cyp0633
GPG Key ID: CF90D09FB1FDCE45
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
simulator/ns-3.39/src/point-to-point/model/rdma-hw.cc
View File

@ -2037,7 +2037,7 @@ RdmaHw::HandleAckSwift(Ptr<RdmaQueuePair> qp, Ptr<Packet> p, CustomHeader& ch)
auto endpoint_cwnd = GetCwndSwift(qp, p, ch, swift_target_endpoint_delay, ih.remote_delay);
// cap max and min cwnd, and get the lower one in fab and endpoint
auto cwnd =
std::min(swift_min_cwnd, std::max(swift_max_cwnd, std::min(fab_cwnd, endpoint_cwnd)));
std::max(swift_min_cwnd, std::min(swift_max_cwnd, std::min(fab_cwnd, endpoint_cwnd)));
if (cwnd < qp->swift.m_cwnd_prev)
{
qp->swift.m_t_last_decrease = Simulator::Now();
@ -2078,13 +2078,13 @@ RdmaHw::GetCwndSwift(Ptr<RdmaQueuePair> qp,
uint64_t target_delay,
uint64_t curr_delay) const
{
bool canDecrease = ch.ack.ih.swift.remote_delay > qp->swift.m_t_last_decrease.GetNanoSeconds();
double cwnd = qp->swift.m_cwnd_prev;
bool canDecrease = ch.ack.ih.swift.ts > qp->swift.m_t_last_decrease.GetNanoSeconds();
double cwnd = qp->m_win;
if (curr_delay < target_delay)
{
if (cwnd >= 1)
{
cwnd = cwnd + swift_ai / cwnd * 1; // TODO: num_acked
cwnd = cwnd + (double)swift_ai / cwnd * 1; // TODO: num_acked
}
else
{