diff --git a/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h b/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h index 70f563e13..84a68a0c0 100644 --- a/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h +++ b/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h @@ -854,7 +854,7 @@ PCODE_DEF(OB_TABLE_API_EXECUTE, 0x1102) PCODE_DEF(OB_TABLE_API_BATCH_EXECUTE, 0x1103) PCODE_DEF(OB_TABLE_API_EXECUTE_QUERY, 0x1104) PCODE_DEF(OB_TABLE_API_QUERY_AND_MUTATE, 0x1105) -PCODE_DEF(OB_TABLE_API_EXECUTE_QUERY_SYNC, 0x1106) +PCODE_DEF(OB_TABLE_API_EXECUTE_QUERY_ASYNC, 0x1106) PCODE_DEF(OB_TABLE_TTL, 0x1107) PCODE_DEF(OB_TTL_REQUEST, 0x1108) PCODE_DEF(OB_TTL_RESPONSE, 0x1109) diff --git a/src/observer/table/ob_table_query_sync_processor.h b/src/observer/table/ob_table_query_sync_processor.h index aaca098c9..11433dd16 100644 --- a/src/observer/table/ob_table_query_sync_processor.h +++ b/src/observer/table/ob_table_query_sync_processor.h @@ -179,9 +179,9 @@ private: * -------------------------------------- ObTableQuerySyncP ---------------------------------------- */ class ObTableQuerySyncP : - public ObTableRpcProcessor > + public ObTableRpcProcessor > { - typedef ObTableRpcProcessor> + typedef ObTableRpcProcessor> ParentType; public: explicit ObTableQuerySyncP(const ObGlobalContext &gctx); diff --git a/src/observer/table/ob_table_rpc_processor.cpp b/src/observer/table/ob_table_rpc_processor.cpp index 5fceb8949..7ddb8a701 100644 --- a/src/observer/table/ob_table_rpc_processor.cpp +++ b/src/observer/table/ob_table_rpc_processor.cpp @@ -895,7 +895,7 @@ template class oceanbase::observer::ObTableRpcProcessor >; template class oceanbase::observer::ObTableRpcProcessor >; template class oceanbase::observer::ObTableRpcProcessor >; -template class oceanbase::observer::ObTableRpcProcessor >; +template class oceanbase::observer::ObTableRpcProcessor >; template class oceanbase::observer::ObTableRpcProcessor >; template diff --git a/src/share/table/ob_table_rpc_proxy.h b/src/share/table/ob_table_rpc_proxy.h index 716ae174d..294724ea1 100644 --- a/src/share/table/ob_table_rpc_proxy.h +++ b/src/share/table/ob_table_rpc_proxy.h @@ -30,7 +30,7 @@ public: RPC_S(PR5 batch_execute, obrpc::OB_TABLE_API_BATCH_EXECUTE, (table::ObTableBatchOperationRequest), table::ObTableBatchOperationResult); RPC_SS(PR5 execute_query, obrpc::OB_TABLE_API_EXECUTE_QUERY, (table::ObTableQueryRequest), table::ObTableQueryResult); RPC_S(PR5 query_and_mutate, obrpc::OB_TABLE_API_QUERY_AND_MUTATE, (table::ObTableQueryAndMutateRequest), table::ObTableQueryAndMutateResult); - RPC_S(PR5 execute_query_sync, obrpc::OB_TABLE_API_EXECUTE_QUERY_SYNC, (table::ObTableQuerySyncRequest), table::ObTableQuerySyncResult); + RPC_S(PR5 execute_query_sync, obrpc::OB_TABLE_API_EXECUTE_QUERY_ASYNC, (table::ObTableQuerySyncRequest), table::ObTableQuerySyncResult); RPC_S(PR5 direct_load, obrpc::OB_TABLE_API_DIRECT_LOAD, (table::ObTableDirectLoadRequest), table::ObTableDirectLoadResult); };