dev/sfxge/sfxge_ev.c

54 	struct sfxge_rxq *rxq;
61 	rxq = sc->rxq[index];
83 	if (rxq->pending != rxq->completed)
84 		sfxge_rx_qcomplete(rxq, eop);
90 	struct sfxge_rxq *rxq;
92 	KASSERT(label == 0, ("unexpected rxq label != 0"));
94 	rxq = evq->sc->rxq[evq->index];
96 	KASSERT(rxq != NULL, ("rxq == NULL"));
97 	KASSERT(evq->index == rxq->index, ("evq->index != rxq->index"));
99 	return (rxq);
108 	struct sfxge_rxq *rxq;
121 	rxq = sfxge_get_rxq_by_label(evq, label);
122 	if (__predict_false(rxq->init_state != SFXGE_RXQ_STARTED))
125 	stop = (id + 1) & rxq->ptr_mask;
126 	id = rxq->pending & rxq->ptr_mask;
127 	delta = (stop >= id) ? (stop - id) : (rxq->entries - id + stop);
128 	rxq->pending += delta;
144 	rx_desc = &rxq->queue[id];
148 	for (; id != stop; id = (id + 1) & rxq->ptr_mask) {
149 		rx_desc = &rxq->queue[id];
160 	if (rxq->pending - rxq->completed >= SFXGE_RX_BATCH)
207 	struct sfxge_rxq *rxq;
215 	rxq = sc->rxq[rxq_index];
217 	KASSERT(rxq != NULL, ("rxq == NULL"));
220 	index = rxq->index;
222 		sfxge_rx_qflush_done(rxq);
227 	magic = sfxge_sw_ev_rxq_magic(SFXGE_SW_EV_RX_QFLUSH_DONE, rxq);
241 	struct sfxge_rxq *rxq;
249 	rxq = sc->rxq[rxq_index];
251 	KASSERT(rxq != NULL, ("rxq == NULL"));
254 	index = rxq->index;
256 	magic = sfxge_sw_ev_rxq_magic(SFXGE_SW_EV_RX_QFLUSH_FAILED, rxq);