compat/cloudabi/cloudabi_futex.c

214 futex_address_create(struct futex_address *fa, struct thread *td,
218 	KASSERT(td == curthread,
261 futex_condvar_lookup(struct thread *td, const cloudabi_condvar_t *address,
268 	error = futex_address_create(&fa_condvar, td, address, scope);
288 futex_condvar_lookup_or_create(struct thread *td,
298 	error = futex_address_create(&fa_condvar, td, condvar, condvar_scope);
301 	error = futex_address_create(&fa_lock, td, lock, lock_scope);
387 futex_lock_lookup(struct thread *td, const cloudabi_lock_t *address,
393 	error = futex_address_create(&fa, td, address, scope);
428 futex_lock_rdlock(struct futex_lock *fl, struct thread *td,
440 		error = futex_queue_sleep(&fl->fl_readers, fl, &fw, td,
517 futex_lock_unlock(struct futex_lock *fl, struct thread *td,
526 	if (fl->fl_owner != LOCK_UNMANAGED && fl->fl_owner != td->td_tid)
708 futex_lock_wrlock(struct futex_lock *fl, struct thread *td,
716 	error = futex_lock_trywrlock(fl, lock, td->td_tid,
737 		error = futex_queue_sleep(&fl->fl_writers, fl, &fw, td,
790 futex_queue_convert_timestamp(struct thread *td, cloudabi_clockid_t clock_id,
799 		error = cloudabi_clock_time_get(td, clock_id, &now);
812     struct futex_waiter *fw, struct thread *td, cloudabi_clockid_t clock_id,
819 	fw->fw_tid = td->td_tid;
825 		error = futex_queue_convert_timestamp(td, clock_id, timeout,
978 cloudabi_futex_condvar_wait(struct thread *td, cloudabi_condvar_t *condvar,
989 	error = futex_condvar_lookup_or_create(td, condvar, condvar_scope, lock,
1007 	error = futex_lock_unlock(fl, td, lock);
1016 	error = futex_queue_sleep(&fc->fc_waiters, fc->fc_lock, &fw, td,
1035 		error2 = futex_lock_wrlock(fl, td, lock,
1052 cloudabi_futex_lock_rdlock(struct thread *td, cloudabi_lock_t *lock,
1060 	error = futex_lock_lookup(td, lock, scope, &fl);
1064 	error = futex_lock_rdlock(fl, td, lock, clock_id, timeout,
1071 cloudabi_futex_lock_wrlock(struct thread *td, cloudabi_lock_t *lock,
1080 	error = futex_lock_lookup(td, lock, scope, &fl);
1085 	error = futex_lock_wrlock(fl, td, lock, clock_id, timeout,
1096 cloudabi_sys_condvar_signal(struct thread *td,
1111 	error = futex_condvar_lookup(td, uap->condvar, uap->scope, &fc);
1153 cloudabi_sys_lock_unlock(struct thread *td,
1159 	error = futex_lock_lookup(td, uap->lock, uap->scope, &fl);
1162 	error = futex_lock_unlock(fl, td, uap->lock);