| 387 | typedef THashMap<TGUID, TIntrusivePtr<TSrvRequestState>, TGUIDHash> TStatesInProcessRequests; |
| 388 | |
| 389 | void AddRequest(TUdpHttpRequest* req) override { |
| 390 | TUdpHttpRequestPtr ptr(req); |
| 391 | |
| 392 | TSrvRequestState* state = new TSrvRequestState(); |
| 393 | |
| 394 | InProcess_[req->ReqId] = state; |
| 395 | try { |
| 396 | TGuard<TSpinLock> m(RequesterPtrPotector_); |
| 397 | if (TRequester* p = P_.load(std::memory_order_acquire)) { |
| 398 | p->OnRequest(ptr, state); //move req. owning to parent |
| 399 | } |
| 400 | } catch (...) { |
| 401 | Cdbg << "ignore exc.: " << CurrentExceptionMessage() << Endl; |
| 402 | } |
| 403 | } |
| 404 | |
| 405 | void AddResponse(TUdpHttpResponse*) override { |
| 406 | Y_ABORT("unexpected response in neh netliba server"); |
no test coverage detected