| 1146 | UserQueues = new TRequesterUserQueues(QueueSizes.Get()); |
| 1147 | } |
| 1148 | bool Start(const TIntrusivePtr<ISocket>& socket) { |
| 1149 | Y_ASSERT(Host.Get() == nullptr); |
| 1150 | Socket = socket; |
| 1151 | UdpHttpThread.Start(); |
| 1152 | HasStarted.Wait(); |
| 1153 | |
| 1154 | if (Host.Get()) { |
| 1155 | return true; |
| 1156 | } |
| 1157 | Socket.Drop(); |
| 1158 | return false; |
| 1159 | } |
| 1160 | TString GetDebugInfoLocked() { |
| 1161 | TString res = KeepRunning ? "State: running\n" : "State: stopping\n"; |
| 1162 | auto promise = NThreading::NewPromise<TString>(); |
no test coverage detected