Home
last modified time | relevance | path

Searched refs:worker_thread_t (Results 1 – 16 of 16) sorted by relevance

/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dthreadpool_generic.h56 struct worker_thread_t struct
60 worker_thread_t* next_in_list; argument
61 worker_thread_t** prev_in_list; argument
66 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
67 & worker_thread_t::next_in_list,
68 & worker_thread_t::prev_in_list>,
135 worker_thread_t* listener;
H A Dthreadpool_generic.cc726 static TP_connection_generic * listener(worker_thread_t *current_thread, in listener()
1038 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1168 TP_connection_generic *get_event(worker_thread_t *current_thread, in get_event()
1544 worker_thread_t this_thread; in worker_main()
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dthreadpool_generic.h56 struct worker_thread_t struct
60 worker_thread_t* next_in_list; argument
61 worker_thread_t** prev_in_list; argument
66 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
67 & worker_thread_t::next_in_list,
68 & worker_thread_t::prev_in_list>,
135 worker_thread_t* listener;
H A Dthreadpool_generic.cc726 static TP_connection_generic * listener(worker_thread_t *current_thread, in listener()
1038 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1168 TP_connection_generic *get_event(worker_thread_t *current_thread, in get_event()
1544 worker_thread_t this_thread; in worker_main()
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dthreadpool_unix.cc99 struct worker_thread_t struct
103 worker_thread_t *next_in_list; argument
104 worker_thread_t **prev_in_list; argument
110 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
111 &worker_thread_t::next_in_list,
112 &worker_thread_t::prev_in_list>
144 worker_thread_t *listener;
707 static connection_t * listener(worker_thread_t *current_thread, in listener()
1025 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1133 static connection_t *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dthreadpool_unix.cc99 struct worker_thread_t struct
103 worker_thread_t *next_in_list; argument
104 worker_thread_t **prev_in_list; argument
110 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
111 &worker_thread_t::next_in_list,
112 &worker_thread_t::prev_in_list>
144 worker_thread_t *listener;
707 static connection_t * listener(worker_thread_t *current_thread, in listener()
1025 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1133 static connection_t *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dthreadpool_unix.cc98 struct worker_thread_t struct
102 worker_thread_t *next_in_list; argument
103 worker_thread_t **prev_in_list; argument
109 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
110 &worker_thread_t::next_in_list,
111 &worker_thread_t::prev_in_list>
142 worker_thread_t *listener;
705 static connection_t * listener(worker_thread_t *current_thread, in listener()
1020 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1128 static connection_t *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dthreadpool_unix.cc98 struct worker_thread_t struct
102 worker_thread_t *next_in_list; argument
103 worker_thread_t **prev_in_list; argument
109 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
110 &worker_thread_t::next_in_list,
111 &worker_thread_t::prev_in_list>
142 worker_thread_t *listener;
705 static connection_t * listener(worker_thread_t *current_thread, in listener()
1020 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1128 static connection_t *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Dthreadpool_unix.cc98 struct worker_thread_t struct
102 worker_thread_t *next_in_list; argument
103 worker_thread_t **prev_in_list; argument
109 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
110 &worker_thread_t::next_in_list,
111 &worker_thread_t::prev_in_list>
142 worker_thread_t *listener;
705 static connection_t * listener(worker_thread_t *current_thread, in listener()
1020 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1128 static connection_t *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Dthreadpool_unix.cc99 struct worker_thread_t struct
103 worker_thread_t *next_in_list; argument
104 worker_thread_t **prev_in_list; argument
110 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
111 &worker_thread_t::next_in_list,
112 &worker_thread_t::prev_in_list>
144 worker_thread_t *listener;
707 static connection_t * listener(worker_thread_t *current_thread, in listener()
1025 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1133 static connection_t *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/mariadb104-server/mariadb-10.4.24/sql/
H A Dthreadpool_generic.cc126 struct worker_thread_t struct
130 worker_thread_t *next_in_list; argument
131 worker_thread_t **prev_in_list; argument
137 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
138 &worker_thread_t::next_in_list,
139 &worker_thread_t::prev_in_list>
186 worker_thread_t *listener; in MY_ALIGNED()
790 static TP_connection_generic * listener(worker_thread_t *current_thread, in listener()
1095 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1220 TP_connection_generic *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/
H A Dthreadpool_generic.cc126 struct worker_thread_t struct
130 worker_thread_t *next_in_list; argument
131 worker_thread_t **prev_in_list; argument
137 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
138 &worker_thread_t::next_in_list,
139 &worker_thread_t::prev_in_list>
186 worker_thread_t *listener; in MY_ALIGNED()
790 static TP_connection_generic * listener(worker_thread_t *current_thread, in listener()
1095 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1220 TP_connection_generic *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/mariadb103-server/mariadb-10.3.34/sql/
H A Dthreadpool_generic.cc126 struct worker_thread_t struct
130 worker_thread_t *next_in_list; argument
131 worker_thread_t **prev_in_list; argument
137 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
138 &worker_thread_t::next_in_list,
139 &worker_thread_t::prev_in_list>
186 worker_thread_t *listener; in MY_ALIGNED()
789 static TP_connection_generic * listener(worker_thread_t *current_thread, in listener()
1094 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1219 TP_connection_generic *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/databases/mariadb103-client/mariadb-10.3.34/sql/
H A Dthreadpool_generic.cc126 struct worker_thread_t struct
130 worker_thread_t *next_in_list; argument
131 worker_thread_t **prev_in_list; argument
137 typedef I_P_List<worker_thread_t, I_P_List_adapter<worker_thread_t, argument
138 &worker_thread_t::next_in_list,
139 &worker_thread_t::prev_in_list>
186 worker_thread_t *listener; in MY_ALIGNED()
789 static TP_connection_generic * listener(worker_thread_t *current_thread, in listener()
1094 worker_thread_t *thread = thread_group->waiting_threads.front(); in wake_thread()
1219 TP_connection_generic *get_event(worker_thread_t *current_thread, in get_event()
[all …]
/dports/net/openmpi3/openmpi-3.1.6/orte/mca/dfs/orted/
H A Ddfs_orted.c110 } worker_thread_t; typedef
111 static void wt_const(worker_thread_t *ptr) in wt_const()
123 static void wt_dest(worker_thread_t *ptr) in wt_dest()
135 OBJ_CLASS_INSTANCE(worker_thread_t,
152 worker_thread_t *wt; \
153 wt = (worker_thread_t*)opal_pointer_array_get_item(&worker_threads, wt_cntr); \
187 worker_thread_t *wt; in init()
210 wt = OBJ_NEW(worker_thread_t); in init()
222 worker_thread_t *wt; in finalize()
239 if (NULL != (wt = (worker_thread_t*)opal_pointer_array_get_item(&worker_threads, i))) { in finalize()
[all …]
/dports/net/corosync2/corosync-2.4.5/
H A DChangeLog13337 * exec/wthread.c (struct worker_thread_t): Rename from
13341 member type: s/struct worker_thread/struct worker_thread_t/