dev/sfxge/sfxge_ev.c

50 	struct sfxge_txq *txq;
58 	if ((txq = evq->txq) != NULL) {
59 		evq->txq = NULL;
60 		evq->txqs = &(evq->txq);
65 			next = txq->next;
66 			txq->next = NULL;
68 			KASSERT(txq->evq_index == index,
69 			    ("txq->evq_index != index"));
71 			if (txq->pending != txq->completed)
72 				sfxge_tx_qcomplete(txq, evq);
74 			txq = next;
75 		} while (txq != NULL);
266 	    (label == SFXGE_TXQ_IP_TCP_UDP_CKSUM), ("unexpected txq label"));
268 	return (evq->sc->txq[index]);
275 	struct sfxge_txq *txq;
282 	txq = sfxge_get_txq_by_label(evq, label);
284 	KASSERT(txq != NULL, ("txq == NULL"));
285 	KASSERT(evq->index == txq->evq_index,
286 	    ("evq->index != txq->evq_index"));
288 	if (__predict_false(txq->init_state != SFXGE_TXQ_STARTED))
291 	stop = (id + 1) & txq->ptr_mask;
292 	id = txq->pending & txq->ptr_mask;
294 	delta = (stop >= id) ? (stop - id) : (txq->entries - id + stop);
295 	txq->pending += delta;
299 	if (txq->next == NULL &&
300 	    evq->txqs != &(txq->next)) {
301 		*(evq->txqs) = txq;
302 		evq->txqs = &(txq->next);
305 	if (txq->pending - txq->completed >= SFXGE_TX_BATCH)
306 		sfxge_tx_qcomplete(txq, evq);
317 	struct sfxge_txq *txq;
325 	txq = sc->txq[txq_index];
327 	KASSERT(txq != NULL, ("txq == NULL"));
328 	KASSERT(txq->init_state == SFXGE_TXQ_INITIALIZED,
329 	    ("txq not initialized"));
331 	if (txq->evq_index == evq->index) {
332 		sfxge_tx_qflush_done(txq);
337 	evq = sc->evq[txq->evq_index];
339 	label = txq->type;
398 		struct sfxge_txq *txq = sfxge_get_txq_by_label(evq, label);
400 		KASSERT(txq != NULL, ("txq == NULL"));
401 		KASSERT(evq->index == txq->evq_index,
402 		    ("evq->index != txq->evq_index"));
404 		sfxge_tx_qflush_done(txq);
649 	KASSERT(evq->txq == NULL, ("evq->txq != NULL"));
650 	KASSERT(evq->txqs == &evq->txq, ("evq->txqs != &evq->txq"));
837 	KASSERT(evq->txqs == &evq->txq, ("evq->txqs != &evq->txq"));
880 	evq->txqs = &evq->txq;