dev/sfxge/sfxge_ev.c

55 	struct sfxge_txq *txq;
63 	if ((txq = evq->txq) != NULL) {
64 		evq->txq = NULL;
65 		evq->txqs = &(evq->txq);
70 			next = txq->next;
71 			txq->next = NULL;
73 			KASSERT(txq->evq_index == index,
74 			    ("txq->evq_index != index"));
76 			if (txq->pending != txq->completed)
77 				sfxge_tx_qcomplete(txq, evq);
79 			txq = next;
80 		} while (txq != NULL);
271 	    (label == SFXGE_TXQ_IP_TCP_UDP_CKSUM), ("unexpected txq label"));
273 	return (evq->sc->txq[index]);
280 	struct sfxge_txq *txq;
287 	txq = sfxge_get_txq_by_label(evq, label);
289 	KASSERT(txq != NULL, ("txq == NULL"));
290 	KASSERT(evq->index == txq->evq_index,
291 	    ("evq->index != txq->evq_index"));
293 	if (__predict_false(txq->init_state != SFXGE_TXQ_STARTED))
296 	stop = (id + 1) & txq->ptr_mask;
297 	id = txq->pending & txq->ptr_mask;
299 	delta = (stop >= id) ? (stop - id) : (txq->entries - id + stop);
300 	txq->pending += delta;
304 	if (txq->next == NULL &&
305 	    evq->txqs != &(txq->next)) {
306 		*(evq->txqs) = txq;
307 		evq->txqs = &(txq->next);
310 	if (txq->pending - txq->completed >= SFXGE_TX_BATCH)
311 		sfxge_tx_qcomplete(txq, evq);
322 	struct sfxge_txq *txq;
329 	txq = sc->txq[txq_index];
331 	KASSERT(txq != NULL, ("txq == NULL"));
332 	KASSERT(txq->init_state == SFXGE_TXQ_INITIALIZED,
333 	    ("txq not initialized"));
335 	if (txq->evq_index == evq->index) {
336 		sfxge_tx_qflush_done(txq);
341 	evq = sc->evq[txq->evq_index];
342 	magic = sfxge_sw_ev_txq_magic(SFXGE_SW_EV_TX_QFLUSH_DONE, txq);
380 		struct sfxge_txq *txq = sfxge_get_txq_by_label(evq, label);
382 		KASSERT(txq != NULL, ("txq == NULL"));
383 		KASSERT(evq->index == txq->evq_index,
384 		    ("evq->index != txq->evq_index"));
386 		sfxge_tx_qflush_done(txq);
631 	KASSERT(evq->txq == NULL, ("evq->txq != NULL"));
632 	KASSERT(evq->txqs == &evq->txq, ("evq->txqs != &evq->txq"));
816 	KASSERT(evq->txqs == &evq->txq, ("evq->txqs != &evq->txq"));
859 	evq->txqs = &evq->txq;