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

Method Start

library/cpp/netliba/v12/udp_http.cpp:1148–1159  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1146 UserQueues = new TRequesterUserQueues(QueueSizes.Get());
1147 }
1148 bool Start(const TIntrusivePtr<ISocket>& socket) {
1149 Y_ASSERT(Host.Get() == nullptr);
1150 Socket = socket;
1151 UdpHttpThread.Start();
1152 HasStarted.Wait();
1153
1154 if (Host.Get()) {
1155 return true;
1156 }
1157 Socket.Drop();
1158 return false;
1159 }
1160 TString GetDebugInfoLocked() {
1161 TString res = KeepRunning ? "State: running\n" : "State: stopping\n";
1162 auto promise = NThreading::NewPromise<TString>();

Callers 1

CreateHttpUdpRequesterFunction · 0.45

Calls 3

GetMethod · 0.45
WaitMethod · 0.45
DropMethod · 0.45

Tested by

no test coverage detected