hw/hfi1/tid_rdma.c

125 			     struct hfi1_pkt_state *ps);
5008 int hfi1_make_tid_rdma_pkt(struct rvt_qp *qp, struct hfi1_pkt_state *ps)
5036 		ps->s_txreq = get_waiting_verbs_txreq(iowork);
5037 		if (ps->s_txreq || hfi1_make_rc_req(qp, ps)) {
5043 	ps->s_txreq = get_txreq(ps->dev, qp);
5044 	if (!ps->s_txreq)
5047 	ohdr = &ps->s_txreq->phdr.hdr.ibh.u.oth;
5050 	    make_tid_rdma_ack(qp, ohdr, ps))
5163 	ps->s_txreq->hdr_dwords = hwords;
5164 	ps->s_txreq->sde = priv->s_sde;
5165 	ps->s_txreq->ss = ss;
5166 	ps->s_txreq->s_cur_size = len;
5168 			     middle, ps);
5171 	hfi1_put_txreq(ps->s_txreq);
5173 	ps->s_txreq = NULL;
5188 			     struct hfi1_pkt_state *ps)
5312 	ps->s_txreq->hdr_dwords = hwords;
5313 	ps->s_txreq->sde = qpriv->s_sde;
5314 	ps->s_txreq->s_cur_size = len;
5315 	ps->s_txreq->ss = NULL;
5317 			     ps);
5318 	ps->s_txreq->txreq.flags |= SDMA_TXREQ_F_VIP;
5351 	struct hfi1_pkt_state ps;
5354 	ps.dev = to_idev(qp->ibqp.device);
5355 	ps.ibp = to_iport(qp->ibqp.device, qp->port_num);
5356 	ps.ppd = ppd_from_ibp(ps.ibp);
5357 	ps.wait = iowait_get_tid_work(&priv->s_iowait);
5358 	ps.in_thread = false;
5359 	ps.timeout_int = qp->timeout_jiffies / 8;
5362 	spin_lock_irqsave(&qp->s_lock, ps.flags);
5368 		spin_unlock_irqrestore(&qp->s_lock, ps.flags);
5374 	ps.timeout = jiffies + ps.timeout_int;
5375 	ps.cpu = priv->s_sde ? priv->s_sde->cpu :
5376 		cpumask_first(cpumask_of_node(ps.ppd->dd->node));
5377 	ps.pkts_sent = false;
5380 	ps.s_txreq = get_waiting_verbs_txreq(ps.wait);
5383 		if (ps.s_txreq) {
5386 				ps.wait = iowait_get_ib_work(&priv->s_iowait);
5388 			spin_unlock_irqrestore(&qp->s_lock, ps.flags);
5394 			if (hfi1_verbs_send(qp, &ps))
5398 			if (hfi1_schedule_send_yield(qp, &ps, true))
5401 			spin_lock_irqsave(&qp->s_lock, ps.flags);
5405 				ps.wait = iowait_get_tid_work(&priv->s_iowait);
5411 	} while (hfi1_make_tid_rdma_pkt(qp, &ps));
5412 	iowait_starve_clear(ps.pkts_sent, &priv->s_iowait);
5413 	spin_unlock_irqrestore(&qp->s_lock, ps.flags);