| /oneTBB/src/tbb/ |
| H A D | thread_request_serializer.cpp | 82 void thread_request_serializer_proxy::register_mandatory_request(int mandatory_delta) { in register_mandatory_request() argument
83 if (mandatory_delta != 0) { in register_mandatory_request()
85 int prev_value = my_num_mandatory_requests.fetch_add(mandatory_delta); in register_mandatory_request()
87 const bool should_try_enable = mandatory_delta > 0 && prev_value == 0; in register_mandatory_request()
88 const bool should_try_disable = mandatory_delta < 0 && prev_value == 1; in register_mandatory_request()
|
| H A D | market.cpp | 121 void market::adjust_demand(pm_client& c, int mandatory_delta, int workers_delta) { in adjust_demand() argument
122 __TBB_ASSERT(-1 <= mandatory_delta && mandatory_delta <= 1, nullptr); in adjust_demand()
128 delta = c.update_request(mandatory_delta, workers_delta); in adjust_demand()
133 my_mandatory_num_requested += mandatory_delta; in adjust_demand()
|
| H A D | pm_client.h | 47 int update_request(int mandatory_delta, int workers_delta) { in update_request() argument
48 auto min_max_workers = my_arena.update_request(mandatory_delta, workers_delta); in update_request()
|
| H A D | threading_control.cpp | 161 void threading_control_impl::adjust_demand(threading_control_client tc_client, int mandatory_delta,… in adjust_demand() argument
163 my_thread_request_serializer->register_mandatory_request(mandatory_delta); in adjust_demand()
164 my_permit_manager->adjust_demand(c, mandatory_delta, workers_delta); in adjust_demand()
388 void threading_control::adjust_demand(threading_control_client client, int mandatory_delta, int wor… in adjust_demand() argument
389 my_pimpl->adjust_demand(client, mandatory_delta, workers_delta); in adjust_demand()
|
| H A D | tcm_adaptor.cpp | 298 void tcm_adaptor::adjust_demand(pm_client& c, int mandatory_delta, int workers_delta) { in adjust_demand() argument
299 __TBB_ASSERT(-1 <= mandatory_delta && mandatory_delta <= 1, nullptr); in adjust_demand()
306 workers_delta = client.update_request(mandatory_delta, workers_delta); in adjust_demand()
|
| H A D | arena.h | 327 void request_workers(int mandatory_delta, int workers_delta, bool wakeup_threads = false);
394 …std::pair</*min workers = */ int, /*max workers = */ int> update_request(int mandatory_delta, int …
424 int mandatory_delta = is_mandatory_needed ? 1 : 0; in advertise_new_work() local
432 request_workers(mandatory_delta, workers_delta, /* wakeup_threads = */ true); in advertise_new_work()
|
| H A D | threading_control.h | 71 void adjust_demand(threading_control_client, int mandatory_delta, int workers_delta);
118 void adjust_demand(threading_control_client client, int mandatory_delta, int workers_delta);
|
| H A D | arena.cpp | 347 void arena::request_workers(int mandatory_delta, int workers_delta, bool wakeup_threads) { in request_workers() argument
348 my_threading_control->adjust_demand(my_tc_client, mandatory_delta, workers_delta); in request_workers()
379 int mandatory_delta = disable_mandatory ? -1 : 0; in out_of_work() local
386 request_workers(mandatory_delta, workers_delta); in out_of_work()
420 std::pair<int, int> arena::update_request(int mandatory_delta, int workers_delta) { in update_request() argument
421 __TBB_ASSERT(-1 <= mandatory_delta && mandatory_delta <= 1, nullptr); in update_request()
427 my_mandatory_requests += mandatory_delta; in update_request()
|
| H A D | tcm_adaptor.h | 46 void adjust_demand(pm_client& c, int mandatory_delta, int workers_delta) override;
|
| H A D | permit_manager.h | 39 virtual void adjust_demand(pm_client&, int mandatory_delta, int workers_delta) = 0;
|
| H A D | market.h | 43 void adjust_demand(pm_client&, int mandatory_delta, int workers_delta) override;
|
| H A D | thread_request_serializer.h | 64 void register_mandatory_request(int mandatory_delta);
|