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

Method AddResponse

library/cpp/netliba/v12/udp_http.cpp:129–139  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

127 AsyncEvent.Signal();
128 }
129 void AddResponse(TUdpHttpResponse* res) {
130 AtomicAdd(QueueSizes->RespCount, 1);
131 AtomicAdd(QueueSizes->RespQueueSize, GetTransferSize(res->DataHolder.Get()));
132 if (res->DataHolder.Get() && res->DataHolder->IsHighPriority) {
133 res->IsHighPriority = true;
134 ResponseListHighPiority.Enqueue(res);
135 } else {
136 ResponseList.Enqueue(res);
137 }
138 AsyncEvent.Signal();
139 }
140 void AddCancel(const TGUID& req) {
141 CancelList.Enqueue(req);
142 AsyncEvent.Signal();

Callers 1

FinishRequestMethod · 0.45

Calls 5

GetTransferSizeFunction · 0.85
AtomicAddFunction · 0.50
GetMethod · 0.45
EnqueueMethod · 0.45
SignalMethod · 0.45

Tested by

no test coverage detected