Incorporation of formatting tweaks with primary code.
norm-ccd
bebopagogo 2025-04-22 16:16:04 -04:00
commit 9500578e89
1 changed files with 3 additions and 3 deletions

View File

@ -2824,15 +2824,15 @@ void NormSenderNode::UpdateRecvRate(const struct timeval& currentTime, unsigned
{ {
// Approximate initial recv_rate when initial packets arrive in a burst // Approximate initial recv_rate when initial packets arrive in a burst
recv_rate = recv_accumulator.GetValue() / NORM_TICK_MIN; recv_rate = recv_accumulator.GetValue() / NORM_TICK_MIN;
TRACE("BURST INIT: accum:%lf tick:%lf rate:%lf kbps\n", recv_accumulator.GetValue(), NORM_TICK_MIN, recv_rate*8.0e-03); //TRACE("BURST INIT: accum:%lf tick:%lf rate:%lf kbps\n", recv_accumulator.GetValue(), NORM_TICK_MIN, recv_rate*8.0e-03);
recv_rate_prev = 0.0; recv_rate_prev = 0.0;
} }
nominal_packet_size += 0.05 * (((double)msgSize) - nominal_packet_size); nominal_packet_size += 0.05 * (((double)msgSize) - nominal_packet_size);
TRACE("UPDATED RECV rate: %lf kbps nsize: %lf\n", 8.0e-3*recv_rate, nominal_packet_size); //TRACE("UPDATED RECV rate: %lf kbps nsize: %lf\n", 8.0e-3*recv_rate, nominal_packet_size);
} }
else else
{ {
TRACE("RATE INIT ZERO\n"); //TRACE("RATE INIT ZERO\n");
recv_rate = recv_rate_prev = 0.0; recv_rate = recv_rate_prev = 0.0;
prev_update_time = currentTime; prev_update_time = currentTime;
recv_accumulator.Reset(); recv_accumulator.Reset();