/netbsd/sys/external/bsd/drm2/dist/drm/amd/amdkfd/ |
H A D | kfd_kernel_queue.c | 95 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 D | kfd_process_queue_manager.c | 43 (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 D | kern_event.c | 391 #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 D | t_kevent.c | 62 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 D | t_timer.c | 91 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 D | t_vnode.c | 24 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 D | t_sig.c | 67 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 D | t_ioctl.c | 57 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 D | t_empty.c | 54 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 D | t_proc3.c | 60 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 D | t_proc4.c | 86 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 D | t_proc2.c | 93 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 D | t_oneshot.c | 54 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 D | shmif_user.c | 62 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 D | t_pipe.c | 60 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 D | t_fifo.c | 78 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 D | t_fifo.c | 78 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 D | t_ttypty.c | 59 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 D | t_pipe.c | 56 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 D | forward.c | 91 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 D | kqueue.c | 80 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 D | kqueue.c | 86 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 D | autounmountd.c | 230 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 D | vnode.c | 51 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 D | pwait.c | 73 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()
|