Home
last modified time | relevance | path

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

12

/openbsd/sys/dev/pci/drm/amd/amdkfd/
H A Dkfd_kernel_queue.c91 kq->pq_kernel_addr = kq->pq->cpu_ptr; in kq_initialize()
92 kq->pq_gpu_addr = kq->pq->gpu_addr; in kq_initialize()
147 kq->queue->mqd_mem_obj = kq->mqd_mgr->allocate_mqd(kq->mqd_mgr->dev, in kq_initialize()
151 kq->mqd_mgr->init_mqd(kq->mqd_mgr, &kq->queue->mqd, in kq_initialize()
160 kq->mqd_mgr->load_mqd(kq->mqd_mgr, kq->queue->mqd, in kq_initialize()
161 kq->queue->pipe, kq->queue->queue, in kq_initialize()
180 kq->mqd_mgr->free_mqd(kq->mqd_mgr, kq->queue->mqd, kq->queue->mqd_mem_obj); in kq_initialize()
202 kq->mqd_mgr->destroy_mqd(kq->mqd_mgr, in kq_uninitialize()
211 kq->mqd_mgr->free_mqd(kq->mqd_mgr, kq->queue->mqd, in kq_uninitialize()
222 kfd_gtt_sa_free(kq->dev, kq->pq); in kq_uninitialize()
[all …]
H A Dkfd_process_queue_manager.c40 (pqn->kq && pqn->kq->queue->properties.queue_id == qid)) in get_queue_by_qid()
300 kq = NULL; in pqm_create_queue()
352 pqn->kq = NULL; in pqm_create_queue()
373 pqn->kq = NULL; in pqm_create_queue()
380 if (!kq) { in pqm_create_queue()
385 pqn->kq = kq; in pqm_create_queue()
435 if (kq) in pqm_create_queue()
466 if (pqn->kq) in pqm_destroy_queue()
479 if (pqn->kq) { in pqm_destroy_queue()
589 if (pqn && pqn->kq) in pqm_get_kernel_queue()
[all …]
H A Dkfd_kernel_queue.h47 int kq_acquire_packet_buffer(struct kernel_queue *kq,
50 void kq_submit_packet(struct kernel_queue *kq);
51 void kq_rollback_packet(struct kernel_queue *kq);
H A Dkfd_packet_manager.c132 struct kernel_queue *kq; in pm_create_runlist_ib() local
166 list_for_each_entry(kq, &qpd->priv_queue_list, list) { in pm_create_runlist_ib()
167 if (!kq->queue->properties.is_active) in pm_create_runlist_ib()
171 kq->queue->queue, qpd->is_debug); in pm_create_runlist_ib()
175 kq->queue, in pm_create_runlist_ib()
/openbsd/regress/sys/kern/kqueue/
H A DMakefile11 kq-exec: ${PROG}
13 kq-pipe: ${PROG}
15 kq-fork: ${PROG}
19 kq-random: ${PROG}
21 kq-tun: ${PROG}
27 kq-pty-1: ${PROG}
29 kq-pty-2: ${PROG}
56 TESTS+= kq-exec
59 TESTS+= kq-fork
61 TESTS+= kq-pipe
[all …]
H A Dkqueue-regress.c62 int kq; in do_regress1() local
95 int kq; in do_regress2() local
102 kq = kqueue(); in do_regress2()
103 if (kq == -1) in do_regress2()
170 kq = kqueue(); in make_chain()
171 if (kq == -1) in make_chain()
217 if (kq == -1) in do_regress4()
258 kq = kqueue(); in do_regress5()
259 if (kq == -1) in do_regress5()
398 if (kq == -1) in do_regress6()
[all …]
H A Dkqueue-timer.c41 int i, kq, n; in do_timer() local
43 ASS((kq = kqueue()) >= 0, in do_timer()
51 n = kevent(kq, &ev, 1, NULL, 0, NULL); in do_timer()
57 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_timer()
67 n = kevent(kq, &ev, 1, NULL, 0, NULL); in do_timer()
73 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_timer()
91 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_timer()
201 int i, kq, n; in do_invalid_timer() local
205 ASS((kq = kqueue()) >= 0, in do_invalid_timer()
260 int kq, msecs, n; in do_reset_timer() local
[all …]
H A Dkqueue-pty.c27 if ((n = kevent(kq, NULL, 0, ev, n, &ts)) < 0) in pty_check()
63 int fd, kq, massa, slave; in pty_rdrw() local
78 if ((kq = kqueue()) == -1) in pty_rdrw()
86 if (kevent(kq, ev, 4, NULL, 0, NULL) < 0) in pty_rdrw()
96 ASSX(pty_check(kq, ev, 4, -massa, slave, massa, slave) == 0); in pty_rdrw()
109 ASSX(pty_check(kq, ev, 4, -massa, slave, massa, slave) == 0); in pty_rdrw()
124 int kq, massa, n, slave; in pty_close() local
129 kq = kqueue(); in pty_close()
130 if (kq == -1) in pty_close()
134 if (kevent(kq, ev, 1, NULL, 0, NULL) == -1) in pty_close()
[all …]
H A Dkqueue-signal.c24 int kq; variable
35 ASS(kevent(kq, NULL, 0, &ke, 1, &ts) == 1, in sigtest()
57 ASS((kq = kqueue()) >= 0, warn("kqueue")); in do_signal()
63 ASS(kevent(kq, &ke, 1, NULL, 0, NULL) == 0, in do_signal()
66 ASS(kevent(kq, &ke, 1, NULL, 0, NULL) == 0, in do_signal()
70 ASS(kevent(kq, &ke, 1, NULL, 0, NULL) != 0, in do_signal()
94 close(kq); in do_signal()
H A Dkqueue-random.c22 int n, fd, kq; in do_random() local
32 ASS((kq = kqueue()) >= 0, in do_random()
39 n = kevent(kq, &ev, 1, NULL, 0, NULL); in do_random()
44 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_random()
50 close(kq); in do_random()
H A Dkqueue-pipe.c47 int kq; in do_pipe() local
59 ASS((kq = kqueue()) >= 0, in do_pipe()
66 n = kevent(kq, &ev, 1, NULL, 0, NULL); in do_pipe()
75 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_pipe()
82 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_pipe()
H A Dkqueue-process.c29 int kq, status; in do_process() local
41 ASS((kq = kqueue()) >= 0, in do_process()
59 ASS(kevent(kq, &ke, 1, NULL, 0, NULL) == 0, in do_process()
65 ASS(kevent(kq, &ke, 1, NULL, 0, NULL) != 0, in do_process()
77 ASS(kevent(kq, NULL, 0, &ke, 1, &ts) == 1, in do_process()
121 ASS(kevent(kq, NULL, 0, &ke, 1, &ts) == 1, in do_process()
142 close(kq); in do_process()
H A Dkqueue-fork.c20 int kq, status; in check_inheritance() local
22 ASS((kq = kqueue()) >= 0, in check_inheritance()
33 if (close(kq) < 0) in check_inheritance()
44 close(kq); in check_inheritance()
H A Dkqueue-flock.c60 int fd, kq; in do_flock() local
74 kq = kqueue(); in do_flock()
76 if (kevent(kq, &kev, 1, NULL, 0, NULL)) in do_flock()
82 if (kevent(kq, &kev, 1, NULL, 0, NULL)) in do_flock()
87 close(kq); in do_flock()
H A Dkqueue-exec.c54 int kq, status; in do_exec_parent() local
65 kq = kqueue1(cloexec ? O_CLOEXEC : 0); in do_exec_parent()
66 if (kq == -1) in do_exec_parent()
68 snprintf(fdbuf, sizeof(fdbuf), "%d", kq); in do_exec_parent()
/openbsd/sys/kern/
H A Dkern_event.c233 free(kq->kq_knlist, M_KEVENT, kq->kq_knlistsize * in KQRELE()
995 if (kq->kq_nknotes > 4 * kq->kq_knlistsize) in kqpoll_done()
1024 task_set(&kq->kq_task, kqueue_task, kq); in kqueue_alloc()
1052 kq = NULL; in dokqueue()
1232 func, line, kq, kq->kq_count, count, nmarker); in kqueue_do_check()
1666 KQREF(kq); in kqueue_scan_setup()
1690 KQRELE(kq); in kqueue_scan_finish()
1734 knote_remove(p, kq, &kq->kq_knlist, i, 1); in kqueue_purge()
1737 knote_remove(p, kq, &kq->kq_knhash, i, 1); in kqueue_purge()
1782 KQRELE(kq); in kqueue_close()
[all …]
H A Dkern_kthread.c116 struct kthread_q *kq; in kthread_create_deferred() local
123 kq = malloc(sizeof *kq, M_TEMP, M_NOWAIT|M_ZERO); in kthread_create_deferred()
124 if (kq == NULL) in kthread_create_deferred()
127 kq->kq_func = func; in kthread_create_deferred()
128 kq->kq_arg = arg; in kthread_create_deferred()
130 SIMPLEQ_INSERT_TAIL(&kthread_q, kq, kq_q); in kthread_create_deferred()
136 struct kthread_q *kq; in kthread_run_deferred_queue() local
141 while ((kq = SIMPLEQ_FIRST(&kthread_q)) != NULL) { in kthread_run_deferred_queue()
143 (*kq->kq_func)(kq->kq_arg); in kthread_run_deferred_queue()
144 free(kq, M_TEMP, sizeof(*kq)); in kthread_run_deferred_queue()
/openbsd/regress/lib/libc/sys/
H A Dt_kevent.c63 int kq; in ATF_TC_BODY() local
65 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
81 int s[2], storage, status, kq; in ATF_TC_BODY() local
87 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
116 kq = *(int *)CMSG_DATA(msg); in ATF_TC_BODY()
130 *(int *)CMSG_DATA(msg) = kq; in ATF_TC_BODY()
145 close(kq); in ATF_TC_BODY()
162 int fd, kq; in ATF_TC_BODY() local
185 (void)close(kq); in ATF_TC_BODY()
197 int kq; in ATF_TC_BODY() local
[all …]
/openbsd/regress/sys/kern/descrip/
H A Ddescrip.c31 int fd, kq, status; in main() local
34 kq = kqueue(); in main()
35 assert(kq == 3); in main()
46 kq = kqueue(); in main()
47 assert(kq == 3); in main()
/openbsd/lib/libevent/
H A Dkqueue.c60 int kq; member
84 int i, kq; in kq_init() local
96 if ((kq = kqueue()) == -1) { in kq_init()
102 kqueueop->kq = kq; in kq_init()
198 res = kevent(kqop->kq, kqop->nchanges ? changes : NULL, kqop->nchanges, in kq_dispatch()
309 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_add()
383 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_del()
446 if (kqop->kq >= 0 && kqop->pid == getpid()) in kq_dealloc()
447 close(kqop->kq); in kq_dealloc()
/openbsd/regress/lib/libpthread/restart/kevent/
H A Dkevent.c26 int kq; in thr_kevent() local
28 CHECKe(kq = kqueue()); in thr_kevent()
29 ASSERT(kevent(kq, NULL, 0, &ev, 1, &ts) == -1); in thr_kevent()
/openbsd/usr.bin/tail/
H A Dforward.c54 static int kq = -1; variable
91 if (fflag && (kq = kqueue()) == -1) in forward()
187 if (!fflag || kq == -1) in forward()
191 if ((nevents = kevent(kq, NULL, 0, &ke, 1, ts)) <= 0) { in forward()
193 close(kq); in forward()
305 if (kq < 0) { in tfqueue()
320 if (kevent(kq, ke, i, NULL, 0, NULL) == -1) { in tfqueue()
/openbsd/usr.sbin/apmd/
H A Dapmd.c422 int kq, nchanges; in main() local
527 kq = kqueue(); in main()
528 if (kq <= 0) in main()
540 if (kevent(kq, ev, nchanges, NULL, 0, &sts) == -1) in main()
548 if ((rv = kevent(kq, NULL, 0, ev, 1, &sts)) == -1) in main()
/openbsd/games/adventure/
H A Dsave.c75 {&kq, sizeof(kq)},
/openbsd/sys/sys/
H A Devent.h302 extern int kqueue_register(struct kqueue *kq, struct kevent *kev,
373 int kevent(int kq, const struct kevent *changelist, int nchanges,

12