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

Method GotResponse

library/cpp/par/par_context.h:109–114  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

107 TAtomic RespCount;
108
109 void GotResponse(int, TVector<char>* response) override {
110 CHROMIUM_TRACE_FUNCTION();
111 if (AtomicDecrement(RespCount) == 0) {
112 QueryProc->SendReply(ReqId, response);
113 }
114 }
115
116 public:
117 TReplyForwarder(TRemoteQueryProcessor* queryProc, const TGUID& reqId, ssize_t RespCount = 1)

Callers

nothing calls this directly

Calls 2

AtomicDecrementFunction · 0.50
SendReplyMethod · 0.45

Tested by

no test coverage detected