diff options
-rw-r--r-- | net/rds/ib_recv.c | 20 |
1 files changed, 12 insertions, 8 deletions
diff --git a/net/rds/ib_recv.c b/net/rds/ib_recv.c index c8c60981cf2e..9c4208f6b451 100644 --- a/net/rds/ib_recv.c +++ b/net/rds/ib_recv.c | |||
@@ -979,18 +979,22 @@ static inline void rds_poll_cq(struct rds_ib_connection *ic, | |||
979 | * to get a recv completion _before_ the rdmacm ESTABLISHED | 979 | * to get a recv completion _before_ the rdmacm ESTABLISHED |
980 | * event is processed. | 980 | * event is processed. |
981 | */ | 981 | */ |
982 | if (rds_conn_up(conn) || rds_conn_connecting(conn)) { | 982 | if (wc.status == IB_WC_SUCCESS) { |
983 | rds_ib_process_recv(conn, recv, wc.byte_len, state); | ||
984 | } else { | ||
983 | /* We expect errors as the qp is drained during shutdown */ | 985 | /* We expect errors as the qp is drained during shutdown */ |
984 | if (wc.status == IB_WC_SUCCESS) { | 986 | if (rds_conn_up(conn) || rds_conn_connecting(conn)) |
985 | rds_ib_process_recv(conn, recv, wc.byte_len, state); | ||
986 | } else { | ||
987 | rds_ib_conn_error(conn, "recv completion on " | 987 | rds_ib_conn_error(conn, "recv completion on " |
988 | "%pI4 had status %u, disconnecting and " | 988 | "%pI4 had status %u, disconnecting and " |
989 | "reconnecting\n", &conn->c_faddr, | 989 | "reconnecting\n", &conn->c_faddr, |
990 | wc.status); | 990 | wc.status); |
991 | } | ||
992 | } | 991 | } |
993 | 992 | ||
993 | /* | ||
994 | * It's very important that we only free this ring entry if we've truly | ||
995 | * freed the resources allocated to the entry. The refilling path can | ||
996 | * leak if we don't. | ||
997 | */ | ||
994 | rds_ib_ring_free(&ic->i_recv_ring, 1); | 998 | rds_ib_ring_free(&ic->i_recv_ring, 1); |
995 | } | 999 | } |
996 | } | 1000 | } |