rdma/krping/krping.c

316 static int server_recv(struct krping_cb *cb, struct ib_wc *wc)
318 	if (wc->byte_len != sizeof(cb->recv_buf)) {
320 		       wc->byte_len);
339 static int client_recv(struct krping_cb *cb, struct ib_wc *wc)
341 	if (wc->byte_len != sizeof(cb->recv_buf)) {
343 		       wc->byte_len);
358 	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 					(uintmax_t)wc.wr_id, wc.status, wc.opcode, wc.vendor_err);
385 		switch (wc.opcode) {
413 				ret = server_recv(cb, &wc);
415 				ret = cb->server ? server_recv(cb, &wc) :
416 						   client_recv(cb, &wc);
418 				printk(KERN_ERR PFX "recv wc error: %d\n", ret);
434 			       __func__, __LINE__, wc.opcode);
914 	struct ib_wc wc;
952 				ne = ib_poll_cq(cb->cq, 1, &wc);
965 		if (cb->poll && wc.status != IB_WC_SUCCESS) {
969 				wc.status, (int) wc.wr_id);
1073 			struct ib_wc wc;
1082 				ne = ib_poll_cq(cb->cq, 1, &wc);
1092 			if (wc.status != IB_WC_SUCCESS) {
1098 					wc.status, (int) wc.wr_id);
1205 			struct ib_wc wc;
1213 				ne = ib_poll_cq(cb->cq, 1, &wc);
1223 			if (wc.status != IB_WC_SUCCESS) {
1229 					wc.status, (int) wc.wr_id);
1265 	struct ib_wc wc;
1282 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1287 	if (wc.status) {
1288 		printk(KERN_ERR PFX "send completiong error %d\n", wc.status);
1298 	struct ib_wc wc;
1315 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1320 	if (wc.status) {
1321 		printk(KERN_ERR PFX "send completiong error %d\n", wc.status);
1332 	struct ib_wc wc;
1349 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1354 	if (wc.status) {
1355 		printk(KERN_ERR PFX "send completiong error %d\n", wc.status);
1560 	struct ib_wc wc;
1578 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1583 	if (wc.status) {
1584 		printk(KERN_ERR PFX "send completion error %d\n", wc.status);
1600 	struct ib_wc wc;
1617 			ne = ib_poll_cq(cb->cq, 1, &wc);
1623 		if (wc.status != IB_WC_SUCCESS) {
1627 				wc.status, (int) wc.wr_id);
1650 	struct ib_wc wc;
1668 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1673 	if (wc.status) {
1674 		printk(KERN_ERR PFX "send completion error %d\n", wc.status);
1689 	struct ib_wc wc;
1707 	while ((ret = ib_poll_cq(cb->cq, 1, &wc) == 0));
1712 	if (wc.status) {
1713 		printk(KERN_ERR PFX "send completion error %d\n", wc.status);
1734 	struct ib_wc wc;
1759 		ret = ib_poll_cq(cb->cq, 1, &wc);
1767 		if (wc.wr_id == 0xdeadbeefcafebabe ||
1768 		    wc.wr_id == 0xcafebabedeadbeef)
1779 	struct ib_wc wc;
1850 		ret = ib_poll_cq(cb->cq, 1, &wc);
1856 			if (wc.status) {
1857 				printk(KERN_ERR PFX "completion error %u\n", wc.status);