Lines Matching refs:idx

172 void TestConcurrentArenasFunc(int idx) {  in TestConcurrentArenasFunc()  argument
187 …ArenaObserver o1(a1, 1, 0, idx*2+1); // the last argument is a "unique" observer/arena id for the … in TestConcurrentArenasFunc()
191 ArenaObserver o2(a2, 2, 1, idx*2+2); in TestConcurrentArenasFunc()
331 TestArenaEntryBody(std::atomic<int> &s, int idx, int i) // init thread-specific instance in TestArenaEntryBody()
332 : FPModeContext(idx+i) in TestArenaEntryBody()
336 , is_expected( (idx&(1<<i)) != 0 ) in TestArenaEntryBody()
341 my_id << idx << ':' << i << '@'; in TestArenaEntryBody()
381 void test(int idx) { in test() argument
382 my_idx = idx; in test()
450 int idx = tbb::this_task_arena::current_thread_index(); in operator ()() local
451 REQUIRE( idx < (my_max_concurrency > 1 ? my_max_concurrency : 2) ); in operator ()()
458 …CHECK_MESSAGE( idx < my_reserved_slots, "External threads are supposed to use only reserved slots … in operator ()()
461 CHECK( idx >= my_reserved_slots ); in operator ()()
620 void operator()( int idx ) const { in operator ()()
621 my_idx = idx; in operator ()()
643 arena.initialize( maxthread, std::min(maxthread,idx) ); in operator ()()
1041 void operator()(int idx) const { in operator ()()
1042 if ( idx==0 ) { // thread 0 works in the arena, thread 1 waits for it (to prevent test hang) in operator ()()
1076 …TestMultipleWaitsArenaWait( int idx, int bunch_size, int num_tasks, std::vector<wait_context*>& wa… in TestMultipleWaitsArenaWait() argument
1077 …: my_idx( idx ), my_bunch_size( bunch_size ), my_num_tasks(num_tasks), my_waiters( waiters ), my_p… in TestMultipleWaitsArenaWait()
1103 void operator()( int idx ) const { in operator ()()
1104 …my_arena.execute( TestMultipleWaitsArenaWait( idx, my_bunch_size, my_num_tasks, my_waiters, my_pro… in operator ()()
1126 int idx = 0; in TestMultipleWaits() local
1132 waiters[idx]->reserve(); in TestMultipleWaits()
1133 …TestMultipleWaitsThreadBody( bunch_size, num_tasks, a, waiters, processed, tgc ), idx++ ).detach(); in TestMultipleWaits()
1139 …TestMultipleWaitsThreadBody( bunch_size, num_tasks, a, waiters, processed, tgc ), idx++ ).detach(); in TestMultipleWaits()
1466 utils::NativeParallelFor(1, [threads](int idx) { in TestDefaultCreatedWorkersAmount() argument
1467 REQUIRE_MESSAGE(idx == 0, "more than 1 thread is going to reset TLS"); in TestDefaultCreatedWorkersAmount()