Class TNetworkEvent

library/cpp/par/par_remote.h:21–49

namespace NPar {
    class TRemoteQueryProcessor;
    struct TNetworkEvent {
        enum class EType {
            IncomingQuery,
            IcomingQueryCancel,
            ReplyReceived
        };
        EType EventType;
        TGUID ReqId;
        TAtomicSharedPtr<TNetworkRequest> Request;
        TAtomicSharedPtr<TNetworkResponse> Response;
        TNetworkEvent() = default;
        explicit TNetworkEvent(TNetworkRequest* request)
            : EventType(EType::IncomingQuery)
            , ReqId(request->ReqId)
            , Request(request)
        {
        }
        explicit TNetworkEvent(TNetworkResponse* response)
            : EventType(EType::ReplyReceived)
            , ReqId(response->ReqId)
            , Response(response)
        {
        }
        explicit TNetworkEvent(const TGUID& reqId)
            : EventType(EType::IcomingQueryCancel)
            , ReqId(reqId)
        {
        }
    };

    struct ICmdProcessor : virtual public TThrRefBase {
        virtual void NewRequest(TRemoteQueryProcessor* p, TNetworkRequest* req) = 0;