Lines Matching full:flows

47 /* Reserved generation value to set to unused flows for kernel contexts */
757 u32 generation = rcd->flows[flow_idx].generation; in kern_setup_hw_flow()
775 rcd->flows[flow_idx].generation = in kern_clear_hw_flow()
776 kern_flow_generation_next(rcd->flows[flow_idx].generation); in kern_clear_hw_flow()
804 rcd->flows[fs->index].generation = fs->generation; in hfi1_kern_setup_hw_flow()
853 rcd->flows[i].generation = mask_generation(get_random_u32()); in hfi1_kern_init_ctxt_generations()
1436 * (6) Reserves and programs HW flows.
1443 * invocation of function call. With flow = &req->flows[req->flow_idx],
1465 struct tid_rdma_flow *flow = &req->flows[req->setup_head]; in hfi1_kern_exp_rcv_setup()
1556 struct tid_rdma_flow *flow = &req->flows[req->clear_tail]; in hfi1_kern_exp_rcv_clear()
1612 kfree(req->flows); in hfi1_kern_exp_rcv_free_flows()
1613 req->flows = NULL; in hfi1_kern_exp_rcv_free_flows()
1634 struct tid_rdma_flow *flows; in hfi1_kern_exp_rcv_alloc_flows() local
1637 if (likely(req->flows)) in hfi1_kern_exp_rcv_alloc_flows()
1639 flows = kmalloc_node(MAX_FLOWS * sizeof(*flows), gfp, in hfi1_kern_exp_rcv_alloc_flows()
1641 if (!flows) in hfi1_kern_exp_rcv_alloc_flows()
1645 flows[i].req = req; in hfi1_kern_exp_rcv_alloc_flows()
1646 flows[i].npagesets = 0; in hfi1_kern_exp_rcv_alloc_flows()
1647 flows[i].pagesets[0].mapped = 0; in hfi1_kern_exp_rcv_alloc_flows()
1648 flows[i].resync_npkts = 0; in hfi1_kern_exp_rcv_alloc_flows()
1650 req->flows = flows; in hfi1_kern_exp_rcv_alloc_flows()
1691 flow = &req->flows[tail]; in find_flow_ib()
1708 struct tid_rdma_flow *flow = &req->flows[req->flow_idx]; in hfi1_build_tid_rdma_read_packet()
1864 flow = &req->flows[req->flow_idx]; in hfi1_build_tid_rdma_read_req()
1903 flow = &req->flows[req->setup_head]; in tid_rdma_rcv_read_request()
2127 fstate = &req->flows[req->clear_tail].flow_state; in tid_rdma_rcv_error()
2351 struct tid_rdma_flow *flow = &req->flows[req->clear_tail]; in hfi1_build_tid_rdma_read_resp()
2474 flow = &req->flows[req->clear_tail]; in hfi1_rc_rcv_tid_rdma_read_resp()
2638 flow = &req->flows[req->clear_tail]; in restart_tid_rdma_read_req()
2756 flow = &req->flows[req->clear_tail]; in handle_read_kdeth_eflags()
2945 flow = &req->flows[req->clear_tail]; in hfi1_handle_kdeth_eflags()
3070 flow = &req->flows[fidx]; in hfi1_tid_rdma_restart_req()
3136 /* Reset all the flows that we are going to resend */ in hfi1_tid_rdma_restart_req()
3142 req->flows[fidx].sent = 0; in hfi1_tid_rdma_restart_req()
3143 req->flows[fidx].pkt = 0; in hfi1_tid_rdma_restart_req()
3144 req->flows[fidx].tid_idx = 0; in hfi1_tid_rdma_restart_req()
3145 req->flows[fidx].tid_offset = 0; in hfi1_tid_rdma_restart_req()
3146 req->flows[fidx].resync_npkts = 0; in hfi1_tid_rdma_restart_req()
3410 * flows are released and recycled at each sync point. in hfi1_compute_tid_rdma_flow_wt()
3852 flow = &req->flows[req->flow_idx]; in hfi1_build_tid_rdma_write_resp()
4106 flow = &req->flows[req->setup_head]; in hfi1_rc_rcv_tid_rdma_write_resp()
4210 struct tid_rdma_flow *flow = &req->flows[req->clear_tail]; in hfi1_build_tid_rdma_packet()
4295 flow = &req->flows[req->clear_tail]; in hfi1_rc_rcv_tid_rdma_write_data()
4349 rcd->flows[flow->idx].psn = psn & HFI1_KDETH_BTH_SEQ_MASK; in hfi1_rc_rcv_tid_rdma_write_data()
4433 struct tid_rdma_flow *flow = &req->flows[iflow]; in hfi1_build_tid_rdma_write_ack()
4545 flow = &req->flows[req->acked_tail]; in hfi1_rc_rcv_tid_rdma_ack()
4575 flow = &req->flows[req->acked_tail]; in hfi1_rc_rcv_tid_rdma_ack()
4637 flow = &req->flows[req->acked_tail]; in hfi1_rc_rcv_tid_rdma_ack()
4675 flow = &rptr->flows[fidx]; in hfi1_rc_rcv_tid_rdma_ack()
4721 if (!req->flows) in hfi1_rc_rcv_tid_rdma_ack()
4723 flow = &req->flows[req->acked_tail]; in hfi1_rc_rcv_tid_rdma_ack()
4850 struct tid_rdma_flow *flow = &req->flows[fidx]; in hfi1_build_tid_rdma_resync()
4912 rcd->flows[fs->index].generation = generation; in hfi1_rc_rcv_tid_rdma_resync()
4947 flow = &req->flows[flow_idx]; in hfi1_rc_rcv_tid_rdma_resync()
5246 * and the clear_tail is the number of flows that are in make_tid_rdma_ack()
5289 full_flow_psn(&req->flows[flow], in make_tid_rdma_ack()
5290 req->flows[flow].flow_state.lpsn)) > 0))) { in make_tid_rdma_ack()