MCPcopy Create free account
hub / github.com/catboost/catboost / AddToResend

Method AddToResend

library/cpp/netliba/v12/net_acks.cpp:103–111  ·  view source on GitHub ↗

called on SendTo() failure

Source from the content-addressed store, hash-verified

101
102 // called on SendTo() failure
103 void TAckTracker::AddToResend(int pkt) {
104 //printf("AddToResend(%d)\n", pkt);
105 if (PacketsInFly.erase(pkt)) {
106 Congestion->FailureOnSend();
107 ResendQueue.push_back(pkt);
108 } else {
109 Y_ASSERT(0);
110 }
111 }
112
113 void TAckTracker::EraseFromResend(int pkt) {
114 //printf("EraseFromResend(%d)\n", pkt);

Callers 1

FlushPacketsMethod · 0.45

Calls 3

eraseMethod · 0.45
FailureOnSendMethod · 0.45
push_backMethod · 0.45

Tested by

no test coverage detected