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

Method GetRequest

library/cpp/netliba/v6/udp_http.cpp:1185–1195  ·  view source on GitHub ↗

///////////////////////////////////////////////////////////////////// TRequesterUserQueues

Source from the content-addressed store, hash-verified

1183 //////////////////////////////////////////////////////////////////////////
1184 // TRequesterUserQueues
1185 TUdpHttpRequest* TRequesterUserQueues::GetRequest() {
1186 TUdpHttpRequest* res = nullptr;
1187 ReqList.Dequeue(&res);
1188 if (res) {
1189 AtomicAdd(QueueSizes->ReqCount, -1);
1190 AtomicAdd(QueueSizes->ReqQueueSize, -GetPacketSize(res->DataHolder.Get()));
1191 }
1192 UpdateAsyncSignalState();
1193 LoadRequestData(res);
1194 return res;
1195 }
1196
1197 TUdpHttpResponse* TRequesterUserQueues::GetResponse() {
1198 TUdpHttpResponse* res = nullptr;

Callers 5

SessionLevelTestFunction · 0.45
GetRequestMethod · 0.45
GetDebugInfoFunction · 0.45
ReceiveLoopFuncMethod · 0.45

Calls 5

GetPacketSizeFunction · 0.85
LoadRequestDataFunction · 0.70
AtomicAddFunction · 0.50
DequeueMethod · 0.45
GetMethod · 0.45

Tested by 1

SessionLevelTestFunction · 0.36