Method Step

library/cpp/netliba/v12/udp_http.cpp:732–792

            ConnectionsCache.insert(std::make_pair(addr, connection));
        }
        void Step() {
            {
                TGuard<TSpinLock> lock(CS);
                DoSends();
            }
            Host->Step();
            for (TIntrusivePtr<TStatsRequest> req; StatsReqList.Dequeue(&req);) {
                switch (req->Req) {
                    case TStatsRequest::DEBUG_INFO: {
                        TGuard<TSpinLock> lock(CS);
                        req->DebugInfo = GetDebugInfoLocked();
                    }
                        req->Complete.Signal();
                        break;
                    case TStatsRequest::HAS_IN_REQUEST: {
                        TGuard<TSpinLock> lock(CS);
                        req->RequestFound = (InRequests.find(req->RequestId) != InRequests.end());
                    }
                        req->Complete.Signal();
                        break;
                    case TStatsRequest::GET_PEER_ADDRESS: {
                        TGuard<TSpinLock> lock(CS);
                        TInRequestHash::const_iterator i = InRequests.find(req->RequestId);
                        if (i != InRequests.end()) {
                            req->PeerAddress = i->second.Connection->GetAddress();
                        } else {
                            TOutRequestHash::const_iterator o = OutRequests.find(req->RequestId);
                            if (o != OutRequests.end()) {
                                req->PeerAddress = o->second.Connection->GetAddress();
                            } else {
                                req->PeerAddress = TUdpAddress();
                            }
                        }
                    }
                        req->Complete.Signal();
                        break;
                    case TStatsRequest::GET_PEER_QUEUE_STATS:
                        /*
                // TODO: infinite stats
                    if (TIntrusivePtr<IConnection>* connection = ConnectionsCache.FindPtr(req->PeerAddress)) {
                        req->QueueStats = (*connection)->GetPendingDataSize();
                    }
                */
                        Y_ABORT_UNLESS(false, "NOT IMPLEMENTED");

                        break;
                    default:
                        Y_ASSERT(0);
                        req->Complete.Signal();
                        break;
                }
            }
            {
                TGuard<TSpinLock> lock(CS);
                DoSends();
                ProcessIncomingPackets();
                AnalyzeSendResults();
                SendPingsIfNeeded();