Searched refs:kq (Results 1 - 8 of 8) sorted by relevance

/darwin-on-arm/xnu/bsd/kern/
H A Dkern_event.c105 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 Dpthread_support.c485 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 Dsys_generic.c1425 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 Dproc_info.c127 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 Dkqueue_timer_tests.c9 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 Devent.h151 #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 Dproc_info.h734 extern int fill_kqueueinfo(struct kqueue * kq, struct kqueue_info * kinfo);
/darwin-on-arm/xnu/tools/tests/MPMMTest/
H A DKQMPMMtest.c346 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);

Completed in 51 milliseconds