Lines Matching refs:pidx
145 int pidx;
205 int (*cmd_recv)(struct perf_ctx *perf, int *pidx, enum perf_cmd *cmd,
254 return !!(link & BIT_ULL_MASK(peer->pidx));
277 sts = ntb_peer_spad_read(perf->ntb, peer->pidx,
284 ntb_peer_spad_write(perf->ntb, peer->pidx,
287 ntb_peer_spad_write(perf->ntb, peer->pidx,
290 ntb_peer_spad_write(perf->ntb, peer->pidx,
304 static int perf_spad_cmd_recv(struct perf_ctx *perf, int *pidx,
318 for (*pidx = 0; *pidx < perf->pcnt; (*pidx)++) {
319 peer = &perf->peers[*pidx];
373 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_LDATA,
381 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_HDATA,
385 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_CMD, cmd);
393 static int perf_msg_cmd_recv(struct perf_ctx *perf, int *pidx,
404 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_CMD);
407 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_LDATA);
410 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_HDATA);
459 int ret, pidx, cmd;
462 while (!(ret = perf->cmd_recv(perf, &pidx, &cmd, &data))) {
463 peer = &perf->peers[pidx];
487 int pidx;
489 for (pidx = 0; pidx < perf->pcnt; pidx++) {
490 peer = &perf->peers[pidx];
534 (void)ntb_peer_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx);
543 ret = ntb_peer_mw_set_trans(perf->ntb, peer->pidx, peer->gidx,
562 (void)ntb_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx);
575 ret = ntb_mw_get_align(perf->ntb, peer->pidx, perf->gidx,
606 ret = ntb_mw_set_trans(perf->ntb, peer->pidx, peer->gidx,
742 int pidx;
755 for (pidx = 0; pidx < perf->pcnt; pidx++)
756 perf_cmd_exec(&perf->peers[pidx], PERF_CMD_CLEAR);
758 for (pidx = 0; pidx < perf->pcnt; pidx++)
759 flush_work(&perf->peers[pidx].service);
761 for (pidx = 0; pidx < perf->pcnt; pidx++) {
762 struct perf_peer *peer = &perf->peers[pidx];
1127 " Peer %d test statistics:\n", perf->test_peer->pidx);
1189 int ret, pidx;
1208 ntb_peer_port_number(perf->ntb, perf->test_peer->pidx),
1209 perf->test_peer->pidx);
1214 for (pidx = 0; pidx < perf->pcnt; pidx++) {
1215 peer = &perf->peers[pidx];
1219 ntb_peer_port_number(perf->ntb, peer->pidx), peer->pidx,
1292 int pidx, ret;
1294 ret = kstrtoint_from_user(ubuf, size, 0, &pidx);
1298 if (pidx < 0 || pidx >= perf->pcnt)
1301 peer = &perf->peers[pidx];
1431 "Peer %d outbuf reduced to %pa\n", peer->pidx,
1441 int pidx, lport, ret;
1445 for (pidx = 0; pidx < perf->pcnt; pidx++) {
1446 peer = &perf->peers[pidx];
1449 peer->pidx = pidx;
1450 if (lport < ntb_peer_port_number(perf->ntb, pidx)) {
1452 perf->gidx = pidx;
1453 peer->gidx = pidx + 1;
1455 peer->gidx = pidx;
1461 perf->gidx = pidx;
1473 for (pidx = 0; pidx < perf->pcnt; pidx++) {
1474 ret = perf_setup_peer_mw(&perf->peers[pidx]);