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

Method ScheduleRequest

library/cpp/neh/multiclient.cpp:280–288  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

278 }
279
280 void ScheduleRequest(TIntrusivePtr<TRequestSupervisor>& rs, const THandleRef& h, const TInstant& deadline) {
281 TJobPtr j(new TNewRequest(rs));
282 JQ_.Enqueue(j);
283 if (!h->Signalled()) {
284 if (deadline.GetValue() < GetNearDeadline_()) {
285 Signal();
286 }
287 }
288 }
289
290 void ScheduleResponse(TRequestSupervisor* rs, THandleRef& h) {
291 TJobPtr j(new TNewResponse(rs, h));

Callers

nothing calls this directly

Calls 4

SignalFunction · 0.85
SignalledMethod · 0.80
EnqueueMethod · 0.45
GetValueMethod · 0.45

Tested by

no test coverage detected