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

Method AddRequestAck

library/cpp/neh/netliba.cpp:219–226  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

217 }
218
219 void AddRequestAck(const TGUID& guid) override {
220 UpdateInFly();
221 TInFly::iterator it = InFly_.find(guid);
222
223 Y_ABORT_UNLESS(it != InFly_.end(), "incorrect complete notification");
224
225 it->second->OnRequestAck();
226 }
227
228 private:
229 TLockFreeQueue<TRequestRef> Q_;

Callers

nothing calls this directly

Calls 3

OnRequestAckMethod · 0.80
findMethod · 0.45
endMethod · 0.45

Tested by

no test coverage detected