Lines Matching refs:opfn
52 spin_lock_irqsave(&priv->opfn.lock, flags); in opfn_conn_request()
58 if (!priv->opfn.extended || !priv->opfn.requested || in opfn_conn_request()
59 priv->opfn.requested == priv->opfn.completed || priv->opfn.curr) in opfn_conn_request()
62 mask = priv->opfn.requested & ~priv->opfn.completed; in opfn_conn_request()
65 priv->opfn.completed |= OPFN_CODE(capcode); in opfn_conn_request()
76 priv->opfn.completed |= OPFN_CODE(capcode); in opfn_conn_request()
88 priv->opfn.curr = capcode; /* A new request is now in progress */ in opfn_conn_request()
90 spin_unlock_irqrestore(&priv->opfn.lock, flags); in opfn_conn_request()
100 spin_lock_irqsave(&priv->opfn.lock, flags); in opfn_conn_request()
105 priv->opfn.curr = STL_VERBS_EXTD_NONE; in opfn_conn_request()
108 spin_unlock_irqrestore(&priv->opfn.lock, flags); in opfn_conn_request()
117 qpriv = container_of(od, struct hfi1_qp_priv, opfn); in opfn_send_conn_request()
132 queue_work(opfn_wq, &priv->opfn.opfn_work); in opfn_schedule_conn_request()
157 spin_lock_irqsave(&priv->opfn.lock, flags); in opfn_conn_response()
158 if (priv->opfn.completed & OPFN_CODE(capcode)) { in opfn_conn_response()
163 priv->opfn.completed &= ~OPFN_CODE(capcode); in opfn_conn_response()
169 priv->opfn.completed |= OPFN_CODE(capcode); in opfn_conn_response()
172 spin_unlock_irqrestore(&priv->opfn.lock, flags); in opfn_conn_response()
188 spin_lock_irqsave(&priv->opfn.lock, flags); in opfn_conn_reply()
193 if (!priv->opfn.curr || capcode != priv->opfn.curr) in opfn_conn_reply()
202 priv->opfn.completed |= OPFN_CODE(capcode); in opfn_conn_reply()
208 priv->opfn.curr = STL_VERBS_EXTD_NONE; in opfn_conn_reply()
211 spin_unlock_irqrestore(&priv->opfn.lock, flags); in opfn_conn_reply()
228 spin_lock_irqsave(&priv->opfn.lock, flags); in opfn_conn_error()
229 while (priv->opfn.completed) { in opfn_conn_error()
230 capcode = priv->opfn.completed & ~(priv->opfn.completed - 1); in opfn_conn_error()
234 priv->opfn.completed &= ~OPFN_CODE(capcode); in opfn_conn_error()
236 priv->opfn.extended = 0; in opfn_conn_error()
237 priv->opfn.requested = 0; in opfn_conn_error()
238 priv->opfn.curr = STL_VERBS_EXTD_NONE; in opfn_conn_error()
239 spin_unlock_irqrestore(&priv->opfn.lock, flags); in opfn_conn_error()
251 spin_lock_irqsave(&priv->opfn.lock, flags); in opfn_qp_init()
266 priv->opfn.requested |= OPFN_MASK(TID_RDMA); in opfn_qp_init()
274 if (priv->opfn.completed & in opfn_qp_init()
276 priv->opfn.completed &= in opfn_qp_init()
290 spin_unlock_irqrestore(&priv->opfn.lock, flags); in opfn_qp_init()
297 if (!priv->opfn.extended && hfi1_opfn_extended(bth1) && in opfn_trigger_conn_request()
299 priv->opfn.extended = 1; in opfn_trigger_conn_request()