| 1132 | |
| 1133 | public: |
| 1134 | TUdpHttp() |
| 1135 | : UdpHttpThread(TThread::TParams(ExecServerThread, (void*)this).SetName("nl12_udp_http")) |
| 1136 | , KeepRunning(1) |
| 1137 | , AbortTransactions(0) |
| 1138 | , PingsSendT(0) |
| 1139 | , ConnectionsCacheT(0) |
| 1140 | , ReportRequestCancel(false) |
| 1141 | , ReportSendRequestAcc(false) |
| 1142 | { |
| 1143 | NHPTimer::GetTime(&PingsSendT); |
| 1144 | NHPTimer::GetTime(&ConnectionsCacheT); |
| 1145 | QueueSizes = new TRequesterUserQueueSizes; |
| 1146 | UserQueues = new TRequesterUserQueues(QueueSizes.Get()); |
| 1147 | } |
| 1148 | bool Start(const TIntrusivePtr<ISocket>& socket) { |
| 1149 | Y_ASSERT(Host.Get() == nullptr); |
| 1150 | Socket = socket; |