msg/async/rdma: keep send after shutdown errno same with posix

Signed-off-by: Haomai Wang <haomai@xsky.com>
ceph · Oct 23, 2016 · 289fad1 · 289fad1
1 parent 5828f28
commit 289fad1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/src/msg/async/rdma/RDMAConnectedSocketImpl.cc b/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
@@ -308,8 +308,11 @@ ssize_t RDMAConnectedSocketImpl::zero_copy_read(bufferptr &data)
 
 ssize_t RDMAConnectedSocketImpl::send(bufferlist &bl, bool more)
 {
-  if (error)
+  if (error) {
+    if (!active)
+      return -EPIPE;
     return -error;
+  }
   size_t bytes = bl.length();
   if (!bytes)
     return 0;

diff --git a/src/msg/async/rdma/RDMAStack.h b/src/msg/async/rdma/RDMAStack.h
@@ -330,11 +330,13 @@ class RDMAConnectedSocketImpl : public ConnectedSocketImpl {
     if (!error)
       fin();
     error = ECONNRESET;
+    active = false;
   }
   virtual void close() override {
     if (!error)
       fin();
     error = ECONNRESET;
+    active = false;
   }
   virtual int fd() const override {
     return notify_fd;