Function RunSlave

library/cpp/par/par_host.cpp:81–93

/////////////////////////////////////////////////////////////////////

    //////////////////////////////////////////////////////////////////////////
    void RunSlave(int workerThreadCount, int port) {
        InitNetworkSubSystem();
        LocalExecutor().RunAdditionalThreads(workerThreadCount);

        TIntrusivePtr<TRemoteQueryProcessor> qp(new TRemoteQueryProcessor);
        TIntrusivePtr<TWriteBufferHandler> wb(new TWriteBufferHandler(qp.Get()));
        TIntrusivePtr<TContextReplica> context(new TContextReplica(qp.Get(), wb->GetWriteBuffer()));
        TIntrusivePtr<TMRCmdsProcessor> mr(new TMRCmdsProcessor(qp.Get(), context.Get()));
        qp->RunSlave(port);
        Y_ASSERT(LocalExecutor().GetQueueSize() == 0);
        LocalExecutor().ClearLPQueue();
        qp->Stop();
    }

    IRootEnvironment* RunLocalMaster(int workerThreadCount) {
        LocalExecutor().RunAdditionalThreads(workerThreadCount);