| 127 | AsyncEvent.Signal(); |
| 128 | } |
| 129 | void AddResponse(TUdpHttpResponse* res) { |
| 130 | AtomicAdd(QueueSizes->RespCount, 1); |
| 131 | AtomicAdd(QueueSizes->RespQueueSize, GetTransferSize(res->DataHolder.Get())); |
| 132 | if (res->DataHolder.Get() && res->DataHolder->IsHighPriority) { |
| 133 | res->IsHighPriority = true; |
| 134 | ResponseListHighPiority.Enqueue(res); |
| 135 | } else { |
| 136 | ResponseList.Enqueue(res); |
| 137 | } |
| 138 | AsyncEvent.Signal(); |
| 139 | } |
| 140 | void AddCancel(const TGUID& req) { |
| 141 | CancelList.Enqueue(req); |
| 142 | AsyncEvent.Signal(); |
no test coverage detected