| 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_))); |
nothing calls this directly
no test coverage detected