return conn->send(std::move(reply));
}
-void Notify::do_timeout()
+void Notify::do_notify_timeout()
{
logger().debug("{} complete={}", __func__, complete);
if (complete) {
bool complete{false};
bool discarded{false};
seastar::timer<seastar::lowres_clock> timeout_timer{
- [this] { do_timeout(); }
+ [this] { do_notify_timeout(); }
};
/// (gid,cookie) -> reply_bl for everyone who acked the notify
std::set<WatchRef> timedout_watchers = {});
/// Called on Notify timeout
- void do_timeout();
+ void do_notify_timeout();
Notify(crimson::net::ConnectionRef conn,
const notify_info_t& ninfo,