186 	struct netmap_kring *rxkring = txkring->pipe;  in netmap_pipe_txsync()  local
190 	struct netmap_ring *txring = txkring->ring, *rxring = rxkring->ring;  in netmap_pipe_txsync()
192 	nm_prdis("%p: %s %x -> %s", txkring, txkring->name, flags, rxkring->name);  in netmap_pipe_txsync()
213 		uint64_t off = nm_get_offset(rxkring, rs);  in netmap_pipe_txsync()
216 		if (nm_get_offset(rxkring, rs) < off) {  in netmap_pipe_txsync()
217 			nm_write_offset(rxkring, rs, off);  in netmap_pipe_txsync()
233 		rxkring->pipe_tail = nk; /* only publish complete packets */  in netmap_pipe_txsync()
234 		rxkring->nm_notify(rxkring, 0);  in netmap_pipe_txsync()
241 netmap_pipe_rxsync(struct netmap_kring *rxkring, int flags)  in netmap_pipe_rxsync()  argument
243 	struct netmap_kring *txkring = rxkring->pipe;  in netmap_pipe_rxsync()
244 	u_int k, lim = rxkring->nkr_num_slots - 1;  in netmap_pipe_rxsync()
246 	struct netmap_ring *txring = txkring->ring, *rxring = rxkring->ring;  in netmap_pipe_rxsync()
248 	nm_prdis("%p: %s %x -> %s", txkring, txkring->name, flags, rxkring->name);  in netmap_pipe_rxsync()
250 		rxkring->nr_hwcur, rxkring->nr_hwtail,  in netmap_pipe_rxsync()
251 		rxkring->rcur, rxkring->rhead, rxkring->rtail);  in netmap_pipe_rxsync()
254 	rxkring->nr_hwtail = rxkring->pipe_tail;  in netmap_pipe_rxsync()
256 	m = rxkring->rhead - rxkring->nr_hwcur; /* released slots */  in netmap_pipe_rxsync()
258 		m += rxkring->nkr_num_slots;  in netmap_pipe_rxsync()
265 	for (k = rxkring->nr_hwcur; m; m--, k = nm_next(k, lim)) {  in netmap_pipe_rxsync()
278 	rxkring->nr_hwcur = k;  in netmap_pipe_rxsync()
281 		rxkring->nr_hwcur, rxkring->nr_hwtail,  in netmap_pipe_rxsync()
282 		rxkring->rcur, rxkring->rhead, rxkring->rtail, k);  in netmap_pipe_rxsync()