hw/hfi1/opfn.c

8 #include "qp.h"
17 	bool (*request)(struct rvt_qp *qp, u64 *data);
18 	bool (*response)(struct rvt_qp *qp, u64 *data);
19 	bool (*reply)(struct rvt_qp *qp, u64 data);
20 	void (*error)(struct rvt_qp *qp);
34 static void opfn_schedule_conn_request(struct rvt_qp *qp);
41 static void opfn_conn_request(struct rvt_qp *qp)
43 	struct hfi1_qp_priv *priv = qp->priv;
51 	trace_hfi1_opfn_state_conn_request(qp);
70 	if (!extd || !extd->request || !extd->request(qp, &data)) {
80 	trace_hfi1_opfn_data_conn_request(qp, capcode, data);
92 	ret = ib_post_send(&qp->ibqp, &wr.wr, NULL);
95 	trace_hfi1_opfn_state_conn_request(qp);
98 	trace_hfi1_msg_opfn_conn_request(qp, "ib_ost_send failed: ret = ",
106 	opfn_schedule_conn_request(qp);
127 static void opfn_schedule_conn_request(struct rvt_qp *qp)
129 	struct hfi1_qp_priv *priv = qp->priv;
131 	trace_hfi1_opfn_state_sched_conn_request(qp);
135 void opfn_conn_response(struct rvt_qp *qp, struct rvt_ack_entry *e,
138 	struct hfi1_qp_priv *priv = qp->priv;
144 	trace_hfi1_opfn_state_conn_response(qp);
146 	trace_hfi1_opfn_data_conn_response(qp, capcode, data);
165 			extd->error(qp);
168 	if (extd->response(qp, &data))
171 	trace_hfi1_opfn_state_conn_response(qp);
175 void opfn_conn_reply(struct rvt_qp *qp, u64 data)
177 	struct hfi1_qp_priv *priv = qp->priv;
182 	trace_hfi1_opfn_state_conn_reply(qp);
184 	trace_hfi1_opfn_data_conn_reply(qp, capcode, data);
201 	if (extd->reply(qp, data))
209 	trace_hfi1_opfn_state_conn_reply(qp);
214 void opfn_conn_error(struct rvt_qp *qp)
216 	struct hfi1_qp_priv *priv = qp->priv;
221 	trace_hfi1_opfn_state_conn_error(qp);
222 	trace_hfi1_msg_opfn_conn_error(qp, "error. qp state ", (u64)qp->state);
233 			extd->error(qp);
242 void opfn_qp_init(struct rvt_qp *qp, struct ib_qp_attr *attr, int attr_mask)
244 	struct ib_qp *ibqp = &qp->ibqp;
245 	struct hfi1_qp_priv *priv = qp->priv;
256 			priv->tid_retry_timeout_jiffies = qp->timeout_jiffies;
257 		if (qp->pmtu == enum_to_mtu(OPA_MTU_4096) ||
258 		    qp->pmtu == enum_to_mtu(OPA_MTU_8192)) {
259 			tid_rdma_opfn_init(qp, local);
283 					opfn_schedule_conn_request(qp);
293 void opfn_trigger_conn_request(struct rvt_qp *qp, u32 bth1)
295 	struct hfi1_qp_priv *priv = qp->priv;
300 		if (qp->state == IB_QPS_RTS)
301 			opfn_conn_request(qp);