diff options
| -rw-r--r-- | rpc/rpc-transport/rdma/src/rdma.c | 19 |
1 files changed, 13 insertions, 6 deletions
diff --git a/rpc/rpc-transport/rdma/src/rdma.c b/rpc/rpc-transport/rdma/src/rdma.c index 4d210f2ee..19f6a25a8 100644 --- a/rpc/rpc-transport/rdma/src/rdma.c +++ b/rpc/rpc-transport/rdma/src/rdma.c @@ -2860,7 +2860,7 @@ rdma_decode_header (rdma_peer_t *peer, rdma_post_t *post, break; case RDMA_ERROR: - ret = rdma_decode_error_msg (peer, post, bytes_in_post); + /* ret = rdma_decode_error_msg (peer, post, bytes_in_post); */ break; default: @@ -3208,13 +3208,20 @@ rdma_process_recv (rdma_peer_t *peer, struct ibv_wc *wc) break; case RDMA_ERROR: - ret = rdma_pollin_notify (peer, post); - if (ret == -1) { - gf_log (RDMA_LOG_NAME, GF_LOG_DEBUG, - "pollin notification failed"); - } + gf_log (RDMA_LOG_NAME, GF_LOG_ERROR, + "an error has happened while transmission of msg, " + "disconnecting the transport"); + rpc_transport_disconnect (peer->trans); goto out; +/* ret = rdma_pollin_notify (peer, post); + if (ret == -1) { + gf_log (RDMA_LOG_NAME, GF_LOG_DEBUG, + "pollin notification failed"); + } + goto out; +*/ + default: gf_log (RDMA_LOG_NAME, GF_LOG_DEBUG, "invalid rdma msg-type (%d)", header->rm_type); |