msg: encode msg/simple and msg/async with features 0

msg/simple and msg/async should explicitly encode with features 0
since the protocol is defined in terms of the legacy encoding.

Signed-off-by: Zhao Junwang <zhjwpku@gmail.com>

diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc
index bcf8e6a3f672650ed4a53fee679c25918a13b2bf..5ce6bea7fbbff9c4bb18cb4f24d4808ff92e3353 100644 (file)
--- a/src/msg/async/AsyncConnection.cc
+++ b/src/msg/async/AsyncConnection.cc
@@ -1177,7 +1177,7 @@ ssize_t AsyncConnection::_process_connection()
           return 0;
         }
 
-        ::encode(async_msgr->get_myaddr(), myaddrbl);
+        ::encode(async_msgr->get_myaddr(), myaddrbl, 0); // legacy
         r = try_send(myaddrbl);
         if (r == 0) {
           state = STATE_CONNECTING_SEND_CONNECT_MSG;
@@ -1392,7 +1392,7 @@ ssize_t AsyncConnection::_process_connection()
 
         bl.append(CEPH_BANNER, strlen(CEPH_BANNER));
 
-        ::encode(async_msgr->get_myaddr(), bl);
+        ::encode(async_msgr->get_myaddr(), bl, 0); // legacy
         port = async_msgr->get_myaddr().get_port();
         // and peer's socket addr (they might not know their ip)
        sockaddr_storage ss;
@@ -1404,7 +1404,7 @@ ssize_t AsyncConnection::_process_connection()
           goto fail;
         }
        socket_addr.set_sockaddr((sockaddr*)&ss);
-        ::encode(socket_addr, bl);
+        ::encode(socket_addr, bl, 0); // legacy
         ldout(async_msgr->cct, 1) << __func__ << " sd=" << sd << " " << socket_addr << dendl;
 
         r = try_send(bl);

diff --git a/src/msg/simple/Pipe.cc b/src/msg/simple/Pipe.cc
index 7c30cd4602f242df7edefa0d4d20697c06c3c801..a9ff49b29a10b395972f19407e19981127c66700 100644 (file)
--- a/src/msg/simple/Pipe.cc
+++ b/src/msg/simple/Pipe.cc
@@ -300,7 +300,7 @@ int Pipe::accept()
   }
 
   // and my addr
-  ::encode(msgr->my_inst.addr, addrs);
+  ::encode(msgr->my_inst.addr, addrs, 0);  // legacy
 
   port = msgr->my_inst.addr.get_port();
 
@@ -313,7 +313,7 @@ int Pipe::accept()
     goto fail_unlocked;
   }
   socket_addr.set_sockaddr((sockaddr*)&ss);
-  ::encode(socket_addr, addrs);
+  ::encode(socket_addr, addrs, 0);  // legacy
 
   r = tcp_write(addrs.c_str(), addrs.length());
   if (r < 0) {
@@ -994,7 +994,7 @@ int Pipe::connect()
 
   msgr->learned_addr(peer_addr_for_me);
 
-  ::encode(msgr->my_inst.addr, myaddrbl);
+  ::encode(msgr->my_inst.addr, myaddrbl, 0);  // legacy
 
   memset(&msg, 0, sizeof(msg));
   msgvec[0].iov_base = myaddrbl.c_str();