rdma/krping/krping.c

312 static int server_recv(struct krping_cb *cb, struct ib_wc *wc)
314 	if (wc->byte_len != sizeof(cb->recv_buf)) {
316 		       wc->byte_len);
335 static int client_recv(struct krping_cb *cb, struct ib_wc *wc)
337 	if (wc->byte_len != sizeof(cb->recv_buf)) {
339 		       wc->byte_len);
354 	struct ib_wc wc;
369 	while ((ret = ib_poll_cq(cb->cq, 1, &wc)) == 1) {
370 		if (wc.status) {
371 			if (wc.status == IB_WC_WR_FLUSH_ERR) {
377 					wc.wr_id, wc.status, wc.opcode, wc.vendor_err);
382 		switch (wc.opcode) {
410 				ret = server_recv(cb, &wc);
412 				ret = cb->server ? server_recv(cb, &wc) :
413 						   client_recv(cb, &wc);
415 				PRINTF(cb, "recv wc error: %d\n", ret);
431 			       __func__, __LINE__, wc.opcode);
1099 	struct ib_wc wc;
1137 				ne = ib_poll_cq(cb->cq, 1, &wc);
1150 		if (cb->poll && wc.status != IB_WC_SUCCESS) {
1154 				wc.status, (int) wc.wr_id);
1256 			struct ib_wc wc;
1265 				ne = ib_poll_cq(cb->cq, 1, &wc);
1275 			if (wc.status != IB_WC_SUCCESS) {
1281 					wc.status, (int) wc.wr_id);
1386 			struct ib_wc wc;
1394 				ne = ib_poll_cq(cb->cq, 1, &wc);
1404 			if (wc.status != IB_WC_SUCCESS) {
1410 					wc.status, (int) wc.wr_id);
1445 	struct ib_wc wc;
1462 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1467 	if (wc.status) {
1468 		PRINTF(cb, "send completiong error %d\n", wc.status);
1478 	struct ib_wc wc;
1495 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1500 	if (wc.status) {
1501 		PRINTF(cb, "send completiong error %d\n", wc.status);
1512 	struct ib_wc wc;
1529 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1534 	if (wc.status) {
1535 		PRINTF(cb, "send completiong error %d\n", wc.status);
1730 	struct ib_wc wc;
1748 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1753 	if (wc.status) {
1754 		PRINTF(cb, "send completion error %d\n", wc.status);
1770 	struct ib_wc wc;
1787 			ne = ib_poll_cq(cb->cq, 1, &wc);
1793 		if (wc.status != IB_WC_SUCCESS) {
1797 				wc.status, (int) wc.wr_id);
1820 	struct ib_wc wc;
1838 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1843 	if (wc.status) {
1844 		PRINTF(cb, "send completion error %d\n", wc.status);
1859 	struct ib_wc wc;
1877 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1882 	if (wc.status) {
1883 		PRINTF(cb, "send completion error %d\n", wc.status);
1899 	struct ib_wc wc;
1967 			ret = ib_poll_cq(cb->cq, 1, &wc);
1973 				if (wc.status) {
1974 					PRINTF(cb, "completion error %u\n", wc.status);
1993 		ret = ib_poll_cq(cb->cq, 1, &wc);
1999 			if (wc.status) {
2000 				PRINTF(cb, "completion error %u opcode %u\n", wc.status, wc.opcode);