dev/netmap/netmap_pipe.c

185 	struct netmap_kring *rxkring = txkring->pipe;
189 	struct netmap_ring *txring = txkring->ring, *rxring = rxkring->ring;
191 	nm_prdis("%p: %s %x -> %s", txkring, txkring->name, flags, rxkring->name);
228 		rxkring->pipe_tail = nk; /* only publish complete packets */
229 		rxkring->nm_notify(rxkring, 0);
236 netmap_pipe_rxsync(struct netmap_kring *rxkring, int flags)
238 	struct netmap_kring *txkring = rxkring->pipe;
239 	u_int k, lim = rxkring->nkr_num_slots - 1;
241 	struct netmap_ring *txring = txkring->ring, *rxring = rxkring->ring;
243 	nm_prdis("%p: %s %x -> %s", txkring, txkring->name, flags, rxkring->name);
245 		rxkring->nr_hwcur, rxkring->nr_hwtail,
246 		rxkring->rcur, rxkring->rhead, rxkring->rtail);
249 	rxkring->nr_hwtail = rxkring->pipe_tail;
251 	m = rxkring->rhead - rxkring->nr_hwcur; /* released slots */
253 		m += rxkring->nkr_num_slots;
260 	for (k = rxkring->nr_hwcur; m; m--, k = nm_next(k, lim)) {
273 	rxkring->nr_hwcur = k;
276 		rxkring->nr_hwcur, rxkring->nr_hwtail,
277 		rxkring->rcur, rxkring->rhead, rxkring->rtail, k);