librdmacm/examples/rping.c

141 	enum test_state state;		/* used for cond/signalling */
172 		cb->state = ADDR_RESOLVED;
175 			cb->state = ERROR;
182 		cb->state = ROUTE_RESOLVED;
187 		cb->state = CONNECT_REQUEST;
200 			cb->state = CONNECTED;
219 		cb->state = DISCONNECTED;
225 		cb->state = ERROR;
252 	if (cb->state <= CONNECTED || cb->state == RDMA_WRITE_COMPLETE)
253 		cb->state = RDMA_READ_ADV;
255 		cb->state = RDMA_WRITE_ADV;
267 	if (cb->state == RDMA_READ_ADV)
268 		cb->state = RDMA_WRITE_ADV;
270 		cb->state = RDMA_WRITE_COMPLETE;
305 			cb->state = RDMA_WRITE_COMPLETE;
311 			cb->state = RDMA_READ_COMPLETE;
345 	cb->state = ERROR;
363 	if (cb->state == ERROR) {
364 		fprintf(stderr, "wait for CONNECTED state %d\n", cb->state);
639 		if (cb->state != RDMA_READ_ADV) {
640 			fprintf(stderr, "wait for RDMA_READ_ADV state %d\n",
641 				cb->state);
663 		if (cb->state != RDMA_READ_COMPLETE) {
664 			fprintf(stderr, "wait for RDMA_READ_COMPLETE state %d\n",
665 				cb->state);
685 		if (cb->state != RDMA_WRITE_ADV) {
686 			fprintf(stderr, "wait for RDMA_WRITE_ADV state %d\n",
687 				cb->state);
711 		if (cb->state != RDMA_WRITE_COMPLETE) {
712 			fprintf(stderr, "wait for RDMA_WRITE_COMPLETE state %d\n",
713 				cb->state);
728 	return (cb->state == DISCONNECTED) ? 0 : ret;
840 	 * Set persistent server threads to DEATCHED state so
856 		if (listening_cb->state != CONNECT_REQUEST) {
857 			fprintf(stderr, "wait for CONNECT_REQUEST state %d\n",
858 				listening_cb->state);
885 	if (cb->state != CONNECT_REQUEST) {
886 		fprintf(stderr, "wait for CONNECT_REQUEST state %d\n",
887 			cb->state);
948 		cb->state = RDMA_READ_ADV;
972 		if (cb->state != RDMA_WRITE_ADV) {
973 			fprintf(stderr, "wait for RDMA_WRITE_ADV state %d\n",
974 				cb->state);
988 		if (cb->state != RDMA_WRITE_COMPLETE) {
989 			fprintf(stderr, "wait for RDMA_WRITE_COMPLETE state %d\n",
990 				cb->state);
1006 	return (cb->state == DISCONNECTED) ? 0 : ret;
1026 	if (cb->state != CONNECTED) {
1027 		fprintf(stderr, "wait for CONNECTED state %d\n", cb->state);
1056 	if (cb->state != ROUTE_RESOLVED) {
1057 		fprintf(stderr, "waiting for addr/route resolution state %d\n",
1058 			cb->state);
1178 	cb->state = IDLE;