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

token_metadata: add debug logs

Browse Source 
We log the new version when the new token
metadata is set.

Also, the log for fence_version is moved
in shared_token_metadata from storage_service
for uniformity.
This commit is contained in:
Petr Gusev
2023-07-31 18:16:21 +04:00
parent 360453fd87
commit fa25e6d63e
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
locator/token_metadata.cc
View File

@@ -1193,6 +1193,7 @@ void shared_token_metadata::set(mutable_token_metadata_ptr tmptr) noexcept {
_shared = std::move(tmptr);
_shared->set_version_tracker(_versions_barrier.start());
tlogger.debug("new token_metadata is set, version {}", _shared->get_version());
}
void shared_token_metadata::update_fence_version(token_metadata::version_t version) {
@@ -1215,6 +1216,7 @@ void shared_token_metadata::update_fence_version(token_metadata::version_t versi
_fence_version, version));
}
_fence_version = version;
tlogger.debug("new fence_version is set, version {}", _fence_version);
}
future<> shared_token_metadata::mutate_token_metadata(seastar::noncopyable_function<future<> (token_metadata&)> func) {

1
service/storage_service.cc
View File

@@ -5819,7 +5819,6 @@ future<raft_topology_cmd_result> storage_service::raft_topology_cmd_handler(shar
future<> storage_service::update_fence_version(token_metadata::version_t new_version) {
return container().invoke_on_all([new_version] (storage_service& ss) {
slogger.debug("update_fence_version, version {}", new_version);
ss._shared_token_metadata.update_fence_version(new_version);
});
}