Home
last modified time | relevance | path

Searched refs:channelfd (Results 1 – 9 of 9) sorted by relevance

/xnu-12377.41.6/tests/skywalk/
H A Dskt_badring.c56 int channelfd; in skt_badringtx_common() local
68 channelfd = os_channel_get_fd(channel); in skt_badringtx_common()
69 assert(channelfd != -1); in skt_badringtx_common()
84 FD_SET(channelfd, &rfdset); in skt_badringtx_common()
86 FD_SET(channelfd, &wfdset); in skt_badringtx_common()
88 FD_SET(channelfd, &efdset); in skt_badringtx_common()
89 error = select(channelfd + 1, &rfdset, &wfdset, &efdset, &timeout); in skt_badringtx_common()
98 assert(!FD_ISSET(channelfd, &rfdset)); in skt_badringtx_common()
99 assert(FD_ISSET(channelfd, &wfdset)); // XXX is it correct to return writable as well as error? in skt_badringtx_common()
100 assert(FD_ISSET(channelfd, &efdset)); in skt_badringtx_common()
[all …]
H A Dskt_oneslot.c55 int channelfd; in skt_oneslot_common() local
70 channelfd = os_channel_get_fd(channel); in skt_oneslot_common()
71 assert(channelfd != -1); in skt_oneslot_common()
89 FD_SET(channelfd, &rfdset); in skt_oneslot_common()
90 FD_SET(channelfd, &wfdset); in skt_oneslot_common()
91 FD_SET(channelfd, &efdset); in skt_oneslot_common()
92 error = select(channelfd + 1, &rfdset, &wfdset, &efdset, NULL); in skt_oneslot_common()
94 assert(!FD_ISSET(channelfd, &rfdset)); in skt_oneslot_common()
95 assert(FD_ISSET(channelfd, &wfdset)); in skt_oneslot_common()
96 assert(!FD_ISSET(channelfd, &efdset)); in skt_oneslot_common()
[all …]
H A Dskt_closecfd.c45 int channelfd; in skt_closecfd_main() local
55 channelfd = os_channel_get_fd(channel); in skt_closecfd_main()
56 assert(channelfd != -1); in skt_closecfd_main()
58 error = close(channelfd); // expected guarded fd fail. in skt_closecfd_main()
81 int channelfd; in skt_writecfd_main() local
92 channelfd = os_channel_get_fd(channel); in skt_writecfd_main()
93 assert(channelfd != -1); in skt_writecfd_main()
95 ret = write(channelfd, buf, sizeof(buf)); in skt_writecfd_main()
119 int channelfd; in skt_readcfd_main() local
130 channelfd = os_channel_get_fd(channel); in skt_readcfd_main()
[all …]
H A Dskt_shutdown.c57 int channelfd, sock_fd; in skt_shutdown_common() local
72 channelfd = os_channel_get_fd(channel); in skt_shutdown_common()
73 assert(channelfd != -1); in skt_shutdown_common()
87 FD_SET(channelfd, &rfdset); in skt_shutdown_common()
88 FD_SET(channelfd, &wfdset); in skt_shutdown_common()
89 FD_SET(channelfd, &efdset); in skt_shutdown_common()
90 error = select(channelfd + 1, &rfdset, &wfdset, &efdset, NULL); in skt_shutdown_common()
93 assert(!FD_ISSET(channelfd, &rfdset)); in skt_shutdown_common()
94 assert(!FD_ISSET(channelfd, &wfdset)); in skt_shutdown_common()
95 assert(FD_ISSET(channelfd, &efdset)); in skt_shutdown_common()
[all …]
H A Dskt_shutdown2.c65 int channelfd; in skt_shutdown2_common() local
80 channelfd = os_channel_get_fd(channel); in skt_shutdown2_common()
81 assert(channelfd != -1); in skt_shutdown2_common()
90 FD_SET(channelfd, &rfdset); in skt_shutdown2_common()
91 FD_SET(channelfd, &efdset); in skt_shutdown2_common()
92 error = select(channelfd + 1, &rfdset, NULL, &efdset, NULL); in skt_shutdown2_common()
95 assert(!FD_ISSET(channelfd, &rfdset)); in skt_shutdown2_common()
96 assert(FD_ISSET(channelfd, &efdset)); in skt_shutdown2_common()
99 fds.fd = channelfd; in skt_shutdown2_common()
105 assert(fds.fd == channelfd); in skt_shutdown2_common()
[all …]
H A Dskt_nslots.c55 int channelfd; in skt_nslots_common() local
77 channelfd = os_channel_get_fd(channel); in skt_nslots_common()
78 assert(channelfd != -1); in skt_nslots_common()
86 fds.fd = channelfd; in skt_nslots_common()
134 FD_SET(channelfd, &fdset); in skt_nslots_common()
135 FD_SET(channelfd, &efdset); in skt_nslots_common()
136 error = select(channelfd + 1, NULL, &fdset, &efdset, NULL); in skt_nslots_common()
139 assert(FD_ISSET(channelfd, &fdset)); in skt_nslots_common()
140 assert(!FD_ISSET(channelfd, &efdset)); in skt_nslots_common()
147 assert(fds.fd == channelfd); in skt_nslots_common()
[all …]
H A Dskt_debug_verify.c55 int channelfd; in skt_debug_verify_main() local
68 channelfd = os_channel_get_fd(channel); in skt_debug_verify_main()
69 assert(channelfd != -1); in skt_debug_verify_main()
73 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_debug_verify_main()
78 assert(kev.ident == channelfd); in skt_debug_verify_main()
107 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in skt_debug_verify_main()
112 assert(kev.ident == channelfd); in skt_debug_verify_main()
H A Dskywalk_test_utils.c835 int channelfd; in sktc_pump_ring_nslots_kq() local
841 channelfd = os_channel_get_fd(channel); in sktc_pump_ring_nslots_kq()
842 assert(channelfd != -1); in sktc_pump_ring_nslots_kq()
846 EV_SET(&kev, channelfd, in sktc_pump_ring_nslots_kq()
880 assert(kev.ident == channelfd); in sktc_pump_ring_nslots_kq()
908 int channelfd; in sktc_pump_ring_nslots_select() local
912 channelfd = os_channel_get_fd(channel); in sktc_pump_ring_nslots_select()
913 assert(channelfd != -1); in sktc_pump_ring_nslots_select()
920 FD_SET(channelfd, &writefds); in sktc_pump_ring_nslots_select()
922 FD_SET(channelfd, &readfds); in sktc_pump_ring_nslots_select()
[all …]
H A Dskywalk_test_common.c675 int channelfd = os_channel_get_fd(sktc_channel); in sktc_setup_channel_worker() local
676 assert(channelfd != -1); in sktc_setup_channel_worker()
680 EV_SET(&kev, channelfd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, NULL); in sktc_setup_channel_worker()
691 EV_SET(&kev, channelfd, EVFILT_WRITE, EV_ADD | EV_ENABLE, 0, 0, NULL); in sktc_setup_channel_worker()