mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

transport: Notify system.clients about "protocol_version"

Browse Source
This commit is contained in:
Juliusz Stasiewicz
2020-10-05 13:35:10 +02:00
parent acf0341e9b
commit d2d162ece3
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
transport/server.cc
View File

@@ -371,6 +371,16 @@ cql_server::connection::read_frame() {
_version = current_version;
throw exceptions::protocol_exception(format("Invalid or unsupported protocol version: {:d}", client_version));
}
auto client_state_notification_f = std::apply(notify_client_change<changed_column::protocol_version>{},
std::tuple_cat(make_client_key(_client_state), std::make_tuple(_version)));
return client_state_notification_f.then_wrapped([this] (future<> f) {
try {
f.get();
} catch (...) {
clogger.info("exception while setting protocol_version in `system.clients`: {}", std::current_exception());
}
return _read_buf.read_exactly(frame_size() - 1).then([this] (temporary_buffer<char> tail) {
temporary_buffer<char> full(frame_size());
full.get_write()[0] = _version;
@@ -385,6 +395,7 @@ cql_server::connection::read_frame() {
}
return make_ready_future<ret_type>(frame);
});
});
});
} else {
// Not the first frame, so we know the size.