librdmacm/examples/udaddy.c

73 static struct cmatest test;
237 	test.connects_left--;
294 	if (test.conn_index == connections) {
298 	node = &test.nodes[test.conn_index++];
323 	test.connects_left--;
347 	test.connects_left--;
382 		/* Cleanup will occur after test completes. */
420 	test.nodes = malloc(sizeof *test.nodes * connections);
421 	if (!test.nodes) {
422 		printf("udaddy: unable to allocate memory for test nodes\n");
425 	memset(test.nodes, 0, sizeof *test.nodes * connections);
428 		test.nodes[i].id = i;
430 			ret = rdma_create_id(test.channel,
431 					     &test.nodes[i].cma_id,
432 					     &test.nodes[i], port_space);
440 		rdma_destroy_id(test.nodes[i].cma_id);
441 	free(test.nodes);
450 		destroy_node(&test.nodes[i]);
451 	free(test.nodes);
473 		if (!test.nodes[i].connected)
477 			ret = ibv_poll_cq(test.nodes[i].cq, 8, wc);
483 			if (ret && !test.nodes[i].ah)
484 				create_reply_ah(&test.nodes[i], wc);
495 	while (test.connects_left && !ret) {
496 		ret = rdma_get_cm_event(test.channel, &event);
533 	ret = rdma_create_id(test.channel, &listen_id, &test, port_space);
540 		ret = get_addr(src_addr, &test.src_in);
544 		test.src_in.sin_family = PF_INET;
546 	test.src_in.sin_port = port;
547 	ret = rdma_bind_addr(listen_id, test.src_addr);
569 			ret = post_sends(&test.nodes[i], IBV_SEND_SIGNALED);
590 		ret = get_addr(src_addr, &test.src_in);
595 	ret = get_addr(dst_addr, &test.dst_in);
599 	test.dst_in.sin_port = port;
603 		ret = rdma_resolve_addr(test.nodes[i].cma_id,
604 					src_addr ? test.src_addr : NULL,
605 					test.dst_addr, 2000);
620 			ret = post_sends(&test.nodes[i], 0);
677 	test.dst_addr = (struct sockaddr *) &test.dst_in;
678 	test.src_addr = (struct sockaddr *) &test.src_in;
679 	test.connects_left = connections;
681 	test.channel = rdma_create_event_channel();
682 	if (!test.channel) {
695 	printf("test complete\n");
697 	rdma_destroy_event_channel(test.channel);