| 278 | { |
| 279 | } |
| 280 | ~TTXUserQueue() { |
| 281 | if (!Queue.IsEmpty()) { |
| 282 | fprintf(stderr, "TTXUserQueue destructed with no empty queue, memory leak..."); |
| 283 | } |
| 284 | Y_ASSERT(Queue.IsEmpty()); |
| 285 | } |
| 286 | |
| 287 | void EnqueueConnect(TConnection* connection) { |
| 288 | Queue.Enqueue(std::make_pair(ETXUserCmd::TXUC_CONNECT, connection)); |