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()
287 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
301 static int perf_spad_cmd_recv(struct perf_ctx *perf, int *pidx, in perf_spad_cmd_recv() argument
315 for (*pidx = 0; *pidx < perf->pcnt; (*pidx)++) { in perf_spad_cmd_recv()
316 peer = &perf->peers[*pidx]; in perf_spad_cmd_recv()
370 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_LDATA, in perf_msg_cmd_send()
378 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_HDATA, in perf_msg_cmd_send()
382 ntb_peer_msg_write(perf->ntb, peer->pidx, PERF_MSG_CMD, cmd); in perf_msg_cmd_send()
390 static int perf_msg_cmd_recv(struct perf_ctx *perf, int *pidx, in perf_msg_cmd_recv() argument
401 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_CMD); in perf_msg_cmd_recv()
404 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_LDATA); in perf_msg_cmd_recv()
407 val = ntb_msg_read(perf->ntb, pidx, PERF_MSG_HDATA); in perf_msg_cmd_recv()
456 int ret, pidx, cmd; in perf_cmd_recv() local
459 while (!(ret = perf->cmd_recv(perf, &pidx, &cmd, &data))) { in perf_cmd_recv()
460 peer = &perf->peers[pidx]; in perf_cmd_recv()
484 int pidx; in perf_link_event() local
486 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_link_event()
487 peer = &perf->peers[pidx]; in perf_link_event()
531 (void)ntb_peer_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx); in perf_free_outbuf()
540 ret = ntb_peer_mw_set_trans(perf->ntb, peer->pidx, peer->gidx, in perf_setup_outbuf()
558 (void)ntb_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx); in perf_free_inbuf()
571 ret = ntb_mw_get_align(perf->ntb, peer->pidx, perf->gidx, in perf_setup_inbuf()
600 ret = ntb_mw_set_trans(perf->ntb, peer->pidx, peer->gidx, in perf_setup_inbuf()
735 int pidx; in perf_disable_service() local
748 for (pidx = 0; pidx < perf->pcnt; pidx++) in perf_disable_service()
749 perf_cmd_exec(&perf->peers[pidx], PERF_CMD_CLEAR); in perf_disable_service()
751 for (pidx = 0; pidx < perf->pcnt; pidx++) in perf_disable_service()
752 flush_work(&perf->peers[pidx].service); in perf_disable_service()
754 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_disable_service()
755 struct perf_peer *peer = &perf->peers[pidx]; in perf_disable_service()
1095 " Peer %d test statistics:\n", perf->test_peer->pidx); in perf_read_stats()
1157 int ret, pidx; in perf_dbgfs_read_info() local
1176 ntb_peer_port_number(perf->ntb, perf->test_peer->pidx), in perf_dbgfs_read_info()
1177 perf->test_peer->pidx); in perf_dbgfs_read_info()
1182 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_dbgfs_read_info()
1183 peer = &perf->peers[pidx]; in perf_dbgfs_read_info()
1187 ntb_peer_port_number(perf->ntb, peer->pidx), peer->pidx, in perf_dbgfs_read_info()
1257 int pidx, ret; in perf_dbgfs_write_run() local
1259 ret = kstrtoint_from_user(ubuf, size, 0, &pidx); in perf_dbgfs_write_run()
1263 if (pidx < 0 || pidx >= perf->pcnt) in perf_dbgfs_write_run()
1266 peer = &perf->peers[pidx]; in perf_dbgfs_write_run()
1394 "Peer %d outbuf reduced to %pa\n", peer->pidx, in perf_setup_peer_mw()
1404 int pidx, lport, ret; in perf_init_peers() local
1408 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_init_peers()
1409 peer = &perf->peers[pidx]; in perf_init_peers()
1412 peer->pidx = pidx; in perf_init_peers()
1413 if (lport < ntb_peer_port_number(perf->ntb, pidx)) { in perf_init_peers()
1415 perf->gidx = pidx; in perf_init_peers()
1416 peer->gidx = pidx + 1; in perf_init_peers()
1418 peer->gidx = pidx; in perf_init_peers()
1423 perf->gidx = pidx; in perf_init_peers()
1425 for (pidx = 0; pidx < perf->pcnt; pidx++) { in perf_init_peers()
1426 ret = perf_setup_peer_mw(&perf->peers[pidx]); in perf_init_peers()