crimson/net/Messenger: add the "mark_down" interface

Signed-off-by: Xuehan Xu <[email protected]>

Author: xxhdx1985126

src/crimson/net/Messenger.h

@@ -57,6 +57,8 @@ class Messenger {
 
   virtual void set_auth_server(crimson::auth::AuthServer *) = 0;
 
+  virtual seastar::future<> mark_down(const entity_addr_t &addr) = 0;
+
   using bind_ertr = crimson::errorator<
     crimson::ct_error::address_in_use, // The address (range) is already bound
     crimson::ct_error::address_not_available

src/crimson/net/SocketMessenger.h

@@ -152,6 +152,18 @@ class SocketMessenger final : public Messenger {
   Interceptor *interceptor = nullptr;
 #endif
 
+  seastar::future<> mark_down(const entity_addr_t& a) final {
+    auto conn = lookup_conn(a);
+    if (conn) {
+      return seastar::smp::submit_to(
+	conn->get_shard_id(),
+	[conn=conn.get()] {
+	conn->mark_down();
+	return seastar::now();
+      }).then([conn] { return seastar::now(); });
+    }
+    return seastar::now();
+  }
 private:
   seastar::future<> accept(SocketFRef &&, const entity_addr_t &);