bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

messaging_service: Introduce STREAM_BLOB and TABLET_STREAM_FILES verb

Browse Source 
They will be used to implement file stream for tablet in the future. Reserve
the verb ID.
This commit is contained in:
Asias He
2023-09-15 10:17:20 +08:00
parent 67cfa12c7d
commit 6beadab9e6
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
message/messaging_service.cc
View File

@@ -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;

4
message/messaging_service.hh
View File

@@ -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