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