WithStats& with_stats)
: msgr{msgr},
with_stats{with_stats},
- tick_timer{[this] {tick();}}
+ report_timer{[this] {report();}}
{}
seastar::future<> Client::start()
{
if (conn == c) {
conn = nullptr;
- tick_timer.cancel();
+ report_timer.cancel();
}
return seastar::now();
}
{
logger().info("{} {}", __func__, *m);
- auto tick_period = std::chrono::seconds{m->stats_period};
- if (tick_period.count()) {
- if (tick_timer.armed()) {
- tick_timer.rearm(tick_timer.get_timeout(), tick_period);
+ auto report_period = std::chrono::seconds{m->stats_period};
+ if (report_period.count()) {
+ if (report_timer.armed()) {
+ report_timer.rearm(report_timer.get_timeout(), report_period);
} else {
- tick_timer.arm_periodic(tick_period);
+ report_timer.arm_periodic(report_period);
}
} else {
- tick_timer.cancel();
+ report_timer.cancel();
}
return seastar::now();
}
-void Client::tick()
+void Client::report()
{
(void) seastar::with_gate(gate, [this] {
if (conn) {
seastar::future<> handle_mgr_conf(crimson::net::Connection* conn,
Ref<MMgrConfigure> m);
seastar::future<> reconnect();
- void tick();
+ void report();
private:
MgrMap mgrmap;
crimson::net::Messenger& msgr;
WithStats& with_stats;
crimson::net::ConnectionRef conn;
- seastar::timer<seastar::lowres_clock> tick_timer;
+ seastar::timer<seastar::lowres_clock> report_timer;
seastar::gate gate;
};