Home
last modified time | relevance | path

Searched refs:EVFILT_READ (Results 1 – 25 of 37) sorted by relevance

12

/xnu-12377.61.12/tests/
H A Dkqueue_fifo_18776047.c108 T_LOG("kevent doing ONESHOT %s", filter == EVFILT_READ ? "read" : "write"); in kevent_one_shot()
138 kevent_one_shot(kq, read_fd, EVFILT_READ);
152 kevent_one_shot(kq, read_fd, EVFILT_READ);
H A Dv4mappedv6_recvpktinfo.c179 EV_SET(&evSet, sockfd, EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, (void *)NULL);
221 if (evList[i].filter == EVFILT_READ) { in do_kqueue()
H A Dpoll_select_kevent_paired_fds.c232 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()
540 reenable_workq(shared.rd_fd, EVFILT_READ); in workqueue_read_fn()
645 .filter = EVFILT_READ, in read_from_fd()
H A Dkqueue_nesting.c41 .filter = EVFILT_READ,
H A Dsocket_0byte_udp_poll_58140856.c72 .filter = EVFILT_READ, in server_poll()
H A Dkqueue_file_tests.c633 …if ((!test->t_is_poll_test) && (test->t_union.tu_kev.filter == EVFILT_READ || test->t_union.tu_kev… in execute_test()
689 if (event == EVFILT_READ || event == EVFILT_WRITE) { in init_test_common()
1571 …init_test(&test, "8.1.1: how much data in file of length LENGTHEN_SIZE?", FILE1, 2, 1, EVFILT_READ… in run_evfilt_read_tests()
1578 …init_test(&test, "8.1.2: block, then write to file", FILE1, 2, 1, EVFILT_READ, strlen(TEST_STRING)… in run_evfilt_read_tests()
1585 init_test(&test, "8.1.3: block, then extend", FILE1, 2, 1, EVFILT_READ, LENGTHEN_SIZE); in run_evfilt_read_tests()
1592 …init_test(&test, "8.1.4: block, then seek to beginning", FILE1, 2, 1, EVFILT_READ, strlen(TEST_STR… in run_evfilt_read_tests()
1601 …init_test(&test, "8.1.5: block, then write to fifo", FILE1, 1, 1, EVFILT_READ, strlen(TEST_STRING)… in run_evfilt_read_tests()
1609 init_test(&test, "8.2.1: just rename", FILE1, 2, 1, EVFILT_READ, NO_EVENT); in run_evfilt_read_tests()
1616 init_test(&test, "8.2.2: delete file", FILE1, 2, 0, EVFILT_READ, NO_EVENT); in run_evfilt_read_tests()
1622 init_test(&test, "8.2.3: write to beginning", FILE1, 2, 1, EVFILT_READ, NO_EVENT); in run_evfilt_read_tests()
[all …]
H A Dkqueue_close.c142 .filter = EVFILT_READ,
H A Dnet_tuntests.c703 EV_SET(&kev, cfds[ri], EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, (void *)(uintptr_t)ri); in setup_channels_and_rings()
846 T_QUIET; T_EXPECT_EQ_SHORT(kev[0].filter, (short)EVFILT_READ, NULL); in xfer_1_packet_singly()
951 T_QUIET; T_EXPECT_EQ_SHORT(kev[e].filter, (short)EVFILT_READ, NULL); in xfer_1_packet_together()
/xnu-12377.61.12/bsd/kern/
H A Dtty_ptmx.c555 case EVFILT_READ: in ptsd_kqops_detach()
582 case EVFILT_READ: in ptsd_kqops_common()
697 case EVFILT_READ: in ptsd_kqfilter()
804 case EVFILT_READ: in ptmx_kqfilter()
834 case EVFILT_READ: in ptmx_kqops_detach()
862 case EVFILT_READ: in ptmx_kqops_common()
/xnu-12377.61.12/tests/skywalk/
H A Dskt_shutdown2.c112 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, in skt_shutdown2_common()
117 assert(kev.filter == EVFILT_READ); in skt_shutdown2_common()
H A Dskt_kqueue.c161 error = wait_on_fd(kq_fd, EVFILT_READ, channel, 0, TIMEOUT_EXPECT); in skt_kqueue_basic_rx()
174 wait_on_fd(kq_fd, EVFILT_READ, channel, 0, TIMEOUT_FAIL); in skt_kqueue_basic_rx()
399 error = wait_on_fd(kq_fd, EVFILT_READ, channel, lowat_val, in skt_kqueue_lowat_basic_rx()
409 error = wait_on_fd(kq_fd, EVFILT_READ, channel, lowat_val, TIMEOUT_FAIL); in skt_kqueue_lowat_basic_rx()
421 error = wait_on_fd(kq_fd, EVFILT_READ, channel, lowat_val, TIMEOUT_DISABLE); in skt_kqueue_lowat_basic_rx()
H A Dskt_debug_verify.c107 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_debug_verify_main()
111 assert(kev.filter == EVFILT_READ); in skt_debug_verify_main()
H A Dskt_shutdown.c295 EV_SET(&sock_kev, sock_fd, EVFILT_READ, EV_ADD | EV_ENABLE, in skt_shutdown_common()
303 assert(sock_kev.filter == EVFILT_READ); in skt_shutdown_common()
313 assert(sock_kev.filter == EVFILT_READ); in skt_shutdown_common()
323 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, in skt_shutdown_common()
H A Dskt_oneslot.c176 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_oneslot_common()
180 assert(kev.filter == EVFILT_READ); in skt_oneslot_common()
H A Dskt_badring.c248 EV_SET(&kevin, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_badringrx_common()
260 assert(kevout.filter == EVFILT_READ); in skt_badringrx_common()
H A Dskt_mangle.c219 error = wait_on_fd(kq_fd, EVFILT_READ, channel, 0, TIMEOUT_FAIL); in skt_mangle_rx()
237 error = wait_on_fd(kq_fd, EVFILT_READ, channel, 0, TIMEOUT_FAIL); in skt_mangle_rx()
H A Dskt_nslots.c222 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE | EV_ONESHOT, 0, 0, NULL); in skt_nslots_common()
226 assert(kev.filter == EVFILT_READ); in skt_nslots_common()
H A Dskt_utun27302538.c65 EV_SET(&kevin, os_channel_get_fd(channel), EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in thread1()
H A Dskt_utunloop.c120 EV_SET(&kev, rxfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_utunloop_xfer_slots()
169 EV_SET(&kev, rxfd, EVFILT_READ, EV_DISABLE, 0, 0, NULL); in skt_utunloop_xfer_slots()
175 EV_SET(&kev, rxfd, EVFILT_READ, EV_ENABLE, 0, 0, NULL); in skt_utunloop_xfer_slots()
205 } else if (kev.filter == EVFILT_READ) { in skt_utunloop_xfer_slots()
H A Dskt_filter.c515 EV_SET(&kev[0], ch_fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in custom_ether_thread()
529 if (evlist.filter == EVFILT_READ) { in custom_ether_thread()
789 EV_SET(&kev[0], ch_fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in filter_thread()
799 if (evlist.filter == EVFILT_READ) { in filter_thread()
H A Dskt_netifdirect.c514 EV_SET(kev + 1, port->fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_netif_send_and_receive()
616 case EVFILT_READ: { in skt_netif_send_and_receive()
629 EV_SET(kev, port->fd, EVFILT_READ, in skt_netif_send_and_receive()
H A Dskt_xfer.c1510 EV_SET(&kev, port->fd, EVFILT_READ, in channel_port_receive_all()
1542 if (evlist.filter == EVFILT_READ) { in channel_port_receive_all()
1610 EV_SET(kev + 1, port->fd, EVFILT_READ, in send_and_receive()
1711 case EVFILT_READ: { in send_and_receive()
1725 EV_SET(kev, port->fd, EVFILT_READ, in send_and_receive()
1854 EV_SET(kev, port->fd, EVFILT_READ, in ping_pong()
1961 EV_SET(kev + n_kev, port->fd, EVFILT_READ, in ping_pong()
2100 EV_SET(kev + n_kev, port->fd, EVFILT_READ, in ping_pong()
2114 assert(evlist[0].filter == EVFILT_READ); in ping_pong()
2142 EV_SET(kev, port->fd, EVFILT_READ, EV_DELETE, in ping_pong()
[all …]
/xnu-12377.61.12/bsd/sys/
H A Devent.h70 #define EVFILT_READ (-1) macro
H A Devent_private.h526 case EVFILT_READ: in knote_get_seltype()
/xnu-12377.61.12/bsd/skywalk/channel/
H A Dchannel.c528 ASSERT(kn->kn_filter == EVFILT_READ); in filt_chrdetach()
569 ASSERT(kn->kn_filter == EVFILT_READ); in filt_chread()
652 ASSERT(kn->kn_filter == EVFILT_READ); in filt_chrtouch()
754 ASSERT(kn->kn_filter == EVFILT_READ); in filt_chrprocess()
777 ASSERT((kn->kn_filter == EVFILT_READ) || in filt_chrwattach()
1079 case EVFILT_READ: in ch_kqfilter()

12