feat(split): register child partition (#391)

XiaoMi · Apr 24, 2020 · bfabb1c · bfabb1c
1 parent 275c3ce
commit bfabb1c
Show file tree

Hide file tree

Showing 20 changed files with 1,057 additions and 7 deletions.
diff --git a/include/dsn/dist/replication/replication.codes.h b/include/dsn/dist/replication/replication.codes.h
@@ -102,6 +102,7 @@ MAKE_EVENT_CODE_RPC(RPC_CM_DUPLICATION_SYNC, TASK_PRIORITY_COMMON)
 MAKE_EVENT_CODE_RPC(RPC_CM_UPDATE_APP_ENV, TASK_PRIORITY_COMMON)
 MAKE_EVENT_CODE_RPC(RPC_CM_DDD_DIAGNOSE, TASK_PRIORITY_COMMON)
 MAKE_EVENT_CODE_RPC(RPC_CM_APP_PARTITION_SPLIT, TASK_PRIORITY_COMMON)
+MAKE_EVENT_CODE_RPC(RPC_CM_REGISTER_CHILD_REPLICA, TASK_PRIORITY_COMMON)
 #undef CURRENT_THREAD_POOL
 
 #define CURRENT_THREAD_POOL THREAD_POOL_META_STATE

diff --git a/include/dsn/dist/replication/replication_enums.h b/include/dsn/dist/replication/replication_enums.h
@@ -58,6 +58,7 @@ ENUM_REG(replication::config_type::CT_REMOVE)
 ENUM_REG(replication::config_type::CT_ADD_SECONDARY_FOR_LB)
 ENUM_REG(replication::config_type::CT_PRIMARY_FORCE_UPDATE_BALLOT)
 ENUM_REG(replication::config_type::CT_DROP_PARTITION)
+ENUM_REG(replication::config_type::CT_REGISTER_CHILD)
 ENUM_END2(replication::config_type::type, config_type)
 
 ENUM_BEGIN2(replication::node_status::type, node_status, replication::node_status::NS_INVALID)

diff --git a/include/dsn/dist/replication/replication_types.h b/include/dsn/dist/replication/replication_types.h
diff --git a/include/dsn/utility/error_code.h b/include/dsn/utility/error_code.h
@@ -118,5 +118,6 @@ DEFINE_ERR_CODE(ERR_IGNORE_BAD_DATA)
 DEFINE_ERR_CODE(ERR_APP_DROPPED)
 DEFINE_ERR_CODE(ERR_MOCK_INTERNAL)
 DEFINE_ERR_CODE(ERR_ZOOKEEPER_OPERATION)
+DEFINE_ERR_CODE(ERR_CHILD_REGISTERED)
 
 } // namespace dsn
diff --git a/src/dist/replication/common/replication_common.h b/src/dist/replication/common/replication_common.h
@@ -123,6 +123,8 @@ class replication_options
     void sanity_check();
 };
 
+typedef rpc_holder<register_child_request, register_child_response> register_child_rpc;
+
 extern const char *partition_status_to_string(partition_status::type status);
 
 class cold_backup_constant