Home
last modified time | relevance | path

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

/oneTBB/src/tbb/
H A Dtask.cpp47 void resume(suspend_point_type* sp) { in resume() argument
48 assert_pointers_valid(sp, sp->m_arena); in resume()
49 task_dispatcher& task_disp = sp->m_resume_task.m_target; in resume()
51 if (sp->try_notify_resume()) { in resume()
55 arena& a = *sp->m_arena; in resume()
60 a.my_resume_task_stream.push(&sp->m_resume_task, random_lane_selector(sp->m_random)); in resume()
64 a.my_critical_task_stream.push(&sp->m_resume_task, random_lane_selector(sp->m_random)); in resume()
182 suspend_point_type* sp = static_cast<suspend_point_type*>(td->my_post_resume_arg); in do_post_resume_action() local
183 sp->recall_owner(); in do_post_resume_action()
186 auto is_our_suspend_point = [sp] (market_context ctx) { in do_post_resume_action()
[all …]
H A Dwaiters.h174 suspend_point_type* sp = slot.default_task_dispatcher().m_suspend_point; in pause() local
176 …auto wakeup_condition = [&] { return !my_arena.is_empty() || sp->m_is_owner_recalled.load(std::mem… in pause()
178 sleep(std::uintptr_t(sp), wakeup_condition); in pause()
H A Dtask_dispatcher.h48 suspend_point_type* sp = slot.default_task_dispatcher().m_suspend_point; in get_self_recall_task() local
49 if (sp && sp->m_is_owner_recalled.load(std::memory_order_acquire)) { in get_self_recall_task()
50 t = &sp->m_resume_task; in get_self_recall_task()
51 __TBB_ASSERT(sp->m_resume_task.m_target.m_thread_data == nullptr, nullptr); in get_self_recall_task()
H A Dscheduler_common.h389 void resume(suspend_point_type* sp) { in resume()
392 sp->m_prev_suspend_point = this; in resume()
395 m_co_context.resume(sp->m_co_context); in resume()
/oneTBB/test/conformance/
H A Dconformance_resumable_tasks.cpp37 oneapi::tbb::task::suspend([&t, &suspend, &resume](oneapi::tbb::task::suspend_point sp) { in __anon366fea4d0102() argument
39 t = std::thread([sp, &resume] { in __anon366fea4d0102()
41 oneapi::tbb::task::resume(sp); in __anon366fea4d0102()
61 … oneapi::tbb::task::suspend([&tg, &suspend, &resume](oneapi::tbb::task::suspend_point sp) { in __anon366fea4d0302() argument
63 tg.run([sp, &resume] { in __anon366fea4d0302()
65 oneapi::tbb::task::resume(sp); in __anon366fea4d0302()
/oneTBB/examples/graph/fgbzip2/
H A Dblocksort.cpp128 stackLo[sp] = lz; \
129 stackHi[sp] = hz; \
130 sp++; \
135 sp--; \
136 lz = stackLo[sp]; \
145 Int32 sp, lo, hi; in fallbackQSort3() local
152 sp = 0; in fallbackQSort3()
155 while (sp > 0) { in fallbackQSort3()
792 Int32 sp, lo, hi, d; in mainQSort3() local
802 sp = 0; in mainQSort3()
[all …]
/oneTBB/test/common/
H A Dtest_invoke.h77 SmartID(std::size_t* sp) : id(999), operate_signal_point(sp) {} in SmartID() argument
80 SmartID(const IDType& n, std::size_t* sp) : id(n), operate_signal_point(sp) {} in SmartID() argument
/oneTBB/include/oneapi/tbb/detail/
H A D_task.h80 static void suspend_callback(void* user_callback, suspend_point sp) { in suspend_callback() argument
84 user_callback_copy(sp); in suspend_callback()
H A D_flow_graph_types_impl.h212 pointer_type sp = reinterpret_cast<pointer_type>(const_cast<char *>(other.value_space));
213 for(size_t i = 0; i < N; ++i, ++dp, ++sp) {
214 (void) new(dp) value_type(*sp);
/oneTBB/test/tbb/
H A Dtest_resumable_tasks.cpp147 tbb::task::suspend([&] (tbb::task::suspend_point sp) { m_asyncActivity.submit(sp); }); in operator ()() argument
H A Dtest_task.cpp642 tbb::task::suspend([&] (tbb::task::suspend_point sp) { in __anon509d20bd1a02() argument
644 suspend_points.push_back(sp); in __anon509d20bd1a02()
657 for (auto sp : suspend_points) variable
658 tbb::task::resume(sp);