feat(bulk-load): meta server send bulk load request (#457)

XiaoMi · May 13, 2020 · c0ee1f6 · c0ee1f6
1 parent 8d5d321
commit c0ee1f6
Show file tree

Hide file tree

Showing 13 changed files with 1,581 additions and 1 deletion.
diff --git a/include/dsn/dist/replication/replication.codes.h b/include/dsn/dist/replication/replication.codes.h
@@ -152,6 +152,7 @@ MAKE_EVENT_CODE(LPC_EXEC_COMMAND_ON_REPLICA, TASK_PRIORITY_LOW)
 MAKE_EVENT_CODE(LPC_PARTITION_SPLIT, TASK_PRIORITY_LOW)
 MAKE_EVENT_CODE(LPC_PARTITION_SPLIT_ERROR, TASK_PRIORITY_COMMON)
 MAKE_EVENT_CODE_RPC(RPC_SPLIT_NOTIFY_CATCH_UP, TASK_PRIORITY_COMMON)
+MAKE_EVENT_CODE_RPC(RPC_BULK_LOAD, TASK_PRIORITY_COMMON)
 MAKE_EVENT_CODE(LPC_REPLICATION_LOW, TASK_PRIORITY_LOW)
 MAKE_EVENT_CODE(LPC_REPLICATION_COMMON, TASK_PRIORITY_COMMON)
 MAKE_EVENT_CODE(LPC_REPLICATION_HIGH, TASK_PRIORITY_HIGH)

diff --git a/include/dsn/dist/replication/replication_types.h b/include/dsn/dist/replication/replication_types.h
diff --git a/src/dist/replication/common/replication_common.h b/src/dist/replication/common/replication_common.h
@@ -36,6 +36,7 @@ typedef std::unordered_map<::dsn::rpc_address, partition_status::type> node_stat
 typedef std::unordered_map<::dsn::rpc_address, dsn::task_ptr> node_tasks;
 
 typedef rpc_holder<start_bulk_load_request, start_bulk_load_response> start_bulk_load_rpc;
+typedef rpc_holder<bulk_load_request, bulk_load_response> bulk_load_rpc;
 
 class replication_options
 {