Method RegisterCallback

library/cpp/par/par_remote.cpp:133–145

    }

    void TRemoteQueryProcessor::RegisterCallback(const TGUID& reqId, IRemoteQueryCancelNotify* notify) {
        CHROMIUM_TRACE_FUNCTION();

        Y_ABORT_UNLESS(!reqId.IsEmpty());
        PAR_DEBUG_LOG << "At " << Requester->GetHostAndPort() << " Register cancel callback for request: " << GetGuidAsString(reqId) << Endl;
        TIntrusivePtr<TQueryResultDst> queryResultDst;
        auto functor = [notify](TIntrusivePtr<TQueryResultDst>& theQueryResultDst) {
            theQueryResultDst->CallbackVector.push_back(notify);
        };
        if (!IncomingRequestsData.LockedValueModify(reqId, functor)) {
            PAR_DEBUG_LOG << "At " << Requester->GetHostAndPort() << " No such request in map, probably already sent reply" << Endl;
        }
    }

    void TRemoteQueryProcessor::RunMaster(const TVector<TNetworkAddress>& baseSearcherAddrs, unsigned short masterListenPort) {
        CHROMIUM_TRACE_FUNCTION();