| /freebsd-10-stable/sys/kern/ |
| D | kern_condvar.c | 56 #define CV_WAITERS_INC(cvp) do { \ argument
57 if ((cvp)->cv_waiters < CV_WAITERS_BOUND) \
58 (cvp)->cv_waiters++; \
64 #define CV_ASSERT(cvp, lock, td) do { \ argument
67 KASSERT((cvp) != NULL, ("%s: cvp NULL", __func__)); \
75 cv_init(struct cv *cvp, const char *desc) in cv_init() argument
78 cvp->cv_description = desc; in cv_init()
79 cvp->cv_waiters = 0; in cv_init()
87 cv_destroy(struct cv *cvp) in cv_destroy() argument
92 sleepq_lock(cvp); in cv_destroy()
[all …]
|
| /freebsd-10-stable/sys/sys/ |
| D | condvar.h | 52 void cv_init(struct cv *cvp, const char *desc);
53 void cv_destroy(struct cv *cvp);
55 void _cv_wait(struct cv *cvp, struct lock_object *lock);
56 void _cv_wait_unlock(struct cv *cvp, struct lock_object *lock);
57 int _cv_wait_sig(struct cv *cvp, struct lock_object *lock);
58 int _cv_timedwait_sbt(struct cv *cvp, struct lock_object *lock,
60 int _cv_timedwait_sig_sbt(struct cv *cvp, struct lock_object *lock,
63 void cv_signal(struct cv *cvp);
64 void cv_broadcastpri(struct cv *cvp, int pri);
66 #define cv_wait(cvp, lock) \ argument
[all …]
|
| /freebsd-10-stable/lib/libthr/thread/ |
| D | thr_cond.c | 64 #define CV_PSHARED(cvp) (((cvp)->__flags & USYNC_PROCESS_SHARED) != 0) argument
69 struct pthread_cond *cvp; in cond_init() local
72 if ((cvp = (pthread_cond_t) in cond_init()
80 cvp->__clock_id = CLOCK_REALTIME; in cond_init()
83 cvp->__flags |= USYNC_PROCESS_SHARED; in cond_init()
84 cvp->__clock_id = (*cond_attr)->c_clockid; in cond_init()
86 *cond = cvp; in cond_init()
109 if (__predict_false((cvp = (*cond)) <= THR_COND_DESTROYED)) { \
110 if (cvp == THR_COND_INITIALIZER) { \
115 } else if (cvp == THR_COND_DESTROYED) { \
[all …]
|
| /freebsd-10-stable/contrib/ntp/lib/isc/include/isc/ |
| D | util.h | 120 #define BROADCAST(cvp) do { \ argument
124 (cvp), __FILE__, __LINE__)); \
125 RUNTIME_CHECK(isc_condition_broadcast((cvp)) == ISC_R_SUCCESS); \
127 #define SIGNAL(cvp) do { \ argument
131 (cvp), __FILE__, __LINE__)); \
132 RUNTIME_CHECK(isc_condition_signal((cvp)) == ISC_R_SUCCESS); \
134 #define WAIT(cvp, lp) do { \ argument
138 (cvp), \
142 RUNTIME_CHECK(isc_condition_wait((cvp), (lp)) == ISC_R_SUCCESS); \
146 (cvp), \
[all …]
|
| /freebsd-10-stable/usr.bin/mkuzip/ |
| D | mkuz_conveyor.c | 53 struct mkuz_conveyor *cvp; member
63 struct mkuz_conveyor *cvp; in cworker() local
68 cvp = cwp->cvp; in cworker()
72 iblk = mkuz_fqueue_deq(cvp->wrk_queue); in cworker()
75 mkuz_fqueue_enq(cvp->wrk_queue, iblk); in cworker()
89 mkuz_fqueue_enq(cvp->results, oblk); in cworker()
121 cwp->cvp = cp; in mkuz_conveyor_ctor()
|
| D | mkuzip.c | 108 struct mkuz_conveyor *cvp; in main() local
277 cvp = mkuz_conveyor_ctor(&cfs); in main()
283 mkuz_fqueue_enq(cvp->wrk_queue, iblk); in main()
289 oblk = mkuz_fqueue_deq_when(cvp->results, cmp_blkno, &io); in main()
345 mkuz_fqueue_enq(cvp->results, oblk); in main()
|
| /freebsd-10-stable/sys/cddl/compat/opensolaris/sys/ |
| D | kcondvar.h | 63 cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, hrtime_t res, in cv_timedwait_hires() argument
72 return (cv_timedwait_sbt(cvp, mp, sbt, pr, 0)); in cv_timedwait_hires()
|
| /freebsd-10-stable/sys/libkern/ |
| D | bcmp.c | 36 typedef const void *cvp; typedef
|
| /freebsd-10-stable/cddl/contrib/opensolaris/lib/libzpool/common/sys/ |
| D | zfs_context.h | 333 extern clock_t cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim,
|