rpc_codec.py 文件源码

def encode_request(self, rpc_request):
        # ?rpc??????
        import protocol, msgpack
        if_success = False
        if not isinstance(rpc_request, protocol.RPCRequest):
            # ????????
            log_message = 'can not serlize non-rpc_request obj'
            self._logger.write_log(log_message, 'error')
            return if_success, None
        try:
            rpc_request_data = msgpack.Packer(use_bin_type=True).pack(rpc_request.content)
            if_success = True
            return if_success, rpc_request_data
        except:
            # ?????
            log_message = 'rpc request serialize failed'
            self._logger.write_log(log_message, 'error')
            return if_success, None