Home
last modified time | relevance | path

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

1234

/netbsd/sys/external/bsd/drm2/dist/drm/amd/amdkfd/
H A Dkfd_kernel_queue.c95 kq->pq_kernel_addr = kq->pq->cpu_ptr; in kq_initialize()
96 kq->pq_gpu_addr = kq->pq->gpu_addr; in kq_initialize()
151 kq->queue->mqd_mem_obj = kq->mqd_mgr->allocate_mqd(kq->mqd_mgr->dev, in kq_initialize()
155 kq->mqd_mgr->init_mqd(kq->mqd_mgr, &kq->queue->mqd, in kq_initialize()
164 kq->mqd_mgr->load_mqd(kq->mqd_mgr, kq->queue->mqd, in kq_initialize()
165 kq->queue->pipe, kq->queue->queue, in kq_initialize()
184 kq->mqd_mgr->free_mqd(kq->mqd_mgr, kq->queue->mqd, kq->queue->mqd_mem_obj); in kq_initialize()
206 kq->mqd_mgr->destroy_mqd(kq->mqd_mgr, in kq_uninitialize()
215 kq->mqd_mgr->free_mqd(kq->mqd_mgr, kq->queue->mqd, in kq_uninitialize()
226 kfd_gtt_sa_free(kq->dev, kq->pq); in kq_uninitialize()
[all …]
H A Dkfd_process_queue_manager.c43 (pqn->kq && pqn->kq->queue->properties.queue_id == qid)) in get_queue_by_qid()
212 kq = NULL; in pqm_create_queue()
263 pqn->kq = NULL; in pqm_create_queue()
284 pqn->kq = NULL; in pqm_create_queue()
291 if (!kq) { in pqm_create_queue()
296 pqn->kq = kq; in pqm_create_queue()
365 if (pqn->kq) in pqm_destroy_queue()
366 dev = pqn->kq->dev; in pqm_destroy_queue()
378 if (pqn->kq) { in pqm_destroy_queue()
479 if (pqn && pqn->kq) in pqm_get_kernel_queue()
[all …]
/netbsd/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
1729 kq = kmem_zalloc(sizeof(*kq), KM_SLEEP); in kqueue1()
2174 !!(kq->kq_count & KQ_RESTART), KQ_COUNT(kq)); in kqueue_printit()
2229 func, line, kq, KQ_COUNT(kq), count, in kqueue_check()
2401 kq_check(kq); in kqueue_scan()
2404 kq_check(kq); in kqueue_scan()
2619 kq_check(kq); in kqueue_poll()
2726 kq_check(kq); in kqueue_close()
2734 kmem_free(kq, sizeof(*kq)); in kqueue_close()
[all …]
/netbsd/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()
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()
125 *(int *)CMSG_DATA(msg) = kq; in ATF_TC_BODY()
136 close(kq); in ATF_TC_BODY()
152 int fd, kq; in ATF_TC_BODY() local
175 (void)close(kq); in ATF_TC_BODY()
187 int kq; in ATF_TC_BODY() local
[all …]
/netbsd/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()
168 int kq; in ATF_TC_BODY() local
170 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
198 int kq; in ATF_TC_BODY() local
200 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
280 int kq; in ATF_TC_BODY() local
282 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
314 int kq; in do_test_timer_units() local
316 ATF_REQUIRE((kq = kqueue()) >= 0); in do_test_timer_units()
[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()
527 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
549 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &ts) == 1); in ATF_TC_BODY()
554 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &ts) == 1); in ATF_TC_BODY()
560 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &ts) == 1); in ATF_TC_BODY()
625 ATF_REQUIRE((kq = kqueue()) != -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()
186 kq = kqueue(); in ATF_TC_BODY()
187 ATF_REQUIRE(kq >= 0); 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_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_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_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/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()
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
165 nn = read(kq, &iev, sizeof(iev)); in rumpcomp_shmif_watchwait()
[all …]
/netbsd/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/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/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/external/bsd/ntp/dist/sntp/libevent/
H A Dkqueue.c80 int kq; member
120 int kq = -1; in kq_init() local
128 if ((kq = kqueue()) == -1) { in kq_init()
133 kqueueop->kq = kq; in kq_init()
156 if (kevent(kq, in kq_init()
303 res = kevent(kqop->kq, changes, n_changes, in kq_dispatch()
426 if (kqop->kq >= 0 && kqop->pid == getpid()) in kqop_free()
427 close(kqop->kq); in kqop_free()
459 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add()
493 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_del()
[all …]
/netbsd/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/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/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/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()

1234