summaryrefslogtreecommitdiffstats
path: root/rpc/rpc-transport/rdma/src
diff options
context:
space:
mode:
authorRaghavendra G <raghavendra@gluster.com>2010-09-02 07:04:48 +0000
committerVijay Bellur <vijay@dev.gluster.com>2010-09-02 06:32:00 -0700
commit77db91866e9e8b333017e3bdb3079d024bb94818 (patch)
tree16e4aa63ef6e5d1f7a465dcf91f6513c09876e97 /rpc/rpc-transport/rdma/src
parent06ef40a683393ee086a74fb56a6e168b550fd716 (diff)
rpc-transport/rdma: when rdma msg of type RDMA_ERROR is recieved, disconnect transport.
Signed-off-by: Raghavendra G <raghavendra@gluster.com> Signed-off-by: Vijay Bellur <vijay@dev.gluster.com> BUG: 1462 () URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=1462
Diffstat (limited to 'rpc/rpc-transport/rdma/src')
-rw-r--r--rpc/rpc-transport/rdma/src/rdma.c19
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 4d210f2eea2..19f6a25a8e9 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);