| /third_party/pulseaudio/src/pulsecore/ |
| D | sink-input.c | 65 if (!(r = i->thread_info.resampler)) in calculate_resampler_history_bytes()
614 i->thread_info.state = i->state; in pa_sink_input_new()
615 i->thread_info.attached = false; in pa_sink_input_new()
616 i->thread_info.sample_spec = i->sample_spec; in pa_sink_input_new()
617 i->thread_info.resampler = resampler; in pa_sink_input_new()
618 i->thread_info.soft_volume = i->soft_volume; in pa_sink_input_new()
619 i->thread_info.muted = i->muted; in pa_sink_input_new()
620 i->thread_info.requested_sink_latency = (pa_usec_t) -1; in pa_sink_input_new()
621 i->thread_info.rewrite_nbytes = 0; in pa_sink_input_new()
622 i->thread_info.rewrite_flush = false; in pa_sink_input_new()
[all …]
|
| D | sink.c | 335 s->thread_info.rtpoll = NULL; in pa_sink_new()
336 …s->thread_info.inputs = pa_hashmap_new_full(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare… in pa_sink_new()
338 s->thread_info.soft_volume = s->soft_volume; in pa_sink_new()
339 s->thread_info.soft_muted = s->muted; in pa_sink_new()
340 s->thread_info.state = s->state; in pa_sink_new()
341 s->thread_info.rewind_nbytes = 0; in pa_sink_new()
342 s->thread_info.last_rewind_nbytes = 0; in pa_sink_new()
343 s->thread_info.rewind_requested = false; in pa_sink_new()
344 s->thread_info.max_rewind = 0; in pa_sink_new()
345 s->thread_info.max_request = 0; 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 | 484 o->thread_info.state = o->state; in pa_source_output_new()
485 o->thread_info.attached = false; in pa_source_output_new()
486 o->thread_info.sample_spec = o->sample_spec; in pa_source_output_new()
487 o->thread_info.resampler = resampler; in pa_source_output_new()
488 o->thread_info.soft_volume = o->soft_volume; in pa_source_output_new()
489 o->thread_info.muted = o->muted; in pa_source_output_new()
490 o->thread_info.requested_source_latency = (pa_usec_t) -1; in pa_source_output_new()
491 o->thread_info.direct_on_input = o->direct_on_input; in pa_source_output_new()
493 o->thread_info.delay_memblockq = pa_memblockq_new( in pa_source_output_new()
507 …pa_memblockq_set_maxrewind(o->thread_info.delay_memblockq, resampler_history + pa_source_get_max_r… in pa_source_output_new()
[all …]
|
| /third_party/pulseaudio/src/modules/ |
| D | module-combine-sink.c | 189 } thread_info; member
393 pa_assert(u->sink->thread_info.state == PA_SINK_RUNNING); in process_render_null()
395 if (u->thread_info.in_null_mode) in process_render_null()
396 u->thread_info.timestamp = now; in process_render_null()
398 while (u->thread_info.timestamp < now + u->block_usec) { in process_render_null()
401 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in process_render_null()
404 u->thread_info.counter += chunk.length; in process_render_null()
407 u->thread_info.timestamp += pa_bytes_to_usec(chunk.length, &u->sink->sample_spec); in process_render_null()
411 if (ate >= u->sink->thread_info.max_request) in process_render_null()
418 pa_smoother_2_put(u->thread_info.smoother, now, in process_render_null()
[all …]
|
| 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()
97 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg()
129 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
144 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind()
145 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind()
148 pa_sink_input_request_rewind(u->sink_input, s->thread_info.rewind_nbytes, true, false, false); in sink_request_rewind()
158 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency()
159 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency()
[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()
109 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
141 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
156 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
157 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
162 s->thread_info.rewind_nbytes + in sink_request_rewind_cb()
173 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
174 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_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()
105 … *((int64_t*) data) += pa_resampler_get_delay_usec(u->source_output->thread_info.resampler); in source_process_msg_cb()
135 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_update_requested_latency_cb()
136 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) in source_update_requested_latency_cb()
155 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_push_cb()
158 if (!PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_output_push_cb()
175 if (PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_process_rewind_cb()
198 if (PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_detach_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()
181 … *((int64_t*) data) += pa_resampler_get_delay_usec(u->source_output->thread_info.resampler); in source_process_msg_cb()
211 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state) || in source_update_requested_latency_cb()
212 !PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) in source_update_requested_latency_cb()
257 if (!PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_push_cb()
260 if (!PA_SOURCE_OUTPUT_IS_LINKED(u->source_output->thread_info.state)) { in source_output_push_cb()
269 if (u->sink && (u->sink->thread_info.state == PA_SINK_RUNNING)) { in source_output_push_cb()
354 if (PA_SOURCE_IS_LINKED(u->source->thread_info.state)) in source_output_process_rewind_cb()
[all …]
|
| 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()
240 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in process_render_use_timing()
265 if (consumed >= u->sink->thread_info.max_request) in process_render_use_timing()
327 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) in thread_func_use_timing()
330 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func_use_timing()
334 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func_use_timing()
375 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
379 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
[all …]
|
| D | module-null-sink.c | 141 if (s->thread_info.state == PA_SINK_SUSPENDED || s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
166 u->block_usec = s->thread_info.max_latency; in sink_update_requested_latency_cb()
201 rewind_nbytes = u->sink->thread_info.rewind_nbytes; in process_rewind()
203 if (!PA_SINK_IS_OPENED(u->sink->thread_info.state) || rewind_nbytes <= 0) in process_rewind()
247 request_size = PA_MIN(request_size, u->sink->thread_info.max_request); in process_render()
257 if (ate >= u->sink->thread_info.max_request) in process_render()
282 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) in thread_func()
285 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
289 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
|
| D | module-virtual-surround-sink.c | 269 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
270 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
281 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
284 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
316 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
332 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
333 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
336 nbytes_sink = s->thread_info.rewind_nbytes + pa_memblockq_get_length(u->memblockq_sink); in sink_request_rewind_cb()
350 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
351 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_cb()
[all …]
|
| 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()
365 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
409 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
424 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
425 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
430 s->thread_info.rewind_nbytes + in sink_request_rewind_cb()
441 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
442 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_cb()
[all …]
|
| D | module-null-source.c | 112 if (s->thread_info.state == PA_SOURCE_SUSPENDED || s->thread_info.state == PA_SOURCE_INIT) { in source_set_state_in_io_thread_cb()
130 u->block_usec = u->source->thread_info.max_latency; in source_update_requested_latency_cb()
156 if (PA_SOURCE_IS_OPENED(u->source->thread_info.state)) { in thread_func()
264 u->block_usec = u->source->thread_info.max_latency; in pa__init()
266 u->source->thread_info.max_rewind = in pa__init()
|
| D | module-solaris.c | 420 if (new_state == s->thread_info.state) in sink_set_state_in_io_thread_cb()
427 pa_assert(PA_SINK_IS_OPENED(s->thread_info.state)); in sink_set_state_in_io_thread_cb()
444 if (s->thread_info.state == PA_SINK_SUSPENDED) { in sink_set_state_in_io_thread_cb()
494 if (new_state == s->thread_info.state) in source_set_state_in_io_thread_cb()
501 pa_assert(PA_SOURCE_IS_OPENED(s->thread_info.state)); in source_set_state_in_io_thread_cb()
512 if (s->thread_info.state == PA_SOURCE_SUSPENDED) { in source_set_state_in_io_thread_cb()
642 if (!PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in process_rewind()
647 rewind_nbytes = u->sink->thread_info.rewind_nbytes; in process_rewind()
687 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
690 if (u->sink && PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
[all …]
|
| D | module-equalizer-sink.c | 252 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
253 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
265 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
270 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
302 if (PA_SINK_IS_OPENED(new_state) && s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
317 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_request_rewind_cb()
318 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
322 …pa_sink_input_request_rewind(u->sink_input, s->thread_info.rewind_nbytes+pa_memblockq_get_length(u… in sink_request_rewind_cb()
332 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_update_requested_latency_cb()
333 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_update_requested_latency_cb()
[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()
426 … *((int64_t*) data) += pa_resampler_get_delay_usec(u->source_output->thread_info.resampler); in source_process_msg_cb()
431 u->thread_info.current_volume = u->source->reference_volume; in source_process_msg_cb()
449 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in sink_process_msg_cb()
450 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
461 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
464 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
[all …]
|
| /third_party/mesa3d/src/amd/vulkan/ |
| D | radv_llvm_helper.cpp | 80 radv_llvm_per_thread_info *thread_info = nullptr; in radv_compile_to_elf() local
84 thread_info = &I; in radv_compile_to_elf()
89 if (!thread_info) { in radv_compile_to_elf()
96 return thread_info->compile_to_memory_buffer(module, pelf_buffer, pelf_size); in radv_compile_to_elf()
|
| /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/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/pulseaudio/src/modules/oss/ |
| D | module-oss.c | 681 if (new_state == s->thread_info.state) in sink_set_state_in_io_thread_cb()
687 pa_assert(PA_SINK_IS_OPENED(s->thread_info.state)); in sink_set_state_in_io_thread_cb()
700 if (s->thread_info.state == PA_SINK_INIT) { in sink_set_state_in_io_thread_cb()
702 quick = u->source && PA_SOURCE_IS_OPENED(u->source->thread_info.state); in sink_set_state_in_io_thread_cb()
705 if (s->thread_info.state == PA_SINK_SUSPENDED) { in sink_set_state_in_io_thread_cb()
730 … trigger(u, new_state, u->source ? u->source->thread_info.state : PA_SOURCE_INVALID_STATE, quick); in sink_set_state_in_io_thread_cb()
769 if (new_state == s->thread_info.state) in source_set_state_in_io_thread_cb()
775 pa_assert(PA_SOURCE_IS_OPENED(s->thread_info.state)); in source_set_state_in_io_thread_cb()
788 if (s->thread_info.state == PA_SOURCE_INIT) { in source_set_state_in_io_thread_cb()
790 quick = u->sink && PA_SINK_IS_OPENED(u->sink->thread_info.state); in source_set_state_in_io_thread_cb()
[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,
|
| /third_party/pulseaudio/src/modules/raop/ |
| D | raop-sink.c | 232 if (u->sink->thread_info.state == PA_SINK_SUSPENDED) { in sink_process_msg()
264 if (u->sink->thread_info.state == PA_SINK_SUSPENDED) { in sink_process_msg()
271 if (u->sink->thread_info.state != PA_SINK_IDLE) { in sink_process_msg()
277 if (u->sink->thread_info.state != PA_SINK_IDLE) in sink_process_msg()
301 if (new_state == s->thread_info.state) in sink_set_state_in_io_thread_cb()
308 pa_assert(PA_SINK_IS_OPENED(s->thread_info.state)); in sink_set_state_in_io_thread_cb()
321 if (s->thread_info.state == PA_SINK_RUNNING) { in sink_set_state_in_io_thread_cb()
459 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { in thread_func()
460 if (u->sink->thread_info.rewind_requested) in thread_func()
513 if (u->sink->thread_info.state != PA_SINK_RUNNING) { in thread_func()
|
| /third_party/mbedtls/programs/ssl/ |
| D | ssl_pthread_server.c | 112 thread_info_t *thread_info = (thread_info_t *) data; in handle_ssl_connection() local
113 mbedtls_net_context *client_fd = &thread_info->client_fd; in handle_ssl_connection()
126 if ((ret = mbedtls_ssl_setup(&ssl, thread_info->config)) != 0) { in handle_ssl_connection()
246 thread_info->thread_complete = 1; in handle_ssl_connection()
|
| /third_party/pulseaudio/src/modules/rtp/ |
| D | module-rtp-recv.c | 230 if (!PA_SINK_IS_OPENED(s->sink_input->sink->thread_info.state)) { in rtpoll_work_cb()
288 sink_delay += pa_resampler_get_delay_usec(s->sink_input->thread_info.resampler); in rtpoll_work_cb()
289 …render_delay = pa_bytes_to_usec(pa_memblockq_get_length(s->sink_input->thread_info.render_memblock… in rtpoll_work_cb()
359 …pa_resampler_set_input_rate(s->sink_input->thread_info.resampler, s->sink_input->sample_spec.rate); in rtpoll_work_cb()
367 s->sink_input->thread_info.underrun_for > 0) { in rtpoll_work_cb()
370 …(size_t) (s->sink_input->thread_info.underrun_for == (uint64_t) -1 ? 0 : s->sink_input->thread_inf… in rtpoll_work_cb()
385 s->rtpoll_item = pa_rtp_context_get_rtpoll_item(s->rtp_context, i->sink->thread_info.rtpoll); in sink_input_attach()
|