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

Method ProcessUdpHttpResponse

library/cpp/par/par_network.cpp:439–452  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

437 }
438
439 void ProcessUdpHttpResponse(TAutoPtr<NNetliba_v12::TUdpHttpResponse>& answer, TAutoPtr<TNetworkResponse>& response) {
440 NNetliba_v12::AbortOnFailedRequest(answer.Get()); //LEGACY
441 response->ReqId = answer->ReqId;
442 if (answer->Ok == NNetliba_v12::TUdpHttpResponse::CANCELED) {
443 response->Status = TNetworkResponse::EStatus::Canceled;
444 } else if (answer->Ok == NNetliba_v12::TUdpHttpResponse::OK) {
445 QuickLZDecompress(&answer->Data);
446 response->Data = std::move(answer->Data);
447 response->Status = TNetworkResponse::EStatus::Ok;
448 } else {
449 response->Status = TNetworkResponse::EStatus::Failed;
450 Y_ASSERT(0); //LEGACY
451 }
452 }
453
454 private:
455 TProcessQueryCancelCallback QueryCancelCallback;

Callers

nothing calls this directly

Calls 4

QuickLZDecompressFunction · 0.85
AbortOnFailedRequestFunction · 0.50
moveFunction · 0.50
GetMethod · 0.45

Tested by

no test coverage detected