86 	struct pingpong_dest	*rem_dest;  member
208 	ctx.rem_dest = calloc(ctx.num_clients, sizeof *ctx.rem_dest);  in pp_init_ctx()
209 	if (!ctx.recv_qp || !ctx.send_qp || !ctx.rem_dest)  in pp_init_ctx()
320 	int sockfd = ctx.rem_dest[index].sockfd;  in recv_termination_ack()
345 	int sockfd = ctx.rem_dest[index].sockfd;  in send_termination_ack()
402 	ctx.rem_dest[index].recv_psn = lrand48() & 0xffffff;  in send_local_dest()
410 		ctx.send_qp[index]->qp_num, ctx.rem_dest[index].recv_psn,  in send_local_dest()
415 		ctx.send_qp[index]->qp_num, ctx.rem_dest[index].recv_psn,  in send_local_dest()
428 	struct pingpong_dest *rem_dest;  in recv_remote_dest()  local
445 	rem_dest = &ctx.rem_dest[index];  in recv_remote_dest()
446 	sscanf(msg, MSG_SSCAN, &rem_dest->lid, &rem_dest->recv_qpn,  in recv_remote_dest()
447 		&rem_dest->send_qpn, &rem_dest->send_psn, &rem_dest->srqn, gid);  in recv_remote_dest()
449 	wire_gid_to_gid(gid, &rem_dest->gid);  in recv_remote_dest()
450 	inet_ntop(AF_INET6, &rem_dest->gid, gid, sizeof(gid));  in recv_remote_dest()
451 	printf(ADDR_FORMAT, "remote", rem_dest->lid, rem_dest->recv_qpn,  in recv_remote_dest()
452 		rem_dest->send_qpn, rem_dest->send_psn, rem_dest->srqn,  in recv_remote_dest()
455 	rem_dest->sockfd = sockfd;  in recv_remote_dest()
464 	attr->grh.dgid = myctx->rem_dest[index].gid;  in set_ah_attr()
474 	attr.dest_qp_num      = ctx.rem_dest[index].send_qpn;  in connect_qps()
476 	attr.rq_psn	      = ctx.rem_dest[index].send_psn;  in connect_qps()
478 	attr.ah_attr.dlid     = ctx.rem_dest[index].lid;  in connect_qps()
482 	if (ctx.rem_dest[index].gid.global.interface_id)  in connect_qps()
496 	attr.sq_psn = ctx.rem_dest[index].recv_psn;  in connect_qps()
506 	attr.dest_qp_num      = ctx.rem_dest[index].recv_qpn;  in connect_qps()
508 	attr.rq_psn	      = ctx.rem_dest[index].send_psn;  in connect_qps()
509 	attr.ah_attr.dlid     = ctx.rem_dest[index].lid;  in connect_qps()
513 	if (ctx.rem_dest[index].gid.global.interface_id)  in connect_qps()
528 	attr.sq_psn = ctx.rem_dest[index].recv_psn;  in connect_qps()
677 		if (ctx.rem_dest[i].sockfd)  in pp_close_ctx()
678 			close(ctx.rem_dest[i].sockfd);  in pp_close_ctx()
729 	free(ctx.rem_dest);  in pp_close_ctx()
777 	wr.qp_type.xrc.remote_srqn = ctx.rem_dest[index].srqn;  in pp_post_send()
779 	qpi = (index + ctx.rem_dest[index].pp_cnt) % ctx.num_clients;  in pp_post_send()
780 	wr.send_flags = (++ctx.rem_dest[index].pp_cnt >= ctx.num_tests) ?  in pp_post_send()
991 			if (ctx.rem_dest[qpi].pp_cnt < ctx.num_tests)  in main()