diff --git a/message/messaging_service.cc b/message/messaging_service.cc index 74dd66b01d..639a802e7a 100644 --- a/message/messaging_service.cc +++ b/message/messaging_service.cc @@ -599,6 +599,7 @@ static constexpr unsigned do_get_rpc_client_idx(messaging_verb verb) { case messaging_verb::UNUSED__REPLICATION_FINISHED: case messaging_verb::UNUSED__REPAIR_CHECKSUM_RANGE: case messaging_verb::STREAM_MUTATION_FRAGMENTS: + case messaging_verb::STREAM_BLOB: case messaging_verb::REPAIR_ROW_LEVEL_START: case messaging_verb::REPAIR_ROW_LEVEL_STOP: case messaging_verb::REPAIR_GET_FULL_ROW_HASHES: @@ -616,6 +617,7 @@ static constexpr unsigned do_get_rpc_client_idx(messaging_verb verb) { case messaging_verb::REPAIR_FLUSH_HINTS_BATCHLOG: case messaging_verb::NODE_OPS_CMD: case messaging_verb::HINT_MUTATION: + case messaging_verb::TABLET_STREAM_FILES: case messaging_verb::TABLET_STREAM_DATA: case messaging_verb::TABLET_CLEANUP: return 1; diff --git a/message/messaging_service.hh b/message/messaging_service.hh index 540118149b..a3edbb7701 100644 --- a/message/messaging_service.hh +++ b/message/messaging_service.hh @@ -186,7 +186,9 @@ enum class messaging_verb : int32_t { TABLET_CLEANUP = 67, JOIN_NODE_REQUEST = 68, JOIN_NODE_RESPONSE = 69, - LAST = 70, + TABLET_STREAM_FILES = 70, + STREAM_BLOB = 71, + LAST = 72, }; } // namespace netw