Lines Matching refs:pidx

145 	int pidx;  member
202 int (*cmd_recv)(struct perf_ctx *perf, int *pidx, enum perf_cmd *cmd,
251 return !!(link & BIT_ULL_MASK(peer->pidx)); in perf_link_is_up()
274 sts = ntb_peer_spad_read(perf->ntb, peer->pidx, in perf_spad_cmd_send()
281 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
284 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
288 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
303 static int perf_spad_cmd_recv(struct perf_ctx *perf, int *pidx, in perf_spad_cmd_recv() argument
317 for (*pidx = 0; *pidx < perf->pcnt; (*pidx)++) { in perf_spad_cmd_recv()
318 peer = &perf->peers[*pidx]; in perf_spad_cmd_recv()
372 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_LDATA, in perf_msg_cmd_send()
380 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_HDATA, in perf_msg_cmd_send()
385 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_CMD, cmd); in perf_msg_cmd_send()
393 static int perf_msg_cmd_recv(struct perf_ctx *perf, int *pidx, in perf_msg_cmd_recv() argument
404 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_CMD); in perf_msg_cmd_recv()
407 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_LDATA); in perf_msg_cmd_recv()
410 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_HDATA); in perf_msg_cmd_recv()
459 int ret, pidx, cmd; in perf_cmd_recv() local
462 while (!(ret = perf->cmd_recv(perf, &pidx, &cmd, &data))) { in perf_cmd_recv()
463 peer = &perf->peers[pidx]; in perf_cmd_recv()
487 int pidx; in perf_link_event() local
489 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_link_event()
490 peer = &perf->peers[pidx]; in perf_link_event()
534 (void)ntb_peer_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx); in perf_free_outbuf()
543 ret = ntb_peer_mw_set_trans(perf->ntb, peer->pidx, peer->gidx, in perf_setup_outbuf()
561 (void)ntb_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx); in perf_free_inbuf()
574 ret = ntb_mw_get_align(perf->ntb, peer->pidx, perf->gidx, in perf_setup_inbuf()
603 ret = ntb_mw_set_trans(perf->ntb, peer->pidx, peer->gidx, in perf_setup_inbuf()
738 int pidx; in perf_disable_service() local
753 for (pidx = 0; pidx < perf->pcnt; pidx++) in perf_disable_service()
754 perf_cmd_exec(&perf->peers[pidx], PERF_CMD_CLEAR); in perf_disable_service()
756 for (pidx = 0; pidx < perf->pcnt; pidx++) in perf_disable_service()
757 flush_work(&perf->peers[pidx].service); in perf_disable_service()
1090 " Peer %d test statistics:\n", perf->test_peer->pidx); in perf_read_stats()
1152 int ret, pidx; in perf_dbgfs_read_info() local
1171 ntb_peer_port_number(perf->ntb, perf->test_peer->pidx), in perf_dbgfs_read_info()
1172 perf->test_peer->pidx); in perf_dbgfs_read_info()
1177 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_dbgfs_read_info()
1178 peer = &perf->peers[pidx]; in perf_dbgfs_read_info()
1182 ntb_peer_port_number(perf->ntb, peer->pidx), peer->pidx, in perf_dbgfs_read_info()
1252 int pidx, ret; in perf_dbgfs_write_run() local
1254 ret = kstrtoint_from_user(ubuf, size, 0, &pidx); in perf_dbgfs_write_run()
1258 if (pidx < 0 || pidx >= perf->pcnt) in perf_dbgfs_write_run()
1261 peer = &perf->peers[pidx]; in perf_dbgfs_write_run()
1389 "Peer %d outbuf reduced to %pa\n", peer->pidx, in perf_setup_peer_mw()
1399 int pidx, lport, ret; in perf_init_peers() local
1403 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_init_peers()
1404 peer = &perf->peers[pidx]; in perf_init_peers()
1407 peer->pidx = pidx; in perf_init_peers()
1408 if (lport < ntb_peer_port_number(perf->ntb, pidx)) { in perf_init_peers()
1410 perf->gidx = pidx; in perf_init_peers()
1411 peer->gidx = pidx + 1; in perf_init_peers()
1413 peer->gidx = pidx; in perf_init_peers()
1418 perf->gidx = pidx; in perf_init_peers()
1420 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_init_peers()
1421 ret = perf_setup_peer_mw(&perf->peers[pidx]); in perf_init_peers()