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

Method ProcessOutputCancelsQueue

library/cpp/neh/tcp2.cpp:696–701  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

694 }
695
696 void ProcessOutputCancelsQueue() {
697 if (OutputLock_.TryAcquire()) {
698 AS_.GetIOService().Post(std::bind(&TConnection::SendMessages, TConnectionRef(this), true));
699 return;
700 }
701 }
702
703 //must be called only from asio thread
704 void ProcessReqsInFlyQueue() {

Callers

nothing calls this directly

Calls 2

TryAcquireMethod · 0.45
PostMethod · 0.45

Tested by

no test coverage detected