mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-22 17:40:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

messaging_service: Add shard_info::get_stats helper

Browse Source 
Will be used in api/messaging_service.cc.
This commit is contained in:
Asias He
2015-07-16 11:11:02 +08:00
parent 8c2cd037a2
commit 70236dbfa6
2 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
message/messaging_service.cc
View File

@@ -138,6 +138,10 @@ messaging_service::shard_info::shard_info(std::unique_ptr<rpc_protocol_client_wr
: rpc_client(std::move(client)) {
}
rpc::stats messaging_service::shard_info::get_stats() const {
return rpc_client->get_stats();
}
void messaging_service::foreach_client(std::function<void(const shard_id& id, const shard_info& info)> f) const {
for (auto i = _clients.cbegin(); i != _clients.cend(); i++) {
f(i->first, i->second);

1
message/messaging_service.hh
View File

@@ -305,6 +305,7 @@ public:
struct shard_info {
shard_info(std::unique_ptr<rpc_protocol_client_wrapper>&& client);
std::unique_ptr<rpc_protocol_client_wrapper> rpc_client;
rpc::stats get_stats() const;
};
void foreach_client(std::function<void(const shard_id& id, const shard_info& info)> f) const;