Lines Matching refs:rem_dest
86 struct pingpong_dest *rem_dest;
208 ctx.rem_dest = calloc(ctx.num_clients, sizeof *ctx.rem_dest);
209 if (!ctx.recv_qp || !ctx.send_qp || !ctx.rem_dest)
320 int sockfd = ctx.rem_dest[index].sockfd;
345 int sockfd = ctx.rem_dest[index].sockfd;
402 ctx.rem_dest[index].recv_psn = lrand48() & 0xffffff;
410 ctx.send_qp[index]->qp_num, ctx.rem_dest[index].recv_psn,
415 ctx.send_qp[index]->qp_num, ctx.rem_dest[index].recv_psn,
428 struct pingpong_dest *rem_dest;
445 rem_dest = &ctx.rem_dest[index];
446 sscanf(msg, MSG_SSCAN, &rem_dest->lid, &rem_dest->recv_qpn,
447 &rem_dest->send_qpn, &rem_dest->send_psn, &rem_dest->srqn, gid);
449 wire_gid_to_gid(gid, &rem_dest->gid);
450 inet_ntop(AF_INET6, &rem_dest->gid, gid, sizeof(gid));
451 printf(ADDR_FORMAT, "remote", rem_dest->lid, rem_dest->recv_qpn,
452 rem_dest->send_qpn, rem_dest->send_psn, rem_dest->srqn,
455 rem_dest->sockfd = sockfd;
464 attr->grh.dgid = myctx->rem_dest[index].gid;
474 attr.dest_qp_num = ctx.rem_dest[index].send_qpn;
476 attr.rq_psn = ctx.rem_dest[index].send_psn;
478 attr.ah_attr.dlid = ctx.rem_dest[index].lid;
482 if (ctx.rem_dest[index].gid.global.interface_id)
496 attr.sq_psn = ctx.rem_dest[index].recv_psn;
506 attr.dest_qp_num = ctx.rem_dest[index].recv_qpn;
508 attr.rq_psn = ctx.rem_dest[index].send_psn;
509 attr.ah_attr.dlid = ctx.rem_dest[index].lid;
513 if (ctx.rem_dest[index].gid.global.interface_id)
528 attr.sq_psn = ctx.rem_dest[index].recv_psn;
673 if (ctx.rem_dest[i].sockfd)
674 close(ctx.rem_dest[i].sockfd);
725 free(ctx.rem_dest);
773 wr.qp_type.xrc.remote_srqn = ctx.rem_dest[index].srqn;
775 qpi = (index + ctx.rem_dest[index].pp_cnt) % ctx.num_clients;
776 wr.send_flags = (++ctx.rem_dest[index].pp_cnt >= ctx.num_tests) ?
987 if (ctx.rem_dest[qpi].pp_cnt < ctx.num_tests)