Lines Matching refs:test
69 static struct cmatest test;
233 test.connects_left--;
273 conn_param.private_data = test.rai->ai_connect;
274 conn_param.private_data_len = test.rai->ai_connect_len;
292 if (test.conn_index == connections) {
296 node = &test.nodes[test.conn_index++];
321 test.connects_left--;
345 test.connects_left--;
380 /* Cleanup will occur after test completes. */
418 test.nodes = malloc(sizeof *test.nodes * connections);
419 if (!test.nodes) {
420 printf("udaddy: unable to allocate memory for test nodes\n");
423 memset(test.nodes, 0, sizeof *test.nodes * connections);
426 test.nodes[i].id = i;
428 ret = rdma_create_id(test.channel,
429 &test.nodes[i].cma_id,
430 &test.nodes[i], hints.ai_port_space);
438 rdma_destroy_id(test.nodes[i].cma_id);
439 free(test.nodes);
448 destroy_node(&test.nodes[i]);
449 free(test.nodes);
471 if (!test.nodes[i].connected)
475 ret = ibv_poll_cq(test.nodes[i].cq, 8, wc);
481 if (ret && !test.nodes[i].ah)
482 create_reply_ah(&test.nodes[i], wc);
493 while (test.connects_left && !ret) {
494 ret = rdma_get_cm_event(test.channel, &event);
509 ret = rdma_create_id(test.channel, &listen_id, &test, hints.ai_port_space);
515 ret = get_rdma_addr(src_addr, dst_addr, port, &hints, &test.rai);
521 ret = rdma_bind_addr(listen_id, test.rai->ai_src_addr);
543 ret = post_sends(&test.nodes[i], IBV_SEND_SIGNALED);
564 ret = get_rdma_addr(src_addr, dst_addr, port, &hints, &test.rai);
572 ret = rdma_resolve_addr(test.nodes[i].cma_id, test.rai->ai_src_addr,
573 test.rai->ai_dst_addr, 2000);
588 ret = post_sends(&test.nodes[i], 0);
667 test.connects_left = connections;
669 test.channel = rdma_create_event_channel();
670 if (!test.channel) {
685 printf("test complete\n");
687 rdma_destroy_event_channel(test.channel);
688 if (test.rai)
689 rdma_freeaddrinfo(test.rai);