librdmacm/examples/cmatose.c

81 static struct cmatest test;
221 	test.disconnects_left--;
222 	test.connects_left--;
278 	if (test.conn_index == connections) {
282 	node = &test.nodes[test.conn_index++];
330 		test.connects_left--;
343 		test.disconnects_left--;
346 		/* Cleanup will occur after test completes. */
384 	test.nodes = malloc(sizeof *test.nodes * connections);
385 	if (!test.nodes) {
386 		printf("cmatose: unable to allocate memory for test nodes\n");
389 	memset(test.nodes, 0, sizeof *test.nodes * connections);
392 		test.nodes[i].id = i;
394 			ret = rdma_create_id(test.channel,
395 					     &test.nodes[i].cma_id,
396 					     &test.nodes[i], RDMA_PS_TCP);
404 		rdma_destroy_id(test.nodes[i].cma_id);
405 	free(test.nodes);
414 		destroy_node(&test.nodes[i]);
415 	free(test.nodes);
424 		if (!test.nodes[i].connected)
428 			ret = ibv_poll_cq(test.nodes[i].cq[index], 8, wc);
443 	while (test.connects_left && !err) {
444 		err = rdma_get_cm_event(test.channel, &event);
462 	while (test.disconnects_left && !err) {
463 		err = rdma_get_cm_event(test.channel, &event);
494 		ret = rdma_migrate_id(test.nodes[i].cma_id, channel);
497 		rdma_destroy_event_channel(test.channel);
498 		test.channel = channel;
533 	ret = rdma_create_id(test.channel, &listen_id, &test, RDMA_PS_TCP);
540 		ret = get_addr(src_addr, &test.addr.src_addr);
543 		if (test.addr.src_addr.sa_family == AF_INET)
544 			((struct sockaddr_in *) &test.addr.src_addr)->sin_port = port;
546 			((struct sockaddr_in6 *) &test.addr.src_addr)->sin6_port = port;
549 		test.addr.src_addr.sa_family = PF_INET;
550 		((struct sockaddr_in *) &test.addr.src_addr)->sin_port = port;
553 	ret = rdma_bind_addr(listen_id, &test.addr.src_addr);
573 			ret = post_sends(&test.nodes[i]);
599 		if (!test.nodes[i].connected)
602 		test.nodes[i].connected = 0;
603 		rdma_disconnect(test.nodes[i].cma_id);
621 		ret = get_addr(src_addr, &test.addr.src_addr);
626 	ret = get_addr(dst_addr, &test.addr.dst_addr);
630 	if (test.addr.dst_addr.sa_family == AF_INET)
631 		((struct sockaddr_in *) &test.addr.dst_addr)->sin_port = port;
633 		((struct sockaddr_in6 *) &test.addr.dst_addr)->sin6_port = port;
637 		ret = rdma_resolve_addr(test.nodes[i].cma_id,
638 					src_addr ? &test.addr.src_addr : NULL,
639 					&test.addr.dst_addr, 2000);
659 			ret = post_sends(&test.nodes[i]);
727 	test.connects_left = connections;
728 	test.disconnects_left = connections;
730 	test.channel = rdma_create_event_channel();
731 	if (!test.channel) {
744 	printf("test complete\n");
746 	rdma_destroy_event_channel(test.channel);