From dbb629c79d6284fd921ee97986a5f95ae96ced90 Mon Sep 17 00:00:00 2001 From: oceanoverflow Date: Wed, 7 Feb 2024 08:50:18 +0000 Subject: [PATCH] [CP] fix storage rpc issue --- src/storage/ob_storage_async_rpc.h | 2 +- src/storage/ob_storage_rpc.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/storage/ob_storage_async_rpc.h b/src/storage/ob_storage_async_rpc.h index 2371e4d77f..c59fd07b92 100644 --- a/src/storage/ob_storage_async_rpc.h +++ b/src/storage/ob_storage_async_rpc.h @@ -31,7 +31,7 @@ namespace storage RPC_HA(obrpc::OB_HA_CHECK_TRANSFER_TABLET_BACKFILL, obrpc::ObCheckTransferTabletBackfillArg, obrpc::ObCheckTransferTabletBackfillRes, ObCheckTransferTabletBackfillProxy); RPC_HA(obrpc::OB_HA_CHANGE_MEMBER_SERVICE, obrpc::ObStorageChangeMemberArg, obrpc::ObStorageChangeMemberRes, ObHAChangeMemberProxy); -RPC_HA(obrpc::OB_CHECK_START_TRANSFER_TABLETS, obrpc::ObTransferTabletInfoArg, obrpc::Int64, ObCheckStartTransferTabletsProxy); +RPC_HA(obrpc::OB_CHECK_START_TRANSFER_TABLETS, obrpc::ObTransferTabletInfoArg, obrpc::ObStorageRpcProxy::ObRpc::Response, ObCheckStartTransferTabletsProxy); RPC_HA(obrpc::OB_HA_FETCH_LS_REPLAY_SCN, obrpc::ObFetchLSReplayScnArg, obrpc::ObFetchLSReplayScnRes, ObFetchLSReplayScnProxy); }//end namespace storage diff --git a/src/storage/ob_storage_rpc.h b/src/storage/ob_storage_rpc.h index d1214f29e4..28bb2ca51c 100644 --- a/src/storage/ob_storage_rpc.h +++ b/src/storage/ob_storage_rpc.h @@ -763,7 +763,7 @@ public: // RPC_AP stands for asynchronous RPC. RPC_AP(PR5 check_transfer_tablet_backfill_completed, OB_HA_CHECK_TRANSFER_TABLET_BACKFILL, (obrpc::ObCheckTransferTabletBackfillArg), obrpc::ObCheckTransferTabletBackfillRes); RPC_AP(PR5 get_config_version_and_transfer_scn, OB_HA_CHANGE_MEMBER_SERVICE, (obrpc::ObStorageChangeMemberArg), obrpc::ObStorageChangeMemberRes); - RPC_AP(PR5 check_start_transfer_tablets, OB_CHECK_START_TRANSFER_TABLETS, (obrpc::ObTransferTabletInfoArg), obrpc::Int64); + RPC_AP(PR5 check_start_transfer_tablets, OB_CHECK_START_TRANSFER_TABLETS, (obrpc::ObTransferTabletInfoArg)); RPC_AP(PR5 fetch_ls_replay_scn, OB_HA_FETCH_LS_REPLAY_SCN, (obrpc::ObFetchLSReplayScnArg), obrpc::ObFetchLSReplayScnRes); };