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 633f57db5b3..c70c84a3260 100644 --- a/rpc/rpc-transport/rdma/src/rdma.c +++ b/rpc/rpc-transport/rdma/src/rdma.c @@ -331,6 +331,7 @@ __rdma_disconnect (rpc_transport_t *this) strerror (errno)); ret = -errno; priv->tcp_connected = 0; + priv->connected = 0; } } @@ -4516,10 +4517,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")); |