| /src/share/examples/puffs/pgfs/ |
| pgfs_waitq.c | 44 struct waiter { struct
45 TAILQ_ENTRY(waiter) list;
59 struct waiter w;
74 struct waiter *w;
91 struct waiter *w;
|
| /src/sys/external/bsd/drm2/dist/drm/i915/ |
| i915_scheduler_types.h | 76 struct i915_sched_node *waiter; member in struct:i915_dependency
|
| i915_sw_fence.c | 167 autoremove_wake_function(struct i915_sw_fence_waiter *waiter, unsigned mode,
170 struct i915_sw_fence_wq *sfw = waiter->private;
181 struct i915_sw_fence_waiter waiter; local in function:i915_sw_fence_wait
185 waiter.flags = 0;
186 waiter.func = autoremove_wake_function;
187 waiter.private = &sfw;
193 list_add_tail(&waiter.entry, &fence->wait.head);
196 list_del(&waiter.entry);
|
| /src/lib/libpthread/ |
| pthread_cond.c | 65 * A dummy waiter that's used to flag that pthread_cond_signal() is in
66 * progress and nobody else should try to modify the waiter list until
128 struct pthread__waiter waiter, *next, *head; local in function:pthread_cond_timedwait
161 waiter.lid = self->pt_lid;
162 waiter.next = head;
166 next = atomic_cas_ptr(&cond->ptc_waiters, head, &waiter);
175 while (waiter.lid &&
194 * And if awoken early, we may still be on the waiter list and must
202 * Wait until released, otherwise "waiter" is still globally
206 while (__predict_false(waiter.lid))
[all...] |
| pthread_mutex.c | 98 struct waiter { struct
99 struct waiter *volatile next;
278 struct waiter waiter; local in function:pthread__mutex_lock_slow
332 * Issue a memory barrier to ensure stores to 'waiter'
335 waiter.next = ptm->ptm_waiters;
336 waiter.lid = self->pt_lid;
340 next = atomic_cas_ptr(&ptm->ptm_waiters, waiter.next, &waiter);
341 if (next != waiter.next)
[all...] |
| /src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/ |
| vchiq_kern_lib.c | 147 struct bulk_waiter_node *waiter; local in function:vchiq_shutdown
148 waiter = list_entry(pos,
155 waiter, waiter->pid);
156 _sema_destroy(&waiter->bulk_waiter.event);
158 kfree(waiter);
385 struct bulk_waiter_node *waiter = NULL; local in function:vchiq_blocking_bulk_transfer
400 waiter = list_entry(pos,
409 if (waiter) {
410 VCHIQ_BULK_T *bulk = waiter->bulk_waiter.bulk
[all...] |
| vchiq_arm.c | 716 struct bulk_waiter_node *waiter = NULL; local in function:vchiq_ioctl
728 waiter = kzalloc(sizeof(struct bulk_waiter_node),
730 if (!waiter) {
734 args.userdata = &waiter->bulk_waiter;
741 waiter = list_entry(pos,
750 if (!waiter) {
759 waiter, current->l_proc->p_pid);
760 args.userdata = &waiter->bulk_waiter;
768 if (!waiter)
771 !waiter->bulk_waiter.bulk)
1318 struct bulk_waiter_node *waiter; local in function:vchiq_close
[all...] |
| vchiq_core.c | 1234 struct bulk_waiter *waiter; local in function:notify_bulks
1236 waiter = bulk->userdata;
1237 if (waiter) {
1238 waiter->actual = bulk->actual;
1239 up(&waiter->event);
|
| /src/tests/kernel/ |
| t_sysv.c | 66 void waiter(void);
468 waiter();
562 waiter(void) function in typeref:typename:void
568 err(EXIT_FAILURE, "waiter: semget");
578 err(EXIT_FAILURE, "waiter: semop -1");
591 err(EXIT_FAILURE, "waiter: semop +1");
|
| /src/sys/external/bsd/drm2/dist/drm/amd/amdkfd/ |
| kfd_events.c | 245 struct kfd_event_waiter *waiter; local in function:destroy_event
248 list_for_each_entry(waiter, &ev->wq.head, wait.entry)
249 waiter->event = NULL;
395 struct kfd_event_waiter *waiter; local in function:set_event
404 list_for_each_entry(waiter, &ev->wq.head, wait.entry)
405 waiter->activated = true;
549 struct kfd_event_waiter *waiter,
557 waiter->event = ev;
558 waiter->activated = ev->signaled;
564 static void init_event_waiter_add_to_waitlist(struct kfd_event_waiter *waiter)
617 struct kfd_event_waiter *waiter; local in function:copy_signaled_event_data
[all...] |
| /src/lib/librumpuser/ |
| rumpfiber.c | 588 TAILQ_HEAD(waithead, waiter);
589 struct waiter { struct
591 TAILQ_ENTRY(waiter) entries;
598 struct waiter w;
618 struct waiter *w;
630 struct waiter *w;
|
| /src/tests/lib/libc/sys/ |
| t_futex_ops.c | 392 DPRINTF(("futex_basic_wait_wake: waking 1 waiter\n"));
872 /* Wake one waiter on 1, move one waiter to 0. */
1430 /* Signal the waiter so that it leaves the futex. */
1496 lwpid_t waiter; local in function:do_test_wake_highest_pri
1526 "lowpri waiter failed to start, nlwps_running=%u", nlwps_running);
1549 "highpri waiter failed to start, nlwps_running=%u", nlwps_running);
1569 RL(_lwp_wait(0, &waiter));
1570 ATF_REQUIRE_EQ_MSG(waiter, lwp_data[1].threadid,
1571 "waiter=%ld lwp_data[1].threadid=%ld"
[all...] |
| /src/libexec/ld.elf_so/ |
| rtld.c | 1722 lwpid_t waiter, self = 0; local in function:_rtld_shared_enter
1737 * Someone has an exclusive lock. Puts us on the waiter list.
1747 waiter = atomic_swap_uint(&_rtld_waiter_shared, self);
1756 /* Try to remove us from the waiter list. */
1758 if (waiter)
1759 _lwp_unpark(waiter, __UNVOLATILE(&_rtld_mutex));
1766 lwpid_t waiter; local in function:_rtld_shared_exit
1783 if ((waiter = _rtld_waiter_exclusive) != 0)
1784 _lwp_unpark(waiter, __UNVOLATILE(&_rtld_mutex));
1790 lwpid_t waiter, self = _lwp_self() local in function:_rtld_exclusive_enter
1823 lwpid_t waiter; local in function:_rtld_exclusive_exit
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/i915/display/ |
| intel_display.c | 15277 intel_atomic_commit_fence_wake(struct i915_sw_fence_waiter *waiter,
15280 struct intel_atomic_state *intel_state = waiter->private;
15294 struct i915_sw_fence_waiter waiter; local in function:intel_atomic_commit_fence_wait
15297 waiter.flags = 0;
15298 waiter.func = intel_atomic_commit_fence_wake;
15299 waiter.private = intel_state;
15302 list_add_tail(&waiter.entry, &intel_state->commit_ready.wait.head);
15313 list_del(&waiter.entry);
|
