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

Method OnSend

library/cpp/neh/tcp2.cpp:873–886  ·  view source on GitHub ↗

must be called only from asio thread

Source from the content-addressed store, hash-verified

871
872 //must be called only from asio thread
873 void OnSend(TRequestId reqId, const TErrorCode& ec, size_t amount, IHandlingContext&) {
874 Y_UNUSED(amount);
875 if (Y_UNLIKELY(ec)) {
876 OnErrorCode(ec);
877 } else {
878 if (Y_LIKELY(reqId)) {
879 DBGOUT("Client::OnSend(" << reqId << ")");
880 LastSendedReqId_.store(reqId, std::memory_order_release);
881 }
882 //output already aquired, used asio thread
883 OutputBuffers_.Clear();
884 SendMessages(true);
885 }
886 }
887
888 //must be called only from asio thread
889 void OnCanRead(const TErrorCode& ec, IHandlingContext& ctx) {

Callers

nothing calls this directly

Calls 3

Y_UNUSEDFunction · 0.85
storeMethod · 0.45
ClearMethod · 0.45

Tested by

no test coverage detected