diff options
| -rw-r--r-- | rpc/rpc-transport/rdma/src/rdma.c | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/rpc/rpc-transport/rdma/src/rdma.c b/rpc/rpc-transport/rdma/src/rdma.c index 7d2bfc0ad74..d27beaf1c25 100644 --- a/rpc/rpc-transport/rdma/src/rdma.c +++ b/rpc/rpc-transport/rdma/src/rdma.c @@ -329,6 +329,7 @@ __rdma_disconnect (rpc_transport_t *this) strerror (errno)); ret = -errno; priv->tcp_connected = 0; + priv->connected = 0; } } @@ -4503,10 +4504,6 @@ rdma_connect (struct rpc_transport *this, int port) struct sockaddr_storage sockaddr; socklen_t sockaddr_len = 0; - if (priv->connected) { - return 0; - } - if (dict_get (options, "non-blocking-io")) { char *nb_connect = data_to_str (dict_get (this->options, "non-blocking-io")); |