Function CreateRequester

library/cpp/par/par_network.cpp:465–499

    };

    TIntrusivePtr<IRequester> CreateRequester(
        int listenPort,
        IRequester::TProcessQueryCancelCallback processQueryCancelCallback,
        IRequester::TProcessQueryCallback processQueryCallback,
        IRequester::TProcessReplyCallback processReplyCallback)
    {
        auto& settings = TParNetworkSettings::GetRef();
        if (settings.RequesterType == TParNetworkSettings::ERequesterType::AutoDetect) {
            TIntrusivePtr<NNetliba_v12::TIBPort> ibPort = NNetliba_v12::GetIBDevice();
            if (ibPort) {
                DEBUG_LOG << "Detected IB port, using Netliba requester" << Endl;
                settings.RequesterType = TParNetworkSettings::ERequesterType::Netliba;
            } else {
                settings.RequesterType = TParNetworkSettings::ERequesterType::NEH;
            }
        }
        switch (settings.RequesterType) {
            case TParNetworkSettings::ERequesterType::NEH:
                DEBUG_LOG << "Creating NEH requester" << Endl;
                return MakeIntrusive<TNehRequester>(
                    listenPort,
                    std::move(processQueryCancelCallback),
                    std::move(processQueryCallback),
                    std::move(processReplyCallback));
            case TParNetworkSettings::ERequesterType::Netliba:
                DEBUG_LOG << "Creating Netliba requester" << Endl;
                return MakeIntrusive<TNetlibaRequester>(
                    listenPort,
                    std::move(processQueryCancelCallback),
                    std::move(processQueryCallback),
                    std::move(processReplyCallback));
            default:
                Y_ABORT("Unknown requester type");
        }
    }
}