Home
last modified time | relevance | path

Searched refs:tid (Results 1 – 11 of 11) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_semaphore.cpp59 void operator()( const int tid ) const { in operator ()()
63 utils::Sleep(tid * tickCounts); in operator ()()
67 tottime[tid] += (t1 - t0).seconds(); in operator ()()
70 if (curval > ourCounts[tid]) { in operator ()()
71 ourCounts[tid] = curval; in operator ()()
179 void operator()( const int tid ) { in operator ()() argument
181 Consume(tid); in operator ()()
183 Produce(tid); in operator ()()
193 void operator()( const int tid ) const { in operator ()()
194 my_filters[tid]->operator()(tid); in operator ()()
H A Dtest_queue_node.cpp59 int tid = value / N; in check_item() local
62 ++next_value[tid]; in check_item()
111 bool check( int tid, T v ) { in check()
113 if ( my_touches[tid][v] != false ) { in check()
121 my_last_touch[tid][v_tid] = v; in check()
122 my_touches[tid][v] = true; in check()
158 void operator()(int tid) const { in operator ()()
162 my_touches.check( tid, v ); in operator ()()
176 void operator()(int tid) const { in operator ()()
264 for (int tid = 0; tid < num_threads; ++tid) next_value[tid] = T(0); in test_parallel() local
[all …]
H A Dtest_sequencer_node.cpp63 void operator()(int tid) const { in operator ()()
64 for (int j = tid; j < N; j+=my_num_threads) { in operator ()()
98 bool check( int tid, T v ) { in check()
99 if ( my_touches[tid][v] != false ) { in check()
103 if ( v <= my_last_touch[tid] ) { in check()
107 my_last_touch[tid] = v; in check()
108 my_touches[tid][v] = true; in check()
145 void operator()(int tid) const { in operator ()()
149 my_touches.check( tid, v ); in operator ()()
167 void operator()(int tid) const { in operator ()()
[all …]
H A Dtest_buffer_node.cpp124 void operator()(int tid) const { in operator ()()
130 CHECK_MESSAGE( my_b.try_put( T (N*tid + j ) ) == true, "" ); in operator ()()
210 for (int tid = 0; tid < num_threads; ++tid) next_value[tid] = T(0); in test_parallel() local
217 for (int tid = 0; tid < num_threads; ++tid) { in test_parallel() local
218 CHECK_MESSAGE( next_value[tid] == T((N*(N-1))/2), "" ); in test_parallel()
H A Dtest_priority_queue_node.cpp48 int tid = value / N; in check_item() local
50 CHECK_MESSAGE( next_value[tid] == T(offset), "" ); in check_item()
51 ++next_value[tid]; in check_item()
85 void operator()(int tid) const { in operator ()()
90 CHECK_MESSAGE( my_q.try_put( T (N*tid + j ) ) == true, "" ); in operator ()()
H A Dtest_flow_graph_priorities.cpp427 void do_nested_work( const std::thread::id& tid, const tbb::blocked_range<int>& subrange );
450 void do_nested_work( const std::thread::id& tid, const tbb::blocked_range<int>& /*subrange*/ ) { in do_nested_work() argument
452 if( !exec_tracker.prioritized_work_started || exec_tracker.prioritized_work_submitter != tid ) in do_nested_work()
482 void do_nested_work<PRIORITIZED_WORK>( const std::thread::id& tid, in do_nested_work() argument
484 if( exec_tracker.prioritized_work_started && exec_tracker.prioritized_work_submitter == tid ) { in do_nested_work()
H A Dtest_tbb_fork.cpp85 DWORD tid = GetCurrentThreadId(); in operator ()() local
88 if (tidTable.insert(acc, tid)) { in operator ()()
/oneTBB/examples/parallel_for/tachyon/src/
H A Dtrace.hpp55 int tid; member
H A Dtrace_rest.cpp94 parms->tid = 0; in trace_shm()
/oneTBB/src/tbb/tools_api/
H A Dittnotify_config.h447 TIDT tid; member
532 h->tid = t; \
549 h->tid = t; \
/oneTBB/src/tbbmalloc/
H A Dfrontend.cpp165 friend int STAT_increment(ThreadId tid, int bin, int ctr);
173 int STAT_increment(ThreadId tid, int bin, int ctr) in STAT_increment() argument
175 return ::STAT_increment(tid.id, bin, ctr); in STAT_increment()
183 std::atomic<pthread_t> tid; member in rml::internal::ThreadId
185 std::atomic<DWORD> tid;
188 ThreadId() : tid(GetMyTID()) {} in ThreadId()
193 …bool isCurrentThreadId() const { return pthread_equal(pthread_self(), tid.load(std::memory_order_r… in isCurrentThreadId()
195 …bool isCurrentThreadId() const { return GetCurrentThreadId() == tid.load(std::memory_order_relaxed… in isCurrentThreadId()
198 tid.store(other.tid.load(std::memory_order_relaxed), std::memory_order_relaxed); in operator =()