diff options
Diffstat (limited to 'xlators/mgmt')
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-handshake.c | 7 | ||||
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-utils.c | 3 |
2 files changed, 6 insertions, 4 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-handshake.c b/xlators/mgmt/glusterd/src/glusterd-handshake.c index dc772ca6f51..550ee2c10b3 100644 --- a/xlators/mgmt/glusterd/src/glusterd-handshake.c +++ b/xlators/mgmt/glusterd/src/glusterd-handshake.c @@ -1824,7 +1824,7 @@ __glusterd_mgmt_hndsk_version_ack_cbk (struct rpc_req *req, struct iovec *iov, out: if (ret != 0 && peerinfo) - rpc_transport_disconnect (peerinfo->rpc->conn.trans); + rpc_transport_disconnect (peerinfo->rpc->conn.trans, _gf_false); rcu_read_unlock (); @@ -1949,7 +1949,8 @@ out: frame->local = NULL; STACK_DESTROY (frame->root); if (peerinfo) - rpc_transport_disconnect (peerinfo->rpc->conn.trans); + rpc_transport_disconnect (peerinfo->rpc->conn.trans, + _gf_false); } rcu_read_unlock (); @@ -2218,7 +2219,7 @@ __glusterd_peer_dump_version_cbk (struct rpc_req *req, struct iovec *iov, out: if (ret != 0 && peerinfo) - rpc_transport_disconnect (peerinfo->rpc->conn.trans); + rpc_transport_disconnect (peerinfo->rpc->conn.trans, _gf_false); rcu_read_unlock (); diff --git a/xlators/mgmt/glusterd/src/glusterd-utils.c b/xlators/mgmt/glusterd/src/glusterd-utils.c index fedfb746c50..a1c9132feda 100644 --- a/xlators/mgmt/glusterd/src/glusterd-utils.c +++ b/xlators/mgmt/glusterd/src/glusterd-utils.c @@ -4059,7 +4059,8 @@ gd_check_and_update_rebalance_info (glusterd_volinfo_t *old_volinfo, //Disconnect from rebalance process if (glusterd_defrag_rpc_get (old->defrag)) { - rpc_transport_disconnect (old->defrag->rpc->conn.trans); + rpc_transport_disconnect (old->defrag->rpc->conn.trans, + _gf_false); glusterd_defrag_rpc_put (old->defrag); } |