Lines Matching full:nodes
64 struct cmatest_node *nodes; member
274 node = &test.nodes[test.conn_index++]; in connect_handler()
375 test.nodes = malloc(sizeof *test.nodes * connections); in alloc_nodes()
376 if (!test.nodes) { in alloc_nodes()
377 printf("cmatose: unable to allocate memory for test nodes\n"); in alloc_nodes()
380 memset(test.nodes, 0, sizeof *test.nodes * connections); in alloc_nodes()
383 test.nodes[i].id = i; in alloc_nodes()
386 &test.nodes[i].cma_id, in alloc_nodes()
387 &test.nodes[i], hints.ai_port_space); in alloc_nodes()
395 rdma_destroy_id(test.nodes[i].cma_id); in alloc_nodes()
396 free(test.nodes); in alloc_nodes()
405 destroy_node(&test.nodes[i]); in destroy_nodes()
406 free(test.nodes); in destroy_nodes()
415 if (!test.nodes[i].connected) in poll_cqs()
419 ret = ibv_poll_cq(test.nodes[i].cq[index], 8, wc); in poll_cqs()
485 ret = rdma_migrate_id(test.nodes[i].cma_id, channel); in migrate_channel()
533 ret = post_sends(&test.nodes[i]); in run_server()
559 if (!test.nodes[i].connected) in run_server()
562 test.nodes[i].connected = 0; in run_server()
563 rdma_disconnect(test.nodes[i].cma_id); in run_server()
589 ret = rdma_resolve_addr(test.nodes[i].cma_id, test.rai->ai_src_addr, in run_client()
610 ret = post_sends(&test.nodes[i]); in run_client()