We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dee9d29 commit c619948Copy full SHA for c619948
libcurvecpr/lib/messager.c
@@ -523,6 +523,11 @@ long long curvecpr_messager_next_timeout (struct curvecpr_messager *messager)
523
524
if (at > block->clock + chicago->rtt_timeout)
525
at = block->clock + chicago->rtt_timeout;
526
+
527
+ /* Writing faster than wr_rate does not make sense and will cause spinning. BUT, if
528
+ there is something to acknowledge, block might still be resent. */
529
+ if (cf->ops.recvmarkq_is_empty(messager) && at < messager->my_sent_clock + chicago->wr_rate)
530
+ at = messager->my_sent_clock + chicago->wr_rate;
531
}
532
533
if (chicago->clock > at)
0 commit comments