Method ProcessIBRequest

library/cpp/netliba/v12/udp_host.cpp:507–526

    }

    bool TUdpHost::ProcessIBRequest() {
        if (IB.Get()) {
            TAutoPtr<TIBRequest> r = IB->GetRequest();
            if (!!r) {
                const TIntrusivePtr<IConnection>* connection = Connections.FindPtr(r->ConnectionGuid);
                Y_ASSERT(connection); // hmm, old connection?
                TUdpRequest* result = nullptr;
                if (connection) {
                    result = new TUdpRequest;
                    result->IsHighPriority = false;
                    result->Connection = *connection;
                    result->Data = r->Data;
                }
                ReceivedClientQueue.Enqueue(result);
                Event.Signal();
                return true;
            }
        }
        return false;
    }

    void TUdpHost::ProcessIBSendResults() {
        if (IB.Get()) {