msgr: set lossy flag on connect attempt

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 06a28135a64fb6a859e3e140da6a12ff0afd1ca1..9a96fb7344f05c77ab4bc4f6afb887845aa1e41b 100644 (file)
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -1142,6 +1142,9 @@ int Rank::Pipe::connect()
     ceph_msg_connect connect;
     connect.global_seq = gseq;
     connect.connect_seq = cseq;
+    connect.flags = 0;
+    if (policy.lossy_tx)
+      connect.flags |= CEPH_MSG_CONNECT_LOSSYTX;
     memset(&msg, 0, sizeof(msg));
     msgvec[0].iov_base = (char*)&connect;
     msgvec[0].iov_len = sizeof(connect);