Home
last modified time | relevance | path

Searched refs:barrier (Results 1 – 25 of 98) sorted by relevance

1234

/freebsd/sys/contrib/ck/src/
H A Dck_barrier_mcs.c34 ck_barrier_mcs_init(struct ck_barrier_mcs *barrier, unsigned int nthr) in ck_barrier_mcs_init() argument
38 ck_pr_store_uint(&barrier->tid, 0); in ck_barrier_mcs_init()
46 barrier[i].havechild[j] = ((i << 2) + j < nthr - 1) ? ~0 : 0; in ck_barrier_mcs_init()
52 barrier[i].childnotready[j] = barrier[i].havechild[j]; in ck_barrier_mcs_init()
56 barrier[i].parent = (i == 0) ? in ck_barrier_mcs_init()
57 &barrier[i].dummy : in ck_barrier_mcs_init()
58 &barrier[(i - 1) >> 2].childnotready[(i - 1) & 3]; in ck_barrier_mcs_init()
61 barrier[i].children[0] = ((i << 1) + 1 >= nthr) ? in ck_barrier_mcs_init()
62 &barrier[i].dummy : in ck_barrier_mcs_init()
63 &barrier[(i << 1) + 1].parentsense; in ck_barrier_mcs_init()
[all …]
H A Dck_barrier_dissemination.c36 ck_barrier_dissemination_init(struct ck_barrier_dissemination *barrier, in ck_barrier_dissemination_init() argument
43 barrier->nthr = nthr; in ck_barrier_dissemination_init()
44 barrier->size = size = ck_internal_log(ck_internal_power_2(nthr)); in ck_barrier_dissemination_init()
45 ck_pr_store_uint(&barrier->tid, 0); in ck_barrier_dissemination_init()
48 barrier[i].flags[0] = barrier_internal[i]; in ck_barrier_dissemination_init()
49 barrier[i].flags[1] = barrier_internal[i] + size; in ck_barrier_dissemination_init()
67 barrier[i].flags[0][k].pflag = &barrier[j].flags[0][k].tflag; in ck_barrier_dissemination_init()
68 barrier[i].flags[1][k].pflag = &barrier[j].flags[1][k].tflag; in ck_barrier_dissemination_init()
71 barrier[i].flags[0][k].tflag = barrier[i].flags[1][k].tflag = 0; in ck_barrier_dissemination_init()
79 ck_barrier_dissemination_subscribe(struct ck_barrier_dissemination *barrier, in ck_barrier_dissemination_subscribe() argument
[all …]
H A Dck_barrier_tournament.c50 ck_barrier_tournament_subscribe(struct ck_barrier_tournament *barrier, in ck_barrier_tournament_subscribe() argument
55 state->vpid = ck_pr_faa_uint(&barrier->tid, 1); in ck_barrier_tournament_subscribe()
60 ck_barrier_tournament_init(struct ck_barrier_tournament *barrier, in ck_barrier_tournament_init() argument
66 ck_pr_store_uint(&barrier->tid, 0); in ck_barrier_tournament_init()
67 barrier->size = size = ck_barrier_tournament_size(nthr); in ck_barrier_tournament_init()
97 ck_pr_store_ptr(&barrier->rounds, rounds); in ck_barrier_tournament_init()
109 ck_barrier_tournament(struct ck_barrier_tournament *barrier, in ck_barrier_tournament() argument
112 struct ck_barrier_tournament_round **rounds = ck_pr_load_ptr(&barrier->rounds); in ck_barrier_tournament()
115 if (barrier->size == 1) in ck_barrier_tournament()
H A Dck_barrier_centralized.c32 ck_barrier_centralized(struct ck_barrier_centralized *barrier, in ck_barrier_centralized() argument
45 value = ck_pr_faa_uint(&barrier->value, 1); in ck_barrier_centralized()
47 ck_pr_store_uint(&barrier->value, 0); in ck_barrier_centralized()
49 ck_pr_store_uint(&barrier->sense, sense); in ck_barrier_centralized()
54 while (sense != ck_pr_load_uint(&barrier->sense)) in ck_barrier_centralized()
H A Dck_barrier_combining.c158 ck_barrier_combining_aux(struct ck_barrier_combining *barrier, in ck_barrier_combining_aux() argument
173 ck_barrier_combining_aux(barrier, tnode->parent, sense); in ck_barrier_combining_aux()
197 ck_barrier_combining(struct ck_barrier_combining *barrier, in ck_barrier_combining() argument
202 ck_barrier_combining_aux(barrier, tnode, state->sense); in ck_barrier_combining()
/freebsd/lib/libthr/thread/
H A Dthr_barrier.c45 _pthread_barrier_destroy(pthread_barrier_t *barrier) in _pthread_barrier_destroy() argument
51 if (barrier == NULL || *barrier == NULL) in _pthread_barrier_destroy()
54 if (*barrier == THR_PSHARED_PTR) { in _pthread_barrier_destroy()
55 bar = __thr_pshared_offpage(barrier, 0); in _pthread_barrier_destroy()
57 *barrier = NULL; in _pthread_barrier_destroy()
62 bar = *barrier; in _pthread_barrier_destroy()
87 *barrier = NULL; in _pthread_barrier_destroy()
89 __thr_pshared_destroy(barrier); in _pthread_barrier_destroy()
96 _pthread_barrier_init(pthread_barrier_t * __restrict barrier, in _pthread_barrier_init() argument
102 if (barrier == NULL || count == 0 || count > INT_MAX) in _pthread_barrier_init()
[all …]
/freebsd/contrib/llvm-project/libcxx/include/
H A Dbarrier14 barrier synopsis
20 class barrier
27 constexpr explicit barrier(ptrdiff_t phase_count,
29 ~barrier();
31 barrier(const barrier&) = delete;
32 barrier& operator=(const barrier&) = delete;
83 The default implementation of __barrier_base is a classic tree barrier.
86 1. Threads that call into std::barrier functions do not provide indices,
87 so a numbering step is added before the actual barrier algorithm,
88 appearing as an N+1 round to the N rounds of the tree barrier.
[all …]
/freebsd/contrib/netbsd-tests/lib/libpthread/
H A Dt_barrier.c44 pthread_barrier_t barrier; variable
56 rv = pthread_barrier_wait(&barrier); in threadfunc()
68 ATF_TC(barrier);
69 ATF_TC_HEAD(barrier, tc) in ATF_TC_HEAD() argument
73 ATF_TC_BODY(barrier, tc) in ATF_TC_BODY() argument
80 PTHREAD_REQUIRE(pthread_barrier_init(&barrier, NULL, COUNT)); in ATF_TC_BODY()
107 ATF_TP_ADD_TC(tp, barrier); in ATF_TP_ADD_TCS()
/freebsd/contrib/opencsd/decoder/source/i_dec/
H A Dtrc_i_decode.cpp75 arm_barrier_t barrier; in DecodeA32() local
99 else if((barrier = inst_ARM_barrier(instr_info->opcode)) != ARM_BARRIER_NONE) in DecodeA32()
101 switch(barrier) in DecodeA32()
129 arm_barrier_t barrier; in DecodeA64() local
146 else if((barrier = inst_A64_barrier(instr_info->opcode)) != ARM_BARRIER_NONE) in DecodeA64()
148 switch(barrier) in DecodeA64()
180 arm_barrier_t barrier; in DecodeT32() local
208 else if((barrier = inst_Thumb_barrier(instr_info->opcode)) != ARM_BARRIER_NONE) in DecodeT32()
210 switch(barrier) in DecodeT32()
/freebsd/sys/contrib/openzfs/module/zstd/
H A Dzfs_zstd.c158 kmutex_t barrier; member
173 kmutex_t barrier; member
296 if (pool->mem && mutex_tryenter(&pool->barrier)) { in zstd_mempool_reap()
306 mutex_exit(&pool->barrier); in zstd_mempool_reap()
347 if (mutex_tryenter(&pool->barrier)) { in zstd_mempool_alloc()
358 mutex_exit(&pool->barrier); in zstd_mempool_alloc()
372 if (mutex_tryenter(&pool->barrier)) { in zstd_mempool_alloc()
396 mutex_exit(&pool->barrier); in zstd_mempool_alloc()
420 mutex_exit(&z->pool->barrier); in zstd_mempool_free()
821 mutex_enter(&zstd_dctx_fallback.barrier); in zstd_dctx_alloc()
[all …]
/freebsd/sys/compat/linuxkpi/common/include/linux/
H A Dcompiler.h98 #define barrier() __asm__ __volatile__("": : :"memory") macro
107 barrier(); \
109 barrier(); \
114 barrier(); \
117 barrier(); \
/freebsd/tools/tools/tscdrift/
H A Dtscdrift.c42 #define barrier() __asm __volatile("" ::: "memory") macro
73 barrier(); in thread_main()
78 barrier(); in thread_main()
139 barrier(); in main()
143 barrier(); in main()
/freebsd/contrib/llvm-project/libcxx/modules/std/
H A Dbarrier.cppm
/freebsd/lib/libc/tests/stdlib/
H A Dlibc_exit_test.c107 static pthread_barrier_t barrier; variable
112 pthread_barrier_wait(&barrier); in myatexit2()
119 pthread_barrier_wait(&barrier); in mythreadexit()
135 pthread_barrier_init(&barrier, NULL, 2); in ATF_TC_BODY()
/freebsd/contrib/llvm-project/openmp/runtime/src/
H A Dkmp_itt.inl120 Note: Thread waiting at join barrier (after __kmp_itt_region_finished) can
165 buff = __kmp_str_format("%s$omp$barrier@%s:%d", str_loc.func,
229 } else { // called for barrier reporting
243 __kmp_str_format("%s$omp$barrier-imbalance:%d@%s:%d", str_loc.func,
246 buff = __kmp_str_format("%s$omp$barrier@%s:%d", str_loc.func,
392 A barrier consists of two phases:
406 would return itt sync object for the next barrier!
409 does not have barrier object or barrier data structure. Barrier is just a
411 structure as a barrier syn
[all...]
H A Dkmp_dispatch_hier.h246 static void barrier(kmp_int32 id, kmp_hier_shared_bdata_t<T> *bdata,
264 void core_barrier_impl<T>::barrier(kmp_int32 id, in barrier() function
292 static void barrier(kmp_int32 id, kmp_hier_shared_bdata_t<T> *bdata,
310 void counter_barrier_impl<T>::barrier(kmp_int32 id, in barrier() function
365 void barrier(kmp_int32 id, kmp_hier_private_bdata_t *tdata) { in barrier() function
374 core_barrier_impl<T>::barrier(id, &hier_barrier, tdata); in barrier()
376 counter_barrier_impl<T>::barrier(id, &hier_barrier, tdata); in barrier()
598 current->barrier(previous_id, tdata); in next_recurse()
788 parent->barrier(pr->get_hier_id(), tdata); in next()
/freebsd/contrib/llvm-project/compiler-rt/lib/tsan/rtl/
H A Dtsan_interceptors_libdispatch.cpp159 #define DISPATCH_INTERCEPT_ASYNC_B(name, barrier) \ argument
167 new_context->is_barrier_block = barrier; \
174 #define DISPATCH_INTERCEPT_SYNC_B(name, barrier) \ argument
179 q, block, &invoke_block, false, true, barrier, 0}; \
187 #define DISPATCH_INTERCEPT_ASYNC_F(name, barrier) \ argument
193 new_context->is_barrier_block = barrier; \
200 #define DISPATCH_INTERCEPT_SYNC_F(name, barrier) \ argument
205 q, context, work, false, true, barrier, 0}; \
213 #define DISPATCH_INTERCEPT(name, barrier) \ argument
214 DISPATCH_INTERCEPT_ASYNC_F(name##_async_f, barrier) \
[all …]
/freebsd/tools/test/stress2/misc/
H A Dcallout_reset_on.sh109 barrier(int mode)
143 barrier(BARRIER_WAIT);
266 barrier(BARRIER_DELETE);
296 barrier(BARRIER_CREATE);
328 rm -f /tmp/crwriter /tmp/crlogger ./barrier.*
/freebsd/contrib/ofed/include/
H A Dudma_barrier.h112 #error No architecture specific memory barrier defines found!
150 #error No architecture specific memory barrier defines found!
220 #error No architecture specific memory barrier defines found!
/freebsd/sys/compat/linuxkpi/common/include/asm/
H A Dbarrier.h58 #define smp_mb__before_atomic() barrier()
59 #define smp_mb__after_atomic() barrier()
/freebsd/sys/contrib/ena-com/
H A Dena_plat.h446 #define barrier() __asm__ __volatile__("": : :"memory") macro
447 #define dma_rmb() barrier()
448 #define mmiowb() barrier()
453 barrier(); \
455 barrier(); \
/freebsd/tests/sys/kern/
H A Dsocket_splice.c821 pthread_barrier_t *barrier; member
846 pthread_barrier_wait(xfer->barrier); in xfer()
880 pthread_barrier_t barrier; in ATF_TC_BODY() local
889 error = pthread_barrier_init(&barrier, NULL, 2); in ATF_TC_BODY()
892 .barrier = &barrier, in ATF_TC_BODY()
897 .barrier = &barrier, in ATF_TC_BODY()
916 error = pthread_barrier_destroy(&barrier); in ATF_TC_BODY()
/freebsd/lib/libpmc/pmu-events/
H A Dlist.h51 #define barrier() __asm__ __volatile__("": : :"memory") macro
57 barrier(); \
59 barrier(); \
64 barrier(); \
67 barrier(); \
/freebsd/cddl/contrib/opensolaris/tools/ctf/cvt/
H A Dbarrier.h47 typedef struct barrier { struct
/freebsd/sys/tools/
H A Dbus_macro.sh51 macro barrier o l f

1234