| /oneTBB/src/tbb/ |
| H A D | thread_dispatcher.cpp | 59 insert_client(*client); in register_client()
63 __TBB_ASSERT(client, nullptr); in try_unregister_client()
68 if (client == &it) { in try_unregister_client()
75 if (!client->references() && !client->has_request()) { in try_unregister_client()
101 my_client_list[client.priority_level()].push_front(client); in insert_client()
110 my_client_list[client.priority_level()].remove(client); in remove_client()
112 if (my_next_client == &client) { in remove_client()
119 if (!client) { in is_client_alive()
126 if (client == &c) { in is_client_alive()
181 while ((client = client_in_need(client)) ) { in process()
[all …]
|
| H A D | market.cpp | 66 auto client = static_cast<tbb_permit_manager_client*>(&c); in unregister_and_destroy_client() local
67 client->~tbb_permit_manager_client(); in unregister_and_destroy_client()
68 cache_aligned_deallocate(client); in unregister_and_destroy_client()
85 tbb_permit_manager_client& client = static_cast<tbb_permit_manager_client&>(**it); in update_allotment() local
86 if (client.max_workers() == 0) { in update_allotment()
87 client.set_allotment(0); in update_allotment()
98 allotted = client.min_workers() > 0 && assigned < max_workers ? 1 : 0; in update_allotment()
100 int tmp = client.max_workers() * assigned_per_priority + carry; in update_allotment()
103 __TBB_ASSERT(allotted <= client.max_workers(), nullptr); in update_allotment()
105 client.set_allotment(allotted); in update_allotment()
[all …]
|
| H A D | thread_dispatcher.h | 45 void register_client(thread_dispatcher_client* client);
46 …bool try_unregister_client(thread_dispatcher_client* client, std::uint64_t aba_epoch, unsigned pri…
65 void destroy_client(thread_dispatcher_client* client);
66 void insert_client(thread_dispatcher_client& client);
67 void remove_client(thread_dispatcher_client& client);
68 bool is_client_alive(thread_dispatcher_client* client);
|
| H A D | private_server.cpp | 97 private_worker( private_server& server, tbb_client& client, const std::size_t i ) : in private_worker() argument
98 my_state(st_init), my_server(server), my_client(client), my_index(i), in private_worker()
113 padded_private_worker( private_server& server, tbb_client& client, const std::size_t i ) in padded_private_worker() argument
114 : private_worker(server,client,i) { suppress_unused_warning(pad); } in padded_private_worker()
180 private_server( tbb_client& client );
327 private_server::private_server( tbb_client& client ) : in private_server() argument
328 my_client(client), in private_server()
329 my_n_thread(client.max_job_count()), in private_server()
330 my_stack_size(client.min_stack_size()), in private_server()
341 private_worker* t = new( &my_thread_array[i] ) padded_private_worker( *this, client, i ); in private_server()
[all …]
|
| H A D | tcm_adaptor.cpp | 286 auto& client = static_cast<tcm_client&>(c); in unregister_and_destroy_client() local
290 client.~tcm_client(); in unregister_and_destroy_client()
292 cache_aligned_deallocate(&client); in unregister_and_destroy_client()
301 auto& client = static_cast<tcm_client&>(c); in adjust_demand() local
306 workers_delta = client.update_request(mandatory_delta, workers_delta); in adjust_demand()
309 if (client.max_workers() == 0) { in adjust_demand()
310 client.deactivate_permit(); in adjust_demand()
312 client.request_permit(my_impl->client_id); in adjust_demand()
316 client.actualize_permit(); in adjust_demand()
|
| H A D | threading_control.h | 50 void publish_client(threading_control_client client, d1::constraints& constraints);
59 client_snapshot prepare_client_destruction(threading_control_client client);
106 void publish_client(threading_control_client client, d1::constraints& constraints);
107 client_snapshot prepare_client_destruction(threading_control_client client);
118 void adjust_demand(threading_control_client client, int mandatory_delta, int workers_delta);
|
| H A D | threading_control.cpp | 122 …ient_snapshot threading_control_impl::prepare_client_destruction(threading_control_client client) { in prepare_client_destruction() argument
123 auto td_client = client.get_thread_dispatcher_client(); in prepare_client_destruction()
124 …return {td_client->get_aba_epoch(), td_client->priority_level(), td_client, client.get_pm_client()… in prepare_client_destruction()
316 void threading_control::publish_client(threading_control_client client, d1::constraints& constraint… in publish_client() argument
317 return my_pimpl->publish_client(client, constraints); in publish_client()
320 …l::client_snapshot threading_control::prepare_client_destruction(threading_control_client client) { in prepare_client_destruction() argument
321 return my_pimpl->prepare_client_destruction(client); in prepare_client_destruction()
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 | governor.cpp | 51 tbb_server* make_private_server( tbb_client& client );
90 rml::tbb_server* governor::create_rml_server ( rml::tbb_client& client ) { in create_rml_server() argument
93 ::rml::factory::status_type status = theRMLServerFactory.make_server( server, client ); in create_rml_server()
101 server = rml::make_private_server( client ); in create_rml_server()
113 bool governor::does_client_join_workers(const rml::tbb_client &client) { in does_client_join_workers() argument
114 return ((const thread_dispatcher&)client).must_join_workers(); in does_client_join_workers()
|
| H A D | tcm_adaptor.h | 41 void register_client(pm_client* client, d1::constraints& constraints) override;
|
| H A D | permit_manager.h | 35 virtual void register_client(pm_client* client, d1::constraints& constraints) = 0;
|
| H A D | market.h | 39 void register_client(pm_client* client, d1::constraints&) override;
|
| H A D | rml_tbb.h | 53 class tbb_client: public ::rml::client {
|
| H A D | rml_base.h | 61 class client: public versioned_object {
|
| H A D | governor.h | 133 static bool does_client_join_workers (const rml::tbb_client &client);
|
| H A D | rml_tbb.cpp | 37 …pe __TBB_make_rml_server( rml::tbb_factory& f, rml::tbb_server*& server, rml::tbb_client& client );
|
| /oneTBB/python/rml/ |
| H A D | ipc_server.cpp | 305 my_client(client), in ipc_worker()
324 : ipc_worker( server,client,i ) { suppress_unused_warning(pad); } in padded_ipc_worker()
339 ipc_waker(ipc_server& server, tbb_client& client, const size_t i) in ipc_waker() argument
340 : padded_ipc_worker( server, client, i ) {} in ipc_waker()
353 : padded_ipc_worker( server, client, i ) {} in ipc_stopper()
463 ipc_server(tbb_client& client);
823 ipc_server::ipc_server(tbb_client& client) : in ipc_server() argument
824 my_client( client ), in ipc_server()
825 my_stack_size( client.min_stack_size() ), in ipc_server()
851 new( my_waker ) ipc_waker( *this, client, my_n_thread ); in ipc_server()
[all …]
|
| /oneTBB/doc/ |
| H A D | Doxyfile.in | 1529 # http://www.mathjax.org) which uses client side Javascript for the rendering
1599 # implemented using a web server instead of a web client using Javascript. There
|