hw/hfi1/opfn.c

9 #include "opfn.h"
52 	spin_lock_irqsave(&priv->opfn.lock, flags);
58 	if (!priv->opfn.extended || !priv->opfn.requested ||
59 	    priv->opfn.requested == priv->opfn.completed || priv->opfn.curr)
62 	mask = priv->opfn.requested & ~priv->opfn.completed;
65 		priv->opfn.completed |= OPFN_CODE(capcode);
76 		priv->opfn.completed |= OPFN_CODE(capcode);
88 	priv->opfn.curr = capcode;	/* A new request is now in progress */
89 	/* Drop opfn.lock before calling ib_post_send() */
90 	spin_unlock_irqrestore(&priv->opfn.lock, flags);
100 	spin_lock_irqsave(&priv->opfn.lock, flags);
103 	 * clear opfn.curr and reschedule to try again
105 	priv->opfn.curr = STL_VERBS_EXTD_NONE;
108 	spin_unlock_irqrestore(&priv->opfn.lock, flags);
117 	qpriv = container_of(od, struct hfi1_qp_priv, opfn);
132 	queue_work(opfn_wq, &priv->opfn.opfn_work);
157 	spin_lock_irqsave(&priv->opfn.lock, flags);
158 	if (priv->opfn.completed & OPFN_CODE(capcode)) {
163 		priv->opfn.completed &= ~OPFN_CODE(capcode);
169 		priv->opfn.completed |= OPFN_CODE(capcode);
172 	spin_unlock_irqrestore(&priv->opfn.lock, flags);
188 	spin_lock_irqsave(&priv->opfn.lock, flags);
193 	if (!priv->opfn.curr || capcode != priv->opfn.curr)
202 		priv->opfn.completed |= OPFN_CODE(capcode);
205 	 * Clear opfn.curr to indicate that the previous request is no longer in
208 	priv->opfn.curr = STL_VERBS_EXTD_NONE;
211 	spin_unlock_irqrestore(&priv->opfn.lock, flags);
228 	spin_lock_irqsave(&priv->opfn.lock, flags);
229 	while (priv->opfn.completed) {
230 		capcode = priv->opfn.completed & ~(priv->opfn.completed - 1);
234 		priv->opfn.completed &= ~OPFN_CODE(capcode);
236 	priv->opfn.extended = 0;
237 	priv->opfn.requested = 0;
238 	priv->opfn.curr = STL_VERBS_EXTD_NONE;
239 	spin_unlock_irqrestore(&priv->opfn.lock, flags);
251 	spin_lock_irqsave(&priv->opfn.lock, flags);
266 				priv->opfn.requested |= OPFN_MASK(TID_RDMA);
269 				 * opfn.completed for TID RDMA has already been
274 				if (priv->opfn.completed &
276 					priv->opfn.completed &=
279 					 * Since the opfn.completed bit was
281 					 * that the opfn.extended is also set.
290 	spin_unlock_irqrestore(&priv->opfn.lock, flags);
297 	if (!priv->opfn.extended && hfi1_opfn_extended(bth1) &&
299 		priv->opfn.extended = 1;