| 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())); |
no test coverage detected