| 449 | } |
| 450 | |
| 451 | inline ~TProto() { |
| 452 | Schedule(new TPacket(TStopPacket(), GetSendAddr(S_))); |
| 453 | |
| 454 | for (size_t i = 0; i < Thrs_.size(); ++i) { |
| 455 | Thrs_[i]->Join(); |
| 456 | } |
| 457 | } |
| 458 | |
| 459 | inline TPacketRef Recv() { |
| 460 | TBuffer tmp; |
nothing calls this directly
no test coverage detected