rdma/krping/krping.c

61 MODULE_DESCRIPTION("RDMA ping client/server");
88 	{"server", OPT_NOPARAM, 's'},
117  *	server receives source rkey/add/len
118  *	server rdma reads "ping" data from source
119  * 	server sends "go ahead" on rdma read completion
121  * 	server receives sink rkey/addr/len
122  * 	server rdma writes "pong" data to sink
123  * 	server sends "go ahead" on rdma write completion
129  * and the main client or server thread.
164 	int server;			/* 0 iff client */
236 					/* listener on server side. */
237 	struct rdma_cm_id *child_cm_id;	/* connection on server side */
274 		if (!cb->server) {
409 				ret = cb->server ? server_recv(cb, &wc) :
497 	if (cb->server || cb->wlat || cb->rlat || cb->bw) {
659 	if (!cb->server || cb->wlat || cb->rlat || cb->bw) {
773 	if (cb->server) {
942 	if (!cb->server || cb->wlat || cb->rlat || cb->bw) {
966 		DEBUG_LOG(cb, "server received sink adv\n");
1000 		DEBUG_LOG(cb, "server posted rdma read req \n");
1011 		DEBUG_LOG(cb, "server received read complete\n");
1015 			PRINTF(cb, "server ping data: %s\n",
1019 		if (cb->server && cb->server_invalidate) {
1029 		DEBUG_LOG(cb, "server posted go ahead\n");
1039 		DEBUG_LOG(cb, "server received sink adv\n");
1071 		DEBUG_LOG(cb, "server rdma write complete \n");
1076 		if (cb->server && cb->server_invalidate) {
1086 		DEBUG_LOG(cb, "server posted go ahead\n");
1149 				cb->server ? "server" : "client");
1224 		if (rcnt < iters && !(scnt < 1 && !cb->server)) {
1275 					cb->server ? "server" : "client");
1404 					cb->server ? "server" : "client");
1684 		/* Wait for server to ACK */
1700 		/* Wait for the server to say the RDMA Write is complete. */
1755 	/* Spin waiting for server's Start STAG/TO/Len */
1792 				cb->server ? "server" : "client");
1845 	/* Spin waiting for server's Start STAG/TO/Len */
1884 	/* Spin waiting for server's Start STAG/TO/Len */
2133 	cb->server = -1;
2158 			DEBUG_LOG(cb, "server\n");
2161 			cb->server = 1;
2162 			DEBUG_LOG(cb, "server\n");
2165 			cb->server = 0;
2253 	if (cb->server == -1) {
2254 		PRINTF(cb, "must be either client or server\n");
2259 	if (cb->server && cb->frtest) {
2297 	if (cb->server)