/darwin-on-arm/xnu/bsd/kern/ |
H A D | kern_event.c | 105 static inline void kqlock(struct kqueue *kq); 106 static inline void kqunlock(struct kqueue *kq); 108 static int kqlock2knoteuse(struct kqueue *kq, struct knote *kn); 109 static int kqlock2knoteusewait(struct kqueue *kq, struct knote *kn); 110 static int kqlock2knotedrop(struct kqueue *kq, struct knote *kn); 111 static int knoteuse2kqlock(struct kqueue *kq, struct knote *kn); 113 static void kqueue_wakeup(struct kqueue *kq, int closed); 144 static int kevent_callback(struct kqueue *kq, struct kevent64_s *kevp, void *data); 145 static void kevent_continue(struct kqueue *kq, void *data, int error); 147 static int kqueue_process(struct kqueue *kq, kevent_callback_ 299 kqlock(struct kqueue *kq) argument 305 kqunlock(struct kqueue *kq) argument 321 kqlock2knoteuse(struct kqueue *kq, struct knote *kn) argument 342 kqlock2knoteusewait(struct kqueue *kq, struct knote *kn) argument 368 knoteuse2kqlock(struct kqueue *kq, struct knote *kn) argument 398 kqlock2knotedrop(struct kqueue *kq, struct knote *kn) argument 423 struct kqueue *kq = kn->kn_kq; local 453 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 464 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 771 struct kqueue *kq = kn->kn_kq; local 786 struct kqueue *kq = kn->kn_kq; local 1058 struct kqueue *kq; local 1102 kqueue_dealloc(struct kqueue *kq) argument 1165 struct kqueue *kq; local 1287 kevent_continue(__unused struct kqueue *kq, void *data, int error) argument 1356 struct kqueue *kq; local 1458 kevent_callback(__unused struct kqueue *kq, struct kevent64_s *kevp, void *data) argument 1522 kevent_register(struct kqueue *kq, struct kevent64_s *kev, __unused struct proc *ctxp) argument 1747 struct kqueue *kq = kn->kn_kq; local 1883 kqueue_begin_processing(struct kqueue *kq) argument 1908 kqueue_end_processing(struct kqueue *kq) argument 1933 kqueue_process(struct kqueue *kq, kevent_callback_t callback, void *data, int *countp, struct proc *p) argument 2000 struct kqueue *kq = (struct kqueue *)data; local 2051 kqueue_scan(struct kqueue *kq, kevent_callback_t callback, kqueue_continue_t continuation, void *data, struct timeval *atvp, struct proc *p) argument 2176 struct kqueue *kq = (struct kqueue *)fp->f_data; local 2262 struct kqueue *kq = (struct kqueue *)fg->fg_data; local 2278 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 2328 struct kqueue *kq = (struct kqueue *)fp->f_fglob->fg_data; local 2340 struct kqueue *kq = (struct kqueue *)fp->f_data; local 2370 kqueue_wakeup(struct kqueue *kq, int closed) argument 2404 struct kqueue *kq = kn->kn_kq; local 2458 struct kqueue *kq = kn->kn_kq; local 2482 struct kqueue *kq = kn->kn_kq; local 2511 struct kqueue *kq = kn->kn_kq; local 2594 struct kqueue *kq = kn->kn_kq; local 2626 struct kqueue *kq = kn->kn_kq; local 2652 struct kqueue *kq = kn->kn_kq; local 2664 struct kqueue *kq = kn->kn_kq; local 2986 fill_kqueueinfo(struct kqueue *kq, struct kqueue_info * kinfo) argument [all...] |
H A D | pthread_support.c | 485 void ksyn_freeallkwe(ksyn_queue_t kq); 490 void ksyn_queue_init(ksyn_queue_t kq); 491 int ksyn_queue_insert(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t mgen, struct uthread * uth, ksyn_waitq_element_t kwe, int firstfit); 492 ksyn_waitq_element_t ksyn_queue_removefirst(ksyn_queue_t kq, ksyn_wait_queue_t kwq); 493 void ksyn_queue_removeitem(ksyn_wait_queue_t kwq, ksyn_queue_t kq, ksyn_waitq_element_t kwe); 494 int ksyn_queue_move_tofree(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t upto, ksyn_queue_t freeq, int all, int reease); 500 uint32_t ksyn_queue_count_tolowest(ksyn_queue_t kq, uint32_t upto); 502 ksyn_waitq_element_t ksyn_queue_find_cvpreposeq(ksyn_queue_t kq, uint32_t cgen); 503 uint32_t ksyn_queue_cvcount_entries(ksyn_queue_t kq, uint32_t upto, uint32_t from, int * numwaitersp, int * numintrp, int * numprepop); 506 ksyn_waitq_element_t ksyn_queue_find_signalseq(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_ 1039 ksyn_queue_find_threadseq(ksyn_wait_queue_t ckwq, __unused ksyn_queue_t kq, thread_t th, uint32_t upto) argument 1066 ksyn_queue_t kq; local 1247 struct ksyn_queue *kq, kfreeq; local 2711 ksyn_freeallkwe(ksyn_queue_t kq) argument 3279 ksyn_queue_t kq; local 3356 ksyn_queue_t kq; local 3847 ksyn_queue_init(ksyn_queue_t kq) argument 3856 ksyn_queue_insert(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t mgen, struct uthread * uth, ksyn_waitq_element_t kwe, int fit) argument 3938 ksyn_queue_removefirst(ksyn_queue_t kq, ksyn_wait_queue_t kwq) argument 3973 ksyn_queue_removeitem(ksyn_wait_queue_t kwq, ksyn_queue_t kq, ksyn_waitq_element_t kwe) argument 4007 ksyn_queue_find_seq(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t seq, int remove) argument 4026 ksyn_queue_find_cvpreposeq(ksyn_queue_t kq, uint32_t cgen) argument 4055 ksyn_queue_find_signalseq(__unused ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t uptoseq, uint32_t signalseq) argument 4108 ksyn_queue_move_tofree(ksyn_wait_queue_t ckwq, ksyn_queue_t kq, uint32_t upto, ksyn_queue_t kfreeq, int all, int release) argument 4340 ksyn_queue_count_tolowest(ksyn_queue_t kq, uint32_t upto) argument 4373 ksyn_queue_t kq; local [all...] |
H A D | sys_generic.c | 1425 struct kqueue *kq; local 1444 kq = kqueue_alloc(p); 1445 if (kq == NULL) 1504 kerror = kevent_register(kq, &kev, p); 1511 kerror = kevent_register(kq, &kev, p); 1527 kerror = kevent_register(kq, &kev, p); 1545 error = kqueue_scan(kq, poll_callback, NULL, cont, &atv, p); 1564 kqueue_dealloc(kq); 1569 poll_callback(__unused struct kqueue *kq, struct kevent64_s *kevp, void *data) argument
|
H A D | proc_info.c | 127 int pid_kqueueinfo(struct kqueue * kq, struct fileproc * fp, int closeonexec, user_addr_t buffer, uint32_t buffersize, int32_t * retval); 1375 pid_kqueueinfo(struct kqueue * kq, struct fileproc *fp, int closeonexec, user_addr_t buffer, __unused uint32_t buffersize, int32_t * retval) argument 1384 if ((error = fill_kqueueinfo(kq, &kqinfo.kqueueinfo)) == 0) { 1530 struct kqueue * kq; local 1532 if ((error = fp_getfkq(p, fd, &fp, &kq)) !=0) { 1537 error = pid_kqueueinfo(kq, fp, closeonexec, buffer, buffersize, retval);
|
/darwin-on-arm/xnu/tools/tests/kqueue_tests/ |
H A D | kqueue_timer_tests.c | 9 int kq, passed, failed; variable 28 ret = kevent64(kq, kev, 1, kev, 1, 0, &timeout); 155 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 164 ret = kevent64(kq, NULL, 0, &kev, 1, 0, NULL); 182 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 196 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 220 kq = kqueue(); 221 assert(kq > 0);
|
/darwin-on-arm/xnu/bsd/sys/ |
H A D | event.h | 151 #define EV_ADD 0x0001 /* add event to kq (implies enable) */ 152 #define EV_DELETE 0x0002 /* delete event from kq */ 437 int kevent(int kq, const struct kevent *changelist, int nchanges, 440 int kevent64(int kq, const struct kevent64_s *changelist,
|
H A D | proc_info.h | 734 extern int fill_kqueueinfo(struct kqueue * kq, struct kqueue_info * kinfo);
|
/darwin-on-arm/xnu/tools/tests/MPMMTest/ |
H A D | KQMPMMtest.c | 346 int kq; local 361 kq = kqueue(); 362 if (kq == -1) { 372 err = kevent64(kq, kev, 1, NULL, 0, 0, NULL); 385 FD_SET(kq, &readfds); 390 count = select(kq + 1, &readfds, NULL, NULL, NULL); 403 err = kevent64(kq, kev, 1, kev, 1, 0, NULL);
|