| 117 | AsyncEvent.Signal(); |
| 118 | } |
| 119 | void AddResponse(TUdpHttpResponse* res) { |
| 120 | AtomicAdd(QueueSizes->RespCount, 1); |
| 121 | AtomicAdd(QueueSizes->RespQueueSize, GetPacketSize(res->DataHolder.Get())); |
| 122 | ResponseList.Enqueue(res); |
| 123 | AsyncEvent.Signal(); |
| 124 | } |
| 125 | void AddCancel(const TGUID& req) { |
| 126 | CancelList.Enqueue(req); |
| 127 | AsyncEvent.Signal(); |
no test coverage detected