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

Method TLink

library/cpp/neh/tcp.cpp:234–249  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

232
233 struct TLink: public TAtomicRefCount<TLink> {
234 inline TLink(TServer* parent, const TAcceptFull& a)
235 : P(parent)
236 , MQ(Executor())
237 {
238 S.Swap(*a.S);
239 SetNoDelay(S, true);
240
241 RemoteHost = PrintHostByRfc(*GetPeerAddr(S));
242
243 TLinkRef self(this);
244
245 Executor()->Create<TLink, &TLink::RecvCycle>(this, "recv");
246 Executor()->Create<TLink, &TLink::SendCycle>(this, "send");
247
248 Executor()->Running()->Yield();
249 }
250
251 inline void Enqueue(TResponcePtr res) {
252 MQ.Enqueue(res);

Callers

nothing calls this directly

Calls 4

SetNoDelayFunction · 0.85
YieldMethod · 0.80
SwapMethod · 0.45
RunningMethod · 0.45

Tested by

no test coverage detected