kq                 69 kern/kern_event.c void	kqueue_wakeup(struct kqueue *kq);
kq                163 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data;
kq                169 kern/kern_event.c 	SLIST_INSERT_HEAD(&kq->kq_sel.si_note, kn, kn_selnext);
kq                176 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data;
kq                178 kern/kern_event.c 	SLIST_REMOVE(&kq->kq_sel.si_note, kn, knote, kn_selnext);
kq                185 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data;
kq                187 kern/kern_event.c 	kn->kn_data = kq->kq_count;
kq                383 kern/kern_event.c 	struct kqueue *kq;
kq                393 kern/kern_event.c 	kq = pool_get(&kqueue_pool, PR_WAITOK);
kq                394 kern/kern_event.c 	bzero(kq, sizeof(*kq));
kq                395 kern/kern_event.c 	TAILQ_INIT(&kq->kq_head);
kq                396 kern/kern_event.c 	fp->f_data = (caddr_t)kq;
kq                400 kern/kern_event.c 	kq->kq_fdp = fdp;
kq                418 kern/kern_event.c 	struct kqueue *kq;
kq                436 kern/kern_event.c 	kq = (struct kqueue *)fp->f_data;
kq                442 kern/kern_event.c 		error = copyin(SCARG(uap, changelist), kq->kq_kev,
kq                447 kern/kern_event.c 			kevp = &kq->kq_kev[i];
kq                449 kern/kern_event.c 			error = kqueue_register(kq, kevp, p);
kq                483 kern/kern_event.c kqueue_register(struct kqueue *kq, struct kevent *kev, struct proc *p)
kq                485 kern/kern_event.c 	struct filedesc *fdp = kq->kq_fdp;
kq                515 kern/kern_event.c 				if (kq == kn->kn_kq &&
kq                527 kern/kern_event.c 				    kq == kn->kn_kq &&
kq                550 kern/kern_event.c 			kn->kn_kq = kq;
kq                620 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)fp->f_data;
kq                666 kern/kern_event.c 	kevp = kq->kq_kev;
kq                668 kern/kern_event.c 	if (kq->kq_count == 0) {
kq                672 kern/kern_event.c 			kq->kq_state |= KQ_SLEEP;
kq                673 kern/kern_event.c 			error = tsleep(kq, PSOCK | PCATCH, "kqread", timeout);
kq                686 kern/kern_event.c 	TAILQ_INSERT_TAIL(&kq->kq_head, &marker, kn_tqe);
kq                688 kern/kern_event.c 		kn = TAILQ_FIRST(&kq->kq_head);
kq                689 kern/kern_event.c 		TAILQ_REMOVE(&kq->kq_head, kn, kn_tqe);
kq                698 kern/kern_event.c 			kq->kq_count--;
kq                704 kern/kern_event.c 			kq->kq_count--;
kq                712 kern/kern_event.c 			kq->kq_count--;
kq                721 kern/kern_event.c 			kq->kq_count--;
kq                723 kern/kern_event.c 			TAILQ_INSERT_TAIL(&kq->kq_head, kn, kn_tqe);
kq                728 kern/kern_event.c 			error = copyout((caddr_t)&kq->kq_kev, (caddr_t)ulistp,
kq                732 kern/kern_event.c 			kevp = kq->kq_kev;
kq                738 kern/kern_event.c 	TAILQ_REMOVE(&kq->kq_head, &marker, kn_tqe);
kq                742 kern/kern_event.c 		error = copyout((caddr_t)&kq->kq_kev, (caddr_t)ulistp,
kq                778 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)fp->f_data;
kq                783 kern/kern_event.c 		if (kq->kq_count) {
kq                786 kern/kern_event.c 			selrecord(p, &kq->kq_sel);
kq                787 kern/kern_event.c 			kq->kq_state |= KQ_SEL;
kq                798 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)fp->f_data;
kq                801 kern/kern_event.c 	st->st_size = kq->kq_count;
kq                811 kern/kern_event.c 	struct kqueue *kq = (struct kqueue *)fp->f_data;
kq                821 kern/kern_event.c 			if (kq == kn->kn_kq) {
kq                839 kern/kern_event.c 				if (kq == kn->kn_kq) {
kq                851 kern/kern_event.c 	pool_put(&kqueue_pool, kq);
kq                858 kern/kern_event.c kqueue_wakeup(struct kqueue *kq)
kq                861 kern/kern_event.c 	if (kq->kq_state & KQ_SLEEP) {
kq                862 kern/kern_event.c 		kq->kq_state &= ~KQ_SLEEP;
kq                863 kern/kern_event.c 		wakeup(kq);
kq                865 kern/kern_event.c 	if (kq->kq_state & KQ_SEL) {
kq                866 kern/kern_event.c 		kq->kq_state &= ~KQ_SEL;
kq                867 kern/kern_event.c 		selwakeup(&kq->kq_sel);
kq                869 kern/kern_event.c 	KNOTE(&kq->kq_sel.si_note, 0);
kq                974 kern/kern_event.c 	struct kqueue *kq = kn->kn_kq;
kq                979 kern/kern_event.c 	TAILQ_INSERT_TAIL(&kq->kq_head, kn, kn_tqe);
kq                981 kern/kern_event.c 	kq->kq_count++;
kq                983 kern/kern_event.c 	kqueue_wakeup(kq);
kq                989 kern/kern_event.c 	struct kqueue *kq = kn->kn_kq;
kq                994 kern/kern_event.c 	TAILQ_REMOVE(&kq->kq_head, kn, kn_tqe);
kq                996 kern/kern_event.c 	kq->kq_count--;
kq                141 kern/kern_kthread.c 	struct kthread_q *kq;
kq                148 kern/kern_kthread.c 	kq = malloc(sizeof *kq, M_TEMP, M_NOWAIT);
kq                149 kern/kern_kthread.c 	if (kq == NULL)
kq                151 kern/kern_kthread.c 	bzero(kq, sizeof *kq);
kq                153 kern/kern_kthread.c 	kq->kq_func = func;
kq                154 kern/kern_kthread.c 	kq->kq_arg = arg;
kq                156 kern/kern_kthread.c 	SIMPLEQ_INSERT_TAIL(&kthread_q, kq, kq_q);
kq                162 kern/kern_kthread.c 	struct kthread_q *kq;
kq                167 kern/kern_kthread.c 	while ((kq = SIMPLEQ_FIRST(&kthread_q)) != NULL) {
kq                169 kern/kern_kthread.c 		(*kq->kq_func)(kq->kq_arg);
kq                170 kern/kern_kthread.c 		free(kq, M_TEMP);
kq                169 sys/event.h    extern int	kqueue_register(struct kqueue *kq,
kq                181 sys/event.h    int	kevent(int kq, const struct kevent *changelist, int nchanges,