Searched refs:thread_dispatcher_client (Results 1 – 7 of 7) sorted by relevance
38 using client_list_type = intrusive_list<thread_dispatcher_client>;44 thread_dispatcher_client* create_client(arena& a);45 void register_client(thread_dispatcher_client* client);64 thread_dispatcher_client* select_next_client(thread_dispatcher_client* hint);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);69 …thread_dispatcher_client* client_in_need(client_list_type* clients, thread_dispatcher_client* hint…70 thread_dispatcher_client* client_in_need(thread_dispatcher_client* prev);[all …]
37 thread_dispatcher_client* thread_dispatcher::select_next_client(thread_dispatcher_client* hint) { in select_next_client()52 thread_dispatcher_client* thread_dispatcher::create_client(arena& a) { in create_client()53 …return new (cache_aligned_allocate(sizeof(thread_dispatcher_client))) thread_dispatcher_client(a, … in create_client()57 void thread_dispatcher::register_client(thread_dispatcher_client* client) { in register_client()94 client->~thread_dispatcher_client(); in destroy_client()99 void thread_dispatcher::insert_client(thread_dispatcher_client& client) { in insert_client()108 void thread_dispatcher::remove_client(thread_dispatcher_client& client) { in remove_client()134 thread_dispatcher_client* thread_dispatcher::client_in_need(client_list_type* clients, thread_dispa… in client_in_need()145 thread_dispatcher_client& t = *it; in client_in_need()159 thread_dispatcher_client* thread_dispatcher::client_in_need(thread_dispatcher_client* prev) { in client_in_need()[all …]
27 class thread_dispatcher_client; variable35 …threading_control_client(pm_client* p, thread_dispatcher_client* t) : my_pm_client(p), my_thread_d… in threading_control_client()44 thread_dispatcher_client* get_thread_dispatcher_client() { in get_thread_dispatcher_client()50 thread_dispatcher_client* my_thread_dispatcher_client{nullptr};
27 class thread_dispatcher_client : public d1::intrusive_list_node /* Need for list in thread pool */ {29 …thread_dispatcher_client(arena& a, std::uint64_t aba_epoch) : my_arena(a), my_aba_epoch(aba_epoch)… in thread_dispatcher_client() function
43 class thread_dispatcher_client; variable154 thread_dispatcher_client* my_last_client;
55 thread_dispatcher_client* my_td_client;
117 thread_dispatcher_client* td_client = my_thread_dispatcher->create_client(a); in create_client()