Home
last modified time | relevance | path

Searched refs:kq (Results 1 – 25 of 80) sorted by relevance

1234

/netbsd-src/sys/external/bsd/drm2/dist/drm/amd/amdkfd/
H A Dkfd_kernel_queue.c45 static bool kq_initialize(struct kernel_queue *kq, struct kfd_dev *dev, in kq_initialize() argument
65 kq->dev = dev; in kq_initialize()
66 kq->nop_packet = nop.u32all; in kq_initialize()
69 kq->mqd_mgr = dev->dqm->mqd_mgrs[KFD_MQD_TYPE_DIQ]; in kq_initialize()
72 kq->mqd_mgr = dev->dqm->mqd_mgrs[KFD_MQD_TYPE_HIQ]; in kq_initialize()
79 if (!kq->mqd_mgr) in kq_initialize()
89 retval = kfd_gtt_sa_allocate(dev, queue_size, &kq->pq); in kq_initialize()
95 kq->pq_kernel_addr = kq->pq->cpu_ptr; in kq_initialize()
96 kq->pq_gpu_addr = kq->pq->gpu_addr; in kq_initialize()
100 retval = kfd_gtt_sa_allocate(dev, PAGE_SIZE, &kq->eop_mem); in kq_initialize()
[all …]
H A Dkfd_process_queue_manager.c43 (pqn->kq && pqn->kq->queue->properties.queue_id == qid)) in get_queue_by_qid()
207 struct kernel_queue *kq; in pqm_create_queue() local
212 kq = NULL; in pqm_create_queue()
263 pqn->kq = NULL; in pqm_create_queue()
284 pqn->kq = NULL; in pqm_create_queue()
290 kq = kernel_queue_init(dev, KFD_QUEUE_TYPE_DIQ); in pqm_create_queue()
291 if (!kq) { in pqm_create_queue()
295 kq->queue->properties.queue_id = *qid; in pqm_create_queue()
296 pqn->kq = kq; in pqm_create_queue()
299 kq, &pdd->qpd); in pqm_create_queue()
[all …]
/netbsd-src/sys/kern/
H A Dkern_event.c391 #define KQ_FLUX_WAIT(kq) (void)cv_wait(&kq->kq_cv, &kq->kq_lock) argument
392 #define KQ_FLUX_WAKEUP(kq) cv_broadcast(&kq->kq_cv) argument
460 struct kqueue *kq = kn->kn_kq; in knote_detach_quiesce() local
461 filedesc_t *fdp = kq->kq_fdp; in knote_detach_quiesce()
465 mutex_spin_enter(&kq->kq_lock); in knote_detach_quiesce()
498 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
501 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
531 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
534 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
870 struct kqueue *kq; in filt_kqdetach() local
[all …]
/netbsd-src/tests/lib/libc/sys/
H A Dt_kevent.c62 int kq; in ATF_TC_BODY() local
64 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
66 ATF_REQUIRE(kevent(kq, &ev, 1, NULL, 0, NULL) != -1); in ATF_TC_BODY()
67 ATF_REQUIRE(kevent(kq, NULL, 0, &ev, 1, NULL) == 1); in ATF_TC_BODY()
80 int s[2], storage, status, kq; in ATF_TC_BODY() local
86 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
111 kq = *(int *)CMSG_DATA(msg); in ATF_TC_BODY()
112 printf("child (pid %d): received kq fd %d\n", getpid(), kq); in ATF_TC_BODY()
125 *(int *)CMSG_DATA(msg) = kq; in ATF_TC_BODY()
128 ATF_CHECK(kevent(kq, &ev, 1, NULL, 0, NULL) != -1); in ATF_TC_BODY()
[all …]
/netbsd-src/tests/kernel/kqueue/
H A Dt_timer.c91 int kq; in ATF_TC_BODY() local
93 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
98 ATF_REQUIRE(kevent(kq, event, 2, NULL, 0, NULL) == 0); in ATF_TC_BODY()
102 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, NULL) == 1); in ATF_TC_BODY()
120 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, in ATF_TC_BODY()
138 kevent(kq, event, 1, NULL, 0, NULL) == -1); in ATF_TC_BODY()
150 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &ts) == 0); in ATF_TC_BODY()
168 int kq; in ATF_TC_BODY() local
170 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
173 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
[all …]
H A Dt_vnode.c24 static int kq = -1; variable
47 kq = kqueue(); in init_kqueue()
48 if (kq < 0) { in init_kqueue()
55 return kevent(kq, eventlist, 1, NULL, 0, NULL); in init_kqueue()
80 (void)close(kq); in cleanup()
99 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
123 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
147 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
171 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
194 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
[all …]
H A Dt_sig.c67 int kq, n, num, status; in ATF_TC_BODY() local
85 RL(kq = kqueue()); in ATF_TC_BODY()
89 RL(ioctl(kq, KFILTER_BYNAME, &km)); in ATF_TC_BODY()
99 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
110 RL(n = kevent(kq, NULL, 0, event, 1, &timeout)); in ATF_TC_BODY()
144 int kq; in ATF_TC_BODY() local
154 kq = kqueue(); in ATF_TC_BODY()
155 ATF_REQUIRE(kq >= 0); in ATF_TC_BODY()
163 ATF_REQUIRE(kevent(kq, events, 2, &events[2], 1, NULL) == 1); in ATF_TC_BODY()
186 kq = kqueue(); in ATF_TC_BODY()
[all …]
H A Dt_ioctl.c57 int kq; in ATF_TC_BODY() local
60 RL(kq = kqueue()); in ATF_TC_BODY()
67 RL(ioctl(kq, KFILTER_BYFILTER, &km)); in ATF_TC_BODY()
72 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYFILTER, &km), -1); in ATF_TC_BODY()
84 int kq; in ATF_TC_BODY() local
86 RL(kq = kqueue()); in ATF_TC_BODY()
92 RL(ioctl(kq, KFILTER_BYNAME, &km)); in ATF_TC_BODY()
97 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYNAME, &km), -1); in ATF_TC_BODY()
H A Dt_empty.c54 int kq, error, sndbufsize; in test_empty() local
58 ATF_REQUIRE((kq = kqueue()) >= 0); in test_empty()
61 ATF_REQUIRE(kevent(kq, &event, 1, NULL, 0, NULL) == 0); in test_empty()
65 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 1); in test_empty()
97 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 0); in test_empty()
122 if (kevent(kq, NULL, 0, &event, 1, &ts) == 1) { in test_empty()
129 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 1); in test_empty()
H A Dt_proc4.c86 int kq, status; in ATF_TC_BODY() local
91 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
96 ATF_REQUIRE(kevent(kq, &event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
113 rv = kevent(kq, NULL, 0, &event, 1, NULL); in ATF_TC_BODY()
160 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 0); in ATF_TC_BODY()
162 (void)close(kq); in ATF_TC_BODY()
H A Dt_proc3.c60 int kq, status; in ATF_TC_BODY() local
64 RL(kq = kqueue()); in ATF_TC_BODY()
68 RL(kevent(kq, &ke, 1, NULL, 0, NULL)); in ATF_TC_BODY()
86 RL(kevent(kq, NULL, 0, &ke, 1, &timeout)); in ATF_TC_BODY()
87 RL(close(kq)); in ATF_TC_BODY()
H A Dt_proc2.c93 int kq, status; in ATF_TC_BODY() local
97 RL(kq = kqueue()); in ATF_TC_BODY()
112 RL(kevent(kq, &ke, 1, NULL, 0, &timeout)); in ATF_TC_BODY()
120 RL(kevent(kq, NULL, 0, &ke, 1, &timeout)); in ATF_TC_BODY()
121 RL(close(kq)); in ATF_TC_BODY()
H A Dt_oneshot.c54 int kq; in ATF_TC_BODY() local
56 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
60 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
62 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, NULL) == 1); in ATF_TC_BODY()
/netbsd-src/sys/rump/net/lib/libshmif/
H A Dshmif_user.c62 int rv, kq; in rumpcomp_shmif_watchsetup() local
64 kq = *kqp; in rumpcomp_shmif_watchsetup()
65 if (kq == -1) { in rumpcomp_shmif_watchsetup()
66 kq = kqueue(); in rumpcomp_shmif_watchsetup()
67 if (kq == -1) { in rumpcomp_shmif_watchsetup()
75 if (kevent(kq, &kev, 1, NULL, 0, NULL) == -1) { in rumpcomp_shmif_watchsetup()
79 *kqp = kq; in rumpcomp_shmif_watchsetup()
87 rumpcomp_shmif_watchwait(int kq) in rumpcomp_shmif_watchwait() argument
95 rv = kevent(kq, NULL, 0, &kev, 1, NULL); in rumpcomp_shmif_watchwait()
156 rumpcomp_shmif_watchwait(int kq) in rumpcomp_shmif_watchwait() argument
[all …]
/netbsd-src/tests/kernel/kqueue/write/
H A Dt_pipe.c60 int kq, n; in ATF_TC_BODY() local
63 RL(kq = kqueue()); in ATF_TC_BODY()
67 ATF_REQUIRE_EQ_MSG((n = kevent(kq, event, 1, NULL, 0, NULL)), in ATF_TC_BODY()
84 int kq, n; in ATF_TC_BODY() local
89 RL(kq = kqueue()); in ATF_TC_BODY()
92 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
103 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
125 int kq; in ATF_TC_BODY() local
128 RL(kq = kqueue()); in ATF_TC_BODY()
131 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
H A Dt_fifo.c78 int rfd, wfd, kq; in ATF_TC_BODY() local
86 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
96 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
99 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
114 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
124 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
131 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
137 (void)close(kq); in ATF_TC_BODY()
/netbsd-src/tests/kernel/kqueue/read/
H A Dt_fifo.c78 int rfd, wfd, kq; in ATF_TC_BODY() local
86 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
96 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
99 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
105 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
114 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
118 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
128 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
132 (void)close(kq); in ATF_TC_BODY()
H A Dt_ttypty.c59 int kq, n, status; in h_check() local
99 RL(kq = kqueue()); in h_check()
102 RL(kevent(kq, event, 1, NULL, 0, NULL)); in h_check()
104 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in h_check()
150 int kq, n; in ATF_TC_BODY() local
158 RL(kq = kqueue()); in ATF_TC_BODY()
161 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
165 RL(n = kevent(kq, NULL, 0, event, 1, &timeout)); in ATF_TC_BODY()
H A Dt_pipe.c56 int kq, n; in ATF_TC_BODY() local
59 RL(kq = kqueue()); in ATF_TC_BODY()
62 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
68 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
/netbsd-src/usr.bin/tail/
H A Dforward.c91 int kq=-1, action=USE_SLEEP; in forward() local
175 kq = kqueue(); in forward()
176 if (kq < 0) in forward()
211 if (kevent(kq, ev, n, NULL, 0, NULL) == -1) { in forward()
212 close(kq); in forward()
213 kq = -1; in forward()
221 if (kevent(kq, NULL, 0, ev, 1, NULL) == -1) in forward()
255 if (kq != -1) in forward()
257 } else if (kq != -1) in forward()
264 if (fflag && kq != -1) in forward()
[all …]
/netbsd-src/external/bsd/libevent/dist/
H A Dkqueue.c86 int kq; member
126 int kq = -1; in kq_init() local
134 if ((kq = kqueue()) == -1) { in kq_init()
139 kqueueop->kq = kq; in kq_init()
162 if (kevent(kq, in kq_init()
318 res = kevent(kqop->kq, changes, n_changes, in kq_dispatch()
441 if (kqop->kq >= 0 && kqop->pid == getpid()) in kqop_free()
442 close(kqop->kq); in kqop_free()
474 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add()
508 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_del()
[all …]
/netbsd-src/usr.sbin/autofs/
H A Dautounmountd.c230 do_wait(int kq, time_t sleep_time) in do_wait() argument
243 nevents = kevent(kq, NULL, 0, &unused, 1, &timeout); in do_wait()
246 nevents = kevent(kq, NULL, 0, &unused, 1, NULL); in do_wait()
266 int ch, debug = 0, error, kq; in main_autounmountd() local
324 kq = kqueue(); in main_autounmountd()
325 if (kq < 0) in main_autounmountd()
329 error = kevent(kq, &event, 1, NULL, 0, NULL); in main_autounmountd()
350 do_wait(kq, sleep_time); in main_autounmountd()
/netbsd-src/regress/sys/kern/kqueue/vnode/
H A Dvnode.c51 int fd, kq, n, i; in main() local
70 kq = kqueue(); in main()
71 if (kq == -1) in main()
86 n = kevent(kq, event, i, NULL, 0, NULL); in main()
97 n = kevent(kq, NULL, 0, event, 1, &timeout); in main()
/netbsd-src/usr.bin/pwait/
H A Dpwait.c73 int kq; in main() local
124 kq = kqueue(); in main()
125 if (kq == -1) in main()
151 if (kevent(kq, e + nleft, 1, NULL, 0, NULL) == -1) in main()
161 switch (rv = kevent(kq, NULL, 0, e, nleft, tsp)) { in main()
/netbsd-src/tests/lib/libc/kevent_nullmnt/
H A Dh_nullmnt.c33 int kq, nev, rsize; in main() local
52 if ((kq = kqueue()) == -1) in main()
61 if (kevent(kq, &eventlist, 1, NULL, 0, NULL) == -1) in main()
71 nev = kevent(kq, NULL, 0, &eventlist, 1, &timeout); in main()

1234