rpc_codec.py 文件源码

def encode_response(self, rpc_response):
        # ?rpc??????
        import protocol, msgpack
        if_success = False
        if not isinstance(rpc_response, protocol.RPCResponse):
            # ????????
            log_message = 'can not serlize non-rpc_response obj'
            self._logger.write_log(log_message, 'error')
            return if_success, None

        try:
            rpc_response_data = msgpack.Packer(use_bin_type=True).pack(rpc_response.content)
            if_success = True
            return if_success, rpc_response_data
        except:
            # ?????
            log_message = 'rpc response serlize failed'
            self._logger.write_log(log_message, 'error')
            return if_success, None
        pass