| 111 | } |
| 112 | |
| 113 | void AddRequest(TUdpHttpRequest* res) { |
| 114 | AtomicAdd(QueueSizes->ReqCount, 1); |
| 115 | AtomicAdd(QueueSizes->ReqQueueSize, GetPacketSize(res->DataHolder.Get())); |
| 116 | ReqList.Enqueue(res); |
| 117 | AsyncEvent.Signal(); |
| 118 | } |
| 119 | void AddResponse(TUdpHttpResponse* res) { |
| 120 | AtomicAdd(QueueSizes->RespCount, 1); |
| 121 | AtomicAdd(QueueSizes->RespQueueSize, GetPacketSize(res->DataHolder.Get())); |
no test coverage detected