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

Method AddRequest

library/cpp/netliba/v12/udp_http.cpp:119–128  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

117 }
118
119 void AddRequest(TUdpHttpRequest* res) {
120 AtomicAdd(QueueSizes->ReqCount, 1);
121 AtomicAdd(QueueSizes->ReqQueueSize, GetTransferSize(res->DataHolder.Get()));
122 if (res->DataHolder->IsHighPriority) {
123 RequestListHighPiority.Enqueue(res);
124 } else {
125 RequestList.Enqueue(res);
126 }
127 AsyncEvent.Signal();
128 }
129 void AddResponse(TUdpHttpResponse* res) {
130 AtomicAdd(QueueSizes->RespCount, 1);
131 AtomicAdd(QueueSizes->RespQueueSize, GetTransferSize(res->DataHolder.Get()));

Callers 1

Calls 5

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

Tested by

no test coverage detected