]> code.delx.au - pulseaudio/blob - src/pulsecore/sink-input.c
delx.au / code / pulseaudio / blob


71642bbfea264d7deee57a235f542fd3a66de917
[pulseaudio] / src / pulsecore / sink-input.c
1 /***
2 This file is part of PulseAudio.
3
4 Copyright 2004-2006 Lennart Poettering
5 Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
6
7 PulseAudio is free software; you can redistribute it and/or modify
8 it under the terms of the GNU Lesser General Public License as published
9 by the Free Software Foundation; either version 2 of the License,
10 or (at your option) any later version.
11
12 PulseAudio is distributed in the hope that it will be useful, but
13 WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 General Public License for more details.
16
17 You should have received a copy of the GNU Lesser General Public License
18 along with PulseAudio; if not, write to the Free Software
19 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
20 USA.
21 ***/
22
23 #ifdef HAVE_CONFIG_H
24 #include <config.h>
25 #endif
26
27 #include <stdio.h>
28 #include <stdlib.h>
29 #include <string.h>
30
31 #include <pulse/utf8.h>
32 #include <pulse/xmalloc.h>
33 #include <pulse/util.h>
34
35 #include <pulsecore/sample-util.h>
36 #include <pulsecore/core-subscribe.h>
37 #include <pulsecore/log.h>
38 #include <pulsecore/play-memblockq.h>
39 #include <pulsecore/namereg.h>
40 #include <pulsecore/core-util.h>
41
42 #include "sink-input.h"
43
44 #define MEMBLOCKQ_MAXLENGTH (32*1024*1024)
45 #define CONVERT_BUFFER_LENGTH (PA_PAGE_SIZE)
46
47 static PA_DEFINE_CHECK_TYPE(pa_sink_input, pa_msgobject);
48
49 static void sink_input_free(pa_object *o);
50
51 pa_sink_input_new_data* pa_sink_input_new_data_init(pa_sink_input_new_data *data) {
52 pa_assert(data);
53
54 memset(data, 0, sizeof(*data));
55 data->resample_method = PA_RESAMPLER_INVALID;
56 data->proplist = pa_proplist_new();
57
58 return data;
59 }
60
61 void pa_sink_input_new_data_set_sample_spec(pa_sink_input_new_data *data, const pa_sample_spec *spec) {
62 pa_assert(data);
63
64 if ((data->sample_spec_is_set = !!spec))
65 data->sample_spec = *spec;
66 }
67
68 void pa_sink_input_new_data_set_channel_map(pa_sink_input_new_data *data, const pa_channel_map *map) {
69 pa_assert(data);
70
71 if ((data->channel_map_is_set = !!map))
72 data->channel_map = *map;
73 }
74
75 void pa_sink_input_new_data_set_soft_volume(pa_sink_input_new_data *data, const pa_cvolume *volume) {
76 pa_assert(data);
77
78 if ((data->soft_volume_is_set = !!volume))
79 data->soft_volume = *volume;
80 }
81
82 void pa_sink_input_new_data_set_virtual_volume(pa_sink_input_new_data *data, const pa_cvolume *volume) {
83 pa_assert(data);
84
85 if ((data->virtual_volume_is_set = !!volume))
86 data->virtual_volume = *volume;
87 }
88
89 void pa_sink_input_new_data_set_muted(pa_sink_input_new_data *data, pa_bool_t mute) {
90 pa_assert(data);
91
92 data->muted_is_set = TRUE;
93 data->muted = !!mute;
94 }
95
96 void pa_sink_input_new_data_done(pa_sink_input_new_data *data) {
97 pa_assert(data);
98
99 pa_proplist_free(data->proplist);
100 }
101
102 /* Called from main context */
103 static void reset_callbacks(pa_sink_input *i) {
104 pa_assert(i);
105
106 i->pop = NULL;
107 i->process_rewind = NULL;
108 i->update_max_rewind = NULL;
109 i->update_max_request = NULL;
110 i->update_sink_requested_latency = NULL;
111 i->update_sink_latency_range = NULL;
112 i->attach = NULL;
113 i->detach = NULL;
114 i->suspend = NULL;
115 i->moved = NULL;
116 i->kill = NULL;
117 i->get_latency = NULL;
118 i->state_change = NULL;
119 i->may_move_to = NULL;
120 }
121
122 /* Called from main context */
123 int pa_sink_input_new(
124 pa_sink_input **_i,
125 pa_core *core,
126 pa_sink_input_new_data *data,
127 pa_sink_input_flags_t flags) {
128
129 pa_sink_input *i;
130 pa_resampler *resampler = NULL;
131 char st[PA_SAMPLE_SPEC_SNPRINT_MAX], cm[PA_CHANNEL_MAP_SNPRINT_MAX];
132 pa_channel_map original_cm;
133 int r;
134
135 pa_assert(_i);
136 pa_assert(core);
137 pa_assert(data);
138
139 if (data->client)
140 pa_proplist_update(data->proplist, PA_UPDATE_MERGE, data->client->proplist);
141
142 if ((r = pa_hook_fire(&core->hooks[PA_CORE_HOOK_SINK_INPUT_NEW], data)) < 0)
143 return r;
144
145 pa_return_val_if_fail(!data->driver || pa_utf8_valid(data->driver), -PA_ERR_INVALID);
146
147 if (!data->sink) {
148 data->sink = pa_namereg_get(core, NULL, PA_NAMEREG_SINK);
149 data->save_sink = FALSE;
150 }
151
152 pa_return_val_if_fail(data->sink, -PA_ERR_NOENTITY);
153 pa_return_val_if_fail(PA_SINK_IS_LINKED(pa_sink_get_state(data->sink)), -PA_ERR_BADSTATE);
154 pa_return_val_if_fail(!data->sync_base || (data->sync_base->sink == data->sink && pa_sink_input_get_state(data->sync_base) == PA_SINK_INPUT_CORKED), -PA_ERR_INVALID);
155 pa_return_val_if_fail(!(flags & PA_SINK_INPUT_FAIL_ON_SUSPEND) || pa_sink_get_state(data->sink) != PA_SINK_SUSPENDED, -PA_ERR_BADSTATE);
156
157 if (!data->sample_spec_is_set)
158 data->sample_spec = data->sink->sample_spec;
159
160 pa_return_val_if_fail(pa_sample_spec_valid(&data->sample_spec), -PA_ERR_INVALID);
161
162 if (!data->channel_map_is_set) {
163 if (pa_channel_map_compatible(&data->sink->channel_map, &data->sample_spec))
164 data->channel_map = data->sink->channel_map;
165 else
166 pa_channel_map_init_extend(&data->channel_map, data->sample_spec.channels, PA_CHANNEL_MAP_DEFAULT);
167 }
168
169 pa_return_val_if_fail(pa_channel_map_valid(&data->channel_map), -PA_ERR_INVALID);
170 pa_return_val_if_fail(pa_channel_map_compatible(&data->channel_map, &data->sample_spec), -PA_ERR_INVALID);
171
172 if (!data->virtual_volume_is_set) {
173
174 if (data->sink->flags & PA_SINK_FLAT_VOLUME) {
175 data->virtual_volume = data->sink->virtual_volume;
176 pa_cvolume_remap(&data->virtual_volume, &data->sink->channel_map, &data->channel_map);
177 } else
178 pa_cvolume_reset(&data->virtual_volume, data->sample_spec.channels);
179
180 data->save_volume = FALSE;
181
182 } else if (!data->virtual_volume_is_absolute) {
183
184 /* When the 'absolute' bool is set then we'll treat the volume
185 * as relative to the sink volume even in flat volume mode */
186 if (data->sink->flags & PA_SINK_FLAT_VOLUME) {
187 pa_cvolume t = data->sink->virtual_volume;
188 pa_cvolume_remap(&t, &data->sink->channel_map, &data->channel_map);
189 pa_sw_cvolume_multiply(&data->virtual_volume, &data->virtual_volume, &t);
190 }
191 }
192
193 pa_return_val_if_fail(pa_cvolume_valid(&data->virtual_volume), -PA_ERR_INVALID);
194 pa_return_val_if_fail(pa_cvolume_compatible(&data->virtual_volume, &data->sample_spec), -PA_ERR_INVALID);
195
196 if (!data->soft_volume_is_set)
197 data->soft_volume = data->virtual_volume;
198
199 pa_return_val_if_fail(pa_cvolume_valid(&data->soft_volume), -PA_ERR_INVALID);
200 pa_return_val_if_fail(pa_cvolume_compatible(&data->soft_volume, &data->sample_spec), -PA_ERR_INVALID);
201
202 if (!data->muted_is_set)
203 data->muted = FALSE;
204
205 if (flags & PA_SINK_INPUT_FIX_FORMAT)
206 data->sample_spec.format = data->sink->sample_spec.format;
207
208 if (flags & PA_SINK_INPUT_FIX_RATE)
209 data->sample_spec.rate = data->sink->sample_spec.rate;
210
211 original_cm = data->channel_map;
212
213 if (flags & PA_SINK_INPUT_FIX_CHANNELS) {
214 data->sample_spec.channels = data->sink->sample_spec.channels;
215 data->channel_map = data->sink->channel_map;
216 }
217
218 pa_assert(pa_sample_spec_valid(&data->sample_spec));
219 pa_assert(pa_channel_map_valid(&data->channel_map));
220
221 /* Due to the fixing of the sample spec the volume might not match anymore */
222 pa_cvolume_remap(&data->soft_volume, &original_cm, &data->channel_map);
223 pa_cvolume_remap(&data->virtual_volume, &original_cm, &data->channel_map);
224
225 if (data->resample_method == PA_RESAMPLER_INVALID)
226 data->resample_method = core->resample_method;
227
228 pa_return_val_if_fail(data->resample_method < PA_RESAMPLER_MAX, -PA_ERR_INVALID);
229
230 if ((r = pa_hook_fire(&core->hooks[PA_CORE_HOOK_SINK_INPUT_FIXATE], data)) < 0)
231 return r;
232
233 if (pa_idxset_size(data->sink->inputs) >= PA_MAX_INPUTS_PER_SINK) {
234 pa_log_warn("Failed to create sink input: too many inputs per sink.");
235 return -PA_ERR_TOOLARGE;
236 }
237
238 if ((flags & PA_SINK_INPUT_VARIABLE_RATE) ||
239 !pa_sample_spec_equal(&data->sample_spec, &data->sink->sample_spec) ||
240 !pa_channel_map_equal(&data->channel_map, &data->sink->channel_map)) {
241
242 if (!(resampler = pa_resampler_new(
243 core->mempool,
244 &data->sample_spec, &data->channel_map,
245 &data->sink->sample_spec, &data->sink->channel_map,
246 data->resample_method,
247 ((flags & PA_SINK_INPUT_VARIABLE_RATE) ? PA_RESAMPLER_VARIABLE_RATE : 0) |
248 ((flags & PA_SINK_INPUT_NO_REMAP) ? PA_RESAMPLER_NO_REMAP : 0) |
249 (core->disable_remixing || (flags & PA_SINK_INPUT_NO_REMIX) ? PA_RESAMPLER_NO_REMIX : 0) |
250 (core->disable_lfe_remixing ? PA_RESAMPLER_NO_LFE : 0)))) {
251 pa_log_warn("Unsupported resampling operation.");
252 return -PA_ERR_NOTSUPPORTED;
253 }
254 }
255
256 i = pa_msgobject_new(pa_sink_input);
257 i->parent.parent.free = sink_input_free;
258 i->parent.process_msg = pa_sink_input_process_msg;
259
260 i->core = core;
261 i->state = PA_SINK_INPUT_INIT;
262 i->flags = flags;
263 i->proplist = pa_proplist_copy(data->proplist);
264 i->driver = pa_xstrdup(pa_path_get_filename(data->driver));
265 i->module = data->module;
266 i->sink = data->sink;
267 i->client = data->client;
268
269 i->requested_resample_method = data->resample_method;
270 i->actual_resample_method = resampler ? pa_resampler_get_method(resampler) : PA_RESAMPLER_INVALID;
271 i->sample_spec = data->sample_spec;
272 i->channel_map = data->channel_map;
273
274 i->virtual_volume = data->virtual_volume;
275 i->soft_volume = data->soft_volume;
276 i->save_volume = data->save_volume;
277 i->save_sink = data->save_sink;
278 i->save_muted = data->save_muted;
279
280 i->muted = data->muted;
281
282 if (data->sync_base) {
283 i->sync_next = data->sync_base->sync_next;
284 i->sync_prev = data->sync_base;
285
286 if (data->sync_base->sync_next)
287 data->sync_base->sync_next->sync_prev = i;
288 data->sync_base->sync_next = i;
289 } else
290 i->sync_next = i->sync_prev = NULL;
291
292 i->direct_outputs = pa_idxset_new(NULL, NULL);
293
294 reset_callbacks(i);
295 i->userdata = NULL;
296
297 i->thread_info.state = i->state;
298 i->thread_info.attached = FALSE;
299 pa_atomic_store(&i->thread_info.drained, 1);
300 i->thread_info.sample_spec = i->sample_spec;
301 i->thread_info.resampler = resampler;
302 i->thread_info.soft_volume = i->soft_volume;
303 i->thread_info.muted = i->muted;
304 i->thread_info.requested_sink_latency = (pa_usec_t) -1;
305 i->thread_info.rewrite_nbytes = 0;
306 i->thread_info.rewrite_flush = FALSE;
307 i->thread_info.dont_rewind_render = FALSE;
308 i->thread_info.underrun_for = (uint64_t) -1;
309 i->thread_info.playing_for = 0;
310 i->thread_info.direct_outputs = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func);
311
312 i->thread_info.render_memblockq = pa_memblockq_new(
313 0,
314 MEMBLOCKQ_MAXLENGTH,
315 0,
316 pa_frame_size(&i->sink->sample_spec),
317 0,
318 1,
319 0,
320 &i->sink->silence);
321
322 pa_assert_se(pa_idxset_put(core->sink_inputs, pa_sink_input_ref(i), &i->index) == 0);
323 pa_assert_se(pa_idxset_put(i->sink->inputs, i, NULL) == 0);
324
325 if (i->client)
326 pa_assert_se(pa_idxset_put(i->client->sink_inputs, i, NULL) >= 0);
327
328 pa_log_info("Created input %u \"%s\" on %s with sample spec %s and channel map %s",
329 i->index,
330 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME)),
331 i->sink->name,
332 pa_sample_spec_snprint(st, sizeof(st), &i->sample_spec),
333 pa_channel_map_snprint(cm, sizeof(cm), &i->channel_map));
334
335 /* Don't forget to call pa_sink_input_put! */
336
337 *_i = i;
338 return 0;
339 }
340
341 /* Called from main context */
342 static void update_n_corked(pa_sink_input *i, pa_sink_input_state_t state) {
343 pa_assert(i);
344
345 if (!i->sink)
346 return;
347
348 if (i->state == PA_SINK_INPUT_CORKED && state != PA_SINK_INPUT_CORKED)
349 pa_assert_se(i->sink->n_corked -- >= 1);
350 else if (i->state != PA_SINK_INPUT_CORKED && state == PA_SINK_INPUT_CORKED)
351 i->sink->n_corked++;
352 }
353
354 /* Called from main context */
355 static void sink_input_set_state(pa_sink_input *i, pa_sink_input_state_t state) {
356 pa_sink_input *ssync;
357 pa_assert(i);
358
359 if (state == PA_SINK_INPUT_DRAINED)
360 state = PA_SINK_INPUT_RUNNING;
361
362 if (i->state == state)
363 return;
364
365 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_STATE, PA_UINT_TO_PTR(state), 0, NULL) == 0);
366
367 update_n_corked(i, state);
368 i->state = state;
369
370 for (ssync = i->sync_prev; ssync; ssync = ssync->sync_prev) {
371 update_n_corked(ssync, state);
372 ssync->state = state;
373 }
374 for (ssync = i->sync_next; ssync; ssync = ssync->sync_next) {
375 update_n_corked(ssync, state);
376 ssync->state = state;
377 }
378
379 if (state != PA_SINK_INPUT_UNLINKED) {
380 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_STATE_CHANGED], i);
381
382 for (ssync = i->sync_prev; ssync; ssync = ssync->sync_prev)
383 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_STATE_CHANGED], ssync);
384
385 for (ssync = i->sync_next; ssync; ssync = ssync->sync_next)
386 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_STATE_CHANGED], ssync);
387 }
388
389 pa_sink_update_status(i->sink);
390 }
391
392 /* Called from main context */
393 void pa_sink_input_unlink(pa_sink_input *i) {
394 pa_bool_t linked;
395 pa_source_output *o, *p = NULL;
396 pa_assert(i);
397
398 /* See pa_sink_unlink() for a couple of comments how this function
399 * works */
400
401 pa_sink_input_ref(i);
402
403 linked = PA_SINK_INPUT_IS_LINKED(i->state);
404
405 if (linked)
406 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_UNLINK], i);
407
408 if (i->sync_prev)
409 i->sync_prev->sync_next = i->sync_next;
410 if (i->sync_next)
411 i->sync_next->sync_prev = i->sync_prev;
412
413 i->sync_prev = i->sync_next = NULL;
414
415 pa_idxset_remove_by_data(i->core->sink_inputs, i, NULL);
416
417 if (i->sink)
418 if (pa_idxset_remove_by_data(i->sink->inputs, i, NULL))
419 pa_sink_input_unref(i);
420
421 if (i->client)
422 pa_idxset_remove_by_data(i->client->sink_inputs, i, NULL);
423
424 while ((o = pa_idxset_first(i->direct_outputs, NULL))) {
425 pa_assert(o != p);
426 pa_source_output_kill(o);
427 p = o;
428 }
429
430 update_n_corked(i, PA_SINK_INPUT_UNLINKED);
431 i->state = PA_SINK_INPUT_UNLINKED;
432
433 if (linked && i->sink) {
434 /* We might need to update the sink's volume if we are in flat volume mode. */
435 if (i->sink->flags & PA_SINK_FLAT_VOLUME) {
436 pa_cvolume new_volume;
437 pa_sink_update_flat_volume(i->sink, &new_volume);
438 pa_sink_set_volume(i->sink, &new_volume, FALSE, FALSE);
439 }
440
441 if (i->sink->asyncmsgq)
442 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_REMOVE_INPUT, i, 0, NULL) == 0);
443 }
444
445 reset_callbacks(i);
446
447 if (linked) {
448 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_REMOVE, i->index);
449 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_UNLINK_POST], i);
450 }
451
452 if (i->sink) {
453 pa_sink_update_status(i->sink);
454 i->sink = NULL;
455 }
456
457 pa_sink_input_unref(i);
458 }
459
460 /* Called from main context */
461 static void sink_input_free(pa_object *o) {
462 pa_sink_input* i = PA_SINK_INPUT(o);
463
464 pa_assert(i);
465 pa_assert(pa_sink_input_refcnt(i) == 0);
466
467 if (PA_SINK_INPUT_IS_LINKED(i->state))
468 pa_sink_input_unlink(i);
469
470 pa_log_info("Freeing input %u \"%s\"", i->index, pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME)));
471
472 pa_assert(!i->thread_info.attached);
473
474 if (i->thread_info.render_memblockq)
475 pa_memblockq_free(i->thread_info.render_memblockq);
476
477 if (i->thread_info.resampler)
478 pa_resampler_free(i->thread_info.resampler);
479
480 if (i->proplist)
481 pa_proplist_free(i->proplist);
482
483 if (i->direct_outputs)
484 pa_idxset_free(i->direct_outputs, NULL, NULL);
485
486 if (i->thread_info.direct_outputs)
487 pa_hashmap_free(i->thread_info.direct_outputs, NULL, NULL);
488
489 pa_xfree(i->driver);
490 pa_xfree(i);
491 }
492
493 /* Called from main context */
494 void pa_sink_input_put(pa_sink_input *i) {
495 pa_sink_input_state_t state;
496 pa_sink_input_assert_ref(i);
497
498 pa_assert(i->state == PA_SINK_INPUT_INIT);
499
500 /* The following fields must be initialized properly */
501 pa_assert(i->pop);
502 pa_assert(i->process_rewind);
503 pa_assert(i->kill);
504
505 i->thread_info.soft_volume = i->soft_volume;
506 i->thread_info.muted = i->muted;
507
508 state = i->flags & PA_SINK_INPUT_START_CORKED ? PA_SINK_INPUT_CORKED : PA_SINK_INPUT_RUNNING;
509
510 update_n_corked(i, state);
511 i->state = state;
512
513 /* We might need to update the sink's volume if we are in flat volume mode. */
514 if (i->sink->flags & PA_SINK_FLAT_VOLUME) {
515 pa_cvolume new_volume;
516 pa_sink_update_flat_volume(i->sink, &new_volume);
517 pa_sink_set_volume(i->sink, &new_volume, FALSE, FALSE);
518 }
519
520 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_ADD_INPUT, i, 0, NULL) == 0);
521
522 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_NEW, i->index);
523 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_PUT], i);
524
525 pa_sink_update_status(i->sink);
526 }
527
528 /* Called from main context */
529 void pa_sink_input_kill(pa_sink_input*i) {
530 pa_sink_input_assert_ref(i);
531 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
532
533 i->kill(i);
534 }
535
536 /* Called from main context */
537 pa_usec_t pa_sink_input_get_latency(pa_sink_input *i, pa_usec_t *sink_latency) {
538 pa_usec_t r[2] = { 0, 0 };
539
540 pa_sink_input_assert_ref(i);
541 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
542
543 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_GET_LATENCY, r, 0, NULL) == 0);
544
545 if (i->get_latency)
546 r[0] += i->get_latency(i);
547
548 if (sink_latency)
549 *sink_latency = r[1];
550
551 return r[0];
552 }
553
554 /* Called from thread context */
555 void pa_sink_input_peek(pa_sink_input *i, size_t slength /* in sink frames */, pa_memchunk *chunk, pa_cvolume *volume) {
556 pa_bool_t do_volume_adj_here;
557 pa_bool_t volume_is_norm;
558 size_t block_size_max_sink, block_size_max_sink_input;
559 size_t ilength;
560
561 pa_sink_input_assert_ref(i);
562 pa_assert(PA_SINK_INPUT_IS_LINKED(i->thread_info.state));
563 pa_assert(pa_frame_aligned(slength, &i->sink->sample_spec));
564 pa_assert(chunk);
565 pa_assert(volume);
566
567 /* pa_log_debug("peek"); */
568
569 pa_assert(i->thread_info.state == PA_SINK_INPUT_RUNNING ||
570 i->thread_info.state == PA_SINK_INPUT_CORKED ||
571 i->thread_info.state == PA_SINK_INPUT_DRAINED);
572
573 block_size_max_sink_input = i->thread_info.resampler ?
574 pa_resampler_max_block_size(i->thread_info.resampler) :
575 pa_frame_align(pa_mempool_block_size_max(i->core->mempool), &i->sample_spec);
576
577 block_size_max_sink = pa_frame_align(pa_mempool_block_size_max(i->core->mempool), &i->sink->sample_spec);
578
579 /* Default buffer size */
580 if (slength <= 0)
581 slength = pa_frame_align(CONVERT_BUFFER_LENGTH, &i->sink->sample_spec);
582
583 if (slength > block_size_max_sink)
584 slength = block_size_max_sink;
585
586 if (i->thread_info.resampler) {
587 ilength = pa_resampler_request(i->thread_info.resampler, slength);
588
589 if (ilength <= 0)
590 ilength = pa_frame_align(CONVERT_BUFFER_LENGTH, &i->sample_spec);
591 } else
592 ilength = slength;
593
594 if (ilength > block_size_max_sink_input)
595 ilength = block_size_max_sink_input;
596
597 /* If the channel maps of the sink and this stream differ, we need
598 * to adjust the volume *before* we resample. Otherwise we can do
599 * it after and leave it for the sink code */
600
601 do_volume_adj_here = !pa_channel_map_equal(&i->channel_map, &i->sink->channel_map);
602 volume_is_norm = pa_cvolume_is_norm(&i->thread_info.soft_volume) && !i->thread_info.muted;
603
604 while (!pa_memblockq_is_readable(i->thread_info.render_memblockq)) {
605 pa_memchunk tchunk;
606
607 /* There's nothing in our render queue. We need to fill it up
608 * with data from the implementor. */
609
610 if (i->thread_info.state == PA_SINK_INPUT_CORKED ||
611 i->pop(i, ilength, &tchunk) < 0) {
612
613 /* OK, we're corked or the implementor didn't give us any
614 * data, so let's just hand out silence */
615 pa_atomic_store(&i->thread_info.drained, 1);
616
617 pa_memblockq_seek(i->thread_info.render_memblockq, (int64_t) slength, PA_SEEK_RELATIVE);
618 i->thread_info.playing_for = 0;
619 if (i->thread_info.underrun_for != (uint64_t) -1)
620 i->thread_info.underrun_for += ilength;
621 break;
622 }
623
624 pa_atomic_store(&i->thread_info.drained, 0);
625
626 pa_assert(tchunk.length > 0);
627 pa_assert(tchunk.memblock);
628
629 i->thread_info.underrun_for = 0;
630 i->thread_info.playing_for += tchunk.length;
631
632 while (tchunk.length > 0) {
633 pa_memchunk wchunk;
634
635 wchunk = tchunk;
636 pa_memblock_ref(wchunk.memblock);
637
638 if (wchunk.length > block_size_max_sink_input)
639 wchunk.length = block_size_max_sink_input;
640
641 /* It might be necessary to adjust the volume here */
642 if (do_volume_adj_here && !volume_is_norm) {
643 pa_memchunk_make_writable(&wchunk, 0);
644
645 if (i->thread_info.muted)
646 pa_silence_memchunk(&wchunk, &i->thread_info.sample_spec);
647 else
648 pa_volume_memchunk(&wchunk, &i->thread_info.sample_spec, &i->thread_info.soft_volume);
649 }
650
651 if (!i->thread_info.resampler)
652 pa_memblockq_push_align(i->thread_info.render_memblockq, &wchunk);
653 else {
654 pa_memchunk rchunk;
655 pa_resampler_run(i->thread_info.resampler, &wchunk, &rchunk);
656
657 /* pa_log_debug("pushing %lu", (unsigned long) rchunk.length); */
658
659 if (rchunk.memblock) {
660 pa_memblockq_push_align(i->thread_info.render_memblockq, &rchunk);
661 pa_memblock_unref(rchunk.memblock);
662 }
663 }
664
665 pa_memblock_unref(wchunk.memblock);
666
667 tchunk.index += wchunk.length;
668 tchunk.length -= wchunk.length;
669 }
670
671 pa_memblock_unref(tchunk.memblock);
672 }
673
674 pa_assert_se(pa_memblockq_peek(i->thread_info.render_memblockq, chunk) >= 0);
675
676 pa_assert(chunk->length > 0);
677 pa_assert(chunk->memblock);
678
679 /* pa_log_debug("peeking %lu", (unsigned long) chunk->length); */
680
681 if (chunk->length > block_size_max_sink)
682 chunk->length = block_size_max_sink;
683
684 /* Let's see if we had to apply the volume adjustment ourselves,
685 * or if this can be done by the sink for us */
686
687 if (do_volume_adj_here)
688 /* We had different channel maps, so we already did the adjustment */
689 pa_cvolume_reset(volume, i->sink->sample_spec.channels);
690 else if (i->thread_info.muted)
691 /* We've both the same channel map, so let's have the sink do the adjustment for us*/
692 pa_cvolume_mute(volume, i->sink->sample_spec.channels);
693 else
694 *volume = i->thread_info.soft_volume;
695 }
696
697 /* Called from thread context */
698 void pa_sink_input_drop(pa_sink_input *i, size_t nbytes /* in sink sample spec */) {
699 pa_sink_input_assert_ref(i);
700
701 pa_assert(PA_SINK_INPUT_IS_LINKED(i->thread_info.state));
702 pa_assert(pa_frame_aligned(nbytes, &i->sink->sample_spec));
703 pa_assert(nbytes > 0);
704
705 /* pa_log_debug("dropping %lu", (unsigned long) nbytes); */
706
707 pa_memblockq_drop(i->thread_info.render_memblockq, nbytes);
708 }
709
710 /* Called from thread context */
711 void pa_sink_input_process_rewind(pa_sink_input *i, size_t nbytes /* in sink sample spec */) {
712 size_t lbq;
713 pa_bool_t called = FALSE;
714 pa_sink_input_assert_ref(i);
715
716 pa_assert(PA_SINK_INPUT_IS_LINKED(i->thread_info.state));
717 pa_assert(pa_frame_aligned(nbytes, &i->sink->sample_spec));
718
719 /* pa_log_debug("rewind(%lu, %lu)", (unsigned long) nbytes, (unsigned long) i->thread_info.rewrite_nbytes); */
720
721 lbq = pa_memblockq_get_length(i->thread_info.render_memblockq);
722
723 if (nbytes > 0 && !i->thread_info.dont_rewind_render) {
724 pa_log_debug("Have to rewind %lu bytes on render memblockq.", (unsigned long) nbytes);
725 pa_memblockq_rewind(i->thread_info.render_memblockq, nbytes);
726 }
727
728 if (i->thread_info.rewrite_nbytes == (size_t) -1) {
729
730 /* We were asked to drop all buffered data, and rerequest new
731 * data from implementor the next time push() is called */
732
733 pa_memblockq_flush_write(i->thread_info.render_memblockq);
734
735 } else if (i->thread_info.rewrite_nbytes > 0) {
736 size_t max_rewrite, amount;
737
738 /* Calculate how much make sense to rewrite at most */
739 max_rewrite = nbytes + lbq;
740
741 /* Transform into local domain */
742 if (i->thread_info.resampler)
743 max_rewrite = pa_resampler_request(i->thread_info.resampler, max_rewrite);
744
745 /* Calculate how much of the rewinded data should actually be rewritten */
746 amount = PA_MIN(i->thread_info.rewrite_nbytes, max_rewrite);
747
748 if (amount > 0) {
749 pa_log_debug("Have to rewind %lu bytes on implementor.", (unsigned long) amount);
750
751 /* Tell the implementor */
752 if (i->process_rewind)
753 i->process_rewind(i, amount);
754 called = TRUE;
755
756 /* Convert back to to sink domain */
757 if (i->thread_info.resampler)
758 amount = pa_resampler_result(i->thread_info.resampler, amount);
759
760 if (amount > 0)
761 /* Ok, now update the write pointer */
762 pa_memblockq_seek(i->thread_info.render_memblockq, - ((int64_t) amount), PA_SEEK_RELATIVE);
763
764 if (i->thread_info.rewrite_flush)
765 pa_memblockq_silence(i->thread_info.render_memblockq);
766
767 /* And reset the resampler */
768 if (i->thread_info.resampler)
769 pa_resampler_reset(i->thread_info.resampler);
770 }
771 }
772
773 if (!called)
774 if (i->process_rewind)
775 i->process_rewind(i, 0);
776
777 i->thread_info.rewrite_nbytes = 0;
778 i->thread_info.rewrite_flush = FALSE;
779 i->thread_info.dont_rewind_render = FALSE;
780 }
781
782 /* Called from thread context */
783 void pa_sink_input_update_max_rewind(pa_sink_input *i, size_t nbytes /* in the sink's sample spec */) {
784 pa_sink_input_assert_ref(i);
785 pa_assert(PA_SINK_INPUT_IS_LINKED(i->thread_info.state));
786 pa_assert(pa_frame_aligned(nbytes, &i->sink->sample_spec));
787
788 pa_memblockq_set_maxrewind(i->thread_info.render_memblockq, nbytes);
789
790 if (i->update_max_rewind)
791 i->update_max_rewind(i, i->thread_info.resampler ? pa_resampler_request(i->thread_info.resampler, nbytes) : nbytes);
792 }
793
794 /* Called from thread context */
795 void pa_sink_input_update_max_request(pa_sink_input *i, size_t nbytes /* in the sink's sample spec */) {
796 pa_sink_input_assert_ref(i);
797 pa_assert(PA_SINK_INPUT_IS_LINKED(i->thread_info.state));
798 pa_assert(pa_frame_aligned(nbytes, &i->sink->sample_spec));
799
800 if (i->update_max_request)
801 i->update_max_request(i, i->thread_info.resampler ? pa_resampler_request(i->thread_info.resampler, nbytes) : nbytes);
802 }
803
804 /* Called from thread context */
805 static pa_usec_t fixup_latency(pa_sink *s, pa_usec_t usec) {
806 pa_sink_assert_ref(s);
807
808 if (usec == (pa_usec_t) -1)
809 return usec;
810
811 if (s->thread_info.max_latency > 0 && usec > s->thread_info.max_latency)
812 usec = s->thread_info.max_latency;
813
814 if (s->thread_info.min_latency > 0 && usec < s->thread_info.min_latency)
815 usec = s->thread_info.min_latency;
816
817 return usec;
818 }
819
820 /* Called from thread context */
821 pa_usec_t pa_sink_input_set_requested_latency_within_thread(pa_sink_input *i, pa_usec_t usec) {
822 pa_sink_input_assert_ref(i);
823
824 usec = fixup_latency(i->sink, usec);
825 i->thread_info.requested_sink_latency = usec;
826 pa_sink_invalidate_requested_latency(i->sink);
827
828 return usec;
829 }
830
831 /* Called from main context */
832 pa_usec_t pa_sink_input_set_requested_latency(pa_sink_input *i, pa_usec_t usec) {
833 pa_sink_input_assert_ref(i);
834
835 if (PA_SINK_INPUT_IS_LINKED(i->state))
836 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_REQUESTED_LATENCY, &usec, 0, NULL) == 0);
837 else
838 /* If this sink input is not realized yet, we have to touch
839 * the thread info data directly */
840
841 i->thread_info.requested_sink_latency = usec;
842
843 return usec;
844 }
845
846 /* Called from main context */
847 pa_usec_t pa_sink_input_get_requested_latency(pa_sink_input *i) {
848 pa_usec_t usec = 0;
849
850 pa_sink_input_assert_ref(i);
851
852 if (PA_SINK_INPUT_IS_LINKED(i->state))
853 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_GET_REQUESTED_LATENCY, &usec, 0, NULL) == 0);
854 else
855 /* If this sink input is not realized yet, we have to touch
856 * the thread info data directly */
857 usec = i->thread_info.requested_sink_latency;
858
859 return usec;
860 }
861
862 /* Called from main context */
863 void pa_sink_input_set_volume(pa_sink_input *i, const pa_cvolume *volume, pa_bool_t save) {
864 pa_sink_input_assert_ref(i);
865 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
866 pa_assert(volume);
867 pa_assert(pa_cvolume_valid(volume));
868 pa_assert(pa_cvolume_compatible(volume, &i->sample_spec));
869
870 if (pa_cvolume_equal(volume, &i->virtual_volume))
871 return;
872
873 i->virtual_volume = *volume;
874 i->save_volume = save;
875
876 if (i->sink->flags & PA_SINK_FLAT_VOLUME) {
877 pa_cvolume new_volume;
878
879 /* We are in flat volume mode, so let's update all sink input
880 * volumes and update the flat volume of the sink */
881
882 pa_sink_update_flat_volume(i->sink, &new_volume);
883 pa_sink_set_volume(i->sink, &new_volume, FALSE, TRUE);
884
885 } else {
886
887 /* OK, we are in normal volume mode. The volume only affects
888 * ourselves */
889
890 i->soft_volume = *volume;
891
892 /* Hooks have the ability to play games with i->soft_volume */
893 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_SET_VOLUME], i);
894
895 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_SOFT_VOLUME, NULL, 0, NULL) == 0);
896 }
897
898 /* The virtual volume changed, let's tell people so */
899 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, i->index);
900 }
901
902 /* Called from main context */
903 const pa_cvolume *pa_sink_input_get_volume(pa_sink_input *i) {
904 pa_sink_input_assert_ref(i);
905 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
906
907 return &i->virtual_volume;
908 }
909
910 /* Called from main context */
911 void pa_sink_input_set_mute(pa_sink_input *i, pa_bool_t mute, pa_bool_t save) {
912 pa_assert(i);
913 pa_sink_input_assert_ref(i);
914 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
915
916 if (!i->muted == !mute)
917 return;
918
919 i->muted = mute;
920 i->save_muted = save;
921
922 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_SOFT_MUTE, NULL, 0, NULL) == 0);
923 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, i->index);
924 }
925
926 /* Called from main context */
927 pa_bool_t pa_sink_input_get_mute(pa_sink_input *i) {
928 pa_sink_input_assert_ref(i);
929 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
930
931 return i->muted;
932 }
933
934 /* Called from main thread */
935 pa_bool_t pa_sink_input_update_proplist(pa_sink_input *i, pa_update_mode_t mode, pa_proplist *p) {
936
937 pa_sink_input_assert_ref(i);
938
939 pa_proplist_update(i->proplist, mode, p);
940
941 if (PA_SINK_IS_LINKED(i->state)) {
942 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_PROPLIST_CHANGED], i);
943 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, i->index);
944 }
945
946 return TRUE;
947 }
948
949 /* Called from main context */
950 void pa_sink_input_cork(pa_sink_input *i, pa_bool_t b) {
951 pa_sink_input_assert_ref(i);
952 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
953
954 sink_input_set_state(i, b ? PA_SINK_INPUT_CORKED : PA_SINK_INPUT_RUNNING);
955 }
956
957 /* Called from main context */
958 int pa_sink_input_set_rate(pa_sink_input *i, uint32_t rate) {
959 pa_sink_input_assert_ref(i);
960 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
961 pa_return_val_if_fail(i->thread_info.resampler, -PA_ERR_BADSTATE);
962
963 if (i->sample_spec.rate == rate)
964 return 0;
965
966 i->sample_spec.rate = rate;
967
968 pa_asyncmsgq_post(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_RATE, PA_UINT_TO_PTR(rate), 0, NULL, NULL);
969
970 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, i->index);
971 return 0;
972 }
973
974 /* Called from main context */
975 void pa_sink_input_set_name(pa_sink_input *i, const char *name) {
976 const char *old;
977 pa_sink_input_assert_ref(i);
978
979 if (!name && !pa_proplist_contains(i->proplist, PA_PROP_MEDIA_NAME))
980 return;
981
982 old = pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME);
983
984 if (old && name && !strcmp(old, name))
985 return;
986
987 if (name)
988 pa_proplist_sets(i->proplist, PA_PROP_MEDIA_NAME, name);
989 else
990 pa_proplist_unset(i->proplist, PA_PROP_MEDIA_NAME);
991
992 if (PA_SINK_INPUT_IS_LINKED(i->state)) {
993 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_PROPLIST_CHANGED], i);
994 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, i->index);
995 }
996 }
997
998 /* Called from main context */
999 pa_resample_method_t pa_sink_input_get_resample_method(pa_sink_input *i) {
1000 pa_sink_input_assert_ref(i);
1001
1002 return i->actual_resample_method;
1003 }
1004
1005 /* Called from main context */
1006 pa_bool_t pa_sink_input_may_move(pa_sink_input *i) {
1007 pa_sink_input_assert_ref(i);
1008 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
1009
1010 if (i->flags & PA_SINK_INPUT_DONT_MOVE)
1011 return FALSE;
1012
1013 if (i->sync_next || i->sync_prev) {
1014 pa_log_warn("Moving synchronised streams not supported.");
1015 return FALSE;
1016 }
1017
1018 return TRUE;
1019 }
1020
1021 /* Called from main context */
1022 pa_bool_t pa_sink_input_may_move_to(pa_sink_input *i, pa_sink *dest) {
1023 pa_sink_input_assert_ref(i);
1024 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
1025 pa_sink_assert_ref(dest);
1026
1027 if (dest == i->sink)
1028 return TRUE;
1029
1030 if (!pa_sink_input_may_move(i))
1031 return FALSE;
1032
1033 if (pa_idxset_size(dest->inputs) >= PA_MAX_INPUTS_PER_SINK) {
1034 pa_log_warn("Failed to move sink input: too many inputs per sink.");
1035 return FALSE;
1036 }
1037
1038 if (i->may_move_to)
1039 if (!i->may_move_to(i, dest))
1040 return FALSE;
1041
1042 return TRUE;
1043 }
1044
1045 /* Called from main context */
1046 int pa_sink_input_start_move(pa_sink_input *i) {
1047 pa_source_output *o, *p = NULL;
1048 pa_sink *origin;
1049 int r;
1050
1051 pa_sink_input_assert_ref(i);
1052 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
1053 pa_assert(i->sink);
1054
1055 if (!pa_sink_input_may_move(i))
1056 return -PA_ERR_NOTSUPPORTED;
1057
1058 if ((r = pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_MOVE_START], i)) < 0)
1059 return r;
1060
1061 origin = i->sink;
1062
1063 /* Kill directly connected outputs */
1064 while ((o = pa_idxset_first(i->direct_outputs, NULL))) {
1065 pa_assert(o != p);
1066 pa_source_output_kill(o);
1067 p = o;
1068 }
1069 pa_assert(pa_idxset_isempty(i->direct_outputs));
1070
1071 pa_idxset_remove_by_data(i->sink->inputs, i, NULL);
1072
1073 if (pa_sink_input_get_state(i) == PA_SINK_INPUT_CORKED)
1074 pa_assert_se(i->sink->n_corked-- >= 1);
1075
1076 if (i->sink->flags & PA_SINK_FLAT_VOLUME) {
1077 pa_cvolume new_volume;
1078
1079 /* Make the absolute volume relative */
1080 i->virtual_volume = i->soft_volume;
1081 pa_cvolume_reset(&i->soft_volume, i->sample_spec.channels);
1082
1083 /* We might need to update the sink's volume if we are in flat
1084 * volume mode. */
1085 pa_sink_update_flat_volume(i->sink, &new_volume);
1086 pa_sink_set_volume(i->sink, &new_volume, FALSE, FALSE);
1087 }
1088
1089 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_START_MOVE, i, 0, NULL) == 0);
1090
1091 pa_sink_update_status(i->sink);
1092 i->sink = NULL;
1093
1094 return 0;
1095 }
1096
1097 /* Called from main context */
1098 int pa_sink_input_finish_move(pa_sink_input *i, pa_sink *dest, pa_bool_t save) {
1099 pa_resampler *new_resampler;
1100
1101 pa_sink_input_assert_ref(i);
1102 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
1103 pa_assert(!i->sink);
1104 pa_sink_assert_ref(dest);
1105
1106 if (!pa_sink_input_may_move_to(i, dest))
1107 return -PA_ERR_NOTSUPPORTED;
1108
1109 if (i->thread_info.resampler &&
1110 pa_sample_spec_equal(pa_resampler_output_sample_spec(i->thread_info.resampler), &dest->sample_spec) &&
1111 pa_channel_map_equal(pa_resampler_output_channel_map(i->thread_info.resampler), &dest->channel_map))
1112
1113 /* Try to reuse the old resampler if possible */
1114 new_resampler = i->thread_info.resampler;
1115
1116 else if ((i->flags & PA_SINK_INPUT_VARIABLE_RATE) ||
1117 !pa_sample_spec_equal(&i->sample_spec, &dest->sample_spec) ||
1118 !pa_channel_map_equal(&i->channel_map, &dest->channel_map)) {
1119
1120 /* Okey, we need a new resampler for the new sink */
1121
1122 if (!(new_resampler = pa_resampler_new(
1123 i->core->mempool,
1124 &i->sample_spec, &i->channel_map,
1125 &dest->sample_spec, &dest->channel_map,
1126 i->requested_resample_method,
1127 ((i->flags & PA_SINK_INPUT_VARIABLE_RATE) ? PA_RESAMPLER_VARIABLE_RATE : 0) |
1128 ((i->flags & PA_SINK_INPUT_NO_REMAP) ? PA_RESAMPLER_NO_REMAP : 0) |
1129 (i->core->disable_remixing || (i->flags & PA_SINK_INPUT_NO_REMIX) ? PA_RESAMPLER_NO_REMIX : 0)))) {
1130 pa_log_warn("Unsupported resampling operation.");
1131 return -PA_ERR_NOTSUPPORTED;
1132 }
1133 } else
1134 new_resampler = NULL;
1135
1136 i->sink = dest;
1137 i->save_sink = save;
1138 pa_idxset_put(dest->inputs, i, NULL);
1139
1140 if (pa_sink_input_get_state(i) == PA_SINK_INPUT_CORKED)
1141 i->sink->n_corked++;
1142
1143 /* Replace resampler and render queue */
1144 if (new_resampler != i->thread_info.resampler) {
1145
1146 if (i->thread_info.resampler)
1147 pa_resampler_free(i->thread_info.resampler);
1148 i->thread_info.resampler = new_resampler;
1149
1150 pa_memblockq_free(i->thread_info.render_memblockq);
1151
1152 i->thread_info.render_memblockq = pa_memblockq_new(
1153 0,
1154 MEMBLOCKQ_MAXLENGTH,
1155 0,
1156 pa_frame_size(&i->sink->sample_spec),
1157 0,
1158 1,
1159 0,
1160 &i->sink->silence);
1161 }
1162
1163 pa_sink_update_status(dest);
1164
1165 if (i->sink->flags & PA_SINK_FLAT_VOLUME) {
1166 pa_cvolume new_volume;
1167
1168 /* Make relative volume absolute again */
1169 pa_cvolume t = dest->virtual_volume;
1170 pa_cvolume_remap(&t, &dest->channel_map, &i->channel_map);
1171 pa_sw_cvolume_multiply(&i->virtual_volume, &i->virtual_volume, &t);
1172
1173 /* We might need to update the sink's volume if we are in flat volume mode. */
1174 pa_sink_update_flat_volume(i->sink, &new_volume);
1175 pa_sink_set_volume(i->sink, &new_volume, FALSE, FALSE);
1176 }
1177
1178 pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_FINISH_MOVE, i, 0, NULL) == 0);
1179
1180 pa_log_debug("Successfully moved sink input %i to %s.", i->index, dest->name);
1181
1182 /* Notify everyone */
1183 if (i->moved)
1184 i->moved(i);
1185
1186 pa_hook_fire(&i->core->hooks[PA_CORE_HOOK_SINK_INPUT_MOVE_FINISH], i);
1187 pa_subscription_post(i->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, i->index);
1188
1189 return 0;
1190 }
1191
1192 /* Called from main context */
1193 int pa_sink_input_move_to(pa_sink_input *i, pa_sink *dest, pa_bool_t save) {
1194 int r;
1195
1196 pa_sink_input_assert_ref(i);
1197 pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
1198 pa_assert(i->sink);
1199 pa_sink_assert_ref(dest);
1200
1201 if (dest == i->sink)
1202 return 0;
1203
1204 if (!pa_sink_input_may_move_to(i, dest))
1205 return -PA_ERR_NOTSUPPORTED;
1206
1207 if ((r = pa_sink_input_start_move(i)) < 0)
1208 return r;
1209
1210 if ((r = pa_sink_input_finish_move(i, dest, save)) < 0)
1211 return r;
1212
1213 return 0;
1214 }
1215
1216 /* Called from IO thread context */
1217 void pa_sink_input_set_state_within_thread(pa_sink_input *i, pa_sink_input_state_t state) {
1218 pa_bool_t corking, uncorking;
1219 pa_sink_input_assert_ref(i);
1220
1221 if (state == i->thread_info.state)
1222 return;
1223
1224 if ((state == PA_SINK_INPUT_DRAINED || state == PA_SINK_INPUT_RUNNING) &&
1225 !(i->thread_info.state == PA_SINK_INPUT_DRAINED || i->thread_info.state != PA_SINK_INPUT_RUNNING))
1226 pa_atomic_store(&i->thread_info.drained, 1);
1227
1228 corking = state == PA_SINK_INPUT_CORKED && i->thread_info.state == PA_SINK_INPUT_RUNNING;
1229 uncorking = i->thread_info.state == PA_SINK_INPUT_CORKED && state == PA_SINK_INPUT_RUNNING;
1230
1231 if (i->state_change)
1232 i->state_change(i, state);
1233
1234 i->thread_info.state = state;
1235
1236 if (corking) {
1237
1238 pa_log_debug("Requesting rewind due to corking");
1239
1240 /* This will tell the implementing sink input driver to rewind
1241 * so that the unplayed already mixed data is not lost */
1242 pa_sink_input_request_rewind(i, 0, TRUE, TRUE, FALSE);
1243
1244 } else if (uncorking) {
1245
1246 i->thread_info.underrun_for = (uint64_t) -1;
1247 i->thread_info.playing_for = 0;
1248
1249 pa_log_debug("Requesting rewind due to uncorking");
1250
1251 /* OK, we're being uncorked. Make sure we're not rewound when
1252 * the hw buffer is remixed and request a remix. */
1253 pa_sink_input_request_rewind(i, 0, FALSE, TRUE, TRUE);
1254 }
1255 }
1256
1257 /* Called from thread context, except when it is not. */
1258 int pa_sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
1259 pa_sink_input *i = PA_SINK_INPUT(o);
1260 pa_sink_input_assert_ref(i);
1261
1262 switch (code) {
1263
1264 case PA_SINK_INPUT_MESSAGE_SET_SOFT_VOLUME:
1265 if (!pa_cvolume_equal(&i->thread_info.soft_volume, &i->soft_volume)) {
1266 i->thread_info.soft_volume = i->soft_volume;
1267 pa_sink_input_request_rewind(i, 0, TRUE, FALSE, FALSE);
1268 }
1269 return 0;
1270
1271 case PA_SINK_INPUT_MESSAGE_SET_SOFT_MUTE:
1272 if (i->thread_info.muted != i->muted) {
1273 i->thread_info.muted = i->muted;
1274 pa_sink_input_request_rewind(i, 0, TRUE, FALSE, FALSE);
1275 }
1276 return 0;
1277
1278 case PA_SINK_INPUT_MESSAGE_GET_LATENCY: {
1279 pa_usec_t *r = userdata;
1280 pa_usec_t sink_usec = 0;
1281
1282 r[0] += pa_bytes_to_usec(pa_memblockq_get_length(i->thread_info.render_memblockq), &i->sink->sample_spec);
1283
1284 if (i->sink->parent.process_msg(PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_GET_LATENCY, &sink_usec, 0, NULL) >= 0)
1285 r[1] += sink_usec;
1286
1287 return 0;
1288 }
1289
1290 case PA_SINK_INPUT_MESSAGE_SET_RATE:
1291
1292 i->thread_info.sample_spec.rate = PA_PTR_TO_UINT(userdata);
1293 pa_resampler_set_input_rate(i->thread_info.resampler, PA_PTR_TO_UINT(userdata));
1294
1295 return 0;
1296
1297 case PA_SINK_INPUT_MESSAGE_SET_STATE: {
1298 pa_sink_input *ssync;
1299
1300 pa_sink_input_set_state_within_thread(i, PA_PTR_TO_UINT(userdata));
1301
1302 for (ssync = i->thread_info.sync_prev; ssync; ssync = ssync->thread_info.sync_prev)
1303 pa_sink_input_set_state_within_thread(ssync, PA_PTR_TO_UINT(userdata));
1304
1305 for (ssync = i->thread_info.sync_next; ssync; ssync = ssync->thread_info.sync_next)
1306 pa_sink_input_set_state_within_thread(ssync, PA_PTR_TO_UINT(userdata));
1307
1308 return 0;
1309 }
1310
1311 case PA_SINK_INPUT_MESSAGE_SET_REQUESTED_LATENCY: {
1312 pa_usec_t *usec = userdata;
1313
1314 *usec = pa_sink_input_set_requested_latency_within_thread(i, *usec);
1315 return 0;
1316 }
1317
1318 case PA_SINK_INPUT_MESSAGE_GET_REQUESTED_LATENCY: {
1319 pa_usec_t *r = userdata;
1320
1321 *r = i->thread_info.requested_sink_latency;
1322 return 0;
1323 }
1324 }
1325
1326 return -PA_ERR_NOTIMPLEMENTED;
1327 }
1328
1329 /* Called from main thread */
1330 pa_sink_input_state_t pa_sink_input_get_state(pa_sink_input *i) {
1331 pa_sink_input_assert_ref(i);
1332
1333 if (i->state == PA_SINK_INPUT_RUNNING || i->state == PA_SINK_INPUT_DRAINED)
1334 return pa_atomic_load(&i->thread_info.drained) ? PA_SINK_INPUT_DRAINED : PA_SINK_INPUT_RUNNING;
1335
1336 return i->state;
1337 }
1338
1339 /* Called from IO context */
1340 pa_bool_t pa_sink_input_safe_to_remove(pa_sink_input *i) {
1341 pa_sink_input_assert_ref(i);
1342
1343 if (PA_SINK_INPUT_IS_LINKED(i->thread_info.state))
1344 return pa_memblockq_is_empty(i->thread_info.render_memblockq);
1345
1346 return TRUE;
1347 }
1348
1349 /* Called from IO context */
1350 void pa_sink_input_request_rewind(pa_sink_input *i, size_t nbytes /* in our sample spec */, pa_bool_t rewrite, pa_bool_t flush, pa_bool_t dont_rewind_render) {
1351 size_t lbq;
1352
1353 /* If 'rewrite' is TRUE the sink is rewound as far as requested
1354 * and possible and the exact value of this is passed back the
1355 * implementor via process_rewind(). If 'flush' is also TRUE all
1356 * already rendered data is also dropped.
1357 *
1358 * If 'rewrite' is FALSE the sink is rewound as far as requested
1359 * and possible and the already rendered data is dropped so that
1360 * in the next iteration we read new data from the
1361 * implementor. This implies 'flush' is TRUE. If
1362 * dont_rewind_render is TRUE then the render memblockq is not
1363 * rewound. */
1364
1365 pa_sink_input_assert_ref(i);
1366
1367 nbytes = PA_MAX(i->thread_info.rewrite_nbytes, nbytes);
1368
1369 /* pa_log_debug("request rewrite %lu", (unsigned long) nbytes); */
1370
1371 /* We don't take rewind requests while we are corked */
1372 if (i->thread_info.state == PA_SINK_INPUT_CORKED)
1373 return;
1374
1375 pa_assert(rewrite || flush);
1376 pa_assert(!dont_rewind_render || !rewrite);
1377
1378 /* Calculate how much we can rewind locally without having to
1379 * touch the sink */
1380 if (rewrite)
1381 lbq = pa_memblockq_get_length(i->thread_info.render_memblockq);
1382 else
1383 lbq = 0;
1384
1385 /* Check if rewinding for the maximum is requested, and if so, fix up */
1386 if (nbytes <= 0) {
1387
1388 /* Calculate maximum number of bytes that could be rewound in theory */
1389 nbytes = i->sink->thread_info.max_rewind + lbq;
1390
1391 /* Transform from sink domain */
1392 if (i->thread_info.resampler)
1393 nbytes = pa_resampler_request(i->thread_info.resampler, nbytes);
1394 }
1395
1396 if (i->thread_info.rewrite_nbytes != (size_t) -1) {
1397 if (rewrite) {
1398 /* Make sure to not overwrite over underruns */
1399 if (nbytes > i->thread_info.playing_for)
1400 nbytes = (size_t) i->thread_info.playing_for;
1401
1402 i->thread_info.rewrite_nbytes = nbytes;
1403 } else
1404 i->thread_info.rewrite_nbytes = (size_t) -1;
1405 }
1406
1407 i->thread_info.rewrite_flush =
1408 i->thread_info.rewrite_flush ||
1409 (flush && i->thread_info.rewrite_nbytes != 0);
1410
1411 i->thread_info.dont_rewind_render =
1412 i->thread_info.dont_rewind_render ||
1413 dont_rewind_render;
1414
1415 if (nbytes != (size_t) -1) {
1416
1417 /* Transform to sink domain */
1418 if (i->thread_info.resampler)
1419 nbytes = pa_resampler_result(i->thread_info.resampler, nbytes);
1420
1421 if (nbytes > lbq)
1422 pa_sink_request_rewind(i->sink, nbytes - lbq);
1423 else
1424 /* This call will make sure process_rewind() is called later */
1425 pa_sink_request_rewind(i->sink, 0);
1426 }
1427 }
1428
1429 /* Called from main context */
1430 pa_memchunk* pa_sink_input_get_silence(pa_sink_input *i, pa_memchunk *ret) {
1431 pa_sink_input_assert_ref(i);
1432 pa_assert(ret);
1433
1434 pa_silence_memchunk_get(
1435 &i->core->silence_cache,
1436 i->core->mempool,
1437 ret,
1438 &i->sample_spec,
1439 i->thread_info.resampler ? pa_resampler_max_block_size(i->thread_info.resampler) : 0);
1440
1441 return ret;
1442 }