| /freebsd/crypto/openssl/crypto/thread/arch/ |
| H A D | thread_win.c | 302 LEGACY_CONDVAR *cv; in ossl_crypto_condvar_new() local 304 if ((cv = OPENSSL_malloc(sizeof(LEGACY_CONDVAR))) == NULL) in ossl_crypto_condvar_new() 307 if ((cv->int_m = ossl_crypto_mutex_new()) == NULL) { in ossl_crypto_condvar_new() 308 OPENSSL_free(cv); in ossl_crypto_condvar_new() 312 if ((cv->sema = CreateSemaphoreA(NULL, 0, LONG_MAX, NULL)) == NULL) { in ossl_crypto_condvar_new() 313 ossl_crypto_mutex_free(&cv->int_m); in ossl_crypto_condvar_new() 314 OPENSSL_free(cv); in ossl_crypto_condvar_new() 318 if ((cv->prewait_sema = CreateSemaphoreA(NULL, 0, LONG_MAX, NULL)) == NULL) { in ossl_crypto_condvar_new() 319 CloseHandle(cv->sema); in ossl_crypto_condvar_new() 320 ossl_crypto_mutex_free(&cv->int_m); in ossl_crypto_condvar_new() [all …]
|
| H A D | thread_posix.c | 168 void ossl_crypto_condvar_wait(CRYPTO_CONDVAR *cv, CRYPTO_MUTEX *mutex) in ossl_crypto_condvar_wait() argument 173 cv_p = (pthread_cond_t *)cv; in ossl_crypto_condvar_wait() 178 void ossl_crypto_condvar_wait_timeout(CRYPTO_CONDVAR *cv, CRYPTO_MUTEX *mutex, in ossl_crypto_condvar_wait_timeout() argument 181 pthread_cond_t *cv_p = (pthread_cond_t *)cv; in ossl_crypto_condvar_wait_timeout() 203 void ossl_crypto_condvar_broadcast(CRYPTO_CONDVAR *cv) in ossl_crypto_condvar_broadcast() argument 207 cv_p = (pthread_cond_t *)cv; in ossl_crypto_condvar_broadcast() 211 void ossl_crypto_condvar_signal(CRYPTO_CONDVAR *cv) in ossl_crypto_condvar_signal() argument 215 cv_p = (pthread_cond_t *)cv; in ossl_crypto_condvar_signal() 219 void ossl_crypto_condvar_free(CRYPTO_CONDVAR **cv) in ossl_crypto_condvar_free() argument 223 if (cv == NULL) in ossl_crypto_condvar_free() [all …]
|
| H A D | thread_none.c | 61 void ossl_crypto_condvar_wait(CRYPTO_CONDVAR *cv, CRYPTO_MUTEX *mutex) in ossl_crypto_condvar_wait() argument 65 void ossl_crypto_condvar_wait_timeout(CRYPTO_CONDVAR *cv, CRYPTO_MUTEX *mutex, in ossl_crypto_condvar_wait_timeout() argument 70 void ossl_crypto_condvar_broadcast(CRYPTO_CONDVAR *cv) in ossl_crypto_condvar_broadcast() argument 74 void ossl_crypto_condvar_signal(CRYPTO_CONDVAR *cv) in ossl_crypto_condvar_signal() argument 78 void ossl_crypto_condvar_free(CRYPTO_CONDVAR **cv) in ossl_crypto_condvar_free() argument
|
| /freebsd/sys/contrib/openzfs/lib/libspl/include/sys/ |
| H A D | condvar.h | 48 extern void cv_init(kcondvar_t *cv, char *name, int type, void *arg); 49 extern void cv_destroy(kcondvar_t *cv); 50 extern void cv_wait(kcondvar_t *cv, kmutex_t *mp); 51 extern int cv_wait_sig(kcondvar_t *cv, kmutex_t *mp); 52 extern int cv_timedwait(kcondvar_t *cv, kmutex_t *mp, clock_t abstime); 55 extern void cv_signal(kcondvar_t *cv); 56 extern void cv_broadcast(kcondvar_t *cv); 58 #define cv_timedwait_io(cv, mp, at) cv_timedwait(cv, mp, at) argument 59 #define cv_timedwait_idle(cv, mp, at) cv_timedwait(cv, mp, at) argument 60 #define cv_timedwait_sig(cv, mp, at) cv_timedwait(cv, mp, at) argument [all …]
|
| /freebsd/contrib/llvm-project/openmp/runtime/src/ |
| H A D | kmp_os.h | 491 #define KMP_COMPARE_AND_STORE_RET32(p, cv, sv) \ 492 InterlockedCompareExchange((volatile long *)(p), (long)(sv), (long)(cv)) 530 #define KMP_COMPARE_AND_STORE_ACQ8(p, cv, sv) \ 531 __kmp_compare_and_store_acq8((p), (cv), (sv)) 532 #define KMP_COMPARE_AND_STORE_REL8(p, cv, sv) \ 533 __kmp_compare_and_store_rel8((p), (cv), (sv)) 534 #define KMP_COMPARE_AND_STORE_ACQ16(p, cv, sv) \ 535 __kmp_compare_and_store_acq16((p), (cv), (sv)) 540 #define KMP_COMPARE_AND_STORE_ACQ32(p, cv, sv) \ 541 __kmp_compare_and_store_acq32((volatile kmp_int32 *)(p), (kmp_int32)(cv), \ [all …]
|
| H A D | z_Windows_NT_util.cpp | 174 void __kmp_win32_cond_init(kmp_win32_cond_t *cv) { in __kmp_win32_cond_init() 175 cv->waiters_count_ = 0; in __kmp_win32_cond_init() 176 cv->wait_generation_count_ = 0; in __kmp_win32_cond_init() 177 cv->release_count_ = 0; in __kmp_win32_cond_init() 180 __kmp_win32_mutex_init(&cv->waiters_count_lock_); in __kmp_win32_cond_init() 183 cv->event_ = CreateEvent(NULL, // no security in __kmp_win32_cond_init() 188 __kmp_itt_system_object_created(cv->event_, "Event"); in __kmp_win32_cond_init() 192 void __kmp_win32_cond_destroy(kmp_win32_cond_t *cv) { in __kmp_win32_cond_destroy() 193 __kmp_win32_mutex_destroy(&cv->waiters_count_lock_); in __kmp_win32_cond_destroy() 194 __kmp_free_handle(cv in __kmp_win32_cond_destroy() 173 __kmp_win32_cond_init(kmp_win32_cond_t * cv) __kmp_win32_cond_init() argument 191 __kmp_win32_cond_destroy(kmp_win32_cond_t * cv) __kmp_win32_cond_destroy() argument 201 __kmp_win32_cond_wait(kmp_win32_cond_t * cv,kmp_win32_mutex_t * mx,kmp_info_t * th,C * flag) __kmp_win32_cond_wait() argument 281 __kmp_win32_cond_broadcast(kmp_win32_cond_t * cv) __kmp_win32_cond_broadcast() argument 297 __kmp_win32_cond_signal(kmp_win32_cond_t * cv) __kmp_win32_cond_signal() argument [all...] |
| /freebsd/contrib/llvm-project/llvm/lib/Support/BLAKE3/ |
| H A D | blake3_portable.c | 37 INLINE void compress_pre(uint32_t state[16], const uint32_t cv[8], in compress_pre() 58 state[0] = cv[0]; in compress_pre() 59 state[1] = cv[1]; in compress_pre() 60 state[2] = cv[2]; in compress_pre() 61 state[3] = cv[3]; in compress_pre() 62 state[4] = cv[4]; in compress_pre() 63 state[5] = cv[5]; in compress_pre() 64 state[6] = cv[6]; in compress_pre() 65 state[7] = cv[7]; in compress_pre() 84 void blake3_compress_in_place_portable(uint32_t cv[8], in blake3_compress_in_place_portable() [all …]
|
| H A D | blake3_dispatch.c | 137 void blake3_compress_in_place(uint32_t cv[8], in blake3_compress_in_place() 146 blake3_compress_in_place_avx512(cv, block, block_len, counter, flags); in blake3_compress_in_place() 152 blake3_compress_in_place_sse41(cv, block, block_len, counter, flags); in blake3_compress_in_place() 158 blake3_compress_in_place_sse2(cv, block, block_len, counter, flags); in blake3_compress_in_place() 163 blake3_compress_in_place_portable(cv, block, block_len, counter, flags); in blake3_compress_in_place() 166 void blake3_compress_xof(const uint32_t cv[8], in blake3_compress_xof() 175 blake3_compress_xof_avx512(cv, block, block_len, counter, flags, out); in blake3_compress_xof() 181 blake3_compress_xof_sse41(cv, block, block_len, counter, flags, out); in blake3_compress_xof() 187 blake3_compress_xof_sse2(cv, block, block_len, counter, flags, out); in blake3_compress_xof() 192 blake3_compress_xof_portable(cv, block, block_len, counter, flags, out); in blake3_compress_xof()
|
| /freebsd/sys/contrib/openzfs/module/icp/algs/blake3/ |
| H A D | blake3_generic.c | 66 static inline void compress_pre(uint32_t state[16], const uint32_t cv[8], in compress_pre() 88 state[0] = cv[0]; in compress_pre() 89 state[1] = cv[1]; in compress_pre() 90 state[2] = cv[2]; in compress_pre() 91 state[3] = cv[3]; in compress_pre() 92 state[4] = cv[4]; in compress_pre() 93 state[5] = cv[5]; in compress_pre() 94 state[6] = cv[6]; in compress_pre() 95 state[7] = cv[7]; in compress_pre() 114 static inline void blake3_compress_in_place_generic(uint32_t cv[8], in blake3_compress_in_place_generic() [all …]
|
| H A D | blake3_impl.c | 41 extern void ASMABI zfs_blake3_compress_in_place_sse2(uint32_t cv[8], 45 extern void ASMABI zfs_blake3_compress_xof_sse2(const uint32_t cv[8], 54 static void blake3_compress_in_place_sse2(uint32_t cv[8], in blake3_compress_in_place_sse2() 58 zfs_blake3_compress_in_place_sse2(cv, block, block_len, counter, in blake3_compress_in_place_sse2() 63 static void blake3_compress_xof_sse2(const uint32_t cv[8], in blake3_compress_xof_sse2() 67 zfs_blake3_compress_xof_sse2(cv, block, block_len, counter, flags, in blake3_compress_xof_sse2() 105 extern void ASMABI zfs_blake3_compress_in_place_sse41(uint32_t cv[8], 109 extern void ASMABI zfs_blake3_compress_xof_sse41(const uint32_t cv[8], 118 static void blake3_compress_in_place_sse41(uint32_t cv[8], in blake3_compress_in_place_sse41() 122 zfs_blake3_compress_in_place_sse41(cv, block, block_len, counter, in blake3_compress_in_place_sse41() [all …]
|
| /freebsd/contrib/llvm-project/llvm/lib/Target/RISCV/ |
| H A D | RISCVInstrInfoXCV.td | 43 def CV_EXTRACT : CVBitManipRII<0b00, 0b000, "cv.extract">; 44 def CV_EXTRACTU : CVBitManipRII<0b01, 0b000, "cv.extractu">; 46 def CV_BCLR : CVBitManipRII<0b00, 0b001, "cv.bclr">; 47 def CV_BSET : CVBitManipRII<0b01, 0b001, "cv.bset">; 48 def CV_BITREV : CVBitManipRII<0b11, 0b001, "cv.bitrev", uimm2>; 50 def CV_EXTRACTR : CVBitManipRR<0b0011000, "cv.extractr">; 51 def CV_EXTRACTUR : CVBitManipRR<0b0011001, "cv.extractur">; 56 "cv.insert", "$rd, $rs1, $is3, $is2">; 59 "cv.insertr", "$rd, $rs1, $rs2">; 62 def CV_BCLRR : CVBitManipRR<0b0011100, "cv [all...] |
| /freebsd/sys/contrib/openzfs/lib/libspl/ |
| H A D | condvar.c | 43 cv_init(kcondvar_t *cv, char *name, int type, void *arg) in cv_init() argument 46 VERIFY0(pthread_cond_init(cv, NULL)); in cv_init() 50 cv_destroy(kcondvar_t *cv) in cv_destroy() argument 52 VERIFY0(pthread_cond_destroy(cv)); in cv_destroy() 56 cv_wait(kcondvar_t *cv, kmutex_t *mp) in cv_wait() argument 59 VERIFY0(pthread_cond_wait(cv, &mp->m_lock)); in cv_wait() 64 cv_wait_sig(kcondvar_t *cv, kmutex_t *mp) in cv_wait_sig() argument 66 cv_wait(cv, mp); in cv_wait_sig() 71 cv_timedwait(kcondvar_t *cv, kmutex_t *mp, clock_t abstime) in cv_timedwait() argument 92 error = pthread_cond_timedwait(cv, &mp->m_lock, &ts); in cv_timedwait() [all …]
|
| /freebsd/contrib/unbound/services/ |
| H A D | view.c | 143 struct config_view* cv; 152 for(cv = cfg->views; cv; cv = cv->next) { in views_apply_cfg() 154 if(!(v = views_enter_view_name(vs, cv->name))) in views_apply_cfg() 156 v->isfirst = cv->isfirst; in views_apply_cfg() 157 if(cv->local_zones || cv->local_data) { in views_apply_cfg() 163 lz_cfg.local_zones = cv in views_apply_cfg() 147 struct config_view* cv; views_apply_cfg() local [all...] |
| /freebsd/sys/contrib/openzfs/include/os/freebsd/spl/sys/ |
| H A D | spl_condvar.h | 48 struct cv { struct 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);
|
| H A D | condvar.h | 85 typedef struct cv kcondvar_t; 93 #define zfs_cv_init(cv, name, type, arg) do { \ argument 96 for (_name = #cv; *_name != '\0'; _name++) { \ 101 _name = #cv; \ 102 cv_init((cv), _name); \ 104 #define cv_init(cv, name, type, arg) zfs_cv_init(cv, name, type, arg) argument
|
| /freebsd/sys/sys/ |
| H A D | condvar.h | 38 struct cv { struct 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);
|
| H A D | tty.h | 99 struct cv t_inwait; /* (t) Input wait queue. */ 100 struct cv t_outwait; /* (t) Output wait queue. */ 101 struct cv t_outserwait; /* (t) Serial output wait queue. */ 102 struct cv t_bgwait; /* (t) Background wait queue. */ 103 struct cv t_dcdwait; /* (t) Carrier Detect wait queue. */ 193 int tty_wait(struct tty *tp, struct cv *cv); 195 int tty_timedwait(struct tty *tp, struct cv *cv, int timo);
|
| /freebsd/contrib/openbsm/bin/auditdistd/ |
| H A D | synch.h | 138 cv_init(pthread_cond_t *cv) in cv_init() argument 149 error = pthread_cond_init(cv, &attr); in cv_init() 155 cv_wait(pthread_cond_t *cv, pthread_mutex_t *lock) in cv_wait() argument 159 error = pthread_cond_wait(cv, lock); in cv_wait() 163 cv_timedwait(pthread_cond_t *cv, pthread_mutex_t *lock, int timeout) in cv_timedwait() argument 169 cv_wait(cv, lock); in cv_timedwait() 177 error = pthread_cond_timedwait(cv, lock, &ts); in cv_timedwait() 181 error = pthread_cond_timedwait_relative_np(cv, lock, &ts); in cv_timedwait() 189 cv_signal(pthread_cond_t *cv) in cv_signal() argument 193 error = pthread_cond_signal(cv); in cv_signal() [all …]
|
| /freebsd/sys/cddl/compat/opensolaris/sys/ |
| H A D | kcondvar.h | 40 typedef struct cv kcondvar_t; 47 #define zfs_cv_init(cv, name, type, arg) do { \ argument 50 for (_name = #cv; *_name != '\0'; _name++) { \ 55 _name = #cv; \ 56 cv_init((cv), _name); \ 58 #define cv_init(cv, name, type, arg) zfs_cv_init(cv, name, type, arg) argument
|
| /freebsd/crypto/openssl/ssl/quic/ |
| H A D | quic_thread_assist.c | 43 ossl_crypto_condvar_wait_timeout(qta->cv, m, deadline); in assist_thread_main() 78 qta->cv = ossl_crypto_condvar_new(); in ossl_quic_thread_assist_init_start() 79 if (qta->cv == NULL) in ossl_quic_thread_assist_init_start() 85 ossl_crypto_condvar_free(&qta->cv); in ossl_quic_thread_assist_init_start() 96 ossl_crypto_condvar_signal(qta->cv); in ossl_quic_thread_assist_stop_async() 131 ossl_crypto_condvar_free(&qta->cv); in ossl_quic_thread_assist_cleanup() 144 ossl_crypto_condvar_signal(qta->cv); in ossl_quic_thread_assist_notify_deadline_changed()
|
| /freebsd/crypto/openssl/providers/implementations/ciphers/ |
| H A D | cipher_aes_hw_s390x.inc | 71 memcpy(adat->plat.s390x.param.kmo_kmf.cv, dat->iv, dat->ivlen); 73 *out = *in ^ adat->plat.s390x.param.kmo_kmf.cv[n]; 92 s390x_km(adat->plat.s390x.param.kmo_kmf.cv, 16, 93 adat->plat.s390x.param.kmo_kmf.cv, 98 out[n] = in[n] ^ adat->plat.s390x.param.kmo_kmf.cv[n]; 103 memcpy(dat->iv, adat->plat.s390x.param.kmo_kmf.cv, dat->ivlen); 128 memcpy(adat->plat.s390x.param.kmo_kmf.cv, dat->iv, dat->ivlen); 131 *out = adat->plat.s390x.param.kmo_kmf.cv[n] ^ tmp; 132 adat->plat.s390x.param.kmo_kmf.cv[n] = dat->enc ? *out : tmp; 151 s390x_km(adat->plat.s390x.param.kmo_kmf.cv, 16, [all …]
|
| /freebsd/lib/libc/iconv/ |
| H A D | citrus_iconv.c | 281 struct _citrus_iconv *cv = NULL; in _citrus_iconv_open() local 329 cv = malloc(sizeof(*cv)); in _citrus_iconv_open() 330 if (cv == NULL) { in _citrus_iconv_open() 335 *rcv = cv; in _citrus_iconv_open() 341 free(cv); in _citrus_iconv_open() 352 _citrus_iconv_close(struct _citrus_iconv *cv) in _citrus_iconv_close() argument 355 if (cv) { in _citrus_iconv_close() 356 (*cv->cv_shared->ci_ops->io_uninit_context)(cv); in _citrus_iconv_close() 357 release_shared(cv->cv_shared); in _citrus_iconv_close() 358 free(cv); in _citrus_iconv_close()
|
| /freebsd/contrib/llvm-project/compiler-rt/lib/asan/ |
| H A D | asan_memory_profile.cpp | 34 void ProcessChunk(const AsanChunkView &cv) { in ProcessChunk() argument 35 if (cv.IsAllocated()) { in ProcessChunk() 36 total_allocated_user_size_ += cv.UsedSize(); in ProcessChunk() 38 u32 id = cv.GetAllocStackId(); in ProcessChunk() 40 Insert(id, cv.UsedSize()); in ProcessChunk() 41 } else if (cv.IsQuarantined()) { in ProcessChunk() 42 total_quarantined_user_size_ += cv.UsedSize(); in ProcessChunk()
|
| /freebsd/sys/contrib/vchiq/interface/compat/ |
| H A D | vchi_bsd.c | 136 cv_init(&c->cv, "VCHI completion cv"); in init_completion() 144 cv_destroy(&c->cv); in destroy_completion() 156 cv_signal(&c->cv); in complete() 172 cv_broadcast(&c->cv); in complete_all() 208 cv_wait(&c->cv, &c->lock); in wait_for_completion() 236 res = cv_timedwait_sig(&c->cv, &c->lock, timeout); in wait_for_completion_interruptible_timeout() 272 res = cv_wait_sig(&c->cv, &c->lock); in wait_for_completion_interruptible() 311 cv_init(&s->cv, "sema cv"); in _sema_init() 319 cv_destroy(&s->cv); in _sema_destroy() 329 cv_wait(&s->cv, &s->mtx); in down() [all …]
|
| /freebsd/lib/libthr/thread/ |
| H A D | thr_umtx.c | 237 _thr_ucond_init(struct ucond *cv) in _thr_ucond_init() argument 240 bzero(cv, sizeof(struct ucond)); in _thr_ucond_init() 244 _thr_ucond_wait(struct ucond *cv, struct umutex *m, in _thr_ucond_wait() argument 255 return (_umtx_op_err(cv, UMTX_OP_CV_WAIT, flags, m, in _thr_ucond_wait() 260 _thr_ucond_signal(struct ucond *cv) in _thr_ucond_signal() argument 263 if (!cv->c_has_waiters) in _thr_ucond_signal() 265 return (_umtx_op_err(cv, UMTX_OP_CV_SIGNAL, 0, NULL, NULL)); in _thr_ucond_signal() 269 _thr_ucond_broadcast(struct ucond *cv) in _thr_ucond_broadcast() argument 272 if (!cv->c_has_waiters) in _thr_ucond_broadcast() 274 return (_umtx_op_err(cv, UMTX_OP_CV_BROADCAST, 0, NULL, NULL)); in _thr_ucond_broadcast()
|