| 1010 | |
| 1011 | public: |
| 1012 | TUdpHttp() |
| 1013 | : myThread(TThread::TParams(ExecServerThread, (void*)this).SetName("nl6_udp_host")) |
| 1014 | , KeepRunning(true) |
| 1015 | , AbortTransactions(false) |
| 1016 | , PingsSendT(0) |
| 1017 | , ReportRequestCancel(false) |
| 1018 | , ReportSendRequestAcc(false) |
| 1019 | { |
| 1020 | NHPTimer::GetTime(&PingsSendT); |
| 1021 | QueueSizes = new TRequesterUserQueueSizes; |
| 1022 | UserQueues = new TRequesterUserQueues(QueueSizes.Get()); |
| 1023 | } |
| 1024 | bool Start(const TIntrusivePtr<NNetlibaSocket::ISocket>& socket) { |
| 1025 | Y_ASSERT(Host.Get() == nullptr); |
| 1026 | Socket = socket; |