Signed-off-by: Michal Jarzabek <stiopa@gmail.com>
}
}
-int AsyncMessenger::send_keepalive(Connection *con)
-{
- con->send_keepalive();
- return 0;
-}
-
void AsyncMessenger::shutdown_connections(bool queue_reset)
{
ldout(cct,1) << __func__ << " " << dendl;
*/
ConnectionRef get_connection(const entity_inst_t& dest) override;
ConnectionRef get_loopback_connection() override;
- int send_keepalive(Connection *con);
virtual void mark_down(const entity_addr_t& addr) override;
virtual void mark_down_all() override {
shutdown_connections(true);