| 1022 | UserQueues = new TRequesterUserQueues(QueueSizes.Get()); |
| 1023 | } |
| 1024 | bool Start(const TIntrusivePtr<NNetlibaSocket::ISocket>& socket) { |
| 1025 | Y_ASSERT(Host.Get() == nullptr); |
| 1026 | Socket = socket; |
| 1027 | myThread.Start(); |
| 1028 | HasStarted.Wait(); |
| 1029 | |
| 1030 | if (Host.Get()) { |
| 1031 | return true; |
| 1032 | } |
| 1033 | Socket.Drop(); |
| 1034 | return false; |
| 1035 | } |
| 1036 | TString GetDebugInfoLocked() { |
| 1037 | TString res = KeepRunning ? "State: running\n" : "State: stopping\n"; |
| 1038 | res += Host->GetDebugInfo(); |
no test coverage detected