/xnu-2782.1.97/osfmk/kern/ |
H A D | wait_queue.c | 330 wait_queue_link_t wql; local 341 queue_remove_first(q, wql, wait_queue_link_t, wql_preposts); 342 assert(!wql_is_preposted(wql)); 426 #define WQSPREV(wqs, wql) ((wait_queue_link_t)queue_prev( \ 427 ((&(wqs)->wqs_setlinks == (queue_t)(wql)) ? \ 428 (queue_t)(wql) : &(wql)->wql_setlinks))) 430 #define WQSNEXT(wqs, wql) ((wait_queue_link_t)queue_next( \ 431 ((&(wqs)->wqs_setlinks == (queue_t)(wql)) ? \ 432 (queue_t)(wql) 519 wait_queue_link_t wql = (wait_queue_link_t)wq_element; local 571 wait_queue_link_internal( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument 638 wait_queue_link_noalloc( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument 661 wait_queue_link_t wql; local 679 wait_queue_link_t wql; local 689 wait_queue_link_free(wait_queue_link_t wql) argument 702 wait_queue_unlink_locked( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument 740 wait_queue_link_t wql; local 792 wait_queue_link_t wql; local 851 wait_queue_link_t wql; local 923 wait_queue_link_t wql; local 966 wait_queue_link_t wql; local 1015 wait_queue_link_t wql; local 1071 wait_queue_link_t wql; local 1127 wait_queue_set_unlink_one( wait_queue_set_t wq_set, wait_queue_link_t wql) argument 1443 wait_queue_link_t wql = (wait_queue_link_t)wq_element; local 1669 wait_queue_link_t wql = (wait_queue_link_t)wq_element; local 1836 wait_queue_link_t wql = (wait_queue_link_t)wq_element; local [all...] |
H A D | wait_queue.h | 214 #define wql_is_preposted(wql) ((wql)->wql_preposts.next != NULL) 215 #define wql_clear_prepost(wql) ((wql)->wql_preposts.next = (wql)->wql_preposts.prev = NULL)
|
/xnu-2782.1.97/osfmk/ipc/ |
H A D | ipc_pset.c | 191 wait_queue_link_t wql) 198 kr = ipc_mqueue_add(&port->ip_messages, &pset->ips_messages, wql); 283 wait_queue_link_t wql; local 310 wql = (wait_queue_link_t) dequeue(links); 311 wait_queue_link_free(wql); 338 wait_queue_link_t wql = wait_queue_link_allocate(); local 347 wait_queue_link_free(wql); 358 result = knote_link_wait_queue(kn, &pset->ips_messages.imq_wait_queue, wql); 368 wait_queue_link_free(wql); 377 wait_queue_link_t wql local 188 ipc_pset_add( ipc_pset_t pset, ipc_port_t port, wait_queue_link_t wql) argument [all...] |
H A D | ipc_mqueue.c | 220 wait_queue_link_t wql) 229 kr = wait_queue_link_noalloc(port_waitq, set_waitq, wql); 743 wait_queue_link_t wql; local 746 queue_remove_first(q, wql, wait_queue_link_t, wql_preposts); 747 assert(!wql_is_preposted(wql)); 757 port_mq = (ipc_mqueue_t)wql->wql_queue; 759 queue_enter(q, wql, wait_queue_link_t, wql_preposts); 783 queue_enter(q, wql, wait_queue_link_t, wql_preposts); 996 wait_queue_link_t wql; local 1015 queue_iterate(q, wql, wait_queue_link_ 217 ipc_mqueue_add( ipc_mqueue_t port_mqueue, ipc_mqueue_t set_mqueue, wait_queue_link_t wql) argument 1048 wait_queue_link_t wql; local [all...] |
H A D | ipc_pset.h | 113 wait_queue_link_t wql);
|
H A D | mach_port.c | 1367 wait_queue_link_t wql; local 1380 wql = WAIT_QUEUE_LINK_NULL; 1382 wql = wait_queue_link_allocate(); 1424 kr = ipc_pset_add(nset, port, wql); 1431 if (kr != KERN_SUCCESS && wql != WAIT_QUEUE_LINK_NULL) 1432 wait_queue_link_free(wql); 1434 wql = (wait_queue_link_t) dequeue(links); 1435 wait_queue_link_free(wql); 2021 wait_queue_link_t wql; local 2029 wql 2079 wait_queue_link_t wql = WAIT_QUEUE_LINK_NULL; local [all...] |
H A D | ipc_right.c | 662 wait_queue_link_t wql; local 673 wql = (wait_queue_link_t) dequeue(links); 674 wait_queue_link_free(wql); 818 wait_queue_link_t wql; local 829 wql = (wait_queue_link_t) dequeue(links); 830 wait_queue_link_free(wql); 1127 wait_queue_link_t wql; local 1219 wql = (wait_queue_link_t) dequeue(links); 1220 wait_queue_link_free(wql); 1456 wait_queue_link_t wql; local [all...] |
H A D | ipc_mqueue.h | 156 wait_queue_link_t wql);
|
H A D | ipc_object.c | 506 wait_queue_link_t wql; local 539 wql = (wait_queue_link_t) dequeue(links); 540 wait_queue_link_free(wql);
|
/xnu-2782.1.97/bsd/dev/i386/ |
H A D | cons.c | 74 int cnselect(__unused dev_t dev, int flag, void * wql, proc_t p); 145 cnselect(__unused dev_t dev, int flag, void *wql, struct proc *p) argument 148 return ((*cdevsw[major(dev)].d_select)(dev, flag, wql, p));
|
/xnu-2782.1.97/bsd/kern/ |
H A D | tty_tty.c | 82 int cttyselect(dev_t dev, int flag, void* wql, proc_t p); 238 cttyselect(__unused dev_t dev, int flag, void* wql, __unused proc_t p) argument 249 error = VNOP_SELECT(ttyvp, flag, FREAD|FWRITE, wql, &context);
|
H A D | sys_socket.c | 312 soo_select(struct fileproc *fp, int which, void *wql, vfs_context_t ctx) argument 339 selrecord(procp, &so->so_rcv.sb_sel, wql); 349 selrecord(procp, &so->so_snd.sb_sel, wql); 359 selrecord(procp, &so->so_rcv.sb_sel, wql);
|
H A D | subr_log.c | 232 logselect(__unused dev_t dev, int rw, void * wql, struct proc *p) argument 242 selrecord(p, &logsoftc.sc_selp, wql);
|
H A D | tty_dev.c | 701 ptsselect(dev_t dev, int rw, void *wql, proc_t p) argument 727 selrecord(p, &tp->t_rsel, wql); 741 selrecord(p, &tp->t_wsel, wql); 750 ptcselect(dev_t dev, int rw, void *wql, proc_t p) argument 786 selrecord(p, &pti->pt_selr, wql); 810 selrecord(p, &pti->pt_selw, wql);
|
H A D | sys_pipe.c | 165 static int pipe_select(struct fileproc *fp, int which, void * wql, 1175 pipe_select(struct fileproc *fp, int which, void *wql, vfs_context_t ctx) argument 1210 selrecord(vfs_context_proc(ctx), &rpipe->pipe_sel, wql); local 1224 selrecord(vfs_context_proc(ctx), &wpipe->pipe_sel, wql); local 1229 selrecord(vfs_context_proc(ctx), &rpipe->pipe_sel, wql); local
|
H A D | kern_event.c | 125 static int kqueue_select(struct fileproc *fp, int which, void *wql, 2315 kqueue_select(struct fileproc *fp, int which, void *wql, argument 2337 if (wql != NULL) { 2343 (wait_queue_link_t)wql); 2597 knote_link_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t wql) argument 2602 kr = wait_queue_link_noalloc(wq, kq->kq_wqs, wql);
|
H A D | posix_sem.c | 176 static int psem_select (struct fileproc *fp, int which, void *wql, vfs_context_t ctx); 1092 __unused void *wql, __unused vfs_context_t ctx) 1091 psem_select(__unused struct fileproc *fp, __unused int which, __unused void *wql, __unused vfs_context_t ctx) argument
|
H A D | posix_shm.c | 180 static int pshm_select (struct fileproc *fp, int which, void *wql, vfs_context_t ctx); 1240 pshm_select(__unused struct fileproc *fp, __unused int which, __unused void *wql, argument
|
/xnu-2782.1.97/bsd/sys/ |
H A D | file_internal.h | 179 void *wql, vfs_context_t ctx); 210 int fo_select(struct fileproc *fp, int which, void *wql, vfs_context_t ctx);
|
H A D | tty.h | 308 int ttyselect(struct tty *tp, int rw, void * wql, struct proc *p); 309 int ttselect(dev_t dev, int rw, void * wql, struct proc *p);
|
H A D | user.h | 147 char * wql; member in struct:uthread::__anon562::_select_data
|
H A D | conf.h | 112 typedef int select_fcn_t(dev_t dev, int which, void * wql, struct proc *p);
|
H A D | event.h | 473 extern int knote_link_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t wql);
|
/xnu-2782.1.97/tools/lldbmacros/ |
H A D | ipc.py | 167 wql = Cast(pset.ips_messages.data.pset.set_queue.wqs_setlinks.next, 'WaitQueueLink *') 170 while unsigned(wql) != unsigned(Cast(setlinksp, 'void *')): 171 portp = kern.GetValueFromAddress(unsigned(wql.wql_element.wqe_queue) - portoff, 'ipc_port *') 176 wql = Cast(wql.wql_setlinks.next, 'WaitQueueLink *')
|
/xnu-2782.1.97/bsd/vfs/ |
H A D | vfs_vnops.c | 127 static int vn_select( struct fileproc *fp, int which, void * wql, 1446 vn_select(struct fileproc *fp, int which, void *wql, __unused vfs_context_t ctx) argument 1465 error = VNOP_SELECT(vp, which, fp->f_fglob->fg_flag, wql, ctx);
|