/dragonfly/sys/kern/ |
H A D | vfs_journal.c | 184 bytes = jo->fifo.windex - jo->fifo.rindex; in journal_wthread() 203 rawp = (void *)(jo->fifo.membase + (jo->fifo.rindex & jo->fifo.mask)); in journal_wthread() 215 if (jo->fifo.rindex == jo->fifo.xindex) { in journal_wthread() 235 avail = jo->fifo.size - (jo->fifo.rindex & jo->fifo.mask); in journal_wthread() 370 rawp = (void *)(jo->fifo.membase + (jo->fifo.xindex & jo->fifo.mask)); in journal_rthread() 466 avail = jo->fifo.size - (jo->fifo.windex - jo->fifo.xindex); in journal_commit_wakeup() 527 availtoend = jo->fifo.size - (jo->fifo.windex & jo->fifo.mask); in journal_reserve() 540 avail = jo->fifo.size - (jo->fifo.windex - jo->fifo.xindex); in journal_reserve() 564 rawp = (void *)(jo->fifo.membase + (jo->fifo.windex & jo->fifo.mask)); in journal_reserve() 645 avail = jo->fifo.size - (jo->fifo.windex - jo->fifo.xindex) + osize; in journal_extend() [all …]
|
H A D | vfs_jops.c | 288 jo->fifo.size = 1; in journal_install_vfs_journal() 289 while (jo->fifo.size < size) in journal_install_vfs_journal() 290 jo->fifo.size <<= 1; in journal_install_vfs_journal() 309 jo->fifo.mask = jo->fifo.size - 1; in journal_install_vfs_journal() 310 jo->fifo.membase = kmalloc(jo->fifo.size, M_JFIFO, M_WAITOK|M_ZERO|M_NULLOK); in journal_install_vfs_journal() 311 if (jo->fifo.membase == NULL) in journal_install_vfs_journal() 389 jo->fifo.rindex = jo->fifo.xindex; in journal_restart() 447 if (jo->fifo.membase) in journal_destroy() 448 kfree(jo->fifo.membase, M_JFIFO); in journal_destroy() 494 rstat->membufused = jo->fifo.windex - jo->fifo.xindex; in journal_status_vfs_journal() [all …]
|
/dragonfly/sys/dev/virtual/vkernel/net/ |
H A D | if_vke.c | 178 fifo->array[NETFIFOINDEX(fifo->windex, sc)] = m; in vke_txfifo_done_enqueue() 180 ++fifo->windex; in vke_txfifo_done_enqueue() 198 m = fifo->array[NETFIFOINDEX(fifo->rindex, sc)]; in vke_txfifo_done_dequeue() 199 fifo->array[NETFIFOINDEX(fifo->rindex, sc)] = nm; in vke_txfifo_done_dequeue() 218 fifo->array[NETFIFOINDEX(fifo->windex, sc)] = m; in vke_txfifo_enqueue() 239 m = fifo->array[NETFIFOINDEX(fifo->rindex, sc)]; in vke_txfifo_dequeue() 240 fifo->array[NETFIFOINDEX(fifo->rindex, sc)] = NULL; in vke_txfifo_dequeue() 272 m = fifo->array[NETFIFOINDEX(fifo->rindex, sc)]; in vke_rxfifo_dequeue() 273 fifo->array[NETFIFOINDEX(fifo->rindex, sc)] = newm; in vke_rxfifo_dequeue() 293 m = fifo->array[NETFIFOINDEX(fifo->rindex, sc)]; in vke_rxfifo_sniff() [all …]
|
/dragonfly/usr.sbin/makefs/hammer2/ |
H A D | hammer2_admin.c | 348 fifo->array = krealloc(fifo->array, size, M_HAMMER2, in hammer2_xop_fifo_alloc() 775 while (fifo->ri != fifo->wi) { in hammer2_xop_retire() 776 chain = fifo->array[fifo->ri & fifo_mask(xop)]; in hammer2_xop_retire() 874 if (fifo->ri == fifo->wi - HAMMER2_XOPFIFO) in hammer2_xop_feed() 876 while (fifo->ri == fifo->wi - xop->fifo_size) { in hammer2_xop_feed() 891 fifo->errors[fifo->wi & fifo_mask(xop)] = error; in hammer2_xop_feed() 892 fifo->array[fifo->wi & fifo_mask(xop)] = chain; in hammer2_xop_feed() 986 if (fifo->ri != fifo->wi) { in hammer2_xop_collect() 988 chain = fifo->array[fifo->ri & fifo_mask(xop)]; in hammer2_xop_collect() 989 error = fifo->errors[fifo->ri & fifo_mask(xop)]; in hammer2_xop_collect() [all …]
|
/dragonfly/sys/netgraph7/bluetooth/drivers/ubtbcmfw/ |
H A D | ubtbcmfw.c | 312 usb_fifo_put_data(fifo, pc, 0, actlen, 1); in ubtbcmfw_read_callback() 317 if (usb_fifo_put_bytes_max(fifo) > 0) { in ubtbcmfw_read_callback() 338 ubtbcmfw_start_read(struct usb_fifo *fifo) in ubtbcmfw_start_read() argument 340 struct ubtbcmfw_softc *sc = usb_fifo_softc(fifo); in ubtbcmfw_start_read() 350 ubtbcmfw_stop_read(struct usb_fifo *fifo) in ubtbcmfw_stop_read() argument 352 struct ubtbcmfw_softc *sc = usb_fifo_softc(fifo); in ubtbcmfw_stop_read() 363 ubtbcmfw_start_write(struct usb_fifo *fifo) in ubtbcmfw_start_write() argument 375 ubtbcmfw_stop_write(struct usb_fifo *fifo) in ubtbcmfw_stop_write() argument 387 ubtbcmfw_open(struct usb_fifo *fifo, int fflags) in ubtbcmfw_open() argument 416 ubtbcmfw_close(struct usb_fifo *fifo, int fflags) in ubtbcmfw_close() argument [all …]
|
/dragonfly/sys/dev/smbus/cyapa/ |
H A D | cyapa.c | 1650 return(fifo->rindex == fifo->windex); in fifo_empty() 1664 if (n > (size_t)(fifo->windex - fifo->rindex)) in fifo_ready() 1665 n = (size_t)(fifo->windex - fifo->rindex); in fifo_ready() 1678 return ((size_t)(fifo->windex - fifo->rindex)); 1699 ptr = fifo->buf + (fifo->rindex & CYAPA_BUFMASK); in fifo_read() 1711 if (fifo->rindex == fifo->windex) { in fifo_read_char() 1715 c = fifo->buf[fifo->rindex & CYAPA_BUFMASK]; in fifo_read_char() 1730 if (fifo->windex - fifo->rindex < CYAPA_BUFSIZE) { in fifo_write_char() 1731 fifo->buf[fifo->windex & CYAPA_BUFMASK] = c; in fifo_write_char() 1748 n = (size_t)(CYAPA_BUFSIZE - (fifo->windex - fifo->rindex)); in fifo_space() [all …]
|
/dragonfly/sys/bus/u4b/input/ |
H A D | uep.c | 89 struct usb_fifo_sc fifo; member 353 usb_fifo_detach(&sc->fifo); in uep_detach() 363 uep_start_read(struct usb_fifo *fifo) in uep_start_read() argument 365 struct uep_softc *sc = usb_fifo_softc(fifo); in uep_start_read() 381 uep_stop_read(struct usb_fifo *fifo) in uep_stop_read() argument 383 struct uep_softc *sc = usb_fifo_softc(fifo); in uep_stop_read() 396 uep_open(struct usb_fifo *fifo, int fflags) in uep_open() argument 399 struct uep_softc *sc = usb_fifo_softc(fifo); in uep_open() 414 uep_close(struct usb_fifo *fifo, int fflags) in uep_close() argument 417 struct uep_softc *sc = usb_fifo_softc(fifo); in uep_close() [all …]
|
H A D | uhid.c | 393 uhid_start_read(struct usb_fifo *fifo) in uhid_start_read() argument 395 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_start_read() 405 uhid_stop_read(struct usb_fifo *fifo) in uhid_stop_read() argument 407 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_stop_read() 414 uhid_start_write(struct usb_fifo *fifo) in uhid_start_write() argument 427 uhid_stop_write(struct usb_fifo *fifo) in uhid_stop_write() argument 505 uhid_open(struct usb_fifo *fifo, int fflags) in uhid_open() argument 519 if (usb_fifo_alloc_buffer(fifo, in uhid_open() 525 if (usb_fifo_alloc_buffer(fifo, in uhid_open() 534 uhid_close(struct usb_fifo *fifo, int fflags) in uhid_close() argument [all …]
|
H A D | ums.c | 864 ums_fifo_start_read(struct usb_fifo *fifo) in ums_fifo_start_read() argument 866 struct ums_softc *sc = usb_fifo_softc(fifo); in ums_fifo_start_read() 872 ums_fifo_stop_read(struct usb_fifo *fifo) in ums_fifo_stop_read() argument 874 struct ums_softc *sc = usb_fifo_softc(fifo); in ums_fifo_stop_read() 996 ums_fifo_open(struct usb_fifo *fifo, int fflags) in ums_fifo_open() argument 998 struct ums_softc *sc = usb_fifo_softc(fifo); in ums_fifo_open() 1017 if (usb_fifo_alloc_buffer(fifo, in ums_fifo_open() 1028 ums_fifo_close(struct usb_fifo *fifo, int fflags) in ums_fifo_close() argument 1030 struct ums_softc *sc = usb_fifo_softc(fifo); in ums_fifo_close() 1035 usb_fifo_free_buffer(fifo); in ums_fifo_close() [all …]
|
H A D | wsp.c | 1229 wsp_start_read(struct usb_fifo *fifo) in wsp_start_read() argument 1231 struct wsp_softc *sc = usb_fifo_softc(fifo); in wsp_start_read() 1252 wsp_stop_read(struct usb_fifo *fifo) in wsp_stop_read() argument 1254 struct wsp_softc *sc = usb_fifo_softc(fifo); in wsp_stop_read() 1261 wsp_open(struct usb_fifo *fifo, int fflags) in wsp_open() argument 1266 struct wsp_softc *sc = usb_fifo_softc(fifo); in wsp_open() 1272 if (usb_fifo_alloc_buffer(fifo, in wsp_open() 1278 usb_fifo_free_buffer(fifo); in wsp_open() 1286 wsp_close(struct usb_fifo *fifo, int fflags) in wsp_close() argument 1292 usb_fifo_free_buffer(fifo); in wsp_close() [all …]
|
/dragonfly/sys/vfs/hammer2/ |
H A D | hammer2_admin.c | 718 while (fifo->ri != fifo->wi) { in hammer2_xop_retire() 719 chain = fifo->array[fifo->ri & HAMMER2_XOPFIFO_MASK]; in hammer2_xop_retire() 812 if (fifo->ri == fifo->wi - HAMMER2_XOPFIFO) in hammer2_xop_feed() 814 while (fifo->ri == fifo->wi - HAMMER2_XOPFIFO) { in hammer2_xop_feed() 824 if (fifo->ri == fifo->wi - HAMMER2_XOPFIFO) { in hammer2_xop_feed() 835 fifo->errors[fifo->wi & HAMMER2_XOPFIFO_MASK] = error; in hammer2_xop_feed() 836 fifo->array[fifo->wi & HAMMER2_XOPFIFO_MASK] = chain; in hammer2_xop_feed() 838 ++fifo->wi; in hammer2_xop_feed() 930 if (fifo->ri != fifo->wi) { in hammer2_xop_collect() 932 chain = fifo->array[fifo->ri & HAMMER2_XOPFIFO_MASK]; in hammer2_xop_collect() [all …]
|
/dragonfly/sys/bus/u4b/storage/ |
H A D | urio.c | 354 urio_start_read(struct usb_fifo *fifo) in urio_start_read() argument 356 struct urio_softc *sc = usb_fifo_softc(fifo); in urio_start_read() 362 urio_stop_read(struct usb_fifo *fifo) in urio_stop_read() argument 371 urio_start_write(struct usb_fifo *fifo) in urio_start_write() argument 379 urio_stop_write(struct usb_fifo *fifo) in urio_stop_write() argument 388 urio_open(struct usb_fifo *fifo, int fflags) in urio_open() argument 398 if (usb_fifo_alloc_buffer(fifo, in urio_open() 408 if (usb_fifo_alloc_buffer(fifo, in urio_open() 418 urio_close(struct usb_fifo *fifo, int fflags) in urio_close() argument 421 usb_fifo_free_buffer(fifo); in urio_close() [all …]
|
/dragonfly/sys/bus/u4b/serial/ |
H A D | ulpt.c | 375 ulpt_start_read(struct usb_fifo *fifo) in ulpt_start_read() argument 383 ulpt_stop_read(struct usb_fifo *fifo) in ulpt_stop_read() argument 391 ulpt_start_write(struct usb_fifo *fifo) in ulpt_start_write() argument 399 ulpt_stop_write(struct usb_fifo *fifo) in ulpt_stop_write() argument 407 ulpt_open(struct usb_fifo *fifo, int fflags) in ulpt_open() argument 419 return (unlpt_open(fifo, fflags)); in ulpt_open() 435 if (usb_fifo_alloc_buffer(fifo, in unlpt_open() 441 sc->sc_fifo_open[USB_FIFO_RX] = fifo; in unlpt_open() 448 if (usb_fifo_alloc_buffer(fifo, in unlpt_open() 454 sc->sc_fifo_open[USB_FIFO_TX] = fifo; in unlpt_open() [all …]
|
/dragonfly/sys/bus/u4b/ |
H A D | usbdi.h | 97 typedef int (usb_fifo_open_t)(struct usb_fifo *fifo, int fflags); 98 typedef void (usb_fifo_close_t)(struct usb_fifo *fifo, int fflags); 100 typedef void (usb_fifo_cmd_t)(struct usb_fifo *fifo); 101 typedef void (usb_fifo_filter_t)(struct usb_fifo *fifo, struct usb_mbuf *m); 600 uint32_t usb_fifo_put_bytes_max(struct usb_fifo *fifo); 601 void usb_fifo_put_data(struct usb_fifo *fifo, struct usb_page_cache *pc, 603 void usb_fifo_put_data_linear(struct usb_fifo *fifo, void *ptr, 606 void usb_fifo_put_data_error(struct usb_fifo *fifo); 610 uint8_t usb_fifo_get_data_linear(struct usb_fifo *fifo, void *ptr, 616 void usb_fifo_get_data_error(struct usb_fifo *fifo); [all …]
|
H A D | usb_dev.c | 247 ppf = cpd->udev->fifo; in usb_ref_device() 263 ppf = cpd->udev->fifo; in usb_ref_device() 448 f = udev->fifo[n + USB_FIFO_TX]; in usb_fifo_create() 465 f = udev->fifo[n + USB_FIFO_RX]; in usb_fifo_create() 522 udev->fifo[n + USB_FIFO_TX] = f; in usb_fifo_create() 548 udev->fifo[n + USB_FIFO_RX] = f; in usb_fifo_create() 587 (f->udev->fifo[f->fifo_index] == f)) { in usb_fifo_free() 588 f->udev->fifo[f->fifo_index] = NULL; in usb_fifo_free() 1922 usb_fifo_dummy_cmd(struct usb_fifo *fifo) in usb_fifo_dummy_cmd() argument 2038 udev->fifo[f_tx->fifo_index] = f_tx; in usb_fifo_attach() [all …]
|
H A D | usb_dev.h | 146 int usb_fifo_wait(struct usb_fifo *fifo); 147 void usb_fifo_signal(struct usb_fifo *fifo); 148 uint8_t usb_fifo_opened(struct usb_fifo *fifo);
|
/dragonfly/sys/dev/misc/syscons/ |
H A D | sysmouse.c | 71 struct event_fifo *fifo; member 196 sc->fifo = kmalloc(sizeof(struct event_fifo), in smopen() 222 kfree(sc->fifo, M_SYSCONS); in smclose() 223 sc->fifo = NULL; in smclose() 240 while (sc->fifo->fill <= 0) { in smread() 274 } while (sc->fifo->fill > 0); in smread() 439 if (sc->fifo->fill > 0) { in smfilter() 451 struct event_fifo *f = sc->fifo; in smqueue() 468 struct event_fifo *f = sc->fifo; in smget() 477 struct event_fifo *f = sc->fifo; in smpop() [all …]
|
/dragonfly/tools/regression/p1003_1b/ |
H A D | main.c | 5 int fifo(int argc, char *argv[]); 16 { "fifo", fifo, 1 },
|
H A D | fifo.c | 84 int fifo(int argc, char *argv[]) in fifo() function 227 int main(int argc, char *argv[]) { return fifo(argc, argv); } in main()
|
H A D | Makefile | 7 fifo.c \
|
H A D | README | 7 p1003_1b fifo : Check that the FIFO scheduler seems to work.
|
/dragonfly/sys/dev/netif/ath/ath/ |
H A D | if_ath_tx_edma.c | 194 ATH_TXQ_INSERT_TAIL(&txq->fifo, bf, bf_list); in ath_edma_tx_fifo_fill() 258 TAILQ_FOREACH(bf, &txq->fifo.axq_q, bf_list) { in ath_edma_dma_restart() 687 bf = ATH_TXQ_FIRST(&txq->fifo); in ath_edma_tx_processq() 724 ATH_TXQ_REMOVE(&txq->fifo, bf, bf_list); in ath_edma_tx_processq() 745 txq->fifo.axq_depth); in ath_edma_tx_processq()
|
/dragonfly/sys/vfs/fifofs/ |
H A D | Makefile | 4 KMOD= fifo
|
/dragonfly/sys/bus/u4b/audio/ |
H A D | uaudio.c | 247 struct usb_fifo_sc fifo; member 5498 sub->fifo.fp[USB_FIFO_RX], in umidi_bulk_read_callback() 5760 umidi_sub_by_fifo(struct usb_fifo *fifo) in umidi_sub_by_fifo() argument 5768 if ((sub->fifo.fp[USB_FIFO_RX] == fifo) || in umidi_sub_by_fifo() 5769 (sub->fifo.fp[USB_FIFO_TX] == fifo)) { in umidi_sub_by_fifo() 5781 umidi_start_read(struct usb_fifo *fifo) in umidi_start_read() argument 5789 umidi_stop_read(struct usb_fifo *fifo) in umidi_stop_read() argument 5816 umidi_stop_write(struct usb_fifo *fifo) in umidi_stop_write() argument 5866 usb_fifo_free_buffer(fifo); in umidi_close() 5869 usb_fifo_free_buffer(fifo); in umidi_close() [all …]
|
/dragonfly/sys/bus/u4b/misc/ |
H A D | ufm.c | 298 ufm_ioctl(struct usb_fifo *fifo, u_long cmd, void *addr, in ufm_ioctl() argument 301 struct ufm_softc *sc = usb_fifo_softc(fifo); in ufm_ioctl()
|