librdmacm/examples/mckey.c

76 static struct cmatest test;
239 	test.connects_left--;
260 	ret = rdma_join_multicast(node->cma_id, test.dst_addr, node);
289 	test.connects_left--;
316 		/* Cleanup will occur after test completes. */
330 		ret = rdma_get_cm_event(test.channel, &event);
381 	test.nodes = malloc(sizeof *test.nodes * connections);
382 	if (!test.nodes) {
383 		printf("mckey: unable to allocate memory for test nodes\n");
386 	memset(test.nodes, 0, sizeof *test.nodes * connections);
389 		test.nodes[i].id = i;
390 		ret = rdma_create_id(test.channel, &test.nodes[i].cma_id,
391 				     &test.nodes[i], port_space);
398 		rdma_destroy_id(test.nodes[i].cma_id);
399 	free(test.nodes);
408 		destroy_node(&test.nodes[i]);
409 	free(test.nodes);
418 		if (!test.nodes[i].connected)
422 			ret = ibv_poll_cq(test.nodes[i].cq, 8, wc);
437 	while (test.connects_left && !ret) {
438 		ret = rdma_get_cm_event(test.channel, &event);
469 		ret = get_addr(src_addr, (struct sockaddr *) &test.src_in);
474 	ret = get_addr(dst_addr, (struct sockaddr *) &test.dst_in);
481 			ret = rdma_bind_addr(test.nodes[i].cma_id,
482 					     test.src_addr);
491 			ret = addr_handler(&test.nodes[i]);
493 			ret = rdma_resolve_addr(test.nodes[i].cma_id,
494 						test.src_addr, test.dst_addr,
507 	pthread_create(&test.cmathread, NULL, cma_thread, NULL);
511 	 * handle reliability issue in this simple test program.
519 				ret = post_sends(&test.nodes[i], 0);
533 		ret = rdma_leave_multicast(test.nodes[i].cma_id,
534 					   test.dst_addr);
560 			test.src_addr = (struct sockaddr *) &test.src_in;
596 	test.dst_addr = (struct sockaddr *) &test.dst_in;
597 	test.connects_left = connections;
599 	test.channel = rdma_create_event_channel();
600 	if (!test.channel) {
610 	printf("test complete\n");
612 	rdma_destroy_event_channel(test.channel);