Home
last modified time | relevance | path

Searched refs:mask (Results 1 – 14 of 14) sorted by relevance

/oneTBB/test/common/
H A Dutils_concurrency_limit.h89 cpu_set_t mask; in get_max_procs()
106 cpu_set_t mask; in get_start_affinity_process() local
135 DWORD_PTR mask = 1; in limit_number_of_threads() local
137 mask |= mask << 1; in limit_number_of_threads()
143 #define setaffinity(mask) sched_setaffinity(getpid(), sizeof(mask_t), &mask) in limit_number_of_threads() argument
175 cpu_set_t* mask = nullptr; in get_thread_affinity_mask() local
179 if (!mask) break; in get_thread_affinity_mask()
181 CPU_ZERO_S(size, mask); in get_thread_affinity_mask()
185 CPU_FREE(mask); in get_thread_affinity_mask()
186 mask = nullptr; in get_thread_affinity_mask()
[all …]
/oneTBB/examples/common/gui/
H A Dxvideo.cpp89 inline void mask2bits(unsigned int mask, unsigned int &save, depth_t &shift) { in mask2bits() argument
90 save = mask; in mask2bits()
91 if (!mask) { in mask2bits()
96 while (!(mask & 1)) in mask2bits()
97 ++shift, mask >>= 1; in mask2bits()
99 while (mask & 1) in mask2bits()
100 ++bits, mask >>= 1; in mask2bits()
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_whitebox.cpp707 mask.reset(); in TestBitMask()
708 mask.set(10, 1); in TestBitMask()
709 mask.set(5, 1); in TestBitMask()
710 mask.set(1, 1); in TestBitMask()
713 mask.reset(); in TestBitMask()
714 mask.set(0, 1); in TestBitMask()
715 mask.set(64, 1); in TestBitMask()
716 mask.set(63, 1); in TestBitMask()
717 mask.set(200, 1); in TestBitMask()
718 mask.set(255, 1); in TestBitMask()
[all …]
/oneTBB/include/oneapi/tbb/
H A Dconcurrent_hash_map.h292 if( sz >= mask ) { // TODO: add custom load_factor in insert_new_node()
732 bucket_accessor b_old( this, hash & mask ); in __TBB_requires()
734 mask = (mask<<1) | 1; // get full mask for new bucket in __TBB_requires()
735 __TBB_ASSERT( (mask&(mask+1))==0 && (hash & mask) == hash, nullptr ); in __TBB_requires()
742 if ((curr_node_hash & mask) == hash) { in __TBB_requires()
968 for(; b <= mask; b++, bp++ ) { in __TBB_requires()
1388 bucket_accessor b( this, hash & mask, /*writer=*/true ); in __TBB_requires()
1398 if (this->check_mask_race(hash, mask)) in __TBB_requires()
1431 bucket_accessor b( this, hash & mask ); in __TBB_requires()
1441 if (this->check_mask_race(hash, mask)) in __TBB_requires()
[all …]
H A Denumerable_thread_specific.h116 std::size_t mask() const { return size() - 1; }
173 std::size_t mask = root->mask();
178 … = root->start(std::hash<key_type>{}(s1.key.load(std::memory_order_relaxed))); ; j = (j+1)&mask ) {
222 std::size_t mask=r->mask();
223 for(std::size_t i = r->start(h); ;i=(i+1)&mask) {
275 std::size_t mask = ir->mask();
276 for(std::size_t i = ir->start(h);; i = (i+1)&mask) {
/oneTBB/src/tbbmalloc/
H A Dtbbmalloc_internal.h182 std::atomic<uintptr_t> mask[SZ]; variable
191 mask[i].fetch_or(1ULL << pos); in set()
193 mask[i].fetch_and(~(1ULL << pos)); in set()
203 … uintptr_t actualMask = mask[idx].load(std::memory_order_relaxed) & (((uintptr_t)1<<pos) - 1); in getMinTrue()
210 if (-1 != (pos = BitScanRev(mask[idx++].load(std::memory_order_relaxed)))) in getMinTrue()
215 void reset() { for (unsigned i=0; i<SZ; i++) mask[i].store(0, std::memory_order_relaxed); } in reset()
/oneTBB/include/oneapi/tbb/detail/
H A D_concurrent_queue_base.h94 std::atomic<std::uintptr_t> mask{};
162 …p->mask.store(p->mask.load(std::memory_order_relaxed) | uintptr_t(1) << index, std::memory_order_r… in push()
190 if (p->mask.load(std::memory_order_relaxed) & (std::uintptr_t(1) << index)) { in pop()
254 … new_page->mask.store(src_page->mask.load(std::memory_order_relaxed), std::memory_order_relaxed); in make_copy()
256 if (new_page->mask.load(std::memory_order_relaxed) & uintptr_t(1) << begin_in_page) { in make_copy()
290 … if (curr_page->mask.load(std::memory_order_relaxed) & (std::uintptr_t(1) << index)) {
575 return (p->mask & uintptr_t(1) << i) != 0; in get_item()
H A D_flow_graph_tagged_buffer_impl.h68 size_t mask() { return my_size - 1; } in mask() function
216 size_t i = this->hash(k) & mask(); in find_ref_with_key()
239 size_t h = this->hash(k) & mask(); in delete_with_key()
/oneTBB/src/tbb/
H A Dmisc_ex.cpp240 DWORD_PTR mask; ///< Affinity mask covering the whole group
324 …pgi.mask = pgi.numProcs == sizeof(DWORD_PTR) * CHAR_BIT ? ~(DWORD_PTR)0 : (DWORD_PTR(1) << pgi.num…
381 TBB_GROUP_AFFINITY ga = { theProcessorGroups[groupIndex].mask, (WORD)groupIndex, {0,0,0} };
H A Dtcm.h100 tcm_cpu_mask_t mask; member
/oneTBB/src/tbbbind/
H A Dtbb_bind.cpp397 void set_affinity_mask( const_affinity_mask mask ) { in set_affinity_mask() argument
398 if (hwloc_bitmap_weight(mask) > 0) { in set_affinity_mask()
399 assertion_hwloc_wrapper(hwloc_set_cpubind, topology, mask, HWLOC_CPUBIND_THREAD); in set_affinity_mask()
/oneTBB/doc/main/tbb_userguide/
H A DGuiding_Task_Scheduler_Execution.rst29 instance. Interfaces from ``tbb::info`` namespace respect the process affinity mask. For instance,
30 if the process affinity mask excludes execution on some of the NUMA nodes, then these NUMA nodes are
/oneTBB/src/tbb/tools_api/
H A Dittnotify_static.h128 …V(ITTAPI, void, suppress_push, (unsigned int mask), (ITT_FORMAT …
130 …ange, (__itt_suppress_mode_t mode, unsigned int mask, void * address, size_t size),(ITT_FORMAT mod…
131 …range,(__itt_suppress_mode_t mode, unsigned int mask, void * address, size_t size),(ITT_FORMAT mod…
H A Dittnotify.h579 void ITTAPI __itt_suppress_push(unsigned int mask);
584 ITT_STUBV(ITTAPI, void, suppress_push, (unsigned int mask))
588 #define __itt_suppress_push(mask)
640 void ITTAPI __itt_suppress_mark_range(__itt_suppress_mode_t mode, unsigned int mask, void * address…
645 ITT_STUBV(ITTAPI, void, suppress_mark_range, (__itt_suppress_mode_t mode, unsigned int mask, void *…
649 #define __itt_suppress_mark_range(mask)
661 void ITTAPI __itt_suppress_clear_range(__itt_suppress_mode_t mode, unsigned int mask, void * addres…
666 ITT_STUBV(ITTAPI, void, suppress_clear_range, (__itt_suppress_mode_t mode, unsigned int mask, void …
670 #define __itt_suppress_clear_range(mask)