Home
last modified time | relevance | path

Searched refs:index (Results 1 – 25 of 42) sorted by relevance

12

/oneTBB/test/common/
H A Dtest_invoke.h47 …for (std::size_t index = get_real_index(this->begin()); index != get_real_index(this->end()); ++in… in increase() local
48 ++(*change_vector)[index]; in increase()
54 …for (std::size_t index = get_real_index(this->begin()); index != get_real_index(this->end()); ++in… in reduction() local
55 result = result + Value(index); in reduction()
63 …for (std::size_t index = get_real_index(this->begin()); index != get_real_index(this->end()); ++in… in scan() local
64 result = result + Value(index); in scan()
65 if (is_final_scan) (*change_vector)[index] = get_real_index(result); in scan()
H A Dcommon_arena_constraints.h99 int index{-1};
105 : index{src.index} in index_info()
111 index = src.index;
199 current_node_info.index = static_cast<int>(current_numa_node->logical_index); in system_info()
209 current_node_info.index = 0; in system_info()
217 return a.index < b.index; in system_info()
250 cki.index = hwloc_cpukinds_get_by_cpuset(topology, cki.cpuset, /*flags*/0); in system_info()
251 REQUIRE_MESSAGE(cki.index >= 0, in system_info()
260 cpu_kind_infos[0].index = -1; in system_info()
398 [&](const index_info& info) { return info.index == c.numa_id; } in prepare_reference_affinity_mask()
[all …]
H A Dconcurrent_unordered_common.h175 const size_type index = c.unsafe_bucket(Value<Table>::key(*it)); in CustomExamine() local
177 …REQUIRE(std::search(c.unsafe_begin(index), c.unsafe_end(index), prev_it, it, utils::IsEqual()) != … in CustomExamine()
H A Dconcurrent_lru_cache_common.h92 std::size_t index = k; in operator() local
94 return my_array_ref[index]; in operator()
/oneTBB/src/tbb/
H A Denvironment.h43 size_t index = std::strspn(s, " ");
44 if (s[index] != '1') return false;
45 index++;
50 index += std::strspn(&s[index], " ");
51 return !s[index];
H A Dthread_data.h101 thread_data(unsigned short index, bool is_worker) in thread_data() argument
102 : my_arena_index{ index } in thread_data()
134 void attach_arena(arena& a, std::size_t index);
205 inline void thread_data::attach_arena(arena& a, std::size_t index) { in attach_arena() argument
207 my_arena_index = static_cast<unsigned short>(index); in attach_arena()
208 my_arena_slot = a.my_slots + index; in attach_arena()
210 my_inbox.attach(my_arena->mailbox(index)); in attach_arena()
H A Darena.cpp156 std::size_t index = tls.my_arena_index; in occupy_free_slot_in_range() local
157 if ( index < lower || index >= upper ) index = tls.my_random.get() % (upper - lower) + lower; in occupy_free_slot_in_range()
158 __TBB_ASSERT( index >= lower && index < upper, nullptr); in occupy_free_slot_in_range()
160 for ( std::size_t i = index; i < upper; ++i ) in occupy_free_slot_in_range()
162 for ( std::size_t i = lower; i < index; ++i ) in occupy_free_slot_in_range()
171 if ( index == out_of_arena ) { in occupy_free_slot()
175 if ( index == out_of_arena ) in occupy_free_slot()
180 return index; in occupy_free_slot()
193 std::size_t index = occupy_free_slot</*as_worker*/true>(tls); in process() local
194 if (index == out_of_arena) { in process()
[all …]
H A Dthread_dispatcher.cpp207 unsigned short index = ++my_first_unused_worker_idx; in create_one_job() local
208 __TBB_ASSERT(index > 0, nullptr); in create_one_job()
211 thread_data* td = new (cache_aligned_allocate(sizeof(thread_data))) thread_data{ index, true }; in create_one_job()
212 __TBB_ASSERT(index <= my_num_workers_hard_limit, nullptr); in create_one_job()
/oneTBB/include/oneapi/tbb/detail/
H A D_segment_table.h154 return get_table()[index] + segment_base(index); in get_segment()
157 value_type& operator[]( size_type index ) {
158 return internal_subscript<true>(index);
161 const value_type& operator[]( size_type index ) const {
315 return size_type(1) << index & ~size_type(1); in segment_base()
320 return index == 0 ? 2 : size_type(1) << index; in segment_size()
331 my_instance.self()->copy_segment(index, from, to); in operator()
338 my_instance.self()->move_segment(index, from, to); in operator()
503 value_type& internal_subscript( size_type index ) { in internal_subscript() argument
510 extend_table_if_necessary(table, index, index + 1); in internal_subscript()
[all …]
H A D_concurrent_queue_base.h85 return items[index];
90 return items[index];
116 if (!index) { in prepare_page()
141 return index; in prepare_page()
212 …size_type end_in_first_page = (index+n_items < items_per_page) ? (index + n_items) : items_per_pag… in assign()
293 ++index;
296 index = 0;
335 auto& from = src[index]; in assign_and_destroy_item()
435 for (size_type index = 0; index < n_queue; ++index) { in clear() local
436 array[index].clear(alloc); in clear()
[all …]
H A D_flow_graph_types_impl.h381 tagged_msg(T const &index, R const &value) : my_tag(index), my_msg(value) {}
384 tagged_msg(T const &index, R (&value)[N]) : my_tag(index), my_msg(value) {}
386 void set_tag(TagType const &index) {my_tag = index;}
H A D_concurrent_unordered_base.h846 void deallocate_segment( segment_type address, size_type index ) { in deallocate_segment() argument
847 destroy_segment(address, index); in deallocate_segment()
850 void destroy_segment( segment_type address, size_type index ) { in destroy_segment() argument
852 for (size_type i = 0; i != this->segment_size(index); ++i) { in destroy_segment()
855 segment_allocator_traits::deallocate(alloc, address, this->segment_size(index)); in destroy_segment()
859 void copy_segment( size_type index, segment_type, segment_type to ) { in copy_segment() argument
860 if (index == 0) { in copy_segment()
866 for (size_type i = 0; i != this->segment_size(index); ++i) { in copy_segment()
872 void move_segment( size_type index, segment_type from, segment_type to ) { in move_segment() argument
873 if (index == 0) { in move_segment()
[all …]
/oneTBB/examples/parallel_for/tachyon/src/
H A Dgrid.cpp181 cur = g->cells[index->z * g->xsize * g->ysize + index->y * g->xsize + index->x]; in cellbound()
277 gridindex index; in engrid_scene() local
299 for (index.z = 0; index.z < g->zsize; index.z++) { in engrid_scene()
300 for (index.y = 0; index.y < g->ysize; index.y++) { in engrid_scene()
301 for (index.x = 0; index.x < g->xsize; index.x++) { in engrid_scene()
340 list = &gold->cells[index->z * gold->xsize * gold->ysize + index->y * gold->xsize + index->x]; in engrid_cell()
452 index->x--; in pos2grid()
454 index->y--; in pos2grid()
456 index->z--; in pos2grid()
458 if (index->x < 0 || index->x > g->xsize || index->y < 0 || index->y > g->ysize || in pos2grid()
[all …]
H A Dgrid.hpp101 static int cellbound(grid *g, gridindex *index, vector *cmin, vector *cmax);
109 static int pos2grid(grid *g, vector *pos, gridindex *index);
/oneTBB/examples/common/gui/
H A Dvideo.hpp129 std::size_t index; member in drawing_area
208 index = base_index; // current index in drawing_area()
212 index = base_index + local_x + local_y * index_stride; in set_pos()
216 assert(index < max_index); in put_pixel()
218 ptr32[index++] = color; in put_pixel()
220 ((unsigned short *)ptr32)[index++] = (unsigned short)color; in put_pixel()
222 if (index & 1) in put_pixel()
224 ((unsigned short *)ptr32)[index++] = (unsigned short)color; in put_pixel()
/oneTBB/include/oneapi/tbb/
H A Dconcurrent_vector.h421 reference operator[]( size_type index ) {
422 return internal_subscript(index);
425 return internal_subscript(index);
428 reference at( size_type index ) { in at() argument
431 const_reference at( size_type index ) const { in at() argument
613 if (index == offset) { in create_segment()
734 return is_power_of_two_at_least(index, 2); in is_first_element_in_segment()
741 reference internal_subscript( size_type index ) { in internal_subscript() argument
979 size_type index = 0; in internal_compact() local
981 for (; index < std::min(this->segment_size(max_block), curr_size); ++index) { in internal_compact()
[all …]
/oneTBB/doc/
H A Dindex.rst4 .. include:: index/index_intro.rst
13 .. include:: index/useful_topics.rst
15 .. include:: index/toctree.rst
/oneTBB/examples/parallel_for/seismic/
H A Duniverse.cpp150 int index = (int)(V[i][j] * (ColorMapSize / 2)) + ColorMapSize / 2; in UpdateStress() local
151 if (index < 0) in UpdateStress()
152 index = 0; in UpdateStress()
153 if (index >= ColorMapSize) in UpdateStress()
154 index = ColorMapSize - 1; in UpdateStress()
156 drawing.put_pixel(c[index]); in UpdateStress()
/oneTBB/test/tbb/
H A Dtest_flow_graph_priorities.cpp105 NodeType* operator()( graph& g, unsigned index, utils::SpinBarrier& barrier ) { in operator ()()
106 if( start_index <= index && index < end_index ) in operator ()()
107 return new NodeType( g, unlimited, BodyType(index, barrier), node_priority_t(index) ); in operator ()()
115 … continue_node<continue_msg>* operator()( graph& g, unsigned index, utils::SpinBarrier& barrier ) { in operator ()()
116 if( start_index <= index && index < end_index ) in operator ()()
117 … return new continue_node<continue_msg>( g, BodyType(index, barrier), node_priority_t(index) ); in operator ()()
H A Dtest_parallel_for_each.cpp302 for (std::size_t index = 0; index < n; ++index) { in test_with_cpp20_iterator() local
303 CHECK(elements[index].item == 42); in test_with_cpp20_iterator()
H A Dtest_global_control.cpp150 ExceptionTest1( int index ) : myIndex( index ) {} in ExceptionTest1() argument
/oneTBB/test/conformance/
H A Dconformance_arena_constraints.cpp50 [&](const index_info& numa_info){ return numa_info.index == numa_id; } in __anonb63cdda60302()
70 … REQUIRE_MESSAGE(core_types[i] == core_types_info[i].index, "Wrong core type index detected.");
/oneTBB/src/tbbmalloc/
H A Dfrontend.cpp827 return indexRequest ? index : (index+1)<<3; in getIndexOrObjectSize()
1493 Bin* bin = tls->bin + index; in privatizeOrphaned()
1580 unsigned int index = getIndex(size); in initEmptyBlock() local
1599 unsigned int index = getIndex(size); in get() local
1600 Block *block = bins[index].pop(); in get()
1602 MALLOC_ITT_SYNC_ACQUIRED(bins+index); in get()
1611 block->shareOrphaned(binTag, index); in put()
1612 MALLOC_ITT_SYNC_RELEASING(bins+index); in put()
1613 bins[index].push(block); in put()
1781 for (unsigned index = 0; index < numBlockBins; index++) { in release() local
[all …]
/oneTBB/doc/main/tbb_userguide/
H A DAdvanced_Example.rst7 An example of a more advanced associative operation is to find the index
29 the index of this value. This is the only information carried between
/oneTBB/src/tbbbind/
H A Dtbb_bind.cpp168 int index = 0; in numa_topology_parsing() local
171 index = static_cast<int>(node_buffer->logical_index); in numa_topology_parsing()
173 hwloc_cpuset_t& current_mask = numa_affinity_masks_list[index]; in numa_topology_parsing()

12