kqueue/libkqueue/read.c

47     struct kevent kev;
50     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]);
51     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
61     struct kevent kev;
65     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]);
66     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
71     kev.data = 1;
72     kevent_cmp(&kev, kevent_get(kqfd));
77     kev.flags = EV_DELETE;
78     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
88     struct kevent kev;
94     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, &sockfd[0]);
95     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
101     kev.data = 2;
102     kevent_cmp(&kev, kevent_get(kqfd));
111     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]);
112     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
122     struct kevent kev;
133     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_DISABLE, 0, 0, &sockfd[0]);
134     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
140     kev.flags = EV_ENABLE;
141     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
143     kev.flags = EV_ADD;
144     kev.data = 1;
145     kevent_cmp(&kev, kevent_get(kqfd));
149     kev.flags = EV_DELETE;
150     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
160     struct kevent kev;
164     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]);
165     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
179     struct kevent kev;
185     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_ONESHOT, 0, 0, &sockfd[0]);
186     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
192     kev.data = 1;
193     kevent_cmp(&kev, kevent_get(kqfd));
199     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]);
200     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) == 0)
217     struct kevent kev;
221     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_DISPATCH, 0, 0, &sockfd[0]);
222     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
229     kev.data = 1;
230     kevent_cmp(&kev, kevent_get(kqfd));
234     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]);
235     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
249     struct kevent kev;
255     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_ONESHOT, NOTE_LOWAT, 2, &sockfd[0]);
256     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
266     if (kevent(kqfd, NULL, 0, &kev, 1, NULL) != 1)
268     KEV_CMP(kev, sockfd[0], EVFILT_READ, 0);
282     struct kevent kev;
287     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]);
288     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)
295     kev.flags |= EV_EOF;
296     kevent_cmp(&kev, kevent_get(kqfd));
299     EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]);
300     if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0)