MCPcopy Create free account
hub / github.com/catboost/catboost / AddRequest

Method AddRequest

library/cpp/neh/netliba.cpp:389–403  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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");

Callers 1

Calls 3

CurrentExceptionMessageFunction · 0.85
loadMethod · 0.45
OnRequestMethod · 0.45

Tested by

no test coverage detected