Home
last modified time | relevance | path

Searched refs:EVFILT_WRITE (Results 1 – 25 of 27) sorted by relevance

12

/xnu-12377.61.12/tests/
H A Duipc_kevent.c39 EV_SET(&chlist, sockets[0], EVFILT_WRITE, EV_ADD | EV_ERROR, 0, 0, 0); in test_kevent()
77 EV_SET(&chlist, sockets[0], EVFILT_WRITE, EV_ADD | EV_ERROR, 0, 0, 0); in test_kevent_lowat()
110 EV_SET(&chlist, sockets[0], EVFILT_WRITE, EV_ADD | EV_ERROR, NOTE_LOWAT, 100, 0); in test_kevent_lowat()
128 EV_SET(&chlist, sockets[0], EVFILT_WRITE, EV_ADD | EV_ERROR, 0, 0, 0); in test_kevent_lowat()
H A Dkqueue_fifo_18776047.c137 kevent_one_shot(kq, write_fd, EVFILT_WRITE);
148 kevent_one_shot(kq, write_fd, EVFILT_WRITE);
H A Dpoll_select_kevent_paired_fds.c216 reenable_workq(shared.wr_fd, EVFILT_WRITE); in workqueue_write_fn()
232 EV_SET(&events, fd, reading ? EVFILT_READ : EVFILT_WRITE, EV_ADD, in drive_kq()
235 EV_SET64(&events64, fd, reading ? EVFILT_READ : EVFILT_WRITE, EV_ADD, in drive_kq()
239 .filter = reading ? EVFILT_READ : EVFILT_WRITE, in drive_kq()
398 .filter = EVFILT_WRITE, in write_to_fd()
H A Dkqueue_file_tests.c633 …est) && (test->t_union.tu_kev.filter == EVFILT_READ || test->t_union.tu_kev.filter == EVFILT_WRITE) in execute_test()
689 if (event == EVFILT_READ || event == EVFILT_WRITE) { in init_test_common()
1673 init_test(&test, "9.1.1: how much space in empty fifo?", FILE1, 1, 1, EVFILT_WRITE, FIFO_SPACE); in run_evfilt_write_tests()
1680 …init_test(&test, "9.1.2: how much space in slightly written fifo?", FILE1, 1, 1, EVFILT_WRITE, FIF… in run_evfilt_write_tests()
1688 init_test(&test, "9.2.1: how much space in a full fifo?", FILE1, 1, 1, EVFILT_WRITE, 0); in run_evfilt_write_tests()
H A Dnet_bridge.c930 EV_SET(&kev, port->fd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in switch_port_check_tx()
935 T_ASSERT_EQ((int)kev.filter, EVFILT_WRITE, NULL); in switch_port_check_tx()
H A Dproc_info.c1960 events[0].filter = EVFILT_WRITE;
/xnu-12377.61.12/tests/skywalk/
H A Dskt_kqueue.c249 wait_on_fd(kq_fd, EVFILT_WRITE, channel, 0, TIMEOUT_DONT_CARE); in skt_kqueue_basic_tx()
288 error = wait_on_fd(kq_fd, EVFILT_WRITE, channel, 0, TIMEOUT_EXPECT); in skt_kqueue_basic_tx()
301 error = wait_on_fd(kq_fd, EVFILT_WRITE, channel, 0, TIMEOUT_FAIL); in skt_kqueue_basic_tx()
572 error = wait_on_fd(kq_fd, EVFILT_WRITE, channel, note_lowat_val, in skt_kqueue_lowat_basic_tx()
580 error = wait_on_fd(kq_fd, EVFILT_WRITE, channel, note_lowat_val, in skt_kqueue_lowat_basic_tx()
602 error = wait_on_fd(kq_fd, EVFILT_WRITE, channel, note_lowat_val, in skt_kqueue_lowat_basic_tx()
H A Dskt_debug_verify.c73 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_debug_verify_main()
77 assert(kev.filter == EVFILT_WRITE); in skt_debug_verify_main()
H A Dskt_shutdown.c128 EV_SET(&sock_kev, sock_fd, EVFILT_WRITE, EV_ADD | EV_ENABLE, in skt_shutdown_common()
136 assert(sock_kev.filter == EVFILT_WRITE); in skt_shutdown_common()
146 assert(sock_kev.filter == EVFILT_WRITE); in skt_shutdown_common()
156 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, in skt_shutdown_common()
H A Dskt_utunloop.c126 EV_SET(&kev, txfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_utunloop_xfer_slots()
154 EV_SET(&kev, txfd, EVFILT_WRITE, EV_DISABLE, 0, 0, NULL); in skt_utunloop_xfer_slots()
160 EV_SET(&kev, txfd, EVFILT_WRITE, EV_ENABLE, 0, 0, NULL); in skt_utunloop_xfer_slots()
203 } else if (kev.filter == EVFILT_WRITE) { in skt_utunloop_xfer_slots()
557 EV_SET(&kev, s, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in sourceudp()
591 assert(kev.filter == EVFILT_WRITE); in sourceudp()
H A Dskt_oneslot.c113 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_oneslot_common()
117 assert(kev.filter == EVFILT_WRITE); in skt_oneslot_common()
H A Dskt_badring.c129 EV_SET(&kevin, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_badringtx_common()
141 assert(kevout.filter == EVFILT_WRITE); in skt_badringtx_common()
H A Dskt_nslots.c152 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE | EV_ONESHOT, 0, 0, NULL); in skt_nslots_common()
156 assert(kev.filter == EVFILT_WRITE); in skt_nslots_common()
H A Dskt_netifdirect.c513 EV_SET(kev + 0, port->fd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_netif_send_and_receive()
638 case EVFILT_WRITE: { in skt_netif_send_and_receive()
667 port->fd, EVFILT_WRITE, in skt_netif_send_and_receive()
H A Dskt_xfer.c1608 EV_SET(kev + 0, port->fd, EVFILT_WRITE, in send_and_receive()
1675 case EVFILT_WRITE: { in send_and_receive()
1703 port->fd, EVFILT_WRITE, in send_and_receive()
1850 EV_SET(kev, port->fd, EVFILT_WRITE, in ping_pong()
1993 assert(evlist[0].filter == EVFILT_WRITE); in ping_pong()
2093 EV_SET(kev + n_kev, port->fd, EVFILT_WRITE, EV_DELETE, in ping_pong()
2153 port->fd, EVFILT_WRITE, in ping_pong()
2236 EV_SET(&kev, port->fd, EVFILT_WRITE, in send_tcp()
2267 case EVFILT_WRITE: { in send_tcp()
2295 port->fd, EVFILT_WRITE, in send_tcp()
[all …]
H A Dskywalk_test_utils.c847 mode == CHANNEL_SYNC_TX ? EVFILT_WRITE : EVFILT_READ, in sktc_pump_ring_nslots_kq()
882 assert(kev.filter == EVFILT_WRITE); in sktc_pump_ring_nslots_kq()
1772 EV_SET(&kev, port->fd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in sktu_channel_port_tx_burst_pkt()
1796 if (evlist.filter != EVFILT_WRITE) { in sktu_channel_port_tx_burst_pkt()
1837 EV_SET(&kev, port->fd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in sktu_channel_port_tx_burst()
1861 if (evlist.filter != EVFILT_WRITE) { in sktu_channel_port_tx_burst()
H A Dskywalk_test_common.c409 assert(kev.filter == EVFILT_WRITE); in sktc_channel_worker_echo()
607 assert(kev.filter == EVFILT_WRITE); in sktc_channel_worker_source()
691 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in sktc_setup_channel_worker()
/xnu-12377.61.12/bsd/kern/
H A Dtty_ptmx.c558 case EVFILT_WRITE: in ptsd_kqops_detach()
591 case EVFILT_WRITE: in ptsd_kqops_common()
700 case EVFILT_WRITE: in ptsd_kqfilter()
807 case EVFILT_WRITE: in ptmx_kqfilter()
837 case EVFILT_WRITE: in ptmx_kqops_detach()
873 case EVFILT_WRITE: in ptmx_kqops_common()
H A Dsys_generic.c1766 kev.filter = EVFILT_WRITE; in poll_nocancel()
1883 case EVFILT_WRITE: in poll_callback()
H A Dtty.c3425 case EVFILT_WRITE: in filt_tty_common()
3561 case EVFILT_WRITE: in filt_ttydetach()
H A Dsys_pipe.c1633 case EVFILT_WRITE: in pipe_kqfilter()
/xnu-12377.61.12/bsd/skywalk/channel/
H A Dchannel.c535 ASSERT(kn->kn_filter == EVFILT_WRITE); in filt_chwdetach()
580 ASSERT(kn->kn_filter == EVFILT_WRITE); in filt_chwrite()
599 enum txrx dir = (ev == EVFILT_WRITE) ? NR_TX : NR_RX; in filt_chtouch()
667 ASSERT(kn->kn_filter == EVFILT_WRITE); in filt_chwtouch()
761 ASSERT(kn->kn_filter == EVFILT_WRITE); in filt_chwprocess()
772 enum txrx dir = (ev == EVFILT_WRITE) ? NR_TX : NR_RX; in filt_chrwattach()
778 (kn->kn_filter == EVFILT_WRITE)); in filt_chrwattach()
814 (ev == EVFILT_WRITE) ? "write" : "read"); in filt_chrwattach()
817 events = (ev == EVFILT_WRITE) ? POLLOUT : POLLIN; in filt_chrwattach()
1083 case EVFILT_WRITE: in ch_kqfilter()
/xnu-12377.61.12/bsd/sys/
H A Devent.h71 #define EVFILT_WRITE (-2) macro
H A Devent_private.h528 case EVFILT_WRITE: in knote_get_seltype()
/xnu-12377.61.12/bsd/vfs/
H A Dvfs_vnops.c1998 case EVFILT_WRITE: in vn_kqfilter()
2184 case EVFILT_WRITE: in filt_vnode_common()

12