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,
226 	while((ret = umad_recv(port, umad, &len, tmo)) < 0 &&
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)
360 		while (umad_recv(port, umad, &len, TMO) < 0 &&
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;
460 	port = madrpc_portid();
464 	port = umad_open_port(NULL, 0);
465 	if (port < 0) {
467 		return port;
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);
485 	umad_close_port(port);