Method FailTransfersForConnection

library/cpp/netliba/v12/udp_host.cpp:965–975

    }

    void TUdpHost::FailTransfersForConnection(TConnection* connection) {
        for (TSendTransfers::TIdIterator i = connection->GetSendQueue().Begin(); i != connection->GetSendQueue().End();) {
            FailedSend(TTransfer(connection, *(i++)));
        }
        Y_ASSERT(connection->GetSendQueue().Empty());

        for (TRecvTransfers::TIdIterator i = connection->GetRecvQueue().Begin(); i != connection->GetRecvQueue().End();) {
            connection->FailedRecvTransfer(*(i++));
        }
        Y_ASSERT(connection->GetRecvQueue().Empty());
    }

    void TUdpHost::SuccessfulSend(const TTransfer& transfer) {
        CheckedCast<TConnection*>(transfer.Connection.Get())->SuccessfulSendTransfer(transfer.Id);