| /third_party/boost/libs/thread/src/pthread/ |
| D | thread.cpp | 92 …boost::detail::thread_data_ptr thread_info = static_cast<boost::detail::thread_data_base*>(data)->… in tls_destructor() local
94 if(thread_info) in tls_destructor()
96 while(!thread_info->tss_data.empty() || thread_info->thread_exit_callbacks) in tls_destructor()
99 while(thread_info->thread_exit_callbacks) in tls_destructor()
101 … detail::thread_exit_callback_node* const current_node=thread_info->thread_exit_callbacks; in tls_destructor()
102 thread_info->thread_exit_callbacks=current_node->next; in tls_destructor()
110 while (!thread_info->tss_data.empty()) in tls_destructor()
113 = thread_info->tss_data.begin(); in tls_destructor()
118 thread_info->tss_data.erase(current); in tls_destructor()
121 thread_info->self.reset(); in tls_destructor()
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | sink-input.c | 551 i->thread_info.state = i->state; in pa_sink_input_new()
552 i->thread_info.attached = false; in pa_sink_input_new()
553 i->thread_info.sample_spec = i->sample_spec; in pa_sink_input_new()
554 i->thread_info.resampler = resampler; in pa_sink_input_new()
555 i->thread_info.soft_volume = i->soft_volume; in pa_sink_input_new()
556 i->thread_info.muted = i->muted; in pa_sink_input_new()
557 i->thread_info.requested_sink_latency = (pa_usec_t) -1; in pa_sink_input_new()
558 i->thread_info.rewrite_nbytes = 0; in pa_sink_input_new()
559 i->thread_info.rewrite_flush = false; in pa_sink_input_new()
560 i->thread_info.dont_rewind_render = false; in pa_sink_input_new()
[all …]
|
| D | sink.c | 334 s->thread_info.rtpoll = NULL; in pa_sink_new()
335 …s->thread_info.inputs = pa_hashmap_new_full(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare… in pa_sink_new()
337 s->thread_info.soft_volume = s->soft_volume; in pa_sink_new()
338 s->thread_info.soft_muted = s->muted; in pa_sink_new()
339 s->thread_info.state = s->state; in pa_sink_new()
340 s->thread_info.rewind_nbytes = 0; in pa_sink_new()
341 s->thread_info.rewind_requested = false; in pa_sink_new()
342 s->thread_info.max_rewind = 0; in pa_sink_new()
343 s->thread_info.max_request = 0; in pa_sink_new()
344 s->thread_info.requested_latency_valid = false; in pa_sink_new()
[all …]
|
| D | source.c | 322 s->thread_info.rtpoll = NULL; in pa_source_new()
323 …s->thread_info.outputs = pa_hashmap_new_full(pa_idxset_trivial_hash_func, pa_idxset_trivial_compar… in pa_source_new()
325 s->thread_info.soft_volume = s->soft_volume; in pa_source_new()
326 s->thread_info.soft_muted = s->muted; in pa_source_new()
327 s->thread_info.state = s->state; in pa_source_new()
328 s->thread_info.max_rewind = 0; in pa_source_new()
329 s->thread_info.requested_latency_valid = false; in pa_source_new()
330 s->thread_info.requested_latency = 0; in pa_source_new()
331 s->thread_info.min_latency = ABSOLUTE_MIN_LATENCY; in pa_source_new()
332 s->thread_info.max_latency = ABSOLUTE_MAX_LATENCY; in pa_source_new()
[all …]
|
| D | source-output.c | 482 o->thread_info.state = o->state; in pa_source_output_new()
483 o->thread_info.attached = false; in pa_source_output_new()
484 o->thread_info.sample_spec = o->sample_spec; in pa_source_output_new()
485 o->thread_info.resampler = resampler; in pa_source_output_new()
486 o->thread_info.soft_volume = o->soft_volume; in pa_source_output_new()
487 o->thread_info.muted = o->muted; in pa_source_output_new()
488 o->thread_info.requested_source_latency = (pa_usec_t) -1; in pa_source_output_new()
489 o->thread_info.direct_on_input = o->direct_on_input; in pa_source_output_new()
491 o->thread_info.delay_memblockq = pa_memblockq_new( in pa_source_output_new()
652 if (o->thread_info.delay_memblockq) in source_output_free()
[all …]
|
| /third_party/pulseaudio/src/modules/ |
| D | module-remap-sink.c | 83 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg()
84 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg()
94 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg()
126 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
141 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind()
142 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind()
145 pa_sink_input_request_rewind(u->sink_input, s->thread_info.rewind_nbytes, true, false, false); in sink_request_rewind()
155 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency()
156 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency()
173 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) in sink_input_pop_cb()
[all …]
|
| D | module-combine-sink.c | 162 } thread_info; member
287 pa_assert(u->sink->thread_info.state == PA_SINK_RUNNING); in process_render_null()
289 if (u->thread_info.in_null_mode) in process_render_null()
290 u->thread_info.timestamp = now; in process_render_null()
292 while (u->thread_info.timestamp < now + u->block_usec) { in process_render_null()
295 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in process_render_null()
298 u->thread_info.counter += chunk.length; in process_render_null()
301 u->thread_info.timestamp += pa_bytes_to_usec(chunk.length, &u->sink->sample_spec); in process_render_null()
305 if (ate >= u->sink->thread_info.max_request) in process_render_null()
311 pa_smoother_put(u->thread_info.smoother, now, in process_render_null()
[all …]
|
| D | module-virtual-sink.c | 94 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
95 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
106 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
138 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
153 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
154 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
159 s->thread_info.rewind_nbytes + in sink_request_rewind_cb()
170 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
171 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_cb()
221 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) in sink_input_pop_cb()
[all …]
|
| D | module-remap-source.c | 91 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_process_msg_cb()
92 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_process_msg_cb()
102 …pa_bytes_to_usec(pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq), &u->sourc… in source_process_msg_cb()
132 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_update_requested_latency_cb()
133 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) in source_update_requested_latency_cb()
152 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_push_cb()
155 if (!PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_output_push_cb()
172 if (PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_process_rewind_cb()
195 if (PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_detach_cb()
209 pa_source_set_rtpoll(u->source, o->source->thread_info.rtpoll); in source_output_attach_cb()
[all …]
|
| D | module-virtual-surround-sink.c | 122 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
123 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
134 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
166 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
181 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
182 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
187 s->thread_info.rewind_nbytes + in sink_request_rewind_cb()
198 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
199 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_cb()
251 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) in sink_input_pop_cb()
[all …]
|
| D | module-virtual-source.c | 165 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_process_msg_cb()
166 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_process_msg_cb()
178 …pa_bytes_to_usec(pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq), &u->sourc… in source_process_msg_cb()
208 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_update_requested_latency_cb()
209 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) in source_update_requested_latency_cb()
254 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_push_cb()
257 if (!PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_output_push_cb()
266 if (u->sink && (u->sink->thread_info.state == PA_SINK_RUNNING)) { in source_output_push_cb()
351 if (PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_process_rewind_cb()
380 pa_source_set_rtpoll(u->source, o->source->thread_info.rtpoll); in source_output_attach_cb()
[all …]
|
| D | module-null-sink.c | 122 if (s->thread_info.state == PA_SINK_SUSPENDED || s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
140 u->block_usec = s->thread_info.max_latency; in sink_update_requested_latency_cb()
183 rewind_nbytes = u->sink->thread_info.rewind_nbytes; in process_rewind()
185 if (!PA_SINK_IS_OPENED(u->sink->thread_info.state) || rewind_nbytes <= 0) in process_rewind()
227 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in process_render()
235 if (ate >= u->sink->thread_info.max_request) in process_render()
260 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) in thread_func()
263 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
267 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
|
| D | module-pipe-sink.c | 145 if (s->thread_info.state == PA_SINK_SUSPENDED || s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
148 } else if (PA_SINK_IS_OPENED(s->thread_info.state)) { in sink_set_state_in_io_thread_cb()
174 u->block_usec = s->thread_info.max_latency; in sink_update_requested_latency_cb()
241 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in process_render_use_timing()
266 if (consumed >= u->sink->thread_info.max_request) in process_render_use_timing()
330 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) in thread_func_use_timing()
333 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func_use_timing()
337 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func_use_timing()
378 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
382 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
[all …]
|
| D | module-null-source.c | 110 if (s->thread_info.state == PA_SOURCE_SUSPENDED || s->thread_info.state == PA_SOURCE_INIT) { in source_set_state_in_io_thread_cb()
127 u->block_usec = u->source->thread_info.max_latency; in source_update_requested_latency_cb()
151 if (PA_SOURCE_IS_OPENED(u->source->thread_info.state)) { in thread_func()
251 u->block_usec = u->source->thread_info.max_latency; in pa__init()
253 u->source->thread_info.max_rewind = in pa__init()
|
| D | module-ladspa-sink.c | 350 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
351 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
362 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
406 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
421 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
422 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
427 s->thread_info.rewind_nbytes + in sink_request_rewind_cb()
438 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
439 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_cb()
474 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) in sink_input_pop_cb()
[all …]
|
| D | module-solaris.c | 407 if (new_state == s->thread_info.state) in sink_set_state_in_io_thread_cb()
414 pa_assert(PA_SINK_IS_OPENED(s->thread_info.state)); in sink_set_state_in_io_thread_cb()
427 if (s->thread_info.state == PA_SINK_SUSPENDED) { in sink_set_state_in_io_thread_cb()
473 if (new_state == s->thread_info.state) in source_set_state_in_io_thread_cb()
480 pa_assert(PA_SOURCE_IS_OPENED(s->thread_info.state)); in source_set_state_in_io_thread_cb()
491 if (s->thread_info.state == PA_SOURCE_SUSPENDED) { in source_set_state_in_io_thread_cb()
621 if (!PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in process_rewind()
626 rewind_nbytes = u->sink->thread_info.rewind_nbytes; in process_rewind()
662 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
665 if (u->sink && PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
[all …]
|
| /third_party/boost/boost/thread/detail/ |
| D | thread.hpp | 175 detail::thread_data_ptr thread_info; member in boost::thread
267 thread_info(make_thread_info(thread_detail::decay_copy(boost::forward<F>(f)))) in thread()
275 thread_info(make_thread_info(thread_detail::decay_copy(boost::forward<F>(f)))) in thread()
284 thread_info(make_thread_info(f)) in thread()
290 thread_info(make_thread_info(f)) in thread()
303 thread_info(make_thread_info(f)) in thread()
312 thread_info(make_thread_info(f)) in thread()
322 thread_info(make_thread_info(boost::move<F>(f))) // todo : Add forward in thread()
324 thread_info(make_thread_info(f)) // todo : Add forward in thread()
333 thread_info(make_thread_info(boost::move<F>(f))) // todo : Add forward in thread()
[all …]
|
| /third_party/boost/boost/thread/pthread/ |
| D | thread_data.hpp | 188 thread_data_base* const thread_info; member in boost::detail::interruption_checker
196 if(thread_info->interrupt_requested) in check_for_interruption()
198 thread_info->interrupt_requested=false; in check_for_interruption()
207 thread_info(detail::get_current_thread_data()),m(cond_mutex), in interruption_checker()
208 set(thread_info && thread_info->interrupt_enabled), done(false) in interruption_checker()
212 lock_guard<mutex> guard(thread_info->data_mutex); in interruption_checker()
214 thread_info->cond_mutex=cond_mutex; in interruption_checker()
215 thread_info->current_cond=cond; in interruption_checker()
229 lock_guard<mutex> guard(thread_info->data_mutex); in unlock_if_locked()
230 thread_info->cond_mutex=NULL; in unlock_if_locked()
[all …]
|
| /third_party/boost/libs/thread/src/win32/ |
| D | thread.cpp | 226 …::boost::detail::thread_data_base* const thread_info(reinterpret_cast<::boost::detail::thread_data… in start()
227 intrusive_ptr_add_ref(thread_info); in start()
236 intrusive_ptr_release(thread_info); in start()
290 … detail::thread_data_base* const thread_info(reinterpret_cast<detail::thread_data_base*>(param)); in thread_start_function() local
291 set_current_thread_data(thread_info); in thread_start_function()
296 thread_info->run(); in thread_start_function()
316 intrusive_ptr_add_ref(thread_info.get()); in start_thread_noexcept()
317 …if (!thread_info->thread_handle.start(&thread_start_function, thread_info.get(), &thread_info->id)) in start_thread_noexcept()
319 intrusive_ptr_release(thread_info.get()); in start_thread_noexcept()
324 …new_thread=_beginthreadex(0,0,&thread_start_function,thread_info.get(),CREATE_SUSPENDED,&thread_in… in start_thread_noexcept()
[all …]
|
| /third_party/pulseaudio/src/modules/echo-cancel/ |
| D | module-echo-cancel.c | 257 } thread_info; member
410 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_process_msg_cb()
411 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_process_msg_cb()
421 …pa_bytes_to_usec(pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq), &u->sourc… in source_process_msg_cb()
428 u->thread_info.current_volume = u->source->reference_volume; in source_process_msg_cb()
446 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
447 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
458 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
525 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
541 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_update_requested_latency_cb()
[all …]
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | scheduler.ipp | 74 thread_info* this_thread_;
104 thread_info* this_thread_;
197 thread_info this_thread;
219 thread_info this_thread;
237 thread_info this_thread;
255 thread_info this_thread;
266 if (thread_info* outer_info = static_cast<thread_info*>(ctx.next_by_key()))
286 thread_info this_thread;
297 if (thread_info* outer_info = static_cast<thread_info*>(ctx.next_by_key()))
325 ++static_cast<thread_info*>(this_thread)->private_outstanding_work;
[all …]
|
| /third_party/boost/boost/asio/detail/ |
| D | scheduler.hpp | 151 typedef scheduler_thread_info thread_info; typedef in boost::asio::detail::scheduler
155 thread_info& this_thread, const boost::system::error_code& ec);
159 thread_info& this_thread, long usec, const boost::system::error_code& ec);
163 thread_info& this_thread, const boost::system::error_code& ec);
|
| /third_party/skia/third_party/externals/microhttpd/src/platform/ |
| D | w32functions.c | 686 } thread_info; in W32_SetThreadName() local
692 thread_info.type = 0x1000; in W32_SetThreadName()
693 thread_info.name = thread_name; in W32_SetThreadName()
694 thread_info.ID = thread_id; in W32_SetThreadName()
695 thread_info.flags = 0; in W32_SetThreadName()
699 …RaiseException(VC_SETNAME_EXC, 0, sizeof(thread_info) / sizeof(ULONG_PTR), (ULONG_PTR*)&thread_inf… in W32_SetThreadName()
|
| /third_party/ltp/testcases/kernel/io/ltp-aiodio/ |
| D | aio-stress.c | 116 struct thread_info;
124 struct thread_info *global_thread_info;
216 struct thread_info { struct
448 static void print_latency(struct thread_info *t) in print_latency()
454 static void print_completion_latency(struct thread_info *t) in print_completion_latency()
464 void finish_io(struct thread_info *t, struct io_unit *io, long result, in finish_io()
483 int read_some_events(struct thread_info *t) in read_some_events()
517 static struct io_unit *find_iou(struct thread_info *t, struct io_oper *oper) in find_iou()
543 static int io_oper_wait(struct thread_info *t, struct io_oper *oper)
620 static struct io_unit *build_iocb(struct thread_info *t, struct io_oper *oper)
[all …]
|
| /third_party/python/Lib/test/ |
| D | test_threadsignals.py | 17 USING_PTHREAD_COND = (sys.thread_info.name == 'pthread'
18 and sys.thread_info.lock == 'mutex+cond')
82 not sys.thread_info.version,
113 not sys.thread_info.version,
|