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

Method TProto

library/cpp/neh/udp.cpp:441–449  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

439
440 public:
441 inline TProto(IOnRequest* cb, TSocketHolder& s)
442 : CB_(cb)
443 , ToSendEv_(TSystemEvent::rAuto)
444 , S_(s.Release())
445 {
446 SetSocketTimeout(S_, 10);
447 Thrs_.push_back(Spawn<TProto, &TProto::ExecuteRecv>(this));
448 Thrs_.push_back(Spawn<TProto, &TProto::ExecuteSend>(this));
449 }
450
451 inline ~TProto() {
452 Schedule(new TPacket(TStopPacket(), GetSendAddr(S_)));

Callers

nothing calls this directly

Calls 3

SetSocketTimeoutFunction · 0.85
ReleaseMethod · 0.45
push_backMethod · 0.45

Tested by

no test coverage detected