RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-10 13:10:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/mon: run tick() periodically

Browse Source 
also send keepalive to monitor in tick()

Signed-off-by: Kefu Chai <kchai@redhat.com>
This commit is contained in:
Kefu Chai 2019-05-09 18:46:50 +08:00
parent 86b5989175
commit 555f1e85f9
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/crimson/mon/MonClient.cc
View File

@ -439,6 +439,12 @@ seastar::future<> Client::start() {
return monmap.build_initial(ceph::common::local_conf(), false);
}).then([this] {
return authenticate();
}).then([this] {
auto interval =
std::chrono::duration_cast<seastar::lowres_clock::duration>(
std::chrono::duration<double>(
local_conf().get_val<double>("mon_client_ping_interval")));
timer.arm_periodic(interval);
});
}
@ -460,8 +466,13 @@ seastar::future<> Client::load_keyring()
void Client::tick()
{
seastar::with_gate(tick_gate, [this] {
return seastar::when_all_succeed(active_con->renew_tickets(),
active_con->renew_rotating_keyring());
if (active_con) {
return seastar::when_all_succeed(active_con->get_conn()->keepalive(),
active_con->renew_tickets(),
active_con->renew_rotating_keyring());
} else {
return seastar::now();
}
});
}
@ -862,6 +873,7 @@ seastar::future<> Client::authenticate()
seastar::future<> Client::stop()
{
return tick_gate.close().then([this] {
timer.cancel();
if (active_con) {
return active_con->close();
} else {