///////////////////////////////////////////////////////////////////// TRequesterUserQueues
| 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; |