Method CacheConnection

library/cpp/netliba/v12/udp_http.cpp:714–731

            return connection;
        }
        void CacheConnection(const TIntrusivePtr<IConnection>& connection) const {
            const TUdpAddress& addr = connection->GetAddress();
            const TConnectionSettings& connectionSettings = connection->GetSettings();

            TConnectionsCache::iterator c = Find(ConnectionsCache, addr, connectionSettings);
            if (c != ConnectionsCache.end()) {
                c->second = connection; // they are equal or we overwrite old connection
                Y_ASSERT(Find(OldConnectionsCache, addr, connectionSettings) == OldConnectionsCache.end());
                return;
            }

            c = Find(OldConnectionsCache, addr, connectionSettings);
            if (c != OldConnectionsCache.end()) {
                OldConnectionsCache.erase(c);
            }

            ConnectionsCache.insert(std::make_pair(addr, connection));
        }
        void Step() {
            {
                TGuard<TSpinLock> lock(CS);