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

Method GetAllPendingDataSize

library/cpp/netliba/v12/udp_http.cpp:1044–1054  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1042 *res = future.GetValue();
1043 }
1044 void GetAllPendingDataSize(TRequesterPendingDataStats* total, TColoredRequesterPendingDataStats* colored) override {
1045 auto promise = NThreading::NewPromise<std::pair<TRequesterPendingDataStats, TColoredRequesterPendingDataStats>>();
1046 Host->GetAllPendingDataSize([promise](const TRequesterPendingDataStats& stat, const TColoredRequesterPendingDataStats& coloredStat) mutable {
1047 promise.SetValue({stat, coloredStat});
1048 });
1049 auto future = promise.GetFuture();
1050 future.Wait();
1051 auto resData = future.GetValue();
1052 *total = resData.first;
1053 colored->Swap(resData.second);
1054 }
1055 bool HasRequest(const TGUID& reqId) override {
1056 TIntrusivePtr<TStatsRequest> req = new TStatsRequest(TStatsRequest::HAS_IN_REQUEST);
1057 req->RequestId = reqId;

Callers 1

GetPendingDataSizeMethod · 0.45

Calls 5

SetValueMethod · 0.45
GetFutureMethod · 0.45
WaitMethod · 0.45
GetValueMethod · 0.45
SwapMethod · 0.45

Tested by

no test coverage detected