Method NewRequest

library/cpp/par/par_wb.h:287–309

        TIntrusivePtr<TLocalDataBuffer> WriteBuffer;

        void NewRequest(TRemoteQueryProcessor* p, TNetworkRequest* req) override {
            CHROMIUM_TRACE_FUNCTION();
            if (req->Url == "wb_copy") {
                Y_ASSERT(req->Url == "wb_copy");
                TVector<i64> data;
                SerializeFromMem(&req->Data, data);

                TVector<TVector<char>> res;
                res.resize(data.size());
                for (int i = 0; i < data.ysize(); ++i) {
                    WriteBuffer->GetData(data[i], &res[i], TLocalDataBuffer::DO_COPY);
                }

                TVector<char> tmp;
                SerializeToMem(&tmp, res);
                int dataSize = tmp.ysize();
                p->SendReply(req->ReqId, &tmp);
                PAR_DEBUG_LOG << "Sending " << dataSize << " bytes from write buffer data" << Endl;

            } else {
                Y_ASSERT(0);
            }
        }

    public:
        TWriteBufferHandler(TRemoteQueryProcessor* queryProc) {