From bc295a00a656e9e9939e4f810e3eb49e9dee823c Mon Sep 17 00:00:00 2001 From: Asias He Date: Tue, 25 Jun 2019 09:33:10 +0800 Subject: [PATCH] messaging_service: Add rpc stream verb for row level repair - REPAIR_GET_ROW_DIFF_WITH_RPC_STREAM Get repair rows from follower nodes - REPAIR_PUT_ROW_DIFF_WITH_RPC_STREAM Put repair rows to follower nodes - REPAIR_GET_FULL_ROW_HASHES_WITH_RPC_STREAM: Get full hashes from follower nodes --- message/messaging_service.cc | 3 +++ message/messaging_service.hh | 5 ++++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/message/messaging_service.cc b/message/messaging_service.cc index 94a5d76d23..7cc8875e08 100644 --- a/message/messaging_service.cc +++ b/message/messaging_service.cc @@ -464,6 +464,9 @@ static constexpr unsigned do_get_rpc_client_idx(messaging_verb verb) { case messaging_verb::REPAIR_GET_ESTIMATED_PARTITIONS: case messaging_verb::REPAIR_SET_ESTIMATED_PARTITIONS: case messaging_verb::REPAIR_GET_DIFF_ALGORITHMS: + case messaging_verb::REPAIR_GET_ROW_DIFF_WITH_RPC_STREAM: + case messaging_verb::REPAIR_PUT_ROW_DIFF_WITH_RPC_STREAM: + case messaging_verb::REPAIR_GET_FULL_ROW_HASHES_WITH_RPC_STREAM: return 2; case messaging_verb::MUTATION_DONE: case messaging_verb::MUTATION_FAILED: diff --git a/message/messaging_service.hh b/message/messaging_service.hh index 32be38e592..415580f992 100644 --- a/message/messaging_service.hh +++ b/message/messaging_service.hh @@ -130,7 +130,10 @@ enum class messaging_verb : int32_t { REPAIR_GET_ESTIMATED_PARTITIONS= 33, REPAIR_SET_ESTIMATED_PARTITIONS= 34, REPAIR_GET_DIFF_ALGORITHMS = 35, - LAST = 36, + REPAIR_GET_ROW_DIFF_WITH_RPC_STREAM = 36, + REPAIR_PUT_ROW_DIFF_WITH_RPC_STREAM = 37, + REPAIR_GET_FULL_ROW_HASHES_WITH_RPC_STREAM = 38, + LAST = 39, }; } // namespace netw