/freebsd-current/sys/contrib/openzfs/include/os/freebsd/spl/sys/ |
H A D | spl_condvar.h | 53 void cv_init(struct cv *cvp, const char *desc); 54 void cv_destroy(struct cv *cvp); 56 void _cv_wait(struct cv *cvp, struct lock_object *lock); 57 void _cv_wait_unlock(struct cv *cvp, struct lock_object *lock); 58 int _cv_wait_sig(struct cv *cvp, struct lock_object *lock); 59 int _cv_timedwait_sbt(struct cv *cvp, struct lock_object *lock, 61 int _cv_timedwait_sig_sbt(struct cv *cvp, struct lock_object *lock, 64 void cv_signal(struct cv *cvp); 65 void cv_broadcastpri(struct cv *cvp, int pri); 67 #define cv_wait(cvp, loc [all...] |
H A D | condvar.h | 107 cv_wait_sig(kcondvar_t *cvp, kmutex_t *mp) argument 110 return (_cv_wait_sig(cvp, &(mp)->lock_object) == 0); 114 cv_timedwait(kcondvar_t *cvp, kmutex_t *mp, clock_t timo) argument 121 rc = _cv_timedwait_sbt((cvp), &(mp)->lock_object, \ 129 cv_timedwait_sig(kcondvar_t *cvp, kmutex_t *mp, clock_t timo) argument 136 rc = _cv_timedwait_sig_sbt(cvp, &(mp)->lock_object, \ 156 cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, argument 170 rc = cv_timedwait_sbt(cvp, mp, zfs_nstosbt(tim), 181 cv_timedwait_sig_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, argument 198 rc = cv_timedwait_sig_sbt(cvp, m [all...] |
/freebsd-current/sys/sys/ |
H A D | condvar.h | 48 void cv_init(struct cv *cvp, const char *desc); 49 void cv_destroy(struct cv *cvp); 51 void _cv_wait(struct cv *cvp, struct lock_object *lock); 52 void _cv_wait_unlock(struct cv *cvp, struct lock_object *lock); 53 int _cv_wait_sig(struct cv *cvp, struct lock_object *lock); 54 int _cv_timedwait_sbt(struct cv *cvp, struct lock_object *lock, 56 int _cv_timedwait_sig_sbt(struct cv *cvp, struct lock_object *lock, 59 void cv_signal(struct cv *cvp); 60 void cv_broadcastpri(struct cv *cvp, int pri); 62 #define cv_wait(cvp, loc [all...] |
/freebsd-current/sys/contrib/openzfs/include/os/linux/spl/sys/ |
H A D | condvar.h | 98 #define cv_init(cvp, name, type, arg) __cv_init(cvp, name, type, arg) 99 #define cv_destroy(cvp) __cv_destroy(cvp) 100 #define cv_wait(cvp, mp) __cv_wait(cvp, mp) 101 #define cv_wait_io(cvp, mp) __cv_wait_io(cvp, mp) 102 #define cv_wait_idle(cvp, mp) __cv_wait_idle(cvp, m [all...] |
/freebsd-current/sys/contrib/openzfs/module/os/linux/spl/ |
H A D | spl-condvar.c | 68 __cv_init(kcondvar_t *cvp, char *name, kcv_type_t type, void *arg) argument 70 ASSERT(cvp); 75 cvp->cv_magic = CV_MAGIC; 76 init_waitqueue_head(&cvp->cv_event); 77 init_waitqueue_head(&cvp->cv_destroy); 78 atomic_set(&cvp->cv_waiters, 0); 79 atomic_set(&cvp->cv_refs, 1); 80 cvp->cv_mutex = NULL; 85 cv_destroy_wakeup(kcondvar_t *cvp) argument 87 if (!atomic_read(&cvp 97 __cv_destroy(kcondvar_t *cvp) argument 117 cv_wait_common(kcondvar_t *cvp, kmutex_t *mp, int state, int io) argument 169 __cv_wait(kcondvar_t *cvp, kmutex_t *mp) argument 176 __cv_wait_io(kcondvar_t *cvp, kmutex_t *mp) argument 183 __cv_wait_io_sig(kcondvar_t *cvp, kmutex_t *mp) argument 192 __cv_wait_sig(kcondvar_t *cvp, kmutex_t *mp) argument 201 __cv_wait_idle(kcondvar_t *cvp, kmutex_t *mp) argument 259 __cv_timedwait_common(kcondvar_t *cvp, kmutex_t *mp, clock_t expire_time, int state, int io) argument 319 __cv_timedwait(kcondvar_t *cvp, kmutex_t *mp, clock_t exp_time) argument 327 __cv_timedwait_io(kcondvar_t *cvp, kmutex_t *mp, clock_t exp_time) argument 335 __cv_timedwait_sig(kcondvar_t *cvp, kmutex_t *mp, clock_t exp_time) argument 345 __cv_timedwait_idle(kcondvar_t *cvp, kmutex_t *mp, clock_t exp_time) argument 364 __cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t expire_time, hrtime_t res, int state) argument 426 cv_timedwait_hires_common(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, int flag, int state) argument 436 cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, int flag) argument 445 cv_timedwait_sig_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, int flag) argument 457 cv_timedwait_idle_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, int flag) argument 474 __cv_signal(kcondvar_t *cvp) argument 494 __cv_broadcast(kcondvar_t *cvp) argument [all...] |
/freebsd-current/sys/kern/ |
H A D | kern_condvar.c | 57 #define CV_WAITERS_INC(cvp) do { \ 58 if ((cvp)->cv_waiters < CV_WAITERS_BOUND) \ 59 (cvp)->cv_waiters++; \ 65 #define CV_ASSERT(cvp, lock, td) do { \ 68 KASSERT((cvp) != NULL, ("%s: cvp NULL", __func__)); \ 76 cv_init(struct cv *cvp, const char *desc) argument 79 cvp->cv_description = desc; 80 cvp->cv_waiters = 0; 88 cv_destroy(struct cv *cvp) argument 108 _cv_wait(struct cv *cvp, struct lock_object *lock) argument 171 _cv_wait_unlock(struct cv *cvp, struct lock_object *lock) argument 228 _cv_wait_sig(struct cv *cvp, struct lock_object *lock) argument 296 _cv_timedwait_sbt(struct cv *cvp, struct lock_object *lock, sbintime_t sbt, sbintime_t pr, int flags) argument 366 _cv_timedwait_sig_sbt(struct cv *cvp, struct lock_object *lock, sbintime_t sbt, sbintime_t pr, int flags) argument 437 cv_signal(struct cv *cvp) argument 463 cv_broadcastpri(struct cv *cvp, int pri) argument [all...] |
/freebsd-current/lib/libthr/thread/ |
H A D | thr_cond.c | 76 #define CV_PSHARED(cvp) (((cvp)->kcond.c_flags & USYNC_PROCESS_SHARED) != 0) 79 cond_init_body(struct pthread_cond *cvp, const struct pthread_cond_attr *cattr) argument 83 cvp->kcond.c_clockid = CLOCK_REALTIME; 86 cvp->kcond.c_flags |= USYNC_PROCESS_SHARED; 87 cvp->kcond.c_clockid = cattr->c_clockid; 94 struct pthread_cond *cvp; local 101 cvp = calloc(1, sizeof(struct pthread_cond)); 102 if (cvp == NULL) 106 cvp 165 struct pthread_cond *cvp; local 204 cond_wait_kernel(struct pthread_cond *cvp, struct pthread_mutex *mp, const struct timespec *abstime, int cancel) argument 276 cond_wait_user(struct pthread_cond *cvp, struct pthread_mutex *mp, const struct timespec *abstime, int cancel) argument 356 struct pthread_cond *cvp; local 426 struct pthread_cond *cvp; local 511 struct pthread_cond *cvp; local [all...] |
/freebsd-current/usr.bin/mkuzip/ |
H A D | mkuz_conveyor.c | 50 struct mkuz_conveyor *cvp; member in struct:cw_args 60 struct mkuz_conveyor *cvp; local 65 cvp = cwp->cvp; 69 iblk = mkuz_fqueue_deq(cvp->wrk_queue); 72 mkuz_fqueue_enq(cvp->wrk_queue, iblk); 87 mkuz_fqueue_enq(cvp->results, oblk); 119 cwp->cvp = cp;
|
H A D | mkuzip.c | 127 struct mkuz_conveyor *cvp; local 324 cvp = mkuz_conveyor_ctor(&cfs); 330 mkuz_fqueue_enq(cvp->wrk_queue, iblk); 336 oblk = mkuz_fqueue_deq_when(cvp->results, cmp_blkno, &io); 392 mkuz_fqueue_enq(cvp->results, oblk);
|
/freebsd-current/sys/cddl/compat/opensolaris/sys/ |
H A D | kcondvar.h | 61 cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, argument 65 return (cv_timedwait_sbt(cvp, mp, nstosbt(tim), nstosbt(res), 0));
|
/freebsd-current/contrib/ntp/libntp/lib/isc/include/isc/ |
H A D | util.h | 120 #define BROADCAST(cvp) do { \ 124 (cvp), __FILE__, __LINE__)); \ 125 RUNTIME_CHECK(isc_condition_broadcast((cvp)) == ISC_R_SUCCESS); \ 127 #define SIGNAL(cvp) do { \ 131 (cvp), __FILE__, __LINE__)); \ 132 RUNTIME_CHECK(isc_condition_signal((cvp)) == ISC_R_SUCCESS); \ 134 #define WAIT(cvp, lp) do { \ 138 (cvp), \ 142 RUNTIME_CHECK(isc_condition_wait((cvp), (lp)) == ISC_R_SUCCESS); \ 146 (cvp), \ [all...] |
/freebsd-current/usr.bin/diff/ |
H A D | diffreg.c | 1497 struct context_vec *cvp = context_vec_start; local 1506 lowa = MAX(1, cvp->a - diff_context); 1508 lowc = MAX(1, cvp->c - diff_context); 1513 f = match_function(ixold, cvp->a - 1, f1); 1527 for (; cvp <= context_vec_ptr; cvp++) 1528 if (cvp->a <= cvp->b) { 1529 cvp = context_vec_start; 1534 while (cvp < 1600 struct context_vec *cvp = context_vec_start; local [all...] |
/freebsd-current/sys/contrib/openzfs/include/sys/ |
H A D | zfs_context.h | 334 extern int cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim,
|