Method DequeueAndRun

library/cpp/netliba/v12/udp_host.cpp:301–325

        }

        void DequeueAndRun() {
            std::pair<ETXUserCmd, void*> cmdPair;
            while (Queue.Dequeue(cmdPair)) {
                const ETXUserCmd cmdId = cmdPair.first;
                switch (cmdId) {
                    case ETXUserCmd::TXUC_CONNECT: {
                        TConnection* connection = reinterpret_cast<TConnection*>(cmdPair.second);
                        ConnectCb(connection);
                    } break;
                    case ETXUserCmd::TXUC_SEND: {
                        const TSendCmd* sendCmd = reinterpret_cast<const TSendCmd*>(cmdPair.second);
                        SendCb(sendCmd->Transfer, sendCmd->Data, sendCmd->Pp, sendCmd->Tos, sendCmd->NetlibaColor);
                        delete sendCmd;
                    } break;
                    case ETXUserCmd::TXUC_CANCEL: {
                        const TCancelCmd* cancelCmd = reinterpret_cast<const TCancelCmd*>(cmdPair.second);
                        CancelCb(cancelCmd->Transfer);
                        delete cancelCmd;
                    } break;
                    default:
                        Y_ABORT_UNLESS(false);
                        break;
                }
            }
        }

    private:
        NThreading::TOneOneQueue<std::pair<ETXUserCmd, void*>> Queue;