Method ProcessMessage

test/brpc_public_pbrpc_protocol_unittest.cpp:121–132

    }

    void ProcessMessage(void (*process)(brpc::InputMessageBase*),
                        brpc::InputMessageBase* msg, bool set_eof) {
        if (msg->_socket == NULL) {
            _socket->ReAddress(&msg->_socket);
        }
        msg->_arg = &_server;
        _socket->PostponeEOF();
        if (set_eof) {
            _socket->SetEOF();
        }
        (*process)(msg);
    }
    
    brpc::policy::MostCommonMessage* MakeRequestMessage(
        brpc::policy::PublicPbrpcRequest* meta) {