update sources to v12.1.1

[ceph.git] / ceph / src / msg / async / AsyncMessenger.cc

diff --git a/ceph/src/msg/async/AsyncMessenger.cc b/ceph/src/msg/async/AsyncMessenger.cc
index 4695844055f122e965b1260308dc0477c46de9a7..1913e8f4c6eea8bb1f530a248094a21475e24925 100644 (file)
--- a/ceph/src/msg/async/AsyncMessenger.cc
+++ b/ceph/src/msg/async/AsyncMessenger.cc
@@ -634,6 +634,15 @@ void AsyncMessenger::set_addr_unknowns(const entity_addr_t &addr)
   }
 }
 
+void AsyncMessenger::set_addr(const entity_addr_t &addr)
+{
+  Mutex::Locker l(lock);
+  entity_addr_t t = addr;
+  t.set_nonce(nonce);
+  set_myaddr(t);
+  _init_local_connection();
+}
+
 void AsyncMessenger::shutdown_connections(bool queue_reset)
 {
   ldout(cct,1) << __func__ << " " << dendl;