| /oneTBB/src/tbb/ |
| H A D | thread_request_serializer.cpp | 29 void thread_request_serializer::update(int delta) { in update() argument
33 int prev_pending_delta = my_pending_delta.fetch_add(counter_value + delta); in update()
40 my_total_request += delta; in update()
41 delta = limit_delta(delta, my_soft_limit, my_total_request); in update()
42 my_thread_dispatcher.adjust_job_count_estimate(delta); in update()
48 int delta = soft_limit - my_soft_limit; in set_active_num_workers() local
49 delta = limit_delta(delta, my_total_request, soft_limit); in set_active_num_workers()
50 my_thread_dispatcher.adjust_job_count_estimate(delta); in set_active_num_workers()
54 int thread_request_serializer::limit_delta(int delta, int limit, int new_value) { in limit_delta() argument
70 int prev_value = new_value - delta; in limit_delta()
[all …]
|
| H A D | thread_request_serializer.h | 33 virtual void update(int delta) = 0;
46 void update(int delta) override;
47 static int limit_delta(int delta, int limit, int new_value);
68 void update(int delta) override;
|
| H A D | market.cpp | 124 int delta{}; in adjust_demand() local
128 delta = c.update_request(mandatory_delta, workers_delta); in adjust_demand()
131 my_total_demand += delta; in adjust_demand()
132 my_priority_level_demand[c.priority_level()] += delta; in adjust_demand()
138 notify_thread_request(delta); in adjust_demand()
|
| H A D | permit_manager.h | 46 void notify_thread_request(int delta) { in notify_thread_request() argument
48 if (delta) { in notify_thread_request()
49 my_thread_request_observer->update(delta); in notify_thread_request()
|
| H A D | private_server.cpp | 198 void adjust_job_count_estimate( int delta ) override;
416 void private_server::adjust_job_count_estimate( int delta ) { in adjust_job_count_estimate() argument
418 my_net_slack_requests+=delta; in adjust_job_count_estimate()
420 if( delta<0 ) { in adjust_job_count_estimate()
421 my_slack+=delta; in adjust_job_count_estimate()
422 } else if( delta>0 ) { in adjust_job_count_estimate()
423 wake_some( delta ); in adjust_job_count_estimate()
|
| H A D | pm_client.h | 49 int delta = min_max_workers.second - my_max_workers; in update_request() local
51 return delta; in update_request()
|
| H A D | tcm_adaptor.cpp | 128 int delta{}; in actualize_permit() local
142 … delta = update_concurrency(new_permit.state != TCM_PERMIT_STATE_INACTIVE ? new_concurrency : 0); in actualize_permit()
145 if (delta) { in actualize_permit()
146 my_tcm_adaptor.notify_thread_request(delta); in actualize_permit()
|
| H A D | thread_dispatcher.cpp | 167 void thread_dispatcher::adjust_job_count_estimate(int delta) { in adjust_job_count_estimate() argument
168 my_server->adjust_job_count_estimate(delta); in adjust_job_count_estimate()
|
| H A D | rml_tbb.h | 38 virtual void adjust_job_count_estimate( int delta ) = 0;
|
| H A D | rml_base.h | 124 virtual void independent_thread_number_changed( int delta ) = 0;
|
| H A D | thread_dispatcher.h | 48 void adjust_job_count_estimate(int delta);
|
| H A D | arena.cpp | 413 int delta = allotment - my_num_workers_allotted.load(std::memory_order_relaxed); in update_concurrency() local
414 if (delta != 0) { in update_concurrency()
417 return delta; in update_concurrency()
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _task.h | 104 void add_reference(std::int64_t delta) { in add_reference() argument
106 …t r = m_ref_count.fetch_add(static_cast<std::uint64_t>(delta)) + static_cast<std::uint64_t>(delta); in add_reference()
141 void reserve(std::uint32_t delta = 1) {
142 add_reference(delta);
145 void release(std::uint32_t delta = 1) {
146 add_reference(-std::int64_t(delta));
|
| /oneTBB/python/rml/ |
| H A D | ipc_server.cpp | 484 void adjust_job_count_estimate(int delta) override;
1057 void ipc_server::adjust_job_count_estimate( int delta ) { in adjust_job_count_estimate() argument
1059 my_net_slack_requests+=delta; in adjust_job_count_estimate()
1062 if( delta<0 ) { in adjust_job_count_estimate()
1063 my_slack+=delta; in adjust_job_count_estimate()
1064 } else if( delta>0 ) { in adjust_job_count_estimate()
1072 wake_some( delta, active_threads ); in adjust_job_count_estimate()
1082 if( delta<0 ) { in adjust_job_count_estimate()
1083 my_slack += delta; in adjust_job_count_estimate()
1085 wake_one_forced( delta ); in adjust_job_count_estimate()
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | concurrent_vector.h | 381 iterator grow_by( size_type delta ) { in grow_by() argument
382 return internal_grow_by_delta(delta); in grow_by()
385 iterator grow_by( size_type delta, const value_type& value ) { in grow_by() argument
386 return internal_grow_by_delta(delta, value); in grow_by()
392 auto delta = std::distance(first, last); in grow_by() local
393 return internal_grow_by_delta(delta, first, last); in grow_by()
854 if (delta == size_type(0)) { in internal_grow_by_delta()
857 size_type start_idx = this->my_size.fetch_add(delta); in internal_grow_by_delta()
858 size_type end_idx = start_idx + delta; in internal_grow_by_delta()
870 int delta = static_cast<int>(new_size) - static_cast<int>(old_size); in internal_grow_to_at_least() local
[all …]
|
| H A D | flow_graph.h | 1897 graph_task* decrement_counter( long long delta ) { in decrement_counter() argument
1898 if ( delta > 0 && size_t(delta) > my_threshold ) { in decrement_counter()
1899 delta = my_threshold; in decrement_counter()
1904 if ( delta > 0 && size_t(delta) > my_count ) { in decrement_counter()
1906 my_future_decrement += (size_t(delta) - my_count); in decrement_counter()
1910 else if ( delta < 0 && size_t(-delta) > my_threshold - my_count ) { in decrement_counter()
1914 my_count -= size_t(delta); // absolute value of delta is sufficiently small in decrement_counter()
|
| /oneTBB/test/conformance/ |
| H A D | conformance_concurrent_vector.cpp | 43 typename Vector::difference_type delta = cp-u.begin(); in CheckConstIterator() local
44 REQUIRE( delta==i ); in CheckConstIterator()
104 typename V::difference_type delta = p-v.begin(); in TestSequentialFor() local
105 REQUIRE( delta==i ); in TestSequentialFor()
146 if( 0<=k+delta && std::size_t(k+delta)<u.size() ) { in TestSequentialFor()
147 V::const_iterator &cpr = (cp += delta); in TestSequentialFor()
149 k += delta; in TestSequentialFor()
151 delta = i*7 % u.size(); in TestSequentialFor()
152 if( 0<=k-delta && std::size_t(k-delta)<u.size() ) { in TestSequentialFor()
154 V::const_iterator &cpr = (cp -= delta); in TestSequentialFor()
[all …]
|
| /oneTBB/test/tbb/ |
| H A D | test_task.cpp | 309 std::size_t delta = 7; in operator ()() local
310 std::size_t start_idx = my_current_task.fetch_add(delta); in operator ()()
313 …for (std::size_t idx = start_idx; idx != std::min(my_task_pool.size(), start_idx + delta); ++idx) { in operator ()()
|
| H A D | test_flow_graph_priorities.cpp | 58 void spin_for( double delta ) { in spin_for() argument
60 while( (tbb::tick_count::now() - start).seconds() < delta ) ; in spin_for()
|
| /oneTBB/src/tbb/tools_api/ |
| H A D | ittnotify.h | 3085 …nter_inc_delta_v3(const __itt_domain *domain, __itt_string_handle *name, unsigned long long delta);
3090 …er_inc_delta_v3, (const __itt_domain *domain, __itt_string_handle *name, unsigned long long delta))
3098 #define __itt_counter_inc_delta_v3(domain,name,delta)
3127 …nter_dec_delta_v3(const __itt_domain *domain, __itt_string_handle *name, unsigned long long delta);
3132 …er_dec_delta_v3, (const __itt_domain *domain, __itt_string_handle *name, unsigned long long delta))
3140 #define __itt_counter_dec_delta_v3(domain,name,delta)
|