infiniband-diags/src/mcm_rereg_test.c

105 static int rereg_send(int port, int agent, ib_portid_t *dport,
114 	if(umad_send(port, agent, umad, len, TMO, 0) < 0) {
124 static int rereg_port_gid(int port, int agent, ib_portid_t *dport,
134 	if(umad_send(port, agent, umad, len, TMO, 0) < 0) {
143 	if(umad_send(port, agent, umad, len, TMO, 0) < 0) {
159 static int rereg_send_all(int port, int agent, ib_portid_t *dport,
175 		ret = rereg_port_gid(port, agent, dport, umad, len, list[i].gid);
193 static int rereg_mcm_rec_send(int port, int agent, ib_portid_t *dport, int cnt)
210 		if (!rereg_port_gid(port, agent, dport, umad, len, port_gid))
220 static int rereg_recv(int port, int agent, ib_portid_t *dport,
243 static int rereg_recv_all(int port, int agent, ib_portid_t *dport,
261 	while (rereg_recv(port, agent, dport, umad, len, TMO) > 0) {
285 			rereg_port_gid(port, agent, dport, umad, len,
298 static int rereg_query_all(int port, int agent, ib_portid_t *dport,
315 		ret = rereg_send(port, agent, dport, umad, len,
322 		ret = rereg_recv(port, agent, dport, umad, len, TMO);
345 static int rereg_mcm_rec_recv(int port, int agent, int cnt)
382 static int rereg_and_test_port(char *guid_file, int port, int agent, ib_portid_t *dport, int timeout)
418 	rereg_send_all(port, agent, dport, list, i);
419 	rereg_recv_all(port, agent, dport, list, i);
421 	rereg_query_all(port, agent, dport, list, i);
432 	int port, agent;
471 	agent = umad_register(port, IB_SA_CLASS, 2, 0, NULL);
475 	cnt = rereg_mcm_rec_send(port, agent, &dport_id, cnt);
477 	rereg_recv_all(port, agent, &dport_id);
479 	rereg_and_test_port(guid_file, port, agent, &dport_id, TMO);
484 	umad_unregister(port, agent);