]> code.delx.au - pulseaudio/blob - src/pulsecore/protocol-native.c
Merge branch 'master' of ssh://rootserver/home/lennart/git/public/pulseaudio
[pulseaudio] / src / pulsecore / protocol-native.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.1 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 <string.h>
28 #include <stdio.h>
29 #include <stdlib.h>
30 #include <unistd.h>
31
32 #include <pulse/rtclock.h>
33 #include <pulse/timeval.h>
34 #include <pulse/version.h>
35 #include <pulse/utf8.h>
36 #include <pulse/util.h>
37 #include <pulse/xmalloc.h>
38
39 #include <pulsecore/native-common.h>
40 #include <pulsecore/packet.h>
41 #include <pulsecore/client.h>
42 #include <pulsecore/source-output.h>
43 #include <pulsecore/sink-input.h>
44 #include <pulsecore/pstream.h>
45 #include <pulsecore/tagstruct.h>
46 #include <pulsecore/pdispatch.h>
47 #include <pulsecore/pstream-util.h>
48 #include <pulsecore/authkey.h>
49 #include <pulsecore/namereg.h>
50 #include <pulsecore/core-scache.h>
51 #include <pulsecore/core-subscribe.h>
52 #include <pulsecore/log.h>
53 #include <pulsecore/strlist.h>
54 #include <pulsecore/shared.h>
55 #include <pulsecore/sample-util.h>
56 #include <pulsecore/llist.h>
57 #include <pulsecore/creds.h>
58 #include <pulsecore/core-util.h>
59 #include <pulsecore/ipacl.h>
60 #include <pulsecore/thread-mq.h>
61
62 #include "protocol-native.h"
63
64 /* Kick a client if it doesn't authenticate within this time */
65 #define AUTH_TIMEOUT (60 * PA_USEC_PER_SEC)
66
67 /* Don't accept more connection than this */
68 #define MAX_CONNECTIONS 64
69
70 #define MAX_MEMBLOCKQ_LENGTH (4*1024*1024) /* 4MB */
71 #define DEFAULT_TLENGTH_MSEC 2000 /* 2s */
72 #define DEFAULT_PROCESS_MSEC 20 /* 20ms */
73 #define DEFAULT_FRAGSIZE_MSEC DEFAULT_TLENGTH_MSEC
74
75 struct pa_native_protocol;
76
77 typedef struct record_stream {
78 pa_msgobject parent;
79
80 pa_native_connection *connection;
81 uint32_t index;
82
83 pa_source_output *source_output;
84 pa_memblockq *memblockq;
85
86 pa_bool_t adjust_latency:1;
87 pa_bool_t early_requests:1;
88
89 pa_buffer_attr buffer_attr;
90
91 pa_atomic_t on_the_fly;
92 pa_usec_t configured_source_latency;
93 size_t drop_initial;
94
95 /* Only updated after SOURCE_OUTPUT_MESSAGE_UPDATE_LATENCY */
96 size_t on_the_fly_snapshot;
97 pa_usec_t current_monitor_latency;
98 pa_usec_t current_source_latency;
99 } record_stream;
100
101 PA_DECLARE_CLASS(record_stream);
102 #define RECORD_STREAM(o) (record_stream_cast(o))
103 static PA_DEFINE_CHECK_TYPE(record_stream, pa_msgobject);
104
105 typedef struct output_stream {
106 pa_msgobject parent;
107 } output_stream;
108
109 PA_DECLARE_CLASS(output_stream);
110 #define OUTPUT_STREAM(o) (output_stream_cast(o))
111 static PA_DEFINE_CHECK_TYPE(output_stream, pa_msgobject);
112
113 typedef struct playback_stream {
114 output_stream parent;
115
116 pa_native_connection *connection;
117 uint32_t index;
118
119 pa_sink_input *sink_input;
120 pa_memblockq *memblockq;
121
122 pa_bool_t adjust_latency:1;
123 pa_bool_t early_requests:1;
124
125 pa_bool_t is_underrun:1;
126 pa_bool_t drain_request:1;
127 uint32_t drain_tag;
128 uint32_t syncid;
129
130 pa_atomic_t missing;
131 pa_usec_t configured_sink_latency;
132 pa_buffer_attr buffer_attr;
133
134 /* Only updated after SINK_INPUT_MESSAGE_UPDATE_LATENCY */
135 int64_t read_index, write_index;
136 size_t render_memblockq_length;
137 pa_usec_t current_sink_latency;
138 uint64_t playing_for, underrun_for;
139 } playback_stream;
140
141 PA_DECLARE_CLASS(playback_stream);
142 #define PLAYBACK_STREAM(o) (playback_stream_cast(o))
143 static PA_DEFINE_CHECK_TYPE(playback_stream, output_stream);
144
145 typedef struct upload_stream {
146 output_stream parent;
147
148 pa_native_connection *connection;
149 uint32_t index;
150
151 pa_memchunk memchunk;
152 size_t length;
153 char *name;
154 pa_sample_spec sample_spec;
155 pa_channel_map channel_map;
156 pa_proplist *proplist;
157 } upload_stream;
158
159 PA_DECLARE_CLASS(upload_stream);
160 #define UPLOAD_STREAM(o) (upload_stream_cast(o))
161 static PA_DEFINE_CHECK_TYPE(upload_stream, output_stream);
162
163 struct pa_native_connection {
164 pa_msgobject parent;
165 pa_native_protocol *protocol;
166 pa_native_options *options;
167 pa_bool_t authorized:1;
168 pa_bool_t is_local:1;
169 uint32_t version;
170 pa_client *client;
171 pa_pstream *pstream;
172 pa_pdispatch *pdispatch;
173 pa_idxset *record_streams, *output_streams;
174 uint32_t rrobin_index;
175 pa_subscription *subscription;
176 pa_time_event *auth_timeout_event;
177 };
178
179 PA_DECLARE_CLASS(pa_native_connection);
180 #define PA_NATIVE_CONNECTION(o) (pa_native_connection_cast(o))
181 static PA_DEFINE_CHECK_TYPE(pa_native_connection, pa_msgobject);
182
183 struct pa_native_protocol {
184 PA_REFCNT_DECLARE;
185
186 pa_core *core;
187 pa_idxset *connections;
188
189 pa_strlist *servers;
190 pa_hook hooks[PA_NATIVE_HOOK_MAX];
191
192 pa_hashmap *extensions;
193 };
194
195 enum {
196 SOURCE_OUTPUT_MESSAGE_UPDATE_LATENCY = PA_SOURCE_OUTPUT_MESSAGE_MAX
197 };
198
199 enum {
200 SINK_INPUT_MESSAGE_POST_DATA = PA_SINK_INPUT_MESSAGE_MAX, /* data from main loop to sink input */
201 SINK_INPUT_MESSAGE_DRAIN, /* disabled prebuf, get playback started. */
202 SINK_INPUT_MESSAGE_FLUSH,
203 SINK_INPUT_MESSAGE_TRIGGER,
204 SINK_INPUT_MESSAGE_SEEK,
205 SINK_INPUT_MESSAGE_PREBUF_FORCE,
206 SINK_INPUT_MESSAGE_UPDATE_LATENCY,
207 SINK_INPUT_MESSAGE_UPDATE_BUFFER_ATTR
208 };
209
210 enum {
211 PLAYBACK_STREAM_MESSAGE_REQUEST_DATA, /* data requested from sink input from the main loop */
212 PLAYBACK_STREAM_MESSAGE_UNDERFLOW,
213 PLAYBACK_STREAM_MESSAGE_OVERFLOW,
214 PLAYBACK_STREAM_MESSAGE_DRAIN_ACK,
215 PLAYBACK_STREAM_MESSAGE_STARTED,
216 PLAYBACK_STREAM_MESSAGE_UPDATE_TLENGTH
217 };
218
219 enum {
220 RECORD_STREAM_MESSAGE_POST_DATA /* data from source output to main loop */
221 };
222
223 enum {
224 CONNECTION_MESSAGE_RELEASE,
225 CONNECTION_MESSAGE_REVOKE
226 };
227
228 static int sink_input_pop_cb(pa_sink_input *i, size_t length, pa_memchunk *chunk);
229 static void sink_input_kill_cb(pa_sink_input *i);
230 static void sink_input_suspend_cb(pa_sink_input *i, pa_bool_t suspend);
231 static void sink_input_moving_cb(pa_sink_input *i, pa_sink *dest);
232 static void sink_input_process_rewind_cb(pa_sink_input *i, size_t nbytes);
233 static void sink_input_update_max_rewind_cb(pa_sink_input *i, size_t nbytes);
234 static void sink_input_update_max_request_cb(pa_sink_input *i, size_t nbytes);
235 static void sink_input_send_event_cb(pa_sink_input *i, const char *event, pa_proplist *pl);
236
237 static void native_connection_send_memblock(pa_native_connection *c);
238 static void playback_stream_request_bytes(struct playback_stream*s);
239
240 static void source_output_kill_cb(pa_source_output *o);
241 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk);
242 static void source_output_suspend_cb(pa_source_output *o, pa_bool_t suspend);
243 static void source_output_moving_cb(pa_source_output *o, pa_source *dest);
244 static pa_usec_t source_output_get_latency_cb(pa_source_output *o);
245 static void source_output_send_event_cb(pa_source_output *o, const char *event, pa_proplist *pl);
246
247 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk);
248 static int source_output_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk);
249
250 static void command_exit(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
251 static void command_create_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
252 static void command_drain_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
253 static void command_create_record_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
254 static void command_delete_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
255 static void command_auth(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
256 static void command_set_client_name(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
257 static void command_lookup(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
258 static void command_stat(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
259 static void command_get_playback_latency(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
260 static void command_get_record_latency(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
261 static void command_create_upload_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
262 static void command_finish_upload_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
263 static void command_play_sample(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
264 static void command_remove_sample(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
265 static void command_get_info(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
266 static void command_get_info_list(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
267 static void command_get_server_info(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
268 static void command_subscribe(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
269 static void command_set_volume(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
270 static void command_set_mute(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
271 static void command_cork_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
272 static void command_trigger_or_flush_or_prebuf_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
273 static void command_set_default_sink_or_source(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
274 static void command_set_stream_name(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
275 static void command_kill(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
276 static void command_load_module(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
277 static void command_unload_module(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
278 static void command_cork_record_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
279 static void command_flush_record_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
280 static void command_move_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
281 static void command_suspend(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
282 static void command_set_stream_buffer_attr(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
283 static void command_update_stream_sample_rate(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
284 static void command_update_proplist(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
285 static void command_remove_proplist(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
286 static void command_extension(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
287 static void command_set_card_profile(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
288 static void command_set_sink_or_source_port(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
289
290 static const pa_pdispatch_cb_t command_table[PA_COMMAND_MAX] = {
291 [PA_COMMAND_ERROR] = NULL,
292 [PA_COMMAND_TIMEOUT] = NULL,
293 [PA_COMMAND_REPLY] = NULL,
294 [PA_COMMAND_CREATE_PLAYBACK_STREAM] = command_create_playback_stream,
295 [PA_COMMAND_DELETE_PLAYBACK_STREAM] = command_delete_stream,
296 [PA_COMMAND_DRAIN_PLAYBACK_STREAM] = command_drain_playback_stream,
297 [PA_COMMAND_CREATE_RECORD_STREAM] = command_create_record_stream,
298 [PA_COMMAND_DELETE_RECORD_STREAM] = command_delete_stream,
299 [PA_COMMAND_AUTH] = command_auth,
300 [PA_COMMAND_REQUEST] = NULL,
301 [PA_COMMAND_EXIT] = command_exit,
302 [PA_COMMAND_SET_CLIENT_NAME] = command_set_client_name,
303 [PA_COMMAND_LOOKUP_SINK] = command_lookup,
304 [PA_COMMAND_LOOKUP_SOURCE] = command_lookup,
305 [PA_COMMAND_STAT] = command_stat,
306 [PA_COMMAND_GET_PLAYBACK_LATENCY] = command_get_playback_latency,
307 [PA_COMMAND_GET_RECORD_LATENCY] = command_get_record_latency,
308 [PA_COMMAND_CREATE_UPLOAD_STREAM] = command_create_upload_stream,
309 [PA_COMMAND_DELETE_UPLOAD_STREAM] = command_delete_stream,
310 [PA_COMMAND_FINISH_UPLOAD_STREAM] = command_finish_upload_stream,
311 [PA_COMMAND_PLAY_SAMPLE] = command_play_sample,
312 [PA_COMMAND_REMOVE_SAMPLE] = command_remove_sample,
313 [PA_COMMAND_GET_SINK_INFO] = command_get_info,
314 [PA_COMMAND_GET_SOURCE_INFO] = command_get_info,
315 [PA_COMMAND_GET_CLIENT_INFO] = command_get_info,
316 [PA_COMMAND_GET_CARD_INFO] = command_get_info,
317 [PA_COMMAND_GET_MODULE_INFO] = command_get_info,
318 [PA_COMMAND_GET_SINK_INPUT_INFO] = command_get_info,
319 [PA_COMMAND_GET_SOURCE_OUTPUT_INFO] = command_get_info,
320 [PA_COMMAND_GET_SAMPLE_INFO] = command_get_info,
321 [PA_COMMAND_GET_SINK_INFO_LIST] = command_get_info_list,
322 [PA_COMMAND_GET_SOURCE_INFO_LIST] = command_get_info_list,
323 [PA_COMMAND_GET_MODULE_INFO_LIST] = command_get_info_list,
324 [PA_COMMAND_GET_CLIENT_INFO_LIST] = command_get_info_list,
325 [PA_COMMAND_GET_CARD_INFO_LIST] = command_get_info_list,
326 [PA_COMMAND_GET_SINK_INPUT_INFO_LIST] = command_get_info_list,
327 [PA_COMMAND_GET_SOURCE_OUTPUT_INFO_LIST] = command_get_info_list,
328 [PA_COMMAND_GET_SAMPLE_INFO_LIST] = command_get_info_list,
329 [PA_COMMAND_GET_SERVER_INFO] = command_get_server_info,
330 [PA_COMMAND_SUBSCRIBE] = command_subscribe,
331
332 [PA_COMMAND_SET_SINK_VOLUME] = command_set_volume,
333 [PA_COMMAND_SET_SINK_INPUT_VOLUME] = command_set_volume,
334 [PA_COMMAND_SET_SOURCE_VOLUME] = command_set_volume,
335
336 [PA_COMMAND_SET_SINK_MUTE] = command_set_mute,
337 [PA_COMMAND_SET_SINK_INPUT_MUTE] = command_set_mute,
338 [PA_COMMAND_SET_SOURCE_MUTE] = command_set_mute,
339
340 [PA_COMMAND_SUSPEND_SINK] = command_suspend,
341 [PA_COMMAND_SUSPEND_SOURCE] = command_suspend,
342
343 [PA_COMMAND_CORK_PLAYBACK_STREAM] = command_cork_playback_stream,
344 [PA_COMMAND_FLUSH_PLAYBACK_STREAM] = command_trigger_or_flush_or_prebuf_playback_stream,
345 [PA_COMMAND_TRIGGER_PLAYBACK_STREAM] = command_trigger_or_flush_or_prebuf_playback_stream,
346 [PA_COMMAND_PREBUF_PLAYBACK_STREAM] = command_trigger_or_flush_or_prebuf_playback_stream,
347
348 [PA_COMMAND_CORK_RECORD_STREAM] = command_cork_record_stream,
349 [PA_COMMAND_FLUSH_RECORD_STREAM] = command_flush_record_stream,
350
351 [PA_COMMAND_SET_DEFAULT_SINK] = command_set_default_sink_or_source,
352 [PA_COMMAND_SET_DEFAULT_SOURCE] = command_set_default_sink_or_source,
353 [PA_COMMAND_SET_PLAYBACK_STREAM_NAME] = command_set_stream_name,
354 [PA_COMMAND_SET_RECORD_STREAM_NAME] = command_set_stream_name,
355 [PA_COMMAND_KILL_CLIENT] = command_kill,
356 [PA_COMMAND_KILL_SINK_INPUT] = command_kill,
357 [PA_COMMAND_KILL_SOURCE_OUTPUT] = command_kill,
358 [PA_COMMAND_LOAD_MODULE] = command_load_module,
359 [PA_COMMAND_UNLOAD_MODULE] = command_unload_module,
360
361 [PA_COMMAND_GET_AUTOLOAD_INFO___OBSOLETE] = NULL,
362 [PA_COMMAND_GET_AUTOLOAD_INFO_LIST___OBSOLETE] = NULL,
363 [PA_COMMAND_ADD_AUTOLOAD___OBSOLETE] = NULL,
364 [PA_COMMAND_REMOVE_AUTOLOAD___OBSOLETE] = NULL,
365
366 [PA_COMMAND_MOVE_SINK_INPUT] = command_move_stream,
367 [PA_COMMAND_MOVE_SOURCE_OUTPUT] = command_move_stream,
368
369 [PA_COMMAND_SET_PLAYBACK_STREAM_BUFFER_ATTR] = command_set_stream_buffer_attr,
370 [PA_COMMAND_SET_RECORD_STREAM_BUFFER_ATTR] = command_set_stream_buffer_attr,
371
372 [PA_COMMAND_UPDATE_PLAYBACK_STREAM_SAMPLE_RATE] = command_update_stream_sample_rate,
373 [PA_COMMAND_UPDATE_RECORD_STREAM_SAMPLE_RATE] = command_update_stream_sample_rate,
374
375 [PA_COMMAND_UPDATE_RECORD_STREAM_PROPLIST] = command_update_proplist,
376 [PA_COMMAND_UPDATE_PLAYBACK_STREAM_PROPLIST] = command_update_proplist,
377 [PA_COMMAND_UPDATE_CLIENT_PROPLIST] = command_update_proplist,
378
379 [PA_COMMAND_REMOVE_RECORD_STREAM_PROPLIST] = command_remove_proplist,
380 [PA_COMMAND_REMOVE_PLAYBACK_STREAM_PROPLIST] = command_remove_proplist,
381 [PA_COMMAND_REMOVE_CLIENT_PROPLIST] = command_remove_proplist,
382
383 [PA_COMMAND_SET_CARD_PROFILE] = command_set_card_profile,
384
385 [PA_COMMAND_SET_SINK_PORT] = command_set_sink_or_source_port,
386 [PA_COMMAND_SET_SOURCE_PORT] = command_set_sink_or_source_port,
387
388 [PA_COMMAND_EXTENSION] = command_extension
389 };
390
391 /* structure management */
392
393 /* Called from main context */
394 static void upload_stream_unlink(upload_stream *s) {
395 pa_assert(s);
396
397 if (!s->connection)
398 return;
399
400 pa_assert_se(pa_idxset_remove_by_data(s->connection->output_streams, s, NULL) == s);
401 s->connection = NULL;
402 upload_stream_unref(s);
403 }
404
405 /* Called from main context */
406 static void upload_stream_free(pa_object *o) {
407 upload_stream *s = UPLOAD_STREAM(o);
408 pa_assert(s);
409
410 upload_stream_unlink(s);
411
412 pa_xfree(s->name);
413
414 if (s->proplist)
415 pa_proplist_free(s->proplist);
416
417 if (s->memchunk.memblock)
418 pa_memblock_unref(s->memchunk.memblock);
419
420 pa_xfree(s);
421 }
422
423 /* Called from main context */
424 static upload_stream* upload_stream_new(
425 pa_native_connection *c,
426 const pa_sample_spec *ss,
427 const pa_channel_map *map,
428 const char *name,
429 size_t length,
430 pa_proplist *p) {
431
432 upload_stream *s;
433
434 pa_assert(c);
435 pa_assert(ss);
436 pa_assert(name);
437 pa_assert(length > 0);
438 pa_assert(p);
439
440 s = pa_msgobject_new(upload_stream);
441 s->parent.parent.parent.free = upload_stream_free;
442 s->connection = c;
443 s->sample_spec = *ss;
444 s->channel_map = *map;
445 s->name = pa_xstrdup(name);
446 pa_memchunk_reset(&s->memchunk);
447 s->length = length;
448 s->proplist = pa_proplist_copy(p);
449 pa_proplist_update(s->proplist, PA_UPDATE_MERGE, c->client->proplist);
450
451 pa_idxset_put(c->output_streams, s, &s->index);
452
453 return s;
454 }
455
456 /* Called from main context */
457 static void record_stream_unlink(record_stream *s) {
458 pa_assert(s);
459
460 if (!s->connection)
461 return;
462
463 if (s->source_output) {
464 pa_source_output_unlink(s->source_output);
465 pa_source_output_unref(s->source_output);
466 s->source_output = NULL;
467 }
468
469 pa_assert_se(pa_idxset_remove_by_data(s->connection->record_streams, s, NULL) == s);
470 s->connection = NULL;
471 record_stream_unref(s);
472 }
473
474 /* Called from main context */
475 static void record_stream_free(pa_object *o) {
476 record_stream *s = RECORD_STREAM(o);
477 pa_assert(s);
478
479 record_stream_unlink(s);
480
481 pa_memblockq_free(s->memblockq);
482 pa_xfree(s);
483 }
484
485 /* Called from main context */
486 static int record_stream_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
487 record_stream *s = RECORD_STREAM(o);
488 record_stream_assert_ref(s);
489
490 if (!s->connection)
491 return -1;
492
493 switch (code) {
494
495 case RECORD_STREAM_MESSAGE_POST_DATA:
496
497 /* We try to keep up to date with how many bytes are
498 * currently on the fly */
499 pa_atomic_sub(&s->on_the_fly, chunk->length);
500
501 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) {
502 /* pa_log_warn("Failed to push data into output queue."); */
503 return -1;
504 }
505
506 if (!pa_pstream_is_pending(s->connection->pstream))
507 native_connection_send_memblock(s->connection);
508
509 break;
510 }
511
512 return 0;
513 }
514
515 /* Called from main context */
516 static void fix_record_buffer_attr_pre(record_stream *s) {
517
518 size_t frame_size;
519 pa_usec_t orig_fragsize_usec, fragsize_usec, source_usec;
520
521 pa_assert(s);
522
523 /* This function will be called from the main thread, before as
524 * well as after the source output has been activated using
525 * pa_source_output_put()! That means it may not touch any
526 * ->thread_info data! */
527
528 frame_size = pa_frame_size(&s->source_output->sample_spec);
529
530 if (s->buffer_attr.maxlength == (uint32_t) -1 || s->buffer_attr.maxlength > MAX_MEMBLOCKQ_LENGTH)
531 s->buffer_attr.maxlength = MAX_MEMBLOCKQ_LENGTH;
532 if (s->buffer_attr.maxlength <= 0)
533 s->buffer_attr.maxlength = (uint32_t) frame_size;
534
535 if (s->buffer_attr.fragsize == (uint32_t) -1)
536 s->buffer_attr.fragsize = (uint32_t) pa_usec_to_bytes(DEFAULT_FRAGSIZE_MSEC*PA_USEC_PER_MSEC, &s->source_output->sample_spec);
537 if (s->buffer_attr.fragsize <= 0)
538 s->buffer_attr.fragsize = (uint32_t) frame_size;
539
540 orig_fragsize_usec = fragsize_usec = pa_bytes_to_usec(s->buffer_attr.fragsize, &s->source_output->sample_spec);
541
542 if (s->early_requests) {
543
544 /* In early request mode we need to emulate the classic
545 * fragment-based playback model. We do this setting the source
546 * latency to the fragment size. */
547
548 source_usec = fragsize_usec;
549
550 } else if (s->adjust_latency) {
551
552 /* So, the user asked us to adjust the latency according to
553 * what the source can provide. Half the latency will be
554 * spent on the hw buffer, half of it in the async buffer
555 * queue we maintain for each client. */
556
557 source_usec = fragsize_usec/2;
558
559 } else {
560
561 /* Ok, the user didn't ask us to adjust the latency, hence we
562 * don't */
563
564 source_usec = (pa_usec_t) -1;
565 }
566
567 if (source_usec != (pa_usec_t) -1)
568 s->configured_source_latency = pa_source_output_set_requested_latency(s->source_output, source_usec);
569 else
570 s->configured_source_latency = 0;
571
572 if (s->early_requests) {
573
574 /* Ok, we didn't necessarily get what we were asking for, so
575 * let's tell the user */
576
577 fragsize_usec = s->configured_source_latency;
578
579 } else if (s->adjust_latency) {
580
581 /* Now subtract what we actually got */
582
583 if (fragsize_usec >= s->configured_source_latency*2)
584 fragsize_usec -= s->configured_source_latency;
585 else
586 fragsize_usec = s->configured_source_latency;
587 }
588
589 if (pa_usec_to_bytes(orig_fragsize_usec, &s->source_output->sample_spec) !=
590 pa_usec_to_bytes(fragsize_usec, &s->source_output->sample_spec))
591
592 s->buffer_attr.fragsize = (uint32_t) pa_usec_to_bytes(fragsize_usec, &s->source_output->sample_spec);
593
594 if (s->buffer_attr.fragsize <= 0)
595 s->buffer_attr.fragsize = (uint32_t) frame_size;
596 }
597
598 /* Called from main context */
599 static void fix_record_buffer_attr_post(record_stream *s) {
600 size_t base;
601
602 pa_assert(s);
603
604 /* This function will be called from the main thread, before as
605 * well as after the source output has been activated using
606 * pa_source_output_put()! That means it may not touch and
607 * ->thread_info data! */
608
609 base = pa_frame_size(&s->source_output->sample_spec);
610
611 s->buffer_attr.fragsize = (s->buffer_attr.fragsize/base)*base;
612 if (s->buffer_attr.fragsize <= 0)
613 s->buffer_attr.fragsize = base;
614
615 if (s->buffer_attr.fragsize > s->buffer_attr.maxlength)
616 s->buffer_attr.fragsize = s->buffer_attr.maxlength;
617 }
618
619 /* Called from main context */
620 static record_stream* record_stream_new(
621 pa_native_connection *c,
622 pa_source *source,
623 pa_sample_spec *ss,
624 pa_channel_map *map,
625 pa_bool_t peak_detect,
626 pa_buffer_attr *attr,
627 pa_source_output_flags_t flags,
628 pa_proplist *p,
629 pa_bool_t adjust_latency,
630 pa_sink_input *direct_on_input,
631 pa_bool_t early_requests,
632 int *ret) {
633
634 record_stream *s;
635 pa_source_output *source_output = NULL;
636 size_t base;
637 pa_source_output_new_data data;
638
639 pa_assert(c);
640 pa_assert(ss);
641 pa_assert(p);
642 pa_assert(ret);
643
644 pa_source_output_new_data_init(&data);
645
646 pa_proplist_update(data.proplist, PA_UPDATE_REPLACE, p);
647 data.driver = __FILE__;
648 data.module = c->options->module;
649 data.client = c->client;
650 data.source = source;
651 data.direct_on_input = direct_on_input;
652 pa_source_output_new_data_set_sample_spec(&data, ss);
653 pa_source_output_new_data_set_channel_map(&data, map);
654 if (peak_detect)
655 data.resample_method = PA_RESAMPLER_PEAKS;
656
657 *ret = -pa_source_output_new(&source_output, c->protocol->core, &data, flags);
658
659 pa_source_output_new_data_done(&data);
660
661 if (!source_output)
662 return NULL;
663
664 s = pa_msgobject_new(record_stream);
665 s->parent.parent.free = record_stream_free;
666 s->parent.process_msg = record_stream_process_msg;
667 s->connection = c;
668 s->source_output = source_output;
669 s->buffer_attr = *attr;
670 s->adjust_latency = adjust_latency;
671 s->early_requests = early_requests;
672 pa_atomic_store(&s->on_the_fly, 0);
673
674 s->source_output->parent.process_msg = source_output_process_msg;
675 s->source_output->push = source_output_push_cb;
676 s->source_output->kill = source_output_kill_cb;
677 s->source_output->get_latency = source_output_get_latency_cb;
678 s->source_output->moving = source_output_moving_cb;
679 s->source_output->suspend = source_output_suspend_cb;
680 s->source_output->send_event = source_output_send_event_cb;
681 s->source_output->userdata = s;
682
683 fix_record_buffer_attr_pre(s);
684
685 s->memblockq = pa_memblockq_new(
686 0,
687 s->buffer_attr.maxlength,
688 0,
689 base = pa_frame_size(&source_output->sample_spec),
690 1,
691 0,
692 0,
693 NULL);
694
695 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
696 fix_record_buffer_attr_post(s);
697
698 *ss = s->source_output->sample_spec;
699 *map = s->source_output->channel_map;
700
701 pa_idxset_put(c->record_streams, s, &s->index);
702
703 pa_log_info("Final latency %0.2f ms = %0.2f ms + %0.2f ms",
704 ((double) pa_bytes_to_usec(s->buffer_attr.fragsize, &source_output->sample_spec) + (double) s->configured_source_latency) / PA_USEC_PER_MSEC,
705 (double) pa_bytes_to_usec(s->buffer_attr.fragsize, &source_output->sample_spec) / PA_USEC_PER_MSEC,
706 (double) s->configured_source_latency / PA_USEC_PER_MSEC);
707
708 pa_source_output_put(s->source_output);
709 return s;
710 }
711
712 /* Called from main context */
713 static void record_stream_send_killed(record_stream *r) {
714 pa_tagstruct *t;
715 record_stream_assert_ref(r);
716
717 t = pa_tagstruct_new(NULL, 0);
718 pa_tagstruct_putu32(t, PA_COMMAND_RECORD_STREAM_KILLED);
719 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
720 pa_tagstruct_putu32(t, r->index);
721 pa_pstream_send_tagstruct(r->connection->pstream, t);
722 }
723
724 /* Called from main context */
725 static void playback_stream_unlink(playback_stream *s) {
726 pa_assert(s);
727
728 if (!s->connection)
729 return;
730
731 if (s->sink_input) {
732 pa_sink_input_unlink(s->sink_input);
733 pa_sink_input_unref(s->sink_input);
734 s->sink_input = NULL;
735 }
736
737 if (s->drain_request)
738 pa_pstream_send_error(s->connection->pstream, s->drain_tag, PA_ERR_NOENTITY);
739
740 pa_assert_se(pa_idxset_remove_by_data(s->connection->output_streams, s, NULL) == s);
741 s->connection = NULL;
742 playback_stream_unref(s);
743 }
744
745 /* Called from main context */
746 static void playback_stream_free(pa_object* o) {
747 playback_stream *s = PLAYBACK_STREAM(o);
748 pa_assert(s);
749
750 playback_stream_unlink(s);
751
752 pa_memblockq_free(s->memblockq);
753 pa_xfree(s);
754 }
755
756 /* Called from main context */
757 static int playback_stream_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
758 playback_stream *s = PLAYBACK_STREAM(o);
759 playback_stream_assert_ref(s);
760
761 if (!s->connection)
762 return -1;
763
764 switch (code) {
765 case PLAYBACK_STREAM_MESSAGE_REQUEST_DATA: {
766 pa_tagstruct *t;
767 int l = 0;
768
769 for (;;) {
770 if ((l = pa_atomic_load(&s->missing)) <= 0)
771 return 0;
772
773 if (pa_atomic_cmpxchg(&s->missing, l, 0))
774 break;
775 }
776
777 t = pa_tagstruct_new(NULL, 0);
778 pa_tagstruct_putu32(t, PA_COMMAND_REQUEST);
779 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
780 pa_tagstruct_putu32(t, s->index);
781 pa_tagstruct_putu32(t, (uint32_t) l);
782 pa_pstream_send_tagstruct(s->connection->pstream, t);
783
784 /* pa_log("Requesting %lu bytes", (unsigned long) l); */
785 break;
786 }
787
788 case PLAYBACK_STREAM_MESSAGE_UNDERFLOW: {
789 pa_tagstruct *t;
790
791 /* pa_log("signalling underflow"); */
792
793 /* Report that we're empty */
794 t = pa_tagstruct_new(NULL, 0);
795 pa_tagstruct_putu32(t, PA_COMMAND_UNDERFLOW);
796 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
797 pa_tagstruct_putu32(t, s->index);
798 pa_pstream_send_tagstruct(s->connection->pstream, t);
799 break;
800 }
801
802 case PLAYBACK_STREAM_MESSAGE_OVERFLOW: {
803 pa_tagstruct *t;
804
805 /* Notify the user we're overflowed*/
806 t = pa_tagstruct_new(NULL, 0);
807 pa_tagstruct_putu32(t, PA_COMMAND_OVERFLOW);
808 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
809 pa_tagstruct_putu32(t, s->index);
810 pa_pstream_send_tagstruct(s->connection->pstream, t);
811 break;
812 }
813
814 case PLAYBACK_STREAM_MESSAGE_STARTED:
815
816 if (s->connection->version >= 13) {
817 pa_tagstruct *t;
818
819 /* Notify the user we started playback */
820 t = pa_tagstruct_new(NULL, 0);
821 pa_tagstruct_putu32(t, PA_COMMAND_STARTED);
822 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
823 pa_tagstruct_putu32(t, s->index);
824 pa_pstream_send_tagstruct(s->connection->pstream, t);
825 }
826
827 break;
828
829 case PLAYBACK_STREAM_MESSAGE_DRAIN_ACK:
830 pa_pstream_send_simple_ack(s->connection->pstream, PA_PTR_TO_UINT(userdata));
831 break;
832
833 case PLAYBACK_STREAM_MESSAGE_UPDATE_TLENGTH: {
834 pa_tagstruct *t;
835
836 s->buffer_attr.tlength = (uint32_t) offset;
837
838 t = pa_tagstruct_new(NULL, 0);
839 pa_tagstruct_putu32(t, PA_COMMAND_PLAYBACK_BUFFER_ATTR_CHANGED);
840 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
841 pa_tagstruct_putu32(t, s->index);
842 pa_tagstruct_putu32(t, s->buffer_attr.maxlength);
843 pa_tagstruct_putu32(t, s->buffer_attr.tlength);
844 pa_tagstruct_putu32(t, s->buffer_attr.prebuf);
845 pa_tagstruct_putu32(t, s->buffer_attr.minreq);
846 pa_tagstruct_put_usec(t, s->configured_sink_latency);
847 pa_pstream_send_tagstruct(s->connection->pstream, t);
848
849 break;
850 }
851 }
852
853 return 0;
854 }
855
856 /* Called from main context */
857 static void fix_playback_buffer_attr(playback_stream *s) {
858 size_t frame_size, max_prebuf;
859 pa_usec_t orig_tlength_usec, tlength_usec, orig_minreq_usec, minreq_usec, sink_usec;
860
861 pa_assert(s);
862
863 /* This function will be called from the main thread, before as
864 * well as after the sink input has been activated using
865 * pa_sink_input_put()! That means it may not touch any
866 * ->thread_info data, such as the memblockq! */
867
868 frame_size = pa_frame_size(&s->sink_input->sample_spec);
869
870 if (s->buffer_attr.maxlength == (uint32_t) -1 || s->buffer_attr.maxlength > MAX_MEMBLOCKQ_LENGTH)
871 s->buffer_attr.maxlength = MAX_MEMBLOCKQ_LENGTH;
872 if (s->buffer_attr.maxlength <= 0)
873 s->buffer_attr.maxlength = (uint32_t) frame_size;
874
875 if (s->buffer_attr.tlength == (uint32_t) -1)
876 s->buffer_attr.tlength = (uint32_t) pa_usec_to_bytes_round_up(DEFAULT_TLENGTH_MSEC*PA_USEC_PER_MSEC, &s->sink_input->sample_spec);
877 if (s->buffer_attr.tlength <= 0)
878 s->buffer_attr.tlength = (uint32_t) frame_size;
879
880 if (s->buffer_attr.minreq == (uint32_t) -1)
881 s->buffer_attr.minreq = (uint32_t) pa_usec_to_bytes_round_up(DEFAULT_PROCESS_MSEC*PA_USEC_PER_MSEC, &s->sink_input->sample_spec);
882 if (s->buffer_attr.minreq <= 0)
883 s->buffer_attr.minreq = (uint32_t) frame_size;
884
885 if (s->buffer_attr.tlength < s->buffer_attr.minreq+frame_size)
886 s->buffer_attr.tlength = s->buffer_attr.minreq+(uint32_t) frame_size;
887
888 orig_tlength_usec = tlength_usec = pa_bytes_to_usec(s->buffer_attr.tlength, &s->sink_input->sample_spec);
889 orig_minreq_usec = minreq_usec = pa_bytes_to_usec(s->buffer_attr.minreq, &s->sink_input->sample_spec);
890
891 pa_log_info("Requested tlength=%0.2f ms, minreq=%0.2f ms",
892 (double) tlength_usec / PA_USEC_PER_MSEC,
893 (double) minreq_usec / PA_USEC_PER_MSEC);
894
895 if (s->early_requests) {
896
897 /* In early request mode we need to emulate the classic
898 * fragment-based playback model. We do this setting the sink
899 * latency to the fragment size. */
900
901 sink_usec = minreq_usec;
902 pa_log_debug("Early requests mode enabled, configuring sink latency to minreq.");
903
904 } else if (s->adjust_latency) {
905
906 /* So, the user asked us to adjust the latency of the stream
907 * buffer according to the what the sink can provide. The
908 * tlength passed in shall be the overall latency. Roughly
909 * half the latency will be spent on the hw buffer, the other
910 * half of it in the async buffer queue we maintain for each
911 * client. In between we'll have a safety space of size
912 * 2*minreq. Why the 2*minreq? When the hw buffer is completey
913 * empty and needs to be filled, then our buffer must have
914 * enough data to fulfill this request immediatly and thus
915 * have at least the same tlength as the size of the hw
916 * buffer. It additionally needs space for 2 times minreq
917 * because if the buffer ran empty and a partial fillup
918 * happens immediately on the next iteration we need to be
919 * able to fulfill it and give the application also minreq
920 * time to fill it up again for the next request Makes 2 times
921 * minreq in plus.. */
922
923 if (tlength_usec > minreq_usec*2)
924 sink_usec = (tlength_usec - minreq_usec*2)/2;
925 else
926 sink_usec = 0;
927
928 pa_log_debug("Adjust latency mode enabled, configuring sink latency to half of overall latency.");
929
930 } else {
931
932 /* Ok, the user didn't ask us to adjust the latency, but we
933 * still need to make sure that the parameters from the user
934 * do make sense. */
935
936 if (tlength_usec > minreq_usec*2)
937 sink_usec = (tlength_usec - minreq_usec*2);
938 else
939 sink_usec = 0;
940
941 pa_log_debug("Traditional mode enabled, modifying sink usec only for compat with minreq.");
942 }
943
944 s->configured_sink_latency = pa_sink_input_set_requested_latency(s->sink_input, sink_usec);
945
946 if (s->early_requests) {
947
948 /* Ok, we didn't necessarily get what we were asking for, so
949 * let's tell the user */
950
951 minreq_usec = s->configured_sink_latency;
952
953 } else if (s->adjust_latency) {
954
955 /* Ok, we didn't necessarily get what we were asking for, so
956 * let's subtract from what we asked for for the remaining
957 * buffer space */
958
959 if (tlength_usec >= s->configured_sink_latency)
960 tlength_usec -= s->configured_sink_latency;
961 }
962
963 /* FIXME: This is actually larger than necessary, since not all of
964 * the sink latency is actually rewritable. */
965 if (tlength_usec < s->configured_sink_latency + 2*minreq_usec)
966 tlength_usec = s->configured_sink_latency + 2*minreq_usec;
967
968 if (pa_usec_to_bytes_round_up(orig_tlength_usec, &s->sink_input->sample_spec) !=
969 pa_usec_to_bytes_round_up(tlength_usec, &s->sink_input->sample_spec))
970 s->buffer_attr.tlength = (uint32_t) pa_usec_to_bytes_round_up(tlength_usec, &s->sink_input->sample_spec);
971
972 if (pa_usec_to_bytes(orig_minreq_usec, &s->sink_input->sample_spec) !=
973 pa_usec_to_bytes(minreq_usec, &s->sink_input->sample_spec))
974 s->buffer_attr.minreq = (uint32_t) pa_usec_to_bytes(minreq_usec, &s->sink_input->sample_spec);
975
976 if (s->buffer_attr.minreq <= 0) {
977 s->buffer_attr.minreq = (uint32_t) frame_size;
978 s->buffer_attr.tlength += (uint32_t) frame_size*2;
979 }
980
981 if (s->buffer_attr.tlength <= s->buffer_attr.minreq)
982 s->buffer_attr.tlength = s->buffer_attr.minreq*2 + (uint32_t) frame_size;
983
984 max_prebuf = s->buffer_attr.tlength + (uint32_t)frame_size - s->buffer_attr.minreq;
985
986 if (s->buffer_attr.prebuf == (uint32_t) -1 ||
987 s->buffer_attr.prebuf > max_prebuf)
988 s->buffer_attr.prebuf = max_prebuf;
989 }
990
991 /* Called from main context */
992 static playback_stream* playback_stream_new(
993 pa_native_connection *c,
994 pa_sink *sink,
995 pa_sample_spec *ss,
996 pa_channel_map *map,
997 pa_buffer_attr *a,
998 pa_cvolume *volume,
999 pa_bool_t muted,
1000 pa_bool_t muted_set,
1001 uint32_t syncid,
1002 uint32_t *missing,
1003 pa_sink_input_flags_t flags,
1004 pa_proplist *p,
1005 pa_bool_t adjust_latency,
1006 pa_bool_t early_requests,
1007 int *ret) {
1008
1009 playback_stream *s, *ssync;
1010 pa_sink_input *sink_input = NULL;
1011 pa_memchunk silence;
1012 uint32_t idx;
1013 int64_t start_index;
1014 pa_sink_input_new_data data;
1015
1016 pa_assert(c);
1017 pa_assert(ss);
1018 pa_assert(missing);
1019 pa_assert(p);
1020 pa_assert(ret);
1021
1022 /* Find syncid group */
1023 for (ssync = pa_idxset_first(c->output_streams, &idx); ssync; ssync = pa_idxset_next(c->output_streams, &idx)) {
1024
1025 if (!playback_stream_isinstance(ssync))
1026 continue;
1027
1028 if (ssync->syncid == syncid)
1029 break;
1030 }
1031
1032 /* Synced streams must connect to the same sink */
1033 if (ssync) {
1034
1035 if (!sink)
1036 sink = ssync->sink_input->sink;
1037 else if (sink != ssync->sink_input->sink) {
1038 *ret = PA_ERR_INVALID;
1039 return NULL;
1040 }
1041 }
1042
1043 pa_sink_input_new_data_init(&data);
1044
1045 pa_proplist_update(data.proplist, PA_UPDATE_REPLACE, p);
1046 data.driver = __FILE__;
1047 data.module = c->options->module;
1048 data.client = c->client;
1049 data.sink = sink;
1050 pa_sink_input_new_data_set_sample_spec(&data, ss);
1051 pa_sink_input_new_data_set_channel_map(&data, map);
1052 if (volume)
1053 pa_sink_input_new_data_set_volume(&data, volume);
1054 if (muted_set)
1055 pa_sink_input_new_data_set_muted(&data, muted);
1056 data.sync_base = ssync ? ssync->sink_input : NULL;
1057
1058 *ret = -pa_sink_input_new(&sink_input, c->protocol->core, &data, flags);
1059
1060 pa_sink_input_new_data_done(&data);
1061
1062 if (!sink_input)
1063 return NULL;
1064
1065 s = pa_msgobject_new(playback_stream);
1066 s->parent.parent.parent.free = playback_stream_free;
1067 s->parent.parent.process_msg = playback_stream_process_msg;
1068 s->connection = c;
1069 s->syncid = syncid;
1070 s->sink_input = sink_input;
1071 s->is_underrun = TRUE;
1072 s->drain_request = FALSE;
1073 pa_atomic_store(&s->missing, 0);
1074 s->buffer_attr = *a;
1075 s->adjust_latency = adjust_latency;
1076 s->early_requests = early_requests;
1077
1078 s->sink_input->parent.process_msg = sink_input_process_msg;
1079 s->sink_input->pop = sink_input_pop_cb;
1080 s->sink_input->process_rewind = sink_input_process_rewind_cb;
1081 s->sink_input->update_max_rewind = sink_input_update_max_rewind_cb;
1082 s->sink_input->update_max_request = sink_input_update_max_request_cb;
1083 s->sink_input->kill = sink_input_kill_cb;
1084 s->sink_input->moving = sink_input_moving_cb;
1085 s->sink_input->suspend = sink_input_suspend_cb;
1086 s->sink_input->send_event = sink_input_send_event_cb;
1087 s->sink_input->userdata = s;
1088
1089 start_index = ssync ? pa_memblockq_get_read_index(ssync->memblockq) : 0;
1090
1091 fix_playback_buffer_attr(s);
1092
1093 pa_sink_input_get_silence(sink_input, &silence);
1094 s->memblockq = pa_memblockq_new(
1095 start_index,
1096 s->buffer_attr.maxlength,
1097 s->buffer_attr.tlength,
1098 pa_frame_size(&sink_input->sample_spec),
1099 s->buffer_attr.prebuf,
1100 s->buffer_attr.minreq,
1101 0,
1102 &silence);
1103 pa_memblock_unref(silence.memblock);
1104
1105 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
1106
1107 *missing = (uint32_t) pa_memblockq_pop_missing(s->memblockq);
1108
1109 *ss = s->sink_input->sample_spec;
1110 *map = s->sink_input->channel_map;
1111
1112 pa_idxset_put(c->output_streams, s, &s->index);
1113
1114 pa_log_info("Final latency %0.2f ms = %0.2f ms + 2*%0.2f ms + %0.2f ms",
1115 ((double) pa_bytes_to_usec(s->buffer_attr.tlength, &sink_input->sample_spec) + (double) s->configured_sink_latency) / PA_USEC_PER_MSEC,
1116 (double) pa_bytes_to_usec(s->buffer_attr.tlength-s->buffer_attr.minreq*2, &sink_input->sample_spec) / PA_USEC_PER_MSEC,
1117 (double) pa_bytes_to_usec(s->buffer_attr.minreq, &sink_input->sample_spec) / PA_USEC_PER_MSEC,
1118 (double) s->configured_sink_latency / PA_USEC_PER_MSEC);
1119
1120 pa_sink_input_put(s->sink_input);
1121 return s;
1122 }
1123
1124 /* Called from IO context */
1125 static void playback_stream_request_bytes(playback_stream *s) {
1126 size_t m, minreq;
1127 int previous_missing;
1128
1129 playback_stream_assert_ref(s);
1130
1131 m = pa_memblockq_pop_missing(s->memblockq);
1132
1133 if (m <= 0)
1134 return;
1135
1136 /* pa_log("request_bytes(%lu)", (unsigned long) m); */
1137
1138 previous_missing = pa_atomic_add(&s->missing, (int) m);
1139 minreq = pa_memblockq_get_minreq(s->memblockq);
1140
1141 if (pa_memblockq_prebuf_active(s->memblockq) ||
1142 (previous_missing < (int) minreq && previous_missing + (int) m >= (int) minreq))
1143 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_REQUEST_DATA, NULL, 0, NULL, NULL);
1144 }
1145
1146
1147 /* Called from main context */
1148 static void playback_stream_send_killed(playback_stream *p) {
1149 pa_tagstruct *t;
1150 playback_stream_assert_ref(p);
1151
1152 t = pa_tagstruct_new(NULL, 0);
1153 pa_tagstruct_putu32(t, PA_COMMAND_PLAYBACK_STREAM_KILLED);
1154 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1155 pa_tagstruct_putu32(t, p->index);
1156 pa_pstream_send_tagstruct(p->connection->pstream, t);
1157 }
1158
1159 /* Called from main context */
1160 static int native_connection_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
1161 pa_native_connection *c = PA_NATIVE_CONNECTION(o);
1162 pa_native_connection_assert_ref(c);
1163
1164 if (!c->protocol)
1165 return -1;
1166
1167 switch (code) {
1168
1169 case CONNECTION_MESSAGE_REVOKE:
1170 pa_pstream_send_revoke(c->pstream, PA_PTR_TO_UINT(userdata));
1171 break;
1172
1173 case CONNECTION_MESSAGE_RELEASE:
1174 pa_pstream_send_release(c->pstream, PA_PTR_TO_UINT(userdata));
1175 break;
1176 }
1177
1178 return 0;
1179 }
1180
1181 /* Called from main context */
1182 static void native_connection_unlink(pa_native_connection *c) {
1183 record_stream *r;
1184 output_stream *o;
1185
1186 pa_assert(c);
1187
1188 if (!c->protocol)
1189 return;
1190
1191 pa_hook_fire(&c->protocol->hooks[PA_NATIVE_HOOK_CONNECTION_UNLINK], c);
1192
1193 if (c->options)
1194 pa_native_options_unref(c->options);
1195
1196 while ((r = pa_idxset_first(c->record_streams, NULL)))
1197 record_stream_unlink(r);
1198
1199 while ((o = pa_idxset_first(c->output_streams, NULL)))
1200 if (playback_stream_isinstance(o))
1201 playback_stream_unlink(PLAYBACK_STREAM(o));
1202 else
1203 upload_stream_unlink(UPLOAD_STREAM(o));
1204
1205 if (c->subscription)
1206 pa_subscription_free(c->subscription);
1207
1208 if (c->pstream)
1209 pa_pstream_unlink(c->pstream);
1210
1211 if (c->auth_timeout_event) {
1212 c->protocol->core->mainloop->time_free(c->auth_timeout_event);
1213 c->auth_timeout_event = NULL;
1214 }
1215
1216 pa_assert_se(pa_idxset_remove_by_data(c->protocol->connections, c, NULL) == c);
1217 c->protocol = NULL;
1218 pa_native_connection_unref(c);
1219 }
1220
1221 /* Called from main context */
1222 static void native_connection_free(pa_object *o) {
1223 pa_native_connection *c = PA_NATIVE_CONNECTION(o);
1224
1225 pa_assert(c);
1226
1227 native_connection_unlink(c);
1228
1229 pa_idxset_free(c->record_streams, NULL, NULL);
1230 pa_idxset_free(c->output_streams, NULL, NULL);
1231
1232 pa_pdispatch_unref(c->pdispatch);
1233 pa_pstream_unref(c->pstream);
1234 pa_client_free(c->client);
1235
1236 pa_xfree(c);
1237 }
1238
1239 /* Called from main context */
1240 static void native_connection_send_memblock(pa_native_connection *c) {
1241 uint32_t start;
1242 record_stream *r;
1243
1244 start = PA_IDXSET_INVALID;
1245 for (;;) {
1246 pa_memchunk chunk;
1247
1248 if (!(r = RECORD_STREAM(pa_idxset_rrobin(c->record_streams, &c->rrobin_index))))
1249 return;
1250
1251 if (start == PA_IDXSET_INVALID)
1252 start = c->rrobin_index;
1253 else if (start == c->rrobin_index)
1254 return;
1255
1256 if (pa_memblockq_peek(r->memblockq, &chunk) >= 0) {
1257 pa_memchunk schunk = chunk;
1258
1259 if (schunk.length > r->buffer_attr.fragsize)
1260 schunk.length = r->buffer_attr.fragsize;
1261
1262 pa_pstream_send_memblock(c->pstream, r->index, 0, PA_SEEK_RELATIVE, &schunk);
1263
1264 pa_memblockq_drop(r->memblockq, schunk.length);
1265 pa_memblock_unref(schunk.memblock);
1266
1267 return;
1268 }
1269 }
1270 }
1271
1272 /*** sink input callbacks ***/
1273
1274 /* Called from thread context */
1275 static void handle_seek(playback_stream *s, int64_t indexw) {
1276 playback_stream_assert_ref(s);
1277
1278 /* pa_log("handle_seek: %llu -- %i", (unsigned long long) s->sink_input->thread_info.underrun_for, pa_memblockq_is_readable(s->memblockq)); */
1279
1280 if (s->sink_input->thread_info.underrun_for > 0) {
1281
1282 /* pa_log("%lu vs. %lu", (unsigned long) pa_memblockq_get_length(s->memblockq), (unsigned long) pa_memblockq_get_prebuf(s->memblockq)); */
1283
1284 if (pa_memblockq_is_readable(s->memblockq)) {
1285
1286 /* We just ended an underrun, let's ask the sink
1287 * for a complete rewind rewrite */
1288
1289 pa_log_debug("Requesting rewind due to end of underrun.");
1290 pa_sink_input_request_rewind(s->sink_input,
1291 (size_t) (s->sink_input->thread_info.underrun_for == (size_t) -1 ? 0 : s->sink_input->thread_info.underrun_for),
1292 FALSE, TRUE, FALSE);
1293 }
1294
1295 } else {
1296 int64_t indexr;
1297
1298 indexr = pa_memblockq_get_read_index(s->memblockq);
1299
1300 if (indexw < indexr) {
1301 /* OK, the sink already asked for this data, so
1302 * let's have it usk us again */
1303
1304 pa_log_debug("Requesting rewind due to rewrite.");
1305 pa_sink_input_request_rewind(s->sink_input, (size_t) (indexr - indexw), TRUE, FALSE, FALSE);
1306 }
1307 }
1308
1309 playback_stream_request_bytes(s);
1310 }
1311
1312 /* Called from thread context */
1313 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
1314 pa_sink_input *i = PA_SINK_INPUT(o);
1315 playback_stream *s;
1316
1317 pa_sink_input_assert_ref(i);
1318 s = PLAYBACK_STREAM(i->userdata);
1319 playback_stream_assert_ref(s);
1320
1321 switch (code) {
1322
1323 case SINK_INPUT_MESSAGE_SEEK: {
1324 int64_t windex;
1325
1326 windex = pa_memblockq_get_write_index(s->memblockq);
1327
1328 /* The client side is incapable of accounting correctly
1329 * for seeks of a type != PA_SEEK_RELATIVE. We need to be
1330 * able to deal with that. */
1331
1332 pa_memblockq_seek(s->memblockq, offset, PA_PTR_TO_UINT(userdata), PA_PTR_TO_UINT(userdata) == PA_SEEK_RELATIVE);
1333
1334 handle_seek(s, windex);
1335 return 0;
1336 }
1337
1338 case SINK_INPUT_MESSAGE_POST_DATA: {
1339 int64_t windex;
1340
1341 pa_assert(chunk);
1342
1343 windex = pa_memblockq_get_write_index(s->memblockq);
1344
1345 /* pa_log("sink input post: %lu %lli", (unsigned long) chunk->length, (long long) windex); */
1346
1347 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) {
1348 pa_log_warn("Failed to push data into queue");
1349 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_OVERFLOW, NULL, 0, NULL, NULL);
1350 pa_memblockq_seek(s->memblockq, (int64_t) chunk->length, PA_SEEK_RELATIVE, TRUE);
1351 }
1352
1353 handle_seek(s, windex);
1354
1355 /* pa_log("sink input post2: %lu", (unsigned long) pa_memblockq_get_length(s->memblockq)); */
1356
1357 return 0;
1358 }
1359
1360 case SINK_INPUT_MESSAGE_DRAIN:
1361 case SINK_INPUT_MESSAGE_FLUSH:
1362 case SINK_INPUT_MESSAGE_PREBUF_FORCE:
1363 case SINK_INPUT_MESSAGE_TRIGGER: {
1364
1365 int64_t windex;
1366 pa_sink_input *isync;
1367 void (*func)(pa_memblockq *bq);
1368
1369 switch (code) {
1370 case SINK_INPUT_MESSAGE_FLUSH:
1371 func = pa_memblockq_flush_write;
1372 break;
1373
1374 case SINK_INPUT_MESSAGE_PREBUF_FORCE:
1375 func = pa_memblockq_prebuf_force;
1376 break;
1377
1378 case SINK_INPUT_MESSAGE_DRAIN:
1379 case SINK_INPUT_MESSAGE_TRIGGER:
1380 func = pa_memblockq_prebuf_disable;
1381 break;
1382
1383 default:
1384 pa_assert_not_reached();
1385 }
1386
1387 windex = pa_memblockq_get_write_index(s->memblockq);
1388 func(s->memblockq);
1389 handle_seek(s, windex);
1390
1391 /* Do the same for all other members in the sync group */
1392 for (isync = i->sync_prev; isync; isync = isync->sync_prev) {
1393 playback_stream *ssync = PLAYBACK_STREAM(isync->userdata);
1394 windex = pa_memblockq_get_write_index(ssync->memblockq);
1395 func(ssync->memblockq);
1396 handle_seek(ssync, windex);
1397 }
1398
1399 for (isync = i->sync_next; isync; isync = isync->sync_next) {
1400 playback_stream *ssync = PLAYBACK_STREAM(isync->userdata);
1401 windex = pa_memblockq_get_write_index(ssync->memblockq);
1402 func(ssync->memblockq);
1403 handle_seek(ssync, windex);
1404 }
1405
1406 if (code == SINK_INPUT_MESSAGE_DRAIN) {
1407 if (!pa_memblockq_is_readable(s->memblockq))
1408 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_DRAIN_ACK, userdata, 0, NULL, NULL);
1409 else {
1410 s->drain_tag = PA_PTR_TO_UINT(userdata);
1411 s->drain_request = TRUE;
1412 }
1413 }
1414
1415 return 0;
1416 }
1417
1418 case SINK_INPUT_MESSAGE_UPDATE_LATENCY:
1419 /* Atomically get a snapshot of all timing parameters... */
1420 s->read_index = pa_memblockq_get_read_index(s->memblockq);
1421 s->write_index = pa_memblockq_get_write_index(s->memblockq);
1422 s->render_memblockq_length = pa_memblockq_get_length(s->sink_input->thread_info.render_memblockq);
1423 s->current_sink_latency = pa_sink_get_latency_within_thread(s->sink_input->sink);
1424 s->underrun_for = s->sink_input->thread_info.underrun_for;
1425 s->playing_for = s->sink_input->thread_info.playing_for;
1426
1427 return 0;
1428
1429 case PA_SINK_INPUT_MESSAGE_SET_STATE: {
1430 int64_t windex;
1431
1432 windex = pa_memblockq_get_write_index(s->memblockq);
1433
1434 pa_memblockq_prebuf_force(s->memblockq);
1435
1436 handle_seek(s, windex);
1437
1438 /* Fall through to the default handler */
1439 break;
1440 }
1441
1442 case PA_SINK_INPUT_MESSAGE_GET_LATENCY: {
1443 pa_usec_t *r = userdata;
1444
1445 *r = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &i->sample_spec);
1446
1447 /* Fall through, the default handler will add in the extra
1448 * latency added by the resampler */
1449 break;
1450 }
1451
1452 case SINK_INPUT_MESSAGE_UPDATE_BUFFER_ATTR: {
1453 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr);
1454 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
1455 return 0;
1456 }
1457 }
1458
1459 return pa_sink_input_process_msg(o, code, userdata, offset, chunk);
1460 }
1461
1462 /* Called from thread context */
1463 static int sink_input_pop_cb(pa_sink_input *i, size_t nbytes, pa_memchunk *chunk) {
1464 playback_stream *s;
1465
1466 pa_sink_input_assert_ref(i);
1467 s = PLAYBACK_STREAM(i->userdata);
1468 playback_stream_assert_ref(s);
1469 pa_assert(chunk);
1470
1471 /* pa_log("%s, pop(): %lu", pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME), (unsigned long) pa_memblockq_get_length(s->memblockq)); */
1472
1473 if (pa_memblockq_is_readable(s->memblockq))
1474 s->is_underrun = FALSE;
1475 else {
1476 if (!s->is_underrun)
1477 pa_log_debug("Underrun on '%s', %lu bytes in queue.", pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME)), (unsigned long) pa_memblockq_get_length(s->memblockq));
1478
1479 if (s->drain_request && pa_sink_input_safe_to_remove(i)) {
1480 s->drain_request = FALSE;
1481 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_DRAIN_ACK, PA_UINT_TO_PTR(s->drain_tag), 0, NULL, NULL);
1482 } else if (!s->is_underrun)
1483 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_UNDERFLOW, NULL, 0, NULL, NULL);
1484
1485 s->is_underrun = TRUE;
1486
1487 playback_stream_request_bytes(s);
1488 }
1489
1490 /* This call will not fail with prebuf=0, hence we check for
1491 underrun explicitly above */
1492 if (pa_memblockq_peek(s->memblockq, chunk) < 0)
1493 return -1;
1494
1495 chunk->length = PA_MIN(nbytes, chunk->length);
1496
1497 if (i->thread_info.underrun_for > 0)
1498 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_STARTED, NULL, 0, NULL, NULL);
1499
1500 pa_memblockq_drop(s->memblockq, chunk->length);
1501 playback_stream_request_bytes(s);
1502
1503 return 0;
1504 }
1505
1506 /* Called from thread context */
1507 static void sink_input_process_rewind_cb(pa_sink_input *i, size_t nbytes) {
1508 playback_stream *s;
1509
1510 pa_sink_input_assert_ref(i);
1511 s = PLAYBACK_STREAM(i->userdata);
1512 playback_stream_assert_ref(s);
1513
1514 /* If we are in an underrun, then we don't rewind */
1515 if (i->thread_info.underrun_for > 0)
1516 return;
1517
1518 pa_memblockq_rewind(s->memblockq, nbytes);
1519 }
1520
1521 /* Called from thread context */
1522 static void sink_input_update_max_rewind_cb(pa_sink_input *i, size_t nbytes) {
1523 playback_stream *s;
1524
1525 pa_sink_input_assert_ref(i);
1526 s = PLAYBACK_STREAM(i->userdata);
1527 playback_stream_assert_ref(s);
1528
1529 pa_memblockq_set_maxrewind(s->memblockq, nbytes);
1530 }
1531
1532 /* Called from thread context */
1533 static void sink_input_update_max_request_cb(pa_sink_input *i, size_t nbytes) {
1534 playback_stream *s;
1535 size_t new_tlength, old_tlength;
1536
1537 pa_sink_input_assert_ref(i);
1538 s = PLAYBACK_STREAM(i->userdata);
1539 playback_stream_assert_ref(s);
1540
1541 old_tlength = pa_memblockq_get_tlength(s->memblockq);
1542 new_tlength = nbytes+2*pa_memblockq_get_minreq(s->memblockq);
1543
1544 if (old_tlength < new_tlength) {
1545 pa_log_debug("max_request changed, trying to update from %zu to %zu.", old_tlength, new_tlength);
1546 pa_memblockq_set_tlength(s->memblockq, new_tlength);
1547 new_tlength = pa_memblockq_get_tlength(s->memblockq);
1548
1549 if (new_tlength == old_tlength)
1550 pa_log_debug("Failed to increase tlength");
1551 else {
1552 pa_log_debug("Notifying client about increased tlength");
1553 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_UPDATE_TLENGTH, NULL, pa_memblockq_get_tlength(s->memblockq), NULL, NULL);
1554 }
1555 }
1556 }
1557
1558 /* Called from main context */
1559 static void sink_input_kill_cb(pa_sink_input *i) {
1560 playback_stream *s;
1561
1562 pa_sink_input_assert_ref(i);
1563 s = PLAYBACK_STREAM(i->userdata);
1564 playback_stream_assert_ref(s);
1565
1566 playback_stream_send_killed(s);
1567 playback_stream_unlink(s);
1568 }
1569
1570 /* Called from main context */
1571 static void sink_input_send_event_cb(pa_sink_input *i, const char *event, pa_proplist *pl) {
1572 playback_stream *s;
1573 pa_tagstruct *t;
1574
1575 pa_sink_input_assert_ref(i);
1576 s = PLAYBACK_STREAM(i->userdata);
1577 playback_stream_assert_ref(s);
1578
1579 if (s->connection->version < 15)
1580 return;
1581
1582 t = pa_tagstruct_new(NULL, 0);
1583 pa_tagstruct_putu32(t, PA_COMMAND_PLAYBACK_STREAM_EVENT);
1584 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1585 pa_tagstruct_putu32(t, s->index);
1586 pa_tagstruct_puts(t, event);
1587 pa_tagstruct_put_proplist(t, pl);
1588 pa_pstream_send_tagstruct(s->connection->pstream, t);
1589 }
1590
1591 /* Called from main context */
1592 static void sink_input_suspend_cb(pa_sink_input *i, pa_bool_t suspend) {
1593 playback_stream *s;
1594 pa_tagstruct *t;
1595
1596 pa_sink_input_assert_ref(i);
1597 s = PLAYBACK_STREAM(i->userdata);
1598 playback_stream_assert_ref(s);
1599
1600 if (s->connection->version < 12)
1601 return;
1602
1603 t = pa_tagstruct_new(NULL, 0);
1604 pa_tagstruct_putu32(t, PA_COMMAND_PLAYBACK_STREAM_SUSPENDED);
1605 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1606 pa_tagstruct_putu32(t, s->index);
1607 pa_tagstruct_put_boolean(t, suspend);
1608 pa_pstream_send_tagstruct(s->connection->pstream, t);
1609 }
1610
1611 /* Called from main context */
1612 static void sink_input_moving_cb(pa_sink_input *i, pa_sink *dest) {
1613 playback_stream *s;
1614 pa_tagstruct *t;
1615
1616 pa_sink_input_assert_ref(i);
1617 s = PLAYBACK_STREAM(i->userdata);
1618 playback_stream_assert_ref(s);
1619
1620 fix_playback_buffer_attr(s);
1621 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr);
1622 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
1623
1624 if (s->connection->version < 12)
1625 return;
1626
1627 t = pa_tagstruct_new(NULL, 0);
1628 pa_tagstruct_putu32(t, PA_COMMAND_PLAYBACK_STREAM_MOVED);
1629 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1630 pa_tagstruct_putu32(t, s->index);
1631 pa_tagstruct_putu32(t, dest->index);
1632 pa_tagstruct_puts(t, dest->name);
1633 pa_tagstruct_put_boolean(t, pa_sink_get_state(dest) == PA_SINK_SUSPENDED);
1634
1635 if (s->connection->version >= 13) {
1636 pa_tagstruct_putu32(t, s->buffer_attr.maxlength);
1637 pa_tagstruct_putu32(t, s->buffer_attr.tlength);
1638 pa_tagstruct_putu32(t, s->buffer_attr.prebuf);
1639 pa_tagstruct_putu32(t, s->buffer_attr.minreq);
1640 pa_tagstruct_put_usec(t, s->configured_sink_latency);
1641 }
1642
1643 pa_pstream_send_tagstruct(s->connection->pstream, t);
1644 }
1645
1646 /*** source_output callbacks ***/
1647
1648 /* Called from thread context */
1649 static int source_output_process_msg(pa_msgobject *_o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
1650 pa_source_output *o = PA_SOURCE_OUTPUT(_o);
1651 record_stream *s;
1652
1653 pa_source_output_assert_ref(o);
1654 s = RECORD_STREAM(o->userdata);
1655 record_stream_assert_ref(s);
1656
1657 switch (code) {
1658 case SOURCE_OUTPUT_MESSAGE_UPDATE_LATENCY:
1659 /* Atomically get a snapshot of all timing parameters... */
1660 s->current_monitor_latency = o->source->monitor_of ? pa_sink_get_latency_within_thread(o->source->monitor_of) : 0;
1661 s->current_source_latency = pa_source_get_latency_within_thread(o->source);
1662 s->on_the_fly_snapshot = pa_atomic_load(&s->on_the_fly);
1663 return 0;
1664 }
1665
1666 return pa_source_output_process_msg(_o, code, userdata, offset, chunk);
1667 }
1668
1669 /* Called from thread context */
1670 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk) {
1671 record_stream *s;
1672
1673 pa_source_output_assert_ref(o);
1674 s = RECORD_STREAM(o->userdata);
1675 record_stream_assert_ref(s);
1676 pa_assert(chunk);
1677
1678 pa_atomic_add(&s->on_the_fly, chunk->length);
1679 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), RECORD_STREAM_MESSAGE_POST_DATA, NULL, 0, chunk, NULL);
1680 }
1681
1682 static void source_output_kill_cb(pa_source_output *o) {
1683 record_stream *s;
1684
1685 pa_source_output_assert_ref(o);
1686 s = RECORD_STREAM(o->userdata);
1687 record_stream_assert_ref(s);
1688
1689 record_stream_send_killed(s);
1690 record_stream_unlink(s);
1691 }
1692
1693 static pa_usec_t source_output_get_latency_cb(pa_source_output *o) {
1694 record_stream *s;
1695
1696 pa_source_output_assert_ref(o);
1697 s = RECORD_STREAM(o->userdata);
1698 record_stream_assert_ref(s);
1699
1700 /*pa_log("get_latency: %u", pa_memblockq_get_length(s->memblockq));*/
1701
1702 return pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &o->sample_spec);
1703 }
1704
1705 /* Called from main context */
1706 static void source_output_send_event_cb(pa_source_output *o, const char *event, pa_proplist *pl) {
1707 record_stream *s;
1708 pa_tagstruct *t;
1709
1710 pa_source_output_assert_ref(o);
1711 s = RECORD_STREAM(o->userdata);
1712 record_stream_assert_ref(s);
1713
1714 if (s->connection->version < 15)
1715 return;
1716
1717 t = pa_tagstruct_new(NULL, 0);
1718 pa_tagstruct_putu32(t, PA_COMMAND_RECORD_STREAM_EVENT);
1719 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1720 pa_tagstruct_putu32(t, s->index);
1721 pa_tagstruct_puts(t, event);
1722 pa_tagstruct_put_proplist(t, pl);
1723 pa_pstream_send_tagstruct(s->connection->pstream, t);
1724 }
1725
1726 /* Called from main context */
1727 static void source_output_suspend_cb(pa_source_output *o, pa_bool_t suspend) {
1728 record_stream *s;
1729 pa_tagstruct *t;
1730
1731 pa_source_output_assert_ref(o);
1732 s = RECORD_STREAM(o->userdata);
1733 record_stream_assert_ref(s);
1734
1735 if (s->connection->version < 12)
1736 return;
1737
1738 t = pa_tagstruct_new(NULL, 0);
1739 pa_tagstruct_putu32(t, PA_COMMAND_RECORD_STREAM_SUSPENDED);
1740 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1741 pa_tagstruct_putu32(t, s->index);
1742 pa_tagstruct_put_boolean(t, suspend);
1743 pa_pstream_send_tagstruct(s->connection->pstream, t);
1744 }
1745
1746 /* Called from main context */
1747 static void source_output_moving_cb(pa_source_output *o, pa_source *dest) {
1748 record_stream *s;
1749 pa_tagstruct *t;
1750
1751 pa_source_output_assert_ref(o);
1752 s = RECORD_STREAM(o->userdata);
1753 record_stream_assert_ref(s);
1754
1755 fix_record_buffer_attr_pre(s);
1756 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength);
1757 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
1758 fix_record_buffer_attr_post(s);
1759
1760 if (s->connection->version < 12)
1761 return;
1762
1763 t = pa_tagstruct_new(NULL, 0);
1764 pa_tagstruct_putu32(t, PA_COMMAND_RECORD_STREAM_MOVED);
1765 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
1766 pa_tagstruct_putu32(t, s->index);
1767 pa_tagstruct_putu32(t, dest->index);
1768 pa_tagstruct_puts(t, dest->name);
1769 pa_tagstruct_put_boolean(t, pa_source_get_state(dest) == PA_SOURCE_SUSPENDED);
1770
1771 if (s->connection->version >= 13) {
1772 pa_tagstruct_putu32(t, s->buffer_attr.maxlength);
1773 pa_tagstruct_putu32(t, s->buffer_attr.fragsize);
1774 pa_tagstruct_put_usec(t, s->configured_source_latency);
1775 }
1776
1777 pa_pstream_send_tagstruct(s->connection->pstream, t);
1778 }
1779
1780 /*** pdispatch callbacks ***/
1781
1782 static void protocol_error(pa_native_connection *c) {
1783 pa_log("protocol error, kicking client");
1784 native_connection_unlink(c);
1785 }
1786
1787 #define CHECK_VALIDITY(pstream, expression, tag, error) do { \
1788 if (!(expression)) { \
1789 pa_pstream_send_error((pstream), (tag), (error)); \
1790 return; \
1791 } \
1792 } while(0);
1793
1794 static pa_tagstruct *reply_new(uint32_t tag) {
1795 pa_tagstruct *reply;
1796
1797 reply = pa_tagstruct_new(NULL, 0);
1798 pa_tagstruct_putu32(reply, PA_COMMAND_REPLY);
1799 pa_tagstruct_putu32(reply, tag);
1800 return reply;
1801 }
1802
1803 static void command_create_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
1804 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
1805 playback_stream *s;
1806 uint32_t sink_index, syncid, missing;
1807 pa_buffer_attr attr;
1808 const char *name = NULL, *sink_name;
1809 pa_sample_spec ss;
1810 pa_channel_map map;
1811 pa_tagstruct *reply;
1812 pa_sink *sink = NULL;
1813 pa_cvolume volume;
1814 pa_bool_t
1815 corked = FALSE,
1816 no_remap = FALSE,
1817 no_remix = FALSE,
1818 fix_format = FALSE,
1819 fix_rate = FALSE,
1820 fix_channels = FALSE,
1821 no_move = FALSE,
1822 variable_rate = FALSE,
1823 muted = FALSE,
1824 adjust_latency = FALSE,
1825 early_requests = FALSE,
1826 dont_inhibit_auto_suspend = FALSE,
1827 muted_set = FALSE,
1828 fail_on_suspend = FALSE;
1829 pa_sink_input_flags_t flags = 0;
1830 pa_proplist *p;
1831 pa_bool_t volume_set = TRUE;
1832 int ret = PA_ERR_INVALID;
1833
1834 pa_native_connection_assert_ref(c);
1835 pa_assert(t);
1836 memset(&attr, 0, sizeof(attr));
1837
1838 if ((c->version < 13 && (pa_tagstruct_gets(t, &name) < 0 || !name)) ||
1839 pa_tagstruct_get(
1840 t,
1841 PA_TAG_SAMPLE_SPEC, &ss,
1842 PA_TAG_CHANNEL_MAP, &map,
1843 PA_TAG_U32, &sink_index,
1844 PA_TAG_STRING, &sink_name,
1845 PA_TAG_U32, &attr.maxlength,
1846 PA_TAG_BOOLEAN, &corked,
1847 PA_TAG_U32, &attr.tlength,
1848 PA_TAG_U32, &attr.prebuf,
1849 PA_TAG_U32, &attr.minreq,
1850 PA_TAG_U32, &syncid,
1851 PA_TAG_CVOLUME, &volume,
1852 PA_TAG_INVALID) < 0) {
1853
1854 protocol_error(c);
1855 return;
1856 }
1857
1858 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
1859 CHECK_VALIDITY(c->pstream, !sink_name || pa_namereg_is_valid_name(sink_name), tag, PA_ERR_INVALID);
1860 CHECK_VALIDITY(c->pstream, sink_index == PA_INVALID_INDEX || !sink_name, tag, PA_ERR_INVALID);
1861 CHECK_VALIDITY(c->pstream, !sink_name || sink_index == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
1862 CHECK_VALIDITY(c->pstream, pa_channel_map_valid(&map), tag, PA_ERR_INVALID);
1863 CHECK_VALIDITY(c->pstream, pa_sample_spec_valid(&ss), tag, PA_ERR_INVALID);
1864 CHECK_VALIDITY(c->pstream, pa_cvolume_valid(&volume), tag, PA_ERR_INVALID);
1865 CHECK_VALIDITY(c->pstream, map.channels == ss.channels && volume.channels == ss.channels, tag, PA_ERR_INVALID);
1866
1867 p = pa_proplist_new();
1868
1869 if (name)
1870 pa_proplist_sets(p, PA_PROP_MEDIA_NAME, name);
1871
1872 if (c->version >= 12) {
1873 /* Since 0.9.8 the user can ask for a couple of additional flags */
1874
1875 if (pa_tagstruct_get_boolean(t, &no_remap) < 0 ||
1876 pa_tagstruct_get_boolean(t, &no_remix) < 0 ||
1877 pa_tagstruct_get_boolean(t, &fix_format) < 0 ||
1878 pa_tagstruct_get_boolean(t, &fix_rate) < 0 ||
1879 pa_tagstruct_get_boolean(t, &fix_channels) < 0 ||
1880 pa_tagstruct_get_boolean(t, &no_move) < 0 ||
1881 pa_tagstruct_get_boolean(t, &variable_rate) < 0) {
1882
1883 protocol_error(c);
1884 pa_proplist_free(p);
1885 return;
1886 }
1887 }
1888
1889 if (c->version >= 13) {
1890
1891 if (pa_tagstruct_get_boolean(t, &muted) < 0 ||
1892 pa_tagstruct_get_boolean(t, &adjust_latency) < 0 ||
1893 pa_tagstruct_get_proplist(t, p) < 0) {
1894 protocol_error(c);
1895 pa_proplist_free(p);
1896 return;
1897 }
1898 }
1899
1900 if (c->version >= 14) {
1901
1902 if (pa_tagstruct_get_boolean(t, &volume_set) < 0 ||
1903 pa_tagstruct_get_boolean(t, &early_requests) < 0) {
1904 protocol_error(c);
1905 pa_proplist_free(p);
1906 return;
1907 }
1908 }
1909
1910 if (c->version >= 15) {
1911
1912 if (pa_tagstruct_get_boolean(t, &muted_set) < 0 ||
1913 pa_tagstruct_get_boolean(t, &dont_inhibit_auto_suspend) < 0 ||
1914 pa_tagstruct_get_boolean(t, &fail_on_suspend) < 0) {
1915 protocol_error(c);
1916 pa_proplist_free(p);
1917 return;
1918 }
1919 }
1920
1921 if (!pa_tagstruct_eof(t)) {
1922 protocol_error(c);
1923 pa_proplist_free(p);
1924 return;
1925 }
1926
1927 if (sink_index != PA_INVALID_INDEX) {
1928
1929 if (!(sink = pa_idxset_get_by_index(c->protocol->core->sinks, sink_index))) {
1930 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
1931 pa_proplist_free(p);
1932 return;
1933 }
1934
1935 } else if (sink_name) {
1936
1937 if (!(sink = pa_namereg_get(c->protocol->core, sink_name, PA_NAMEREG_SINK))) {
1938 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
1939 pa_proplist_free(p);
1940 return;
1941 }
1942 }
1943
1944 flags =
1945 (corked ? PA_SINK_INPUT_START_CORKED : 0) |
1946 (no_remap ? PA_SINK_INPUT_NO_REMAP : 0) |
1947 (no_remix ? PA_SINK_INPUT_NO_REMIX : 0) |
1948 (fix_format ? PA_SINK_INPUT_FIX_FORMAT : 0) |
1949 (fix_rate ? PA_SINK_INPUT_FIX_RATE : 0) |
1950 (fix_channels ? PA_SINK_INPUT_FIX_CHANNELS : 0) |
1951 (no_move ? PA_SINK_INPUT_DONT_MOVE : 0) |
1952 (variable_rate ? PA_SINK_INPUT_VARIABLE_RATE : 0) |
1953 (dont_inhibit_auto_suspend ? PA_SINK_INPUT_DONT_INHIBIT_AUTO_SUSPEND : 0) |
1954 (fail_on_suspend ? PA_SINK_INPUT_FAIL_ON_SUSPEND : 0);
1955
1956 /* Only since protocol version 15 there's a seperate muted_set
1957 * flag. For older versions we synthesize it here */
1958 muted_set = muted_set || muted;
1959
1960 s = playback_stream_new(c, sink, &ss, &map, &attr, volume_set ? &volume : NULL, muted, muted_set, syncid, &missing, flags, p, adjust_latency, early_requests, &ret);
1961 pa_proplist_free(p);
1962
1963 CHECK_VALIDITY(c->pstream, s, tag, ret);
1964
1965 reply = reply_new(tag);
1966 pa_tagstruct_putu32(reply, s->index);
1967 pa_assert(s->sink_input);
1968 pa_tagstruct_putu32(reply, s->sink_input->index);
1969 pa_tagstruct_putu32(reply, missing);
1970
1971 /* pa_log("initial request is %u", missing); */
1972
1973 if (c->version >= 9) {
1974 /* Since 0.9.0 we support sending the buffer metrics back to the client */
1975
1976 pa_tagstruct_putu32(reply, (uint32_t) s->buffer_attr.maxlength);
1977 pa_tagstruct_putu32(reply, (uint32_t) s->buffer_attr.tlength);
1978 pa_tagstruct_putu32(reply, (uint32_t) s->buffer_attr.prebuf);
1979 pa_tagstruct_putu32(reply, (uint32_t) s->buffer_attr.minreq);
1980 }
1981
1982 if (c->version >= 12) {
1983 /* Since 0.9.8 we support sending the chosen sample
1984 * spec/channel map/device/suspend status back to the
1985 * client */
1986
1987 pa_tagstruct_put_sample_spec(reply, &ss);
1988 pa_tagstruct_put_channel_map(reply, &map);
1989
1990 pa_tagstruct_putu32(reply, s->sink_input->sink->index);
1991 pa_tagstruct_puts(reply, s->sink_input->sink->name);
1992
1993 pa_tagstruct_put_boolean(reply, pa_sink_get_state(s->sink_input->sink) == PA_SINK_SUSPENDED);
1994 }
1995
1996 if (c->version >= 13)
1997 pa_tagstruct_put_usec(reply, s->configured_sink_latency);
1998
1999 pa_pstream_send_tagstruct(c->pstream, reply);
2000 }
2001
2002 static void command_delete_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2003 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2004 uint32_t channel;
2005
2006 pa_native_connection_assert_ref(c);
2007 pa_assert(t);
2008
2009 if (pa_tagstruct_getu32(t, &channel) < 0 ||
2010 !pa_tagstruct_eof(t)) {
2011 protocol_error(c);
2012 return;
2013 }
2014
2015 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2016
2017 switch (command) {
2018
2019 case PA_COMMAND_DELETE_PLAYBACK_STREAM: {
2020 playback_stream *s;
2021 if (!(s = pa_idxset_get_by_index(c->output_streams, channel)) || !playback_stream_isinstance(s)) {
2022 pa_pstream_send_error(c->pstream, tag, PA_ERR_EXIST);
2023 return;
2024 }
2025
2026 playback_stream_unlink(s);
2027 break;
2028 }
2029
2030 case PA_COMMAND_DELETE_RECORD_STREAM: {
2031 record_stream *s;
2032 if (!(s = pa_idxset_get_by_index(c->record_streams, channel))) {
2033 pa_pstream_send_error(c->pstream, tag, PA_ERR_EXIST);
2034 return;
2035 }
2036
2037 record_stream_unlink(s);
2038 break;
2039 }
2040
2041 case PA_COMMAND_DELETE_UPLOAD_STREAM: {
2042 upload_stream *s;
2043
2044 if (!(s = pa_idxset_get_by_index(c->output_streams, channel)) || !upload_stream_isinstance(s)) {
2045 pa_pstream_send_error(c->pstream, tag, PA_ERR_EXIST);
2046 return;
2047 }
2048
2049 upload_stream_unlink(s);
2050 break;
2051 }
2052
2053 default:
2054 pa_assert_not_reached();
2055 }
2056
2057 pa_pstream_send_simple_ack(c->pstream, tag);
2058 }
2059
2060 static void command_create_record_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2061 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2062 record_stream *s;
2063 pa_buffer_attr attr;
2064 uint32_t source_index;
2065 const char *name = NULL, *source_name;
2066 pa_sample_spec ss;
2067 pa_channel_map map;
2068 pa_tagstruct *reply;
2069 pa_source *source = NULL;
2070 pa_bool_t
2071 corked = FALSE,
2072 no_remap = FALSE,
2073 no_remix = FALSE,
2074 fix_format = FALSE,
2075 fix_rate = FALSE,
2076 fix_channels = FALSE,
2077 no_move = FALSE,
2078 variable_rate = FALSE,
2079 adjust_latency = FALSE,
2080 peak_detect = FALSE,
2081 early_requests = FALSE,
2082 dont_inhibit_auto_suspend = FALSE,
2083 fail_on_suspend = FALSE;
2084 pa_source_output_flags_t flags = 0;
2085 pa_proplist *p;
2086 uint32_t direct_on_input_idx = PA_INVALID_INDEX;
2087 pa_sink_input *direct_on_input = NULL;
2088 int ret = PA_ERR_INVALID;
2089
2090 pa_native_connection_assert_ref(c);
2091 pa_assert(t);
2092
2093 memset(&attr, 0, sizeof(attr));
2094
2095 if ((c->version < 13 && (pa_tagstruct_gets(t, &name) < 0 || !name)) ||
2096 pa_tagstruct_get_sample_spec(t, &ss) < 0 ||
2097 pa_tagstruct_get_channel_map(t, &map) < 0 ||
2098 pa_tagstruct_getu32(t, &source_index) < 0 ||
2099 pa_tagstruct_gets(t, &source_name) < 0 ||
2100 pa_tagstruct_getu32(t, &attr.maxlength) < 0 ||
2101 pa_tagstruct_get_boolean(t, &corked) < 0 ||
2102 pa_tagstruct_getu32(t, &attr.fragsize) < 0) {
2103 protocol_error(c);
2104 return;
2105 }
2106
2107 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2108 CHECK_VALIDITY(c->pstream, !source_name || pa_namereg_is_valid_name(source_name), tag, PA_ERR_INVALID);
2109 CHECK_VALIDITY(c->pstream, source_index == PA_INVALID_INDEX || !source_name, tag, PA_ERR_INVALID);
2110 CHECK_VALIDITY(c->pstream, !source_name || source_index == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
2111 CHECK_VALIDITY(c->pstream, pa_sample_spec_valid(&ss), tag, PA_ERR_INVALID);
2112 CHECK_VALIDITY(c->pstream, pa_channel_map_valid(&map), tag, PA_ERR_INVALID);
2113 CHECK_VALIDITY(c->pstream, map.channels == ss.channels, tag, PA_ERR_INVALID);
2114
2115 p = pa_proplist_new();
2116
2117 if (name)
2118 pa_proplist_sets(p, PA_PROP_MEDIA_NAME, name);
2119
2120 if (c->version >= 12) {
2121 /* Since 0.9.8 the user can ask for a couple of additional flags */
2122
2123 if (pa_tagstruct_get_boolean(t, &no_remap) < 0 ||
2124 pa_tagstruct_get_boolean(t, &no_remix) < 0 ||
2125 pa_tagstruct_get_boolean(t, &fix_format) < 0 ||
2126 pa_tagstruct_get_boolean(t, &fix_rate) < 0 ||
2127 pa_tagstruct_get_boolean(t, &fix_channels) < 0 ||
2128 pa_tagstruct_get_boolean(t, &no_move) < 0 ||
2129 pa_tagstruct_get_boolean(t, &variable_rate) < 0) {
2130
2131 protocol_error(c);
2132 pa_proplist_free(p);
2133 return;
2134 }
2135 }
2136
2137 if (c->version >= 13) {
2138
2139 if (pa_tagstruct_get_boolean(t, &peak_detect) < 0 ||
2140 pa_tagstruct_get_boolean(t, &adjust_latency) < 0 ||
2141 pa_tagstruct_get_proplist(t, p) < 0 ||
2142 pa_tagstruct_getu32(t, &direct_on_input_idx) < 0) {
2143 protocol_error(c);
2144 pa_proplist_free(p);
2145 return;
2146 }
2147 }
2148
2149 if (c->version >= 14) {
2150
2151 if (pa_tagstruct_get_boolean(t, &early_requests) < 0) {
2152 protocol_error(c);
2153 pa_proplist_free(p);
2154 return;
2155 }
2156 }
2157
2158 if (c->version >= 15) {
2159
2160 if (pa_tagstruct_get_boolean(t, &dont_inhibit_auto_suspend) < 0 ||
2161 pa_tagstruct_get_boolean(t, &fail_on_suspend) < 0) {
2162 protocol_error(c);
2163 pa_proplist_free(p);
2164 return;
2165 }
2166 }
2167
2168 if (!pa_tagstruct_eof(t)) {
2169 protocol_error(c);
2170 pa_proplist_free(p);
2171 return;
2172 }
2173
2174 if (source_index != PA_INVALID_INDEX) {
2175
2176 if (!(source = pa_idxset_get_by_index(c->protocol->core->sources, source_index))) {
2177 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
2178 pa_proplist_free(p);
2179 return;
2180 }
2181
2182 } else if (source_name) {
2183
2184 if (!(source = pa_namereg_get(c->protocol->core, source_name, PA_NAMEREG_SOURCE))) {
2185 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
2186 pa_proplist_free(p);
2187 return;
2188 }
2189 }
2190
2191 if (direct_on_input_idx != PA_INVALID_INDEX) {
2192
2193 if (!(direct_on_input = pa_idxset_get_by_index(c->protocol->core->sink_inputs, direct_on_input_idx))) {
2194 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
2195 pa_proplist_free(p);
2196 return;
2197 }
2198 }
2199
2200 flags =
2201 (corked ? PA_SOURCE_OUTPUT_START_CORKED : 0) |
2202 (no_remap ? PA_SOURCE_OUTPUT_NO_REMAP : 0) |
2203 (no_remix ? PA_SOURCE_OUTPUT_NO_REMIX : 0) |
2204 (fix_format ? PA_SOURCE_OUTPUT_FIX_FORMAT : 0) |
2205 (fix_rate ? PA_SOURCE_OUTPUT_FIX_RATE : 0) |
2206 (fix_channels ? PA_SOURCE_OUTPUT_FIX_CHANNELS : 0) |
2207 (no_move ? PA_SOURCE_OUTPUT_DONT_MOVE : 0) |
2208 (variable_rate ? PA_SOURCE_OUTPUT_VARIABLE_RATE : 0) |
2209 (dont_inhibit_auto_suspend ? PA_SOURCE_OUTPUT_DONT_INHIBIT_AUTO_SUSPEND : 0) |
2210 (fail_on_suspend ? PA_SOURCE_OUTPUT_FAIL_ON_SUSPEND : 0);
2211
2212 s = record_stream_new(c, source, &ss, &map, peak_detect, &attr, flags, p, adjust_latency, direct_on_input, early_requests, &ret);
2213 pa_proplist_free(p);
2214
2215 CHECK_VALIDITY(c->pstream, s, tag, ret);
2216
2217 reply = reply_new(tag);
2218 pa_tagstruct_putu32(reply, s->index);
2219 pa_assert(s->source_output);
2220 pa_tagstruct_putu32(reply, s->source_output->index);
2221
2222 if (c->version >= 9) {
2223 /* Since 0.9 we support sending the buffer metrics back to the client */
2224
2225 pa_tagstruct_putu32(reply, (uint32_t) s->buffer_attr.maxlength);
2226 pa_tagstruct_putu32(reply, (uint32_t) s->buffer_attr.fragsize);
2227 }
2228
2229 if (c->version >= 12) {
2230 /* Since 0.9.8 we support sending the chosen sample
2231 * spec/channel map/device/suspend status back to the
2232 * client */
2233
2234 pa_tagstruct_put_sample_spec(reply, &ss);
2235 pa_tagstruct_put_channel_map(reply, &map);
2236
2237 pa_tagstruct_putu32(reply, s->source_output->source->index);
2238 pa_tagstruct_puts(reply, s->source_output->source->name);
2239
2240 pa_tagstruct_put_boolean(reply, pa_source_get_state(s->source_output->source) == PA_SOURCE_SUSPENDED);
2241 }
2242
2243 if (c->version >= 13)
2244 pa_tagstruct_put_usec(reply, s->configured_source_latency);
2245
2246 pa_pstream_send_tagstruct(c->pstream, reply);
2247 }
2248
2249 static void command_exit(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2250 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2251 int ret;
2252
2253 pa_native_connection_assert_ref(c);
2254 pa_assert(t);
2255
2256 if (!pa_tagstruct_eof(t)) {
2257 protocol_error(c);
2258 return;
2259 }
2260
2261 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2262 ret = pa_core_exit(c->protocol->core, FALSE, 0);
2263 CHECK_VALIDITY(c->pstream, ret >= 0, tag, PA_ERR_ACCESS);
2264
2265 pa_pstream_send_simple_ack(c->pstream, tag); /* nonsense */
2266 }
2267
2268 static void command_auth(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2269 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2270 const void*cookie;
2271 pa_tagstruct *reply;
2272 pa_bool_t shm_on_remote = FALSE, do_shm;
2273
2274 pa_native_connection_assert_ref(c);
2275 pa_assert(t);
2276
2277 if (pa_tagstruct_getu32(t, &c->version) < 0 ||
2278 pa_tagstruct_get_arbitrary(t, &cookie, PA_NATIVE_COOKIE_LENGTH) < 0 ||
2279 !pa_tagstruct_eof(t)) {
2280 protocol_error(c);
2281 return;
2282 }
2283
2284 /* Minimum supported version */
2285 if (c->version < 8) {
2286 pa_pstream_send_error(c->pstream, tag, PA_ERR_VERSION);
2287 return;
2288 }
2289
2290 /* Starting with protocol version 13 the MSB of the version tag
2291 reflects if shm is available for this pa_native_connection or
2292 not. */
2293 if (c->version >= 13) {
2294 shm_on_remote = !!(c->version & 0x80000000U);
2295 c->version &= 0x7FFFFFFFU;
2296 }
2297
2298 pa_log_debug("Protocol version: remote %u, local %u", c->version, PA_PROTOCOL_VERSION);
2299
2300 pa_proplist_setf(c->client->proplist, "native-protocol.version", "%u", c->version);
2301
2302 if (!c->authorized) {
2303 pa_bool_t success = FALSE;
2304
2305 #ifdef HAVE_CREDS
2306 const pa_creds *creds;
2307
2308 if ((creds = pa_pdispatch_creds(pd))) {
2309 if (creds->uid == getuid())
2310 success = TRUE;
2311 else if (c->options->auth_group) {
2312 int r;
2313 gid_t gid;
2314
2315 if ((gid = pa_get_gid_of_group(c->options->auth_group)) == (gid_t) -1)
2316 pa_log_warn("Failed to get GID of group '%s'", c->options->auth_group);
2317 else if (gid == creds->gid)
2318 success = TRUE;
2319
2320 if (!success) {
2321 if ((r = pa_uid_in_group(creds->uid, c->options->auth_group)) < 0)
2322 pa_log_warn("Failed to check group membership.");
2323 else if (r > 0)
2324 success = TRUE;
2325 }
2326 }
2327
2328 pa_log_info("Got credentials: uid=%lu gid=%lu success=%i",
2329 (unsigned long) creds->uid,
2330 (unsigned long) creds->gid,
2331 (int) success);
2332 }
2333 #endif
2334
2335 if (!success && c->options->auth_cookie) {
2336 const uint8_t *ac;
2337
2338 if ((ac = pa_auth_cookie_read(c->options->auth_cookie, PA_NATIVE_COOKIE_LENGTH)))
2339 if (memcmp(ac, cookie, PA_NATIVE_COOKIE_LENGTH) == 0)
2340 success = TRUE;
2341 }
2342
2343 if (!success) {
2344 pa_log_warn("Denied access to client with invalid authorization data.");
2345 pa_pstream_send_error(c->pstream, tag, PA_ERR_ACCESS);
2346 return;
2347 }
2348
2349 c->authorized = TRUE;
2350 if (c->auth_timeout_event) {
2351 c->protocol->core->mainloop->time_free(c->auth_timeout_event);
2352 c->auth_timeout_event = NULL;
2353 }
2354 }
2355
2356 /* Enable shared memory support if possible */
2357 do_shm =
2358 pa_mempool_is_shared(c->protocol->core->mempool) &&
2359 c->is_local;
2360
2361 pa_log_debug("SHM possible: %s", pa_yes_no(do_shm));
2362
2363 if (do_shm)
2364 if (c->version < 10 || (c->version >= 13 && !shm_on_remote))
2365 do_shm = FALSE;
2366
2367 #ifdef HAVE_CREDS
2368 if (do_shm) {
2369 /* Only enable SHM if both sides are owned by the same
2370 * user. This is a security measure because otherwise data
2371 * private to the user might leak. */
2372
2373 const pa_creds *creds;
2374 if (!(creds = pa_pdispatch_creds(pd)) || getuid() != creds->uid)
2375 do_shm = FALSE;
2376 }
2377 #endif
2378
2379 pa_log_debug("Negotiated SHM: %s", pa_yes_no(do_shm));
2380 pa_pstream_enable_shm(c->pstream, do_shm);
2381
2382 reply = reply_new(tag);
2383 pa_tagstruct_putu32(reply, PA_PROTOCOL_VERSION | (do_shm ? 0x80000000 : 0));
2384
2385 #ifdef HAVE_CREDS
2386 {
2387 /* SHM support is only enabled after both sides made sure they are the same user. */
2388
2389 pa_creds ucred;
2390
2391 ucred.uid = getuid();
2392 ucred.gid = getgid();
2393
2394 pa_pstream_send_tagstruct_with_creds(c->pstream, reply, &ucred);
2395 }
2396 #else
2397 pa_pstream_send_tagstruct(c->pstream, reply);
2398 #endif
2399 }
2400
2401 static void command_set_client_name(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2402 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2403 const char *name = NULL;
2404 pa_proplist *p;
2405 pa_tagstruct *reply;
2406
2407 pa_native_connection_assert_ref(c);
2408 pa_assert(t);
2409
2410 p = pa_proplist_new();
2411
2412 if ((c->version < 13 && pa_tagstruct_gets(t, &name) < 0) ||
2413 (c->version >= 13 && pa_tagstruct_get_proplist(t, p) < 0) ||
2414 !pa_tagstruct_eof(t)) {
2415
2416 protocol_error(c);
2417 pa_proplist_free(p);
2418 return;
2419 }
2420
2421 if (name)
2422 if (pa_proplist_sets(p, PA_PROP_APPLICATION_NAME, name) < 0) {
2423 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
2424 pa_proplist_free(p);
2425 return;
2426 }
2427
2428 pa_client_update_proplist(c->client, PA_UPDATE_REPLACE, p);
2429 pa_proplist_free(p);
2430
2431 reply = reply_new(tag);
2432
2433 if (c->version >= 13)
2434 pa_tagstruct_putu32(reply, c->client->index);
2435
2436 pa_pstream_send_tagstruct(c->pstream, reply);
2437 }
2438
2439 static void command_lookup(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2440 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2441 const char *name;
2442 uint32_t idx = PA_IDXSET_INVALID;
2443
2444 pa_native_connection_assert_ref(c);
2445 pa_assert(t);
2446
2447 if (pa_tagstruct_gets(t, &name) < 0 ||
2448 !pa_tagstruct_eof(t)) {
2449 protocol_error(c);
2450 return;
2451 }
2452
2453 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2454 CHECK_VALIDITY(c->pstream, name && pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
2455
2456 if (command == PA_COMMAND_LOOKUP_SINK) {
2457 pa_sink *sink;
2458 if ((sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK)))
2459 idx = sink->index;
2460 } else {
2461 pa_source *source;
2462 pa_assert(command == PA_COMMAND_LOOKUP_SOURCE);
2463 if ((source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE)))
2464 idx = source->index;
2465 }
2466
2467 if (idx == PA_IDXSET_INVALID)
2468 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
2469 else {
2470 pa_tagstruct *reply;
2471 reply = reply_new(tag);
2472 pa_tagstruct_putu32(reply, idx);
2473 pa_pstream_send_tagstruct(c->pstream, reply);
2474 }
2475 }
2476
2477 static void command_drain_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2478 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2479 uint32_t idx;
2480 playback_stream *s;
2481
2482 pa_native_connection_assert_ref(c);
2483 pa_assert(t);
2484
2485 if (pa_tagstruct_getu32(t, &idx) < 0 ||
2486 !pa_tagstruct_eof(t)) {
2487 protocol_error(c);
2488 return;
2489 }
2490
2491 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2492 s = pa_idxset_get_by_index(c->output_streams, idx);
2493 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
2494 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
2495
2496 pa_asyncmsgq_post(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_DRAIN, PA_UINT_TO_PTR(tag), 0, NULL, NULL);
2497 }
2498
2499 static void command_stat(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2500 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2501 pa_tagstruct *reply;
2502 const pa_mempool_stat *stat;
2503
2504 pa_native_connection_assert_ref(c);
2505 pa_assert(t);
2506
2507 if (!pa_tagstruct_eof(t)) {
2508 protocol_error(c);
2509 return;
2510 }
2511
2512 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2513
2514 stat = pa_mempool_get_stat(c->protocol->core->mempool);
2515
2516 reply = reply_new(tag);
2517 pa_tagstruct_putu32(reply, (uint32_t) pa_atomic_load(&stat->n_allocated));
2518 pa_tagstruct_putu32(reply, (uint32_t) pa_atomic_load(&stat->allocated_size));
2519 pa_tagstruct_putu32(reply, (uint32_t) pa_atomic_load(&stat->n_accumulated));
2520 pa_tagstruct_putu32(reply, (uint32_t) pa_atomic_load(&stat->accumulated_size));
2521 pa_tagstruct_putu32(reply, (uint32_t) pa_scache_total_size(c->protocol->core));
2522 pa_pstream_send_tagstruct(c->pstream, reply);
2523 }
2524
2525 static void command_get_playback_latency(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2526 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2527 pa_tagstruct *reply;
2528 playback_stream *s;
2529 struct timeval tv, now;
2530 uint32_t idx;
2531
2532 pa_native_connection_assert_ref(c);
2533 pa_assert(t);
2534
2535 if (pa_tagstruct_getu32(t, &idx) < 0 ||
2536 pa_tagstruct_get_timeval(t, &tv) < 0 ||
2537 !pa_tagstruct_eof(t)) {
2538 protocol_error(c);
2539 return;
2540 }
2541
2542 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2543 s = pa_idxset_get_by_index(c->output_streams, idx);
2544 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
2545 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
2546
2547 /* Get an atomic snapshot of all timing parameters */
2548 pa_assert_se(pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_UPDATE_LATENCY, s, 0, NULL) == 0);
2549
2550 reply = reply_new(tag);
2551 pa_tagstruct_put_usec(reply,
2552 s->current_sink_latency +
2553 pa_bytes_to_usec(s->render_memblockq_length, &s->sink_input->sink->sample_spec));
2554 pa_tagstruct_put_usec(reply, 0);
2555 pa_tagstruct_put_boolean(reply,
2556 s->playing_for > 0 &&
2557 pa_sink_get_state(s->sink_input->sink) == PA_SINK_RUNNING &&
2558 pa_sink_input_get_state(s->sink_input) == PA_SINK_INPUT_RUNNING);
2559 pa_tagstruct_put_timeval(reply, &tv);
2560 pa_tagstruct_put_timeval(reply, pa_gettimeofday(&now));
2561 pa_tagstruct_puts64(reply, s->write_index);
2562 pa_tagstruct_puts64(reply, s->read_index);
2563
2564 if (c->version >= 13) {
2565 pa_tagstruct_putu64(reply, s->underrun_for);
2566 pa_tagstruct_putu64(reply, s->playing_for);
2567 }
2568
2569 pa_pstream_send_tagstruct(c->pstream, reply);
2570 }
2571
2572 static void command_get_record_latency(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2573 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2574 pa_tagstruct *reply;
2575 record_stream *s;
2576 struct timeval tv, now;
2577 uint32_t idx;
2578
2579 pa_native_connection_assert_ref(c);
2580 pa_assert(t);
2581
2582 if (pa_tagstruct_getu32(t, &idx) < 0 ||
2583 pa_tagstruct_get_timeval(t, &tv) < 0 ||
2584 !pa_tagstruct_eof(t)) {
2585 protocol_error(c);
2586 return;
2587 }
2588
2589 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2590 s = pa_idxset_get_by_index(c->record_streams, idx);
2591 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
2592
2593 /* Get an atomic snapshot of all timing parameters */
2594 pa_assert_se(pa_asyncmsgq_send(s->source_output->source->asyncmsgq, PA_MSGOBJECT(s->source_output), SOURCE_OUTPUT_MESSAGE_UPDATE_LATENCY, s, 0, NULL) == 0);
2595
2596 reply = reply_new(tag);
2597 pa_tagstruct_put_usec(reply, s->current_monitor_latency);
2598 pa_tagstruct_put_usec(reply,
2599 s->current_source_latency +
2600 pa_bytes_to_usec(s->on_the_fly_snapshot, &s->source_output->sample_spec));
2601 pa_tagstruct_put_boolean(reply,
2602 pa_source_get_state(s->source_output->source) == PA_SOURCE_RUNNING &&
2603 pa_source_output_get_state(s->source_output) == PA_SOURCE_OUTPUT_RUNNING);
2604 pa_tagstruct_put_timeval(reply, &tv);
2605 pa_tagstruct_put_timeval(reply, pa_gettimeofday(&now));
2606 pa_tagstruct_puts64(reply, pa_memblockq_get_write_index(s->memblockq));
2607 pa_tagstruct_puts64(reply, pa_memblockq_get_read_index(s->memblockq));
2608 pa_pstream_send_tagstruct(c->pstream, reply);
2609 }
2610
2611 static void command_create_upload_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2612 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2613 upload_stream *s;
2614 uint32_t length;
2615 const char *name = NULL;
2616 pa_sample_spec ss;
2617 pa_channel_map map;
2618 pa_tagstruct *reply;
2619 pa_proplist *p;
2620
2621 pa_native_connection_assert_ref(c);
2622 pa_assert(t);
2623
2624 if (pa_tagstruct_gets(t, &name) < 0 ||
2625 pa_tagstruct_get_sample_spec(t, &ss) < 0 ||
2626 pa_tagstruct_get_channel_map(t, &map) < 0 ||
2627 pa_tagstruct_getu32(t, &length) < 0) {
2628 protocol_error(c);
2629 return;
2630 }
2631
2632 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2633 CHECK_VALIDITY(c->pstream, pa_sample_spec_valid(&ss), tag, PA_ERR_INVALID);
2634 CHECK_VALIDITY(c->pstream, pa_channel_map_valid(&map), tag, PA_ERR_INVALID);
2635 CHECK_VALIDITY(c->pstream, map.channels == ss.channels, tag, PA_ERR_INVALID);
2636 CHECK_VALIDITY(c->pstream, (length % pa_frame_size(&ss)) == 0 && length > 0, tag, PA_ERR_INVALID);
2637 CHECK_VALIDITY(c->pstream, length <= PA_SCACHE_ENTRY_SIZE_MAX, tag, PA_ERR_TOOLARGE);
2638
2639 p = pa_proplist_new();
2640
2641 if ((c->version >= 13 && pa_tagstruct_get_proplist(t, p) < 0) ||
2642 !pa_tagstruct_eof(t)) {
2643
2644 protocol_error(c);
2645 pa_proplist_free(p);
2646 return;
2647 }
2648
2649 if (c->version < 13)
2650 pa_proplist_sets(p, PA_PROP_MEDIA_NAME, name);
2651 else if (!name)
2652 if (!(name = pa_proplist_gets(p, PA_PROP_EVENT_ID)))
2653 name = pa_proplist_gets(p, PA_PROP_MEDIA_NAME);
2654
2655 if (!name || !pa_namereg_is_valid_name(name)) {
2656 pa_proplist_free(p);
2657 CHECK_VALIDITY(c->pstream, FALSE, tag, PA_ERR_INVALID);
2658 }
2659
2660 s = upload_stream_new(c, &ss, &map, name, length, p);
2661 pa_proplist_free(p);
2662
2663 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_INVALID);
2664
2665 reply = reply_new(tag);
2666 pa_tagstruct_putu32(reply, s->index);
2667 pa_tagstruct_putu32(reply, length);
2668 pa_pstream_send_tagstruct(c->pstream, reply);
2669 }
2670
2671 static void command_finish_upload_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2672 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2673 uint32_t channel;
2674 upload_stream *s;
2675 uint32_t idx;
2676
2677 pa_native_connection_assert_ref(c);
2678 pa_assert(t);
2679
2680 if (pa_tagstruct_getu32(t, &channel) < 0 ||
2681 !pa_tagstruct_eof(t)) {
2682 protocol_error(c);
2683 return;
2684 }
2685
2686 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2687
2688 s = pa_idxset_get_by_index(c->output_streams, channel);
2689 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
2690 CHECK_VALIDITY(c->pstream, upload_stream_isinstance(s), tag, PA_ERR_NOENTITY);
2691
2692 if (!s->memchunk.memblock)
2693 pa_pstream_send_error(c->pstream, tag, PA_ERR_TOOLARGE);
2694 else if (pa_scache_add_item(c->protocol->core, s->name, &s->sample_spec, &s->channel_map, &s->memchunk, s->proplist, &idx) < 0)
2695 pa_pstream_send_error(c->pstream, tag, PA_ERR_INTERNAL);
2696 else
2697 pa_pstream_send_simple_ack(c->pstream, tag);
2698
2699 upload_stream_unlink(s);
2700 }
2701
2702 static void command_play_sample(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2703 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2704 uint32_t sink_index;
2705 pa_volume_t volume;
2706 pa_sink *sink;
2707 const char *name, *sink_name;
2708 uint32_t idx;
2709 pa_proplist *p;
2710 pa_tagstruct *reply;
2711
2712 pa_native_connection_assert_ref(c);
2713 pa_assert(t);
2714
2715 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2716
2717 if (pa_tagstruct_getu32(t, &sink_index) < 0 ||
2718 pa_tagstruct_gets(t, &sink_name) < 0 ||
2719 pa_tagstruct_getu32(t, &volume) < 0 ||
2720 pa_tagstruct_gets(t, &name) < 0) {
2721 protocol_error(c);
2722 return;
2723 }
2724
2725 CHECK_VALIDITY(c->pstream, !sink_name || pa_namereg_is_valid_name(sink_name), tag, PA_ERR_INVALID);
2726 CHECK_VALIDITY(c->pstream, sink_index == PA_INVALID_INDEX || !sink_name, tag, PA_ERR_INVALID);
2727 CHECK_VALIDITY(c->pstream, !sink_name || sink_index == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
2728 CHECK_VALIDITY(c->pstream, name && pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
2729
2730 if (sink_index != PA_INVALID_INDEX)
2731 sink = pa_idxset_get_by_index(c->protocol->core->sinks, sink_index);
2732 else
2733 sink = pa_namereg_get(c->protocol->core, sink_name, PA_NAMEREG_SINK);
2734
2735 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY);
2736
2737 p = pa_proplist_new();
2738
2739 if ((c->version >= 13 && pa_tagstruct_get_proplist(t, p) < 0) ||
2740 !pa_tagstruct_eof(t)) {
2741 protocol_error(c);
2742 pa_proplist_free(p);
2743 return;
2744 }
2745
2746 pa_proplist_update(p, PA_UPDATE_MERGE, c->client->proplist);
2747
2748 if (pa_scache_play_item(c->protocol->core, name, sink, volume, p, &idx) < 0) {
2749 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
2750 pa_proplist_free(p);
2751 return;
2752 }
2753
2754 pa_proplist_free(p);
2755
2756 reply = reply_new(tag);
2757
2758 if (c->version >= 13)
2759 pa_tagstruct_putu32(reply, idx);
2760
2761 pa_pstream_send_tagstruct(c->pstream, reply);
2762 }
2763
2764 static void command_remove_sample(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
2765 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
2766 const char *name;
2767
2768 pa_native_connection_assert_ref(c);
2769 pa_assert(t);
2770
2771 if (pa_tagstruct_gets(t, &name) < 0 ||
2772 !pa_tagstruct_eof(t)) {
2773 protocol_error(c);
2774 return;
2775 }
2776
2777 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
2778 CHECK_VALIDITY(c->pstream, name && pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
2779
2780 if (pa_scache_remove_item(c->protocol->core, name) < 0) {
2781 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
2782 return;
2783 }
2784
2785 pa_pstream_send_simple_ack(c->pstream, tag);
2786 }
2787
2788 static void fixup_sample_spec(pa_native_connection *c, pa_sample_spec *fixed, const pa_sample_spec *original) {
2789 pa_assert(c);
2790 pa_assert(fixed);
2791 pa_assert(original);
2792
2793 *fixed = *original;
2794
2795 if (c->version < 12) {
2796 /* Before protocol version 12 we didn't support S32 samples,
2797 * so we need to lie about this to the client */
2798
2799 if (fixed->format == PA_SAMPLE_S32LE)
2800 fixed->format = PA_SAMPLE_FLOAT32LE;
2801 if (fixed->format == PA_SAMPLE_S32BE)
2802 fixed->format = PA_SAMPLE_FLOAT32BE;
2803 }
2804
2805 if (c->version < 15) {
2806 if (fixed->format == PA_SAMPLE_S24LE || fixed->format == PA_SAMPLE_S24_32LE)
2807 fixed->format = PA_SAMPLE_FLOAT32LE;
2808 if (fixed->format == PA_SAMPLE_S24BE || fixed->format == PA_SAMPLE_S24_32BE)
2809 fixed->format = PA_SAMPLE_FLOAT32BE;
2810 }
2811 }
2812
2813 static void sink_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_sink *sink) {
2814 pa_sample_spec fixed_ss;
2815
2816 pa_assert(t);
2817 pa_sink_assert_ref(sink);
2818
2819 fixup_sample_spec(c, &fixed_ss, &sink->sample_spec);
2820
2821 pa_tagstruct_put(
2822 t,
2823 PA_TAG_U32, sink->index,
2824 PA_TAG_STRING, sink->name,
2825 PA_TAG_STRING, pa_strnull(pa_proplist_gets(sink->proplist, PA_PROP_DEVICE_DESCRIPTION)),
2826 PA_TAG_SAMPLE_SPEC, &fixed_ss,
2827 PA_TAG_CHANNEL_MAP, &sink->channel_map,
2828 PA_TAG_U32, sink->module ? sink->module->index : PA_INVALID_INDEX,
2829 PA_TAG_CVOLUME, pa_sink_get_volume(sink, FALSE, FALSE),
2830 PA_TAG_BOOLEAN, pa_sink_get_mute(sink, FALSE),
2831 PA_TAG_U32, sink->monitor_source ? sink->monitor_source->index : PA_INVALID_INDEX,
2832 PA_TAG_STRING, sink->monitor_source ? sink->monitor_source->name : NULL,
2833 PA_TAG_USEC, pa_sink_get_latency(sink),
2834 PA_TAG_STRING, sink->driver,
2835 PA_TAG_U32, sink->flags,
2836 PA_TAG_INVALID);
2837
2838 if (c->version >= 13) {
2839 pa_tagstruct_put_proplist(t, sink->proplist);
2840 pa_tagstruct_put_usec(t, pa_sink_get_requested_latency(sink));
2841 }
2842
2843 if (c->version >= 15) {
2844 pa_tagstruct_put_volume(t, sink->base_volume);
2845 if (PA_UNLIKELY(pa_sink_get_state(sink) == PA_SINK_INVALID_STATE))
2846 pa_log_error("Internal sink state is invalid.");
2847 pa_tagstruct_putu32(t, pa_sink_get_state(sink));
2848 pa_tagstruct_putu32(t, sink->n_volume_steps);
2849 pa_tagstruct_putu32(t, sink->card ? sink->card->index : PA_INVALID_INDEX);
2850 }
2851
2852 if (c->version >= 16) {
2853 pa_tagstruct_putu32(t, sink->ports ? pa_hashmap_size(sink->ports) : 0);
2854
2855 if (sink->ports) {
2856 void *state;
2857 pa_device_port *p;
2858
2859 PA_HASHMAP_FOREACH(p, sink->ports, state) {
2860 pa_tagstruct_puts(t, p->name);
2861 pa_tagstruct_puts(t, p->description);
2862 pa_tagstruct_putu32(t, p->priority);
2863 }
2864 }
2865
2866 pa_tagstruct_puts(t, sink->active_port ? sink->active_port->name : NULL);
2867 }
2868 }
2869
2870 static void source_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_source *source) {
2871 pa_sample_spec fixed_ss;
2872
2873 pa_assert(t);
2874 pa_source_assert_ref(source);
2875
2876 fixup_sample_spec(c, &fixed_ss, &source->sample_spec);
2877
2878 pa_tagstruct_put(
2879 t,
2880 PA_TAG_U32, source->index,
2881 PA_TAG_STRING, source->name,
2882 PA_TAG_STRING, pa_strnull(pa_proplist_gets(source->proplist, PA_PROP_DEVICE_DESCRIPTION)),
2883 PA_TAG_SAMPLE_SPEC, &fixed_ss,
2884 PA_TAG_CHANNEL_MAP, &source->channel_map,
2885 PA_TAG_U32, source->module ? source->module->index : PA_INVALID_INDEX,
2886 PA_TAG_CVOLUME, pa_source_get_volume(source, FALSE),
2887 PA_TAG_BOOLEAN, pa_source_get_mute(source, FALSE),
2888 PA_TAG_U32, source->monitor_of ? source->monitor_of->index : PA_INVALID_INDEX,
2889 PA_TAG_STRING, source->monitor_of ? source->monitor_of->name : NULL,
2890 PA_TAG_USEC, pa_source_get_latency(source),
2891 PA_TAG_STRING, source->driver,
2892 PA_TAG_U32, source->flags,
2893 PA_TAG_INVALID);
2894
2895 if (c->version >= 13) {
2896 pa_tagstruct_put_proplist(t, source->proplist);
2897 pa_tagstruct_put_usec(t, pa_source_get_requested_latency(source));
2898 }
2899
2900 if (c->version >= 15) {
2901 pa_tagstruct_put_volume(t, source->base_volume);
2902 if (PA_UNLIKELY(pa_source_get_state(source) == PA_SOURCE_INVALID_STATE))
2903 pa_log_error("Internal source state is invalid.");
2904 pa_tagstruct_putu32(t, pa_source_get_state(source));
2905 pa_tagstruct_putu32(t, source->n_volume_steps);
2906 pa_tagstruct_putu32(t, source->card ? source->card->index : PA_INVALID_INDEX);
2907 }
2908
2909 if (c->version >= 16) {
2910
2911 pa_tagstruct_putu32(t, source->ports ? pa_hashmap_size(source->ports) : 0);
2912
2913 if (source->ports) {
2914 void *state;
2915 pa_device_port *p;
2916
2917 PA_HASHMAP_FOREACH(p, source->ports, state) {
2918 pa_tagstruct_puts(t, p->name);
2919 pa_tagstruct_puts(t, p->description);
2920 pa_tagstruct_putu32(t, p->priority);
2921 }
2922 }
2923
2924 pa_tagstruct_puts(t, source->active_port ? source->active_port->name : NULL);
2925 }
2926 }
2927
2928 static void client_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_client *client) {
2929 pa_assert(t);
2930 pa_assert(client);
2931
2932 pa_tagstruct_putu32(t, client->index);
2933 pa_tagstruct_puts(t, pa_strnull(pa_proplist_gets(client->proplist, PA_PROP_APPLICATION_NAME)));
2934 pa_tagstruct_putu32(t, client->module ? client->module->index : PA_INVALID_INDEX);
2935 pa_tagstruct_puts(t, client->driver);
2936
2937 if (c->version >= 13)
2938 pa_tagstruct_put_proplist(t, client->proplist);
2939 }
2940
2941 static void card_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_card *card) {
2942 void *state = NULL;
2943 pa_card_profile *p;
2944
2945 pa_assert(t);
2946 pa_assert(card);
2947
2948 pa_tagstruct_putu32(t, card->index);
2949 pa_tagstruct_puts(t, card->name);
2950 pa_tagstruct_putu32(t, card->module ? card->module->index : PA_INVALID_INDEX);
2951 pa_tagstruct_puts(t, card->driver);
2952
2953 pa_tagstruct_putu32(t, card->profiles ? pa_hashmap_size(card->profiles) : 0);
2954
2955 if (card->profiles) {
2956 while ((p = pa_hashmap_iterate(card->profiles, &state, NULL))) {
2957 pa_tagstruct_puts(t, p->name);
2958 pa_tagstruct_puts(t, p->description);
2959 pa_tagstruct_putu32(t, p->n_sinks);
2960 pa_tagstruct_putu32(t, p->n_sources);
2961 pa_tagstruct_putu32(t, p->priority);
2962 }
2963 }
2964
2965 pa_tagstruct_puts(t, card->active_profile ? card->active_profile->name : NULL);
2966 pa_tagstruct_put_proplist(t, card->proplist);
2967 }
2968
2969 static void module_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_module *module) {
2970 pa_assert(t);
2971 pa_assert(module);
2972
2973 pa_tagstruct_putu32(t, module->index);
2974 pa_tagstruct_puts(t, module->name);
2975 pa_tagstruct_puts(t, module->argument);
2976 pa_tagstruct_putu32(t, (uint32_t) pa_module_get_n_used(module));
2977
2978 if (c->version < 15)
2979 pa_tagstruct_put_boolean(t, FALSE); /* autoload is obsolete */
2980
2981 if (c->version >= 15)
2982 pa_tagstruct_put_proplist(t, module->proplist);
2983 }
2984
2985 static void sink_input_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_sink_input *s) {
2986 pa_sample_spec fixed_ss;
2987 pa_usec_t sink_latency;
2988 pa_cvolume v;
2989
2990 pa_assert(t);
2991 pa_sink_input_assert_ref(s);
2992
2993 fixup_sample_spec(c, &fixed_ss, &s->sample_spec);
2994
2995 pa_tagstruct_putu32(t, s->index);
2996 pa_tagstruct_puts(t, pa_strnull(pa_proplist_gets(s->proplist, PA_PROP_MEDIA_NAME)));
2997 pa_tagstruct_putu32(t, s->module ? s->module->index : PA_INVALID_INDEX);
2998 pa_tagstruct_putu32(t, s->client ? s->client->index : PA_INVALID_INDEX);
2999 pa_tagstruct_putu32(t, s->sink->index);
3000 pa_tagstruct_put_sample_spec(t, &fixed_ss);
3001 pa_tagstruct_put_channel_map(t, &s->channel_map);
3002 pa_tagstruct_put_cvolume(t, pa_sink_input_get_volume(s, &v, TRUE));
3003 pa_tagstruct_put_usec(t, pa_sink_input_get_latency(s, &sink_latency));
3004 pa_tagstruct_put_usec(t, sink_latency);
3005 pa_tagstruct_puts(t, pa_resample_method_to_string(pa_sink_input_get_resample_method(s)));
3006 pa_tagstruct_puts(t, s->driver);
3007 if (c->version >= 11)
3008 pa_tagstruct_put_boolean(t, pa_sink_input_get_mute(s));
3009 if (c->version >= 13)
3010 pa_tagstruct_put_proplist(t, s->proplist);
3011 }
3012
3013 static void source_output_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_source_output *s) {
3014 pa_sample_spec fixed_ss;
3015 pa_usec_t source_latency;
3016
3017 pa_assert(t);
3018 pa_source_output_assert_ref(s);
3019
3020 fixup_sample_spec(c, &fixed_ss, &s->sample_spec);
3021
3022 pa_tagstruct_putu32(t, s->index);
3023 pa_tagstruct_puts(t, pa_strnull(pa_proplist_gets(s->proplist, PA_PROP_MEDIA_NAME)));
3024 pa_tagstruct_putu32(t, s->module ? s->module->index : PA_INVALID_INDEX);
3025 pa_tagstruct_putu32(t, s->client ? s->client->index : PA_INVALID_INDEX);
3026 pa_tagstruct_putu32(t, s->source->index);
3027 pa_tagstruct_put_sample_spec(t, &fixed_ss);
3028 pa_tagstruct_put_channel_map(t, &s->channel_map);
3029 pa_tagstruct_put_usec(t, pa_source_output_get_latency(s, &source_latency));
3030 pa_tagstruct_put_usec(t, source_latency);
3031 pa_tagstruct_puts(t, pa_resample_method_to_string(pa_source_output_get_resample_method(s)));
3032 pa_tagstruct_puts(t, s->driver);
3033
3034 if (c->version >= 13)
3035 pa_tagstruct_put_proplist(t, s->proplist);
3036 }
3037
3038 static void scache_fill_tagstruct(pa_native_connection *c, pa_tagstruct *t, pa_scache_entry *e) {
3039 pa_sample_spec fixed_ss;
3040 pa_cvolume v;
3041
3042 pa_assert(t);
3043 pa_assert(e);
3044
3045 if (e->memchunk.memblock)
3046 fixup_sample_spec(c, &fixed_ss, &e->sample_spec);
3047 else
3048 memset(&fixed_ss, 0, sizeof(fixed_ss));
3049
3050 pa_tagstruct_putu32(t, e->index);
3051 pa_tagstruct_puts(t, e->name);
3052
3053 if (e->volume_is_set)
3054 v = e->volume;
3055 else
3056 pa_cvolume_init(&v);
3057
3058 pa_tagstruct_put_cvolume(t, &v);
3059 pa_tagstruct_put_usec(t, e->memchunk.memblock ? pa_bytes_to_usec(e->memchunk.length, &e->sample_spec) : 0);
3060 pa_tagstruct_put_sample_spec(t, &fixed_ss);
3061 pa_tagstruct_put_channel_map(t, &e->channel_map);
3062 pa_tagstruct_putu32(t, (uint32_t) e->memchunk.length);
3063 pa_tagstruct_put_boolean(t, e->lazy);
3064 pa_tagstruct_puts(t, e->filename);
3065
3066 if (c->version >= 13)
3067 pa_tagstruct_put_proplist(t, e->proplist);
3068 }
3069
3070 static void command_get_info(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3071 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3072 uint32_t idx;
3073 pa_sink *sink = NULL;
3074 pa_source *source = NULL;
3075 pa_client *client = NULL;
3076 pa_card *card = NULL;
3077 pa_module *module = NULL;
3078 pa_sink_input *si = NULL;
3079 pa_source_output *so = NULL;
3080 pa_scache_entry *sce = NULL;
3081 const char *name = NULL;
3082 pa_tagstruct *reply;
3083
3084 pa_native_connection_assert_ref(c);
3085 pa_assert(t);
3086
3087 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3088 (command != PA_COMMAND_GET_CLIENT_INFO &&
3089 command != PA_COMMAND_GET_MODULE_INFO &&
3090 command != PA_COMMAND_GET_SINK_INPUT_INFO &&
3091 command != PA_COMMAND_GET_SOURCE_OUTPUT_INFO &&
3092 pa_tagstruct_gets(t, &name) < 0) ||
3093 !pa_tagstruct_eof(t)) {
3094 protocol_error(c);
3095 return;
3096 }
3097
3098 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3099 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
3100 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
3101 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
3102 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
3103
3104 if (command == PA_COMMAND_GET_SINK_INFO) {
3105 if (idx != PA_INVALID_INDEX)
3106 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
3107 else
3108 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
3109 } else if (command == PA_COMMAND_GET_SOURCE_INFO) {
3110 if (idx != PA_INVALID_INDEX)
3111 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
3112 else
3113 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
3114 } else if (command == PA_COMMAND_GET_CARD_INFO) {
3115 if (idx != PA_INVALID_INDEX)
3116 card = pa_idxset_get_by_index(c->protocol->core->cards, idx);
3117 else
3118 card = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_CARD);
3119 } else if (command == PA_COMMAND_GET_CLIENT_INFO)
3120 client = pa_idxset_get_by_index(c->protocol->core->clients, idx);
3121 else if (command == PA_COMMAND_GET_MODULE_INFO)
3122 module = pa_idxset_get_by_index(c->protocol->core->modules, idx);
3123 else if (command == PA_COMMAND_GET_SINK_INPUT_INFO)
3124 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3125 else if (command == PA_COMMAND_GET_SOURCE_OUTPUT_INFO)
3126 so = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
3127 else {
3128 pa_assert(command == PA_COMMAND_GET_SAMPLE_INFO);
3129 if (idx != PA_INVALID_INDEX)
3130 sce = pa_idxset_get_by_index(c->protocol->core->scache, idx);
3131 else
3132 sce = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SAMPLE);
3133 }
3134
3135 if (!sink && !source && !client && !card && !module && !si && !so && !sce) {
3136 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY);
3137 return;
3138 }
3139
3140 reply = reply_new(tag);
3141 if (sink)
3142 sink_fill_tagstruct(c, reply, sink);
3143 else if (source)
3144 source_fill_tagstruct(c, reply, source);
3145 else if (client)
3146 client_fill_tagstruct(c, reply, client);
3147 else if (card)
3148 card_fill_tagstruct(c, reply, card);
3149 else if (module)
3150 module_fill_tagstruct(c, reply, module);
3151 else if (si)
3152 sink_input_fill_tagstruct(c, reply, si);
3153 else if (so)
3154 source_output_fill_tagstruct(c, reply, so);
3155 else
3156 scache_fill_tagstruct(c, reply, sce);
3157 pa_pstream_send_tagstruct(c->pstream, reply);
3158 }
3159
3160 static void command_get_info_list(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3161 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3162 pa_idxset *i;
3163 uint32_t idx;
3164 void *p;
3165 pa_tagstruct *reply;
3166
3167 pa_native_connection_assert_ref(c);
3168 pa_assert(t);
3169
3170 if (!pa_tagstruct_eof(t)) {
3171 protocol_error(c);
3172 return;
3173 }
3174
3175 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3176
3177 reply = reply_new(tag);
3178
3179 if (command == PA_COMMAND_GET_SINK_INFO_LIST)
3180 i = c->protocol->core->sinks;
3181 else if (command == PA_COMMAND_GET_SOURCE_INFO_LIST)
3182 i = c->protocol->core->sources;
3183 else if (command == PA_COMMAND_GET_CLIENT_INFO_LIST)
3184 i = c->protocol->core->clients;
3185 else if (command == PA_COMMAND_GET_CARD_INFO_LIST)
3186 i = c->protocol->core->cards;
3187 else if (command == PA_COMMAND_GET_MODULE_INFO_LIST)
3188 i = c->protocol->core->modules;
3189 else if (command == PA_COMMAND_GET_SINK_INPUT_INFO_LIST)
3190 i = c->protocol->core->sink_inputs;
3191 else if (command == PA_COMMAND_GET_SOURCE_OUTPUT_INFO_LIST)
3192 i = c->protocol->core->source_outputs;
3193 else {
3194 pa_assert(command == PA_COMMAND_GET_SAMPLE_INFO_LIST);
3195 i = c->protocol->core->scache;
3196 }
3197
3198 if (i) {
3199 for (p = pa_idxset_first(i, &idx); p; p = pa_idxset_next(i, &idx)) {
3200 if (command == PA_COMMAND_GET_SINK_INFO_LIST)
3201 sink_fill_tagstruct(c, reply, p);
3202 else if (command == PA_COMMAND_GET_SOURCE_INFO_LIST)
3203 source_fill_tagstruct(c, reply, p);
3204 else if (command == PA_COMMAND_GET_CLIENT_INFO_LIST)
3205 client_fill_tagstruct(c, reply, p);
3206 else if (command == PA_COMMAND_GET_CARD_INFO_LIST)
3207 card_fill_tagstruct(c, reply, p);
3208 else if (command == PA_COMMAND_GET_MODULE_INFO_LIST)
3209 module_fill_tagstruct(c, reply, p);
3210 else if (command == PA_COMMAND_GET_SINK_INPUT_INFO_LIST)
3211 sink_input_fill_tagstruct(c, reply, p);
3212 else if (command == PA_COMMAND_GET_SOURCE_OUTPUT_INFO_LIST)
3213 source_output_fill_tagstruct(c, reply, p);
3214 else {
3215 pa_assert(command == PA_COMMAND_GET_SAMPLE_INFO_LIST);
3216 scache_fill_tagstruct(c, reply, p);
3217 }
3218 }
3219 }
3220
3221 pa_pstream_send_tagstruct(c->pstream, reply);
3222 }
3223
3224 static void command_get_server_info(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3225 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3226 pa_tagstruct *reply;
3227 pa_sink *def_sink;
3228 pa_source *def_source;
3229 pa_sample_spec fixed_ss;
3230 char *h, *u;
3231
3232 pa_native_connection_assert_ref(c);
3233 pa_assert(t);
3234
3235 if (!pa_tagstruct_eof(t)) {
3236 protocol_error(c);
3237 return;
3238 }
3239
3240 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3241
3242 reply = reply_new(tag);
3243 pa_tagstruct_puts(reply, PACKAGE_NAME);
3244 pa_tagstruct_puts(reply, PACKAGE_VERSION);
3245
3246 u = pa_get_user_name_malloc();
3247 pa_tagstruct_puts(reply, u);
3248 pa_xfree(u);
3249
3250 h = pa_get_host_name_malloc();
3251 pa_tagstruct_puts(reply, h);
3252 pa_xfree(h);
3253
3254 fixup_sample_spec(c, &fixed_ss, &c->protocol->core->default_sample_spec);
3255 pa_tagstruct_put_sample_spec(reply, &fixed_ss);
3256
3257 def_sink = pa_namereg_get_default_sink(c->protocol->core);
3258 pa_tagstruct_puts(reply, def_sink ? def_sink->name : NULL);
3259 def_source = pa_namereg_get_default_source(c->protocol->core);
3260 pa_tagstruct_puts(reply, def_source ? def_source->name : NULL);
3261
3262 pa_tagstruct_putu32(reply, c->protocol->core->cookie);
3263
3264 if (c->version >= 15)
3265 pa_tagstruct_put_channel_map(reply, &c->protocol->core->default_channel_map);
3266
3267 pa_pstream_send_tagstruct(c->pstream, reply);
3268 }
3269
3270 static void subscription_cb(pa_core *core, pa_subscription_event_type_t e, uint32_t idx, void *userdata) {
3271 pa_tagstruct *t;
3272 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3273
3274 pa_native_connection_assert_ref(c);
3275
3276 t = pa_tagstruct_new(NULL, 0);
3277 pa_tagstruct_putu32(t, PA_COMMAND_SUBSCRIBE_EVENT);
3278 pa_tagstruct_putu32(t, (uint32_t) -1);
3279 pa_tagstruct_putu32(t, e);
3280 pa_tagstruct_putu32(t, idx);
3281 pa_pstream_send_tagstruct(c->pstream, t);
3282 }
3283
3284 static void command_subscribe(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3285 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3286 pa_subscription_mask_t m;
3287
3288 pa_native_connection_assert_ref(c);
3289 pa_assert(t);
3290
3291 if (pa_tagstruct_getu32(t, &m) < 0 ||
3292 !pa_tagstruct_eof(t)) {
3293 protocol_error(c);
3294 return;
3295 }
3296
3297 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3298 CHECK_VALIDITY(c->pstream, (m & ~PA_SUBSCRIPTION_MASK_ALL) == 0, tag, PA_ERR_INVALID);
3299
3300 if (c->subscription)
3301 pa_subscription_free(c->subscription);
3302
3303 if (m != 0) {
3304 c->subscription = pa_subscription_new(c->protocol->core, m, subscription_cb, c);
3305 pa_assert(c->subscription);
3306 } else
3307 c->subscription = NULL;
3308
3309 pa_pstream_send_simple_ack(c->pstream, tag);
3310 }
3311
3312 static void command_set_volume(
3313 pa_pdispatch *pd,
3314 uint32_t command,
3315 uint32_t tag,
3316 pa_tagstruct *t,
3317 void *userdata) {
3318
3319 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3320 uint32_t idx;
3321 pa_cvolume volume;
3322 pa_sink *sink = NULL;
3323 pa_source *source = NULL;
3324 pa_sink_input *si = NULL;
3325 const char *name = NULL;
3326
3327 pa_native_connection_assert_ref(c);
3328 pa_assert(t);
3329
3330 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3331 (command == PA_COMMAND_SET_SINK_VOLUME && pa_tagstruct_gets(t, &name) < 0) ||
3332 (command == PA_COMMAND_SET_SOURCE_VOLUME && pa_tagstruct_gets(t, &name) < 0) ||
3333 pa_tagstruct_get_cvolume(t, &volume) ||
3334 !pa_tagstruct_eof(t)) {
3335 protocol_error(c);
3336 return;
3337 }
3338
3339 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3340 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
3341 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
3342 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
3343 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
3344 CHECK_VALIDITY(c->pstream, pa_cvolume_valid(&volume), tag, PA_ERR_INVALID);
3345
3346 switch (command) {
3347
3348 case PA_COMMAND_SET_SINK_VOLUME:
3349 if (idx != PA_INVALID_INDEX)
3350 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
3351 else
3352 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
3353 break;
3354
3355 case PA_COMMAND_SET_SOURCE_VOLUME:
3356 if (idx != PA_INVALID_INDEX)
3357 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
3358 else
3359 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
3360 break;
3361
3362 case PA_COMMAND_SET_SINK_INPUT_VOLUME:
3363 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3364 break;
3365
3366 default:
3367 pa_assert_not_reached();
3368 }
3369
3370 CHECK_VALIDITY(c->pstream, si || sink || source, tag, PA_ERR_NOENTITY);
3371
3372 if (sink)
3373 pa_sink_set_volume(sink, &volume, TRUE, TRUE, TRUE, TRUE);
3374 else if (source)
3375 pa_source_set_volume(source, &volume, TRUE);
3376 else if (si)
3377 pa_sink_input_set_volume(si, &volume, TRUE, TRUE);
3378
3379 pa_pstream_send_simple_ack(c->pstream, tag);
3380 }
3381
3382 static void command_set_mute(
3383 pa_pdispatch *pd,
3384 uint32_t command,
3385 uint32_t tag,
3386 pa_tagstruct *t,
3387 void *userdata) {
3388
3389 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3390 uint32_t idx;
3391 pa_bool_t mute;
3392 pa_sink *sink = NULL;
3393 pa_source *source = NULL;
3394 pa_sink_input *si = NULL;
3395 const char *name = NULL;
3396
3397 pa_native_connection_assert_ref(c);
3398 pa_assert(t);
3399
3400 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3401 (command == PA_COMMAND_SET_SINK_MUTE && pa_tagstruct_gets(t, &name) < 0) ||
3402 (command == PA_COMMAND_SET_SOURCE_MUTE && pa_tagstruct_gets(t, &name) < 0) ||
3403 pa_tagstruct_get_boolean(t, &mute) ||
3404 !pa_tagstruct_eof(t)) {
3405 protocol_error(c);
3406 return;
3407 }
3408
3409 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3410 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
3411 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
3412 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
3413 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
3414
3415 switch (command) {
3416
3417 case PA_COMMAND_SET_SINK_MUTE:
3418
3419 if (idx != PA_INVALID_INDEX)
3420 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
3421 else
3422 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
3423
3424 break;
3425
3426 case PA_COMMAND_SET_SOURCE_MUTE:
3427 if (idx != PA_INVALID_INDEX)
3428 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
3429 else
3430 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
3431
3432 break;
3433
3434 case PA_COMMAND_SET_SINK_INPUT_MUTE:
3435 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3436 break;
3437
3438 default:
3439 pa_assert_not_reached();
3440 }
3441
3442 CHECK_VALIDITY(c->pstream, si || sink || source, tag, PA_ERR_NOENTITY);
3443
3444 if (sink)
3445 pa_sink_set_mute(sink, mute, TRUE);
3446 else if (source)
3447 pa_source_set_mute(source, mute, TRUE);
3448 else if (si)
3449 pa_sink_input_set_mute(si, mute, TRUE);
3450
3451 pa_pstream_send_simple_ack(c->pstream, tag);
3452 }
3453
3454 static void command_cork_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3455 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3456 uint32_t idx;
3457 pa_bool_t b;
3458 playback_stream *s;
3459
3460 pa_native_connection_assert_ref(c);
3461 pa_assert(t);
3462
3463 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3464 pa_tagstruct_get_boolean(t, &b) < 0 ||
3465 !pa_tagstruct_eof(t)) {
3466 protocol_error(c);
3467 return;
3468 }
3469
3470 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3471 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID);
3472 s = pa_idxset_get_by_index(c->output_streams, idx);
3473 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3474 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
3475
3476 pa_sink_input_cork(s->sink_input, b);
3477
3478 if (b)
3479 s->is_underrun = TRUE;
3480
3481 pa_pstream_send_simple_ack(c->pstream, tag);
3482 }
3483
3484 static void command_trigger_or_flush_or_prebuf_playback_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3485 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3486 uint32_t idx;
3487 playback_stream *s;
3488
3489 pa_native_connection_assert_ref(c);
3490 pa_assert(t);
3491
3492 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3493 !pa_tagstruct_eof(t)) {
3494 protocol_error(c);
3495 return;
3496 }
3497
3498 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3499 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID);
3500 s = pa_idxset_get_by_index(c->output_streams, idx);
3501 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3502 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
3503
3504 switch (command) {
3505 case PA_COMMAND_FLUSH_PLAYBACK_STREAM:
3506 pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_FLUSH, NULL, 0, NULL);
3507 break;
3508
3509 case PA_COMMAND_PREBUF_PLAYBACK_STREAM:
3510 pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_PREBUF_FORCE, NULL, 0, NULL);
3511 break;
3512
3513 case PA_COMMAND_TRIGGER_PLAYBACK_STREAM:
3514 pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_TRIGGER, NULL, 0, NULL);
3515 break;
3516
3517 default:
3518 pa_assert_not_reached();
3519 }
3520
3521 pa_pstream_send_simple_ack(c->pstream, tag);
3522 }
3523
3524 static void command_cork_record_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3525 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3526 uint32_t idx;
3527 record_stream *s;
3528 pa_bool_t b;
3529
3530 pa_native_connection_assert_ref(c);
3531 pa_assert(t);
3532
3533 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3534 pa_tagstruct_get_boolean(t, &b) < 0 ||
3535 !pa_tagstruct_eof(t)) {
3536 protocol_error(c);
3537 return;
3538 }
3539
3540 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3541 s = pa_idxset_get_by_index(c->record_streams, idx);
3542 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3543
3544 pa_source_output_cork(s->source_output, b);
3545 pa_memblockq_prebuf_force(s->memblockq);
3546 pa_pstream_send_simple_ack(c->pstream, tag);
3547 }
3548
3549 static void command_flush_record_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3550 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3551 uint32_t idx;
3552 record_stream *s;
3553
3554 pa_native_connection_assert_ref(c);
3555 pa_assert(t);
3556
3557 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3558 !pa_tagstruct_eof(t)) {
3559 protocol_error(c);
3560 return;
3561 }
3562
3563 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3564 s = pa_idxset_get_by_index(c->record_streams, idx);
3565 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3566
3567 pa_memblockq_flush_read(s->memblockq);
3568 pa_pstream_send_simple_ack(c->pstream, tag);
3569 }
3570
3571 static void command_set_stream_buffer_attr(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3572 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3573 uint32_t idx;
3574 pa_buffer_attr a;
3575 pa_tagstruct *reply;
3576
3577 pa_native_connection_assert_ref(c);
3578 pa_assert(t);
3579
3580 memset(&a, 0, sizeof(a));
3581
3582 if (pa_tagstruct_getu32(t, &idx) < 0) {
3583 protocol_error(c);
3584 return;
3585 }
3586
3587 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3588
3589 if (command == PA_COMMAND_SET_PLAYBACK_STREAM_BUFFER_ATTR) {
3590 playback_stream *s;
3591 pa_bool_t adjust_latency = FALSE, early_requests = FALSE;
3592
3593 s = pa_idxset_get_by_index(c->output_streams, idx);
3594 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3595 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
3596
3597 if (pa_tagstruct_get(
3598 t,
3599 PA_TAG_U32, &a.maxlength,
3600 PA_TAG_U32, &a.tlength,
3601 PA_TAG_U32, &a.prebuf,
3602 PA_TAG_U32, &a.minreq,
3603 PA_TAG_INVALID) < 0 ||
3604 (c->version >= 13 && pa_tagstruct_get_boolean(t, &adjust_latency) < 0) ||
3605 (c->version >= 14 && pa_tagstruct_get_boolean(t, &early_requests) < 0) ||
3606 !pa_tagstruct_eof(t)) {
3607 protocol_error(c);
3608 return;
3609 }
3610
3611 s->adjust_latency = adjust_latency;
3612 s->early_requests = early_requests;
3613 s->buffer_attr = a;
3614
3615 fix_playback_buffer_attr(s);
3616 pa_assert_se(pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_UPDATE_BUFFER_ATTR, NULL, 0, NULL) == 0);
3617
3618 reply = reply_new(tag);
3619 pa_tagstruct_putu32(reply, s->buffer_attr.maxlength);
3620 pa_tagstruct_putu32(reply, s->buffer_attr.tlength);
3621 pa_tagstruct_putu32(reply, s->buffer_attr.prebuf);
3622 pa_tagstruct_putu32(reply, s->buffer_attr.minreq);
3623
3624 if (c->version >= 13)
3625 pa_tagstruct_put_usec(reply, s->configured_sink_latency);
3626
3627 } else {
3628 record_stream *s;
3629 pa_bool_t adjust_latency = FALSE, early_requests = FALSE;
3630 pa_assert(command == PA_COMMAND_SET_RECORD_STREAM_BUFFER_ATTR);
3631
3632 s = pa_idxset_get_by_index(c->record_streams, idx);
3633 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3634
3635 if (pa_tagstruct_get(
3636 t,
3637 PA_TAG_U32, &a.maxlength,
3638 PA_TAG_U32, &a.fragsize,
3639 PA_TAG_INVALID) < 0 ||
3640 (c->version >= 13 && pa_tagstruct_get_boolean(t, &adjust_latency) < 0) ||
3641 (c->version >= 14 && pa_tagstruct_get_boolean(t, &early_requests) < 0) ||
3642 !pa_tagstruct_eof(t)) {
3643 protocol_error(c);
3644 return;
3645 }
3646
3647 s->adjust_latency = adjust_latency;
3648 s->early_requests = early_requests;
3649 s->buffer_attr = a;
3650
3651 fix_record_buffer_attr_pre(s);
3652 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength);
3653 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
3654 fix_record_buffer_attr_post(s);
3655
3656 reply = reply_new(tag);
3657 pa_tagstruct_putu32(reply, s->buffer_attr.maxlength);
3658 pa_tagstruct_putu32(reply, s->buffer_attr.fragsize);
3659
3660 if (c->version >= 13)
3661 pa_tagstruct_put_usec(reply, s->configured_source_latency);
3662 }
3663
3664 pa_pstream_send_tagstruct(c->pstream, reply);
3665 }
3666
3667 static void command_update_stream_sample_rate(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3668 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3669 uint32_t idx;
3670 uint32_t rate;
3671
3672 pa_native_connection_assert_ref(c);
3673 pa_assert(t);
3674
3675 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3676 pa_tagstruct_getu32(t, &rate) < 0 ||
3677 !pa_tagstruct_eof(t)) {
3678 protocol_error(c);
3679 return;
3680 }
3681
3682 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3683 CHECK_VALIDITY(c->pstream, rate > 0 && rate <= PA_RATE_MAX, tag, PA_ERR_INVALID);
3684
3685 if (command == PA_COMMAND_UPDATE_PLAYBACK_STREAM_SAMPLE_RATE) {
3686 playback_stream *s;
3687
3688 s = pa_idxset_get_by_index(c->output_streams, idx);
3689 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3690 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
3691
3692 pa_sink_input_set_rate(s->sink_input, rate);
3693
3694 } else {
3695 record_stream *s;
3696 pa_assert(command == PA_COMMAND_UPDATE_RECORD_STREAM_SAMPLE_RATE);
3697
3698 s = pa_idxset_get_by_index(c->record_streams, idx);
3699 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3700
3701 pa_source_output_set_rate(s->source_output, rate);
3702 }
3703
3704 pa_pstream_send_simple_ack(c->pstream, tag);
3705 }
3706
3707 static void command_update_proplist(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3708 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3709 uint32_t idx;
3710 uint32_t mode;
3711 pa_proplist *p;
3712
3713 pa_native_connection_assert_ref(c);
3714 pa_assert(t);
3715
3716 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3717
3718 p = pa_proplist_new();
3719
3720 if (command == PA_COMMAND_UPDATE_CLIENT_PROPLIST) {
3721
3722 if (pa_tagstruct_getu32(t, &mode) < 0 ||
3723 pa_tagstruct_get_proplist(t, p) < 0 ||
3724 !pa_tagstruct_eof(t)) {
3725 protocol_error(c);
3726 pa_proplist_free(p);
3727 return;
3728 }
3729
3730 } else {
3731
3732 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3733 pa_tagstruct_getu32(t, &mode) < 0 ||
3734 pa_tagstruct_get_proplist(t, p) < 0 ||
3735 !pa_tagstruct_eof(t)) {
3736 protocol_error(c);
3737 pa_proplist_free(p);
3738 return;
3739 }
3740 }
3741
3742 if (!(mode == PA_UPDATE_SET || mode == PA_UPDATE_MERGE || mode == PA_UPDATE_REPLACE)) {
3743 pa_proplist_free(p);
3744 CHECK_VALIDITY(c->pstream, FALSE, tag, PA_ERR_INVALID);
3745 }
3746
3747 if (command == PA_COMMAND_UPDATE_PLAYBACK_STREAM_PROPLIST) {
3748 playback_stream *s;
3749
3750 s = pa_idxset_get_by_index(c->output_streams, idx);
3751 if (!s || !playback_stream_isinstance(s)) {
3752 pa_proplist_free(p);
3753 CHECK_VALIDITY(c->pstream, FALSE, tag, PA_ERR_NOENTITY);
3754 }
3755 pa_sink_input_update_proplist(s->sink_input, mode, p);
3756
3757 } else if (command == PA_COMMAND_UPDATE_RECORD_STREAM_PROPLIST) {
3758 record_stream *s;
3759
3760 if (!(s = pa_idxset_get_by_index(c->record_streams, idx))) {
3761 pa_proplist_free(p);
3762 CHECK_VALIDITY(c->pstream, FALSE, tag, PA_ERR_NOENTITY);
3763 }
3764 pa_source_output_update_proplist(s->source_output, mode, p);
3765
3766 } else {
3767 pa_assert(command == PA_COMMAND_UPDATE_CLIENT_PROPLIST);
3768
3769 pa_client_update_proplist(c->client, mode, p);
3770 }
3771
3772 pa_pstream_send_simple_ack(c->pstream, tag);
3773 pa_proplist_free(p);
3774 }
3775
3776 static void command_remove_proplist(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3777 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3778 uint32_t idx;
3779 unsigned changed = 0;
3780 pa_proplist *p;
3781 pa_strlist *l = NULL;
3782
3783 pa_native_connection_assert_ref(c);
3784 pa_assert(t);
3785
3786 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3787
3788 if (command != PA_COMMAND_REMOVE_CLIENT_PROPLIST) {
3789
3790 if (pa_tagstruct_getu32(t, &idx) < 0) {
3791 protocol_error(c);
3792 return;
3793 }
3794 }
3795
3796 if (command == PA_COMMAND_REMOVE_PLAYBACK_STREAM_PROPLIST) {
3797 playback_stream *s;
3798
3799 s = pa_idxset_get_by_index(c->output_streams, idx);
3800 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3801 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
3802
3803 p = s->sink_input->proplist;
3804
3805 } else if (command == PA_COMMAND_REMOVE_RECORD_STREAM_PROPLIST) {
3806 record_stream *s;
3807
3808 s = pa_idxset_get_by_index(c->record_streams, idx);
3809 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3810
3811 p = s->source_output->proplist;
3812 } else {
3813 pa_assert(command == PA_COMMAND_REMOVE_CLIENT_PROPLIST);
3814
3815 p = c->client->proplist;
3816 }
3817
3818 for (;;) {
3819 const char *k;
3820
3821 if (pa_tagstruct_gets(t, &k) < 0) {
3822 protocol_error(c);
3823 pa_strlist_free(l);
3824 return;
3825 }
3826
3827 if (!k)
3828 break;
3829
3830 l = pa_strlist_prepend(l, k);
3831 }
3832
3833 if (!pa_tagstruct_eof(t)) {
3834 protocol_error(c);
3835 pa_strlist_free(l);
3836 return;
3837 }
3838
3839 for (;;) {
3840 char *z;
3841
3842 l = pa_strlist_pop(l, &z);
3843
3844 if (!z)
3845 break;
3846
3847 changed += (unsigned) (pa_proplist_unset(p, z) >= 0);
3848 pa_xfree(z);
3849 }
3850
3851 pa_pstream_send_simple_ack(c->pstream, tag);
3852
3853 if (changed) {
3854 if (command == PA_COMMAND_REMOVE_PLAYBACK_STREAM_PROPLIST) {
3855 playback_stream *s;
3856
3857 s = pa_idxset_get_by_index(c->output_streams, idx);
3858 pa_subscription_post(c->protocol->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, s->sink_input->index);
3859
3860 } else if (command == PA_COMMAND_REMOVE_RECORD_STREAM_PROPLIST) {
3861 record_stream *s;
3862
3863 s = pa_idxset_get_by_index(c->record_streams, idx);
3864 pa_subscription_post(c->protocol->core, PA_SUBSCRIPTION_EVENT_SOURCE_OUTPUT|PA_SUBSCRIPTION_EVENT_CHANGE, s->source_output->index);
3865
3866 } else {
3867 pa_assert(command == PA_COMMAND_REMOVE_CLIENT_PROPLIST);
3868 pa_subscription_post(c->protocol->core, PA_SUBSCRIPTION_EVENT_CLIENT|PA_SUBSCRIPTION_EVENT_CHANGE, c->client->index);
3869 }
3870 }
3871 }
3872
3873 static void command_set_default_sink_or_source(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3874 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3875 const char *s;
3876
3877 pa_native_connection_assert_ref(c);
3878 pa_assert(t);
3879
3880 if (pa_tagstruct_gets(t, &s) < 0 ||
3881 !pa_tagstruct_eof(t)) {
3882 protocol_error(c);
3883 return;
3884 }
3885
3886 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3887 CHECK_VALIDITY(c->pstream, !s || pa_namereg_is_valid_name(s), tag, PA_ERR_INVALID);
3888
3889 if (command == PA_COMMAND_SET_DEFAULT_SOURCE) {
3890 pa_source *source;
3891
3892 source = pa_namereg_get(c->protocol->core, s, PA_NAMEREG_SOURCE);
3893 CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY);
3894
3895 pa_namereg_set_default_source(c->protocol->core, source);
3896 } else {
3897 pa_sink *sink;
3898 pa_assert(command == PA_COMMAND_SET_DEFAULT_SINK);
3899
3900 sink = pa_namereg_get(c->protocol->core, s, PA_NAMEREG_SINK);
3901 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY);
3902
3903 pa_namereg_set_default_sink(c->protocol->core, sink);
3904 }
3905
3906 pa_pstream_send_simple_ack(c->pstream, tag);
3907 }
3908
3909 static void command_set_stream_name(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3910 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3911 uint32_t idx;
3912 const char *name;
3913
3914 pa_native_connection_assert_ref(c);
3915 pa_assert(t);
3916
3917 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3918 pa_tagstruct_gets(t, &name) < 0 ||
3919 !pa_tagstruct_eof(t)) {
3920 protocol_error(c);
3921 return;
3922 }
3923
3924 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3925 CHECK_VALIDITY(c->pstream, name && pa_utf8_valid(name), tag, PA_ERR_INVALID);
3926
3927 if (command == PA_COMMAND_SET_PLAYBACK_STREAM_NAME) {
3928 playback_stream *s;
3929
3930 s = pa_idxset_get_by_index(c->output_streams, idx);
3931 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3932 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY);
3933
3934 pa_sink_input_set_name(s->sink_input, name);
3935
3936 } else {
3937 record_stream *s;
3938 pa_assert(command == PA_COMMAND_SET_RECORD_STREAM_NAME);
3939
3940 s = pa_idxset_get_by_index(c->record_streams, idx);
3941 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3942
3943 pa_source_output_set_name(s->source_output, name);
3944 }
3945
3946 pa_pstream_send_simple_ack(c->pstream, tag);
3947 }
3948
3949 static void command_kill(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3950 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3951 uint32_t idx;
3952
3953 pa_native_connection_assert_ref(c);
3954 pa_assert(t);
3955
3956 if (pa_tagstruct_getu32(t, &idx) < 0 ||
3957 !pa_tagstruct_eof(t)) {
3958 protocol_error(c);
3959 return;
3960 }
3961
3962 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
3963
3964 if (command == PA_COMMAND_KILL_CLIENT) {
3965 pa_client *client;
3966
3967 client = pa_idxset_get_by_index(c->protocol->core->clients, idx);
3968 CHECK_VALIDITY(c->pstream, client, tag, PA_ERR_NOENTITY);
3969
3970 pa_native_connection_ref(c);
3971 pa_client_kill(client);
3972
3973 } else if (command == PA_COMMAND_KILL_SINK_INPUT) {
3974 pa_sink_input *s;
3975
3976 s = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3977 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3978
3979 pa_native_connection_ref(c);
3980 pa_sink_input_kill(s);
3981 } else {
3982 pa_source_output *s;
3983
3984 pa_assert(command == PA_COMMAND_KILL_SOURCE_OUTPUT);
3985
3986 s = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
3987 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
3988
3989 pa_native_connection_ref(c);
3990 pa_source_output_kill(s);
3991 }
3992
3993 pa_pstream_send_simple_ack(c->pstream, tag);
3994 pa_native_connection_unref(c);
3995 }
3996
3997 static void command_load_module(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
3998 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
3999 pa_module *m;
4000 const char *name, *argument;
4001 pa_tagstruct *reply;
4002
4003 pa_native_connection_assert_ref(c);
4004 pa_assert(t);
4005
4006 if (pa_tagstruct_gets(t, &name) < 0 ||
4007 pa_tagstruct_gets(t, &argument) < 0 ||
4008 !pa_tagstruct_eof(t)) {
4009 protocol_error(c);
4010 return;
4011 }
4012
4013 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4014 CHECK_VALIDITY(c->pstream, name && *name && pa_utf8_valid(name) && !strchr(name, '/'), tag, PA_ERR_INVALID);
4015 CHECK_VALIDITY(c->pstream, !argument || pa_utf8_valid(argument), tag, PA_ERR_INVALID);
4016
4017 if (!(m = pa_module_load(c->protocol->core, name, argument))) {
4018 pa_pstream_send_error(c->pstream, tag, PA_ERR_MODINITFAILED);
4019 return;
4020 }
4021
4022 reply = reply_new(tag);
4023 pa_tagstruct_putu32(reply, m->index);
4024 pa_pstream_send_tagstruct(c->pstream, reply);
4025 }
4026
4027 static void command_unload_module(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
4028 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4029 uint32_t idx;
4030 pa_module *m;
4031
4032 pa_native_connection_assert_ref(c);
4033 pa_assert(t);
4034
4035 if (pa_tagstruct_getu32(t, &idx) < 0 ||
4036 !pa_tagstruct_eof(t)) {
4037 protocol_error(c);
4038 return;
4039 }
4040
4041 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4042 m = pa_idxset_get_by_index(c->protocol->core->modules, idx);
4043 CHECK_VALIDITY(c->pstream, m, tag, PA_ERR_NOENTITY);
4044
4045 pa_module_unload_request(m, FALSE);
4046 pa_pstream_send_simple_ack(c->pstream, tag);
4047 }
4048
4049 static void command_move_stream(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
4050 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4051 uint32_t idx = PA_INVALID_INDEX, idx_device = PA_INVALID_INDEX;
4052 const char *name_device = NULL;
4053
4054 pa_native_connection_assert_ref(c);
4055 pa_assert(t);
4056
4057 if (pa_tagstruct_getu32(t, &idx) < 0 ||
4058 pa_tagstruct_getu32(t, &idx_device) < 0 ||
4059 pa_tagstruct_gets(t, &name_device) < 0 ||
4060 !pa_tagstruct_eof(t)) {
4061 protocol_error(c);
4062 return;
4063 }
4064
4065 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4066 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4067
4068 CHECK_VALIDITY(c->pstream, !name_device || pa_namereg_is_valid_name(name_device), tag, PA_ERR_INVALID);
4069 CHECK_VALIDITY(c->pstream, idx_device != PA_INVALID_INDEX || name_device, tag, PA_ERR_INVALID);
4070 CHECK_VALIDITY(c->pstream, idx_device == PA_INVALID_INDEX || !name_device, tag, PA_ERR_INVALID);
4071 CHECK_VALIDITY(c->pstream, !name_device || idx_device == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4072
4073 if (command == PA_COMMAND_MOVE_SINK_INPUT) {
4074 pa_sink_input *si = NULL;
4075 pa_sink *sink = NULL;
4076
4077 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
4078
4079 if (idx_device != PA_INVALID_INDEX)
4080 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx_device);
4081 else
4082 sink = pa_namereg_get(c->protocol->core, name_device, PA_NAMEREG_SINK);
4083
4084 CHECK_VALIDITY(c->pstream, si && sink, tag, PA_ERR_NOENTITY);
4085
4086 if (pa_sink_input_move_to(si, sink, TRUE) < 0) {
4087 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
4088 return;
4089 }
4090 } else {
4091 pa_source_output *so = NULL;
4092 pa_source *source;
4093
4094 pa_assert(command == PA_COMMAND_MOVE_SOURCE_OUTPUT);
4095
4096 so = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
4097
4098 if (idx_device != PA_INVALID_INDEX)
4099 source = pa_idxset_get_by_index(c->protocol->core->sources, idx_device);
4100 else
4101 source = pa_namereg_get(c->protocol->core, name_device, PA_NAMEREG_SOURCE);
4102
4103 CHECK_VALIDITY(c->pstream, so && source, tag, PA_ERR_NOENTITY);
4104
4105 if (pa_source_output_move_to(so, source, TRUE) < 0) {
4106 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
4107 return;
4108 }
4109 }
4110
4111 pa_pstream_send_simple_ack(c->pstream, tag);
4112 }
4113
4114 static void command_suspend(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
4115 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4116 uint32_t idx = PA_INVALID_INDEX;
4117 const char *name = NULL;
4118 pa_bool_t b;
4119
4120 pa_native_connection_assert_ref(c);
4121 pa_assert(t);
4122
4123 if (pa_tagstruct_getu32(t, &idx) < 0 ||
4124 pa_tagstruct_gets(t, &name) < 0 ||
4125 pa_tagstruct_get_boolean(t, &b) < 0 ||
4126 !pa_tagstruct_eof(t)) {
4127 protocol_error(c);
4128 return;
4129 }
4130
4131 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4132 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name) || *name == 0, tag, PA_ERR_INVALID);
4133 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
4134 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
4135 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4136
4137 if (command == PA_COMMAND_SUSPEND_SINK) {
4138
4139 if (idx == PA_INVALID_INDEX && name && !*name) {
4140
4141 pa_log_debug("%s all sinks", b ? "Suspending" : "Resuming");
4142
4143 if (pa_sink_suspend_all(c->protocol->core, b, PA_SUSPEND_USER) < 0) {
4144 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
4145 return;
4146 }
4147 } else {
4148 pa_sink *sink = NULL;
4149
4150 if (idx != PA_INVALID_INDEX)
4151 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
4152 else
4153 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
4154
4155 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY);
4156
4157 if (pa_sink_suspend(sink, b, PA_SUSPEND_USER) < 0) {
4158 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
4159 return;
4160 }
4161 }
4162 } else {
4163
4164 pa_assert(command == PA_COMMAND_SUSPEND_SOURCE);
4165
4166 if (idx == PA_INVALID_INDEX && name && !*name) {
4167
4168 pa_log_debug("%s all sources", b ? "Suspending" : "Resuming");
4169
4170 if (pa_source_suspend_all(c->protocol->core, b, PA_SUSPEND_USER) < 0) {
4171 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
4172 return;
4173 }
4174
4175 } else {
4176 pa_source *source;
4177
4178 if (idx != PA_INVALID_INDEX)
4179 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
4180 else
4181 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
4182
4183 CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY);
4184
4185 if (pa_source_suspend(source, b, PA_SUSPEND_USER) < 0) {
4186 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID);
4187 return;
4188 }
4189 }
4190 }
4191
4192 pa_pstream_send_simple_ack(c->pstream, tag);
4193 }
4194
4195 static void command_extension(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
4196 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4197 uint32_t idx = PA_INVALID_INDEX;
4198 const char *name = NULL;
4199 pa_module *m;
4200 pa_native_protocol_ext_cb_t cb;
4201
4202 pa_native_connection_assert_ref(c);
4203 pa_assert(t);
4204
4205 if (pa_tagstruct_getu32(t, &idx) < 0 ||
4206 pa_tagstruct_gets(t, &name) < 0) {
4207 protocol_error(c);
4208 return;
4209 }
4210
4211 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4212 CHECK_VALIDITY(c->pstream, !name || pa_utf8_valid(name), tag, PA_ERR_INVALID);
4213 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
4214 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
4215 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4216
4217 if (idx != PA_INVALID_INDEX)
4218 m = pa_idxset_get_by_index(c->protocol->core->modules, idx);
4219 else {
4220 for (m = pa_idxset_first(c->protocol->core->modules, &idx); m; m = pa_idxset_next(c->protocol->core->modules, &idx))
4221 if (strcmp(name, m->name) == 0)
4222 break;
4223 }
4224
4225 CHECK_VALIDITY(c->pstream, m, tag, PA_ERR_NOEXTENSION);
4226 CHECK_VALIDITY(c->pstream, m->load_once || idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4227
4228 cb = (pa_native_protocol_ext_cb_t) (unsigned long) pa_hashmap_get(c->protocol->extensions, m);
4229 CHECK_VALIDITY(c->pstream, cb, tag, PA_ERR_NOEXTENSION);
4230
4231 if (cb(c->protocol, m, c, tag, t) < 0)
4232 protocol_error(c);
4233 }
4234
4235 static void command_set_card_profile(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
4236 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4237 uint32_t idx = PA_INVALID_INDEX;
4238 const char *name = NULL, *profile = NULL;
4239 pa_card *card = NULL;
4240 int ret;
4241
4242 pa_native_connection_assert_ref(c);
4243 pa_assert(t);
4244
4245 if (pa_tagstruct_getu32(t, &idx) < 0 ||
4246 pa_tagstruct_gets(t, &name) < 0 ||
4247 pa_tagstruct_gets(t, &profile) < 0 ||
4248 !pa_tagstruct_eof(t)) {
4249 protocol_error(c);
4250 return;
4251 }
4252
4253 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4254 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
4255 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
4256 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
4257 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4258
4259 if (idx != PA_INVALID_INDEX)
4260 card = pa_idxset_get_by_index(c->protocol->core->cards, idx);
4261 else
4262 card = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_CARD);
4263
4264 CHECK_VALIDITY(c->pstream, card, tag, PA_ERR_NOENTITY);
4265
4266 if ((ret = pa_card_set_profile(card, profile, TRUE)) < 0) {
4267 pa_pstream_send_error(c->pstream, tag, -ret);
4268 return;
4269 }
4270
4271 pa_pstream_send_simple_ack(c->pstream, tag);
4272 }
4273
4274 static void command_set_sink_or_source_port(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
4275 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4276 uint32_t idx = PA_INVALID_INDEX;
4277 const char *name = NULL, *port = NULL;
4278 int ret;
4279
4280 pa_native_connection_assert_ref(c);
4281 pa_assert(t);
4282
4283 if (pa_tagstruct_getu32(t, &idx) < 0 ||
4284 pa_tagstruct_gets(t, &name) < 0 ||
4285 pa_tagstruct_gets(t, &port) < 0 ||
4286 !pa_tagstruct_eof(t)) {
4287 protocol_error(c);
4288 return;
4289 }
4290
4291 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
4292 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID);
4293 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX || name, tag, PA_ERR_INVALID);
4294 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID);
4295 CHECK_VALIDITY(c->pstream, !name || idx == PA_INVALID_INDEX, tag, PA_ERR_INVALID);
4296
4297 if (command == PA_COMMAND_SET_SINK_PORT) {
4298 pa_sink *sink;
4299
4300 if (idx != PA_INVALID_INDEX)
4301 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
4302 else
4303 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
4304
4305 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY);
4306
4307 if ((ret = pa_sink_set_port(sink, port, TRUE)) < 0) {
4308 pa_pstream_send_error(c->pstream, tag, -ret);
4309 return;
4310 }
4311 } else {
4312 pa_source *source;
4313
4314 pa_assert(command = PA_COMMAND_SET_SOURCE_PORT);
4315
4316 if (idx != PA_INVALID_INDEX)
4317 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
4318 else
4319 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
4320
4321 CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY);
4322
4323 if ((ret = pa_source_set_port(source, port, TRUE)) < 0) {
4324 pa_pstream_send_error(c->pstream, tag, -ret);
4325 return;
4326 }
4327 }
4328
4329 pa_pstream_send_simple_ack(c->pstream, tag);
4330 }
4331
4332 /*** pstream callbacks ***/
4333
4334 static void pstream_packet_callback(pa_pstream *p, pa_packet *packet, const pa_creds *creds, void *userdata) {
4335 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4336
4337 pa_assert(p);
4338 pa_assert(packet);
4339 pa_native_connection_assert_ref(c);
4340
4341 if (pa_pdispatch_run(c->pdispatch, packet, creds, c) < 0) {
4342 pa_log("invalid packet.");
4343 native_connection_unlink(c);
4344 }
4345 }
4346
4347 static void pstream_memblock_callback(pa_pstream *p, uint32_t channel, int64_t offset, pa_seek_mode_t seek, const pa_memchunk *chunk, void *userdata) {
4348 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4349 output_stream *stream;
4350
4351 pa_assert(p);
4352 pa_assert(chunk);
4353 pa_native_connection_assert_ref(c);
4354
4355 if (!(stream = OUTPUT_STREAM(pa_idxset_get_by_index(c->output_streams, channel)))) {
4356 pa_log_debug("Client sent block for invalid stream.");
4357 /* Ignoring */
4358 return;
4359 }
4360
4361 /* pa_log("got %lu bytes", (unsigned long) chunk->length); */
4362
4363 if (playback_stream_isinstance(stream)) {
4364 playback_stream *ps = PLAYBACK_STREAM(stream);
4365
4366 if (chunk->memblock) {
4367 if (seek != PA_SEEK_RELATIVE || offset != 0)
4368 pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAGE_SEEK, PA_UINT_TO_PTR(seek), offset, NULL, NULL);
4369
4370 pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAGE_POST_DATA, NULL, 0, chunk, NULL);
4371 } else
4372 pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAGE_SEEK, PA_UINT_TO_PTR(seek), offset+chunk->length, NULL, NULL);
4373
4374 } else {
4375 upload_stream *u = UPLOAD_STREAM(stream);
4376 size_t l;
4377
4378 if (!u->memchunk.memblock) {
4379 if (u->length == chunk->length && chunk->memblock) {
4380 u->memchunk = *chunk;
4381 pa_memblock_ref(u->memchunk.memblock);
4382 u->length = 0;
4383 } else {
4384 u->memchunk.memblock = pa_memblock_new(c->protocol->core->mempool, u->length);
4385 u->memchunk.index = u->memchunk.length = 0;
4386 }
4387 }
4388
4389 pa_assert(u->memchunk.memblock);
4390
4391 l = u->length;
4392 if (l > chunk->length)
4393 l = chunk->length;
4394
4395 if (l > 0) {
4396 void *dst;
4397 dst = pa_memblock_acquire(u->memchunk.memblock);
4398
4399 if (chunk->memblock) {
4400 void *src;
4401 src = pa_memblock_acquire(chunk->memblock);
4402
4403 memcpy((uint8_t*) dst + u->memchunk.index + u->memchunk.length,
4404 (uint8_t*) src + chunk->index, l);
4405
4406 pa_memblock_release(chunk->memblock);
4407 } else
4408 pa_silence_memory((uint8_t*) dst + u->memchunk.index + u->memchunk.length, l, &u->sample_spec);
4409
4410 pa_memblock_release(u->memchunk.memblock);
4411
4412 u->memchunk.length += l;
4413 u->length -= l;
4414 }
4415 }
4416 }
4417
4418 static void pstream_die_callback(pa_pstream *p, void *userdata) {
4419 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4420
4421 pa_assert(p);
4422 pa_native_connection_assert_ref(c);
4423
4424 native_connection_unlink(c);
4425 pa_log_info("Connection died.");
4426 }
4427
4428 static void pstream_drain_callback(pa_pstream *p, void *userdata) {
4429 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4430
4431 pa_assert(p);
4432 pa_native_connection_assert_ref(c);
4433
4434 native_connection_send_memblock(c);
4435 }
4436
4437 static void pstream_revoke_callback(pa_pstream *p, uint32_t block_id, void *userdata) {
4438 pa_thread_mq *q;
4439
4440 if (!(q = pa_thread_mq_get()))
4441 pa_pstream_send_revoke(p, block_id);
4442 else
4443 pa_asyncmsgq_post(q->outq, PA_MSGOBJECT(userdata), CONNECTION_MESSAGE_REVOKE, PA_UINT_TO_PTR(block_id), 0, NULL, NULL);
4444 }
4445
4446 static void pstream_release_callback(pa_pstream *p, uint32_t block_id, void *userdata) {
4447 pa_thread_mq *q;
4448
4449 if (!(q = pa_thread_mq_get()))
4450 pa_pstream_send_release(p, block_id);
4451 else
4452 pa_asyncmsgq_post(q->outq, PA_MSGOBJECT(userdata), CONNECTION_MESSAGE_RELEASE, PA_UINT_TO_PTR(block_id), 0, NULL, NULL);
4453 }
4454
4455 /*** client callbacks ***/
4456
4457 static void client_kill_cb(pa_client *c) {
4458 pa_assert(c);
4459
4460 native_connection_unlink(PA_NATIVE_CONNECTION(c->userdata));
4461 pa_log_info("Connection killed.");
4462 }
4463
4464 static void client_send_event_cb(pa_client *client, const char*event, pa_proplist *pl) {
4465 pa_tagstruct *t;
4466 pa_native_connection *c;
4467
4468 pa_assert(client);
4469 c = PA_NATIVE_CONNECTION(client->userdata);
4470 pa_native_connection_assert_ref(c);
4471
4472 if (c->version < 15)
4473 return;
4474
4475 t = pa_tagstruct_new(NULL, 0);
4476 pa_tagstruct_putu32(t, PA_COMMAND_CLIENT_EVENT);
4477 pa_tagstruct_putu32(t, (uint32_t) -1); /* tag */
4478 pa_tagstruct_puts(t, event);
4479 pa_tagstruct_put_proplist(t, pl);
4480 pa_pstream_send_tagstruct(c->pstream, t);
4481 }
4482
4483 /*** module entry points ***/
4484
4485 static void auth_timeout(pa_mainloop_api*m, pa_time_event *e, const struct timeval *t, void *userdata) {
4486 pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
4487
4488 pa_assert(m);
4489 pa_native_connection_assert_ref(c);
4490 pa_assert(c->auth_timeout_event == e);
4491
4492 if (!c->authorized) {
4493 native_connection_unlink(c);
4494 pa_log_info("Connection terminated due to authentication timeout.");
4495 }
4496 }
4497
4498 void pa_native_protocol_connect(pa_native_protocol *p, pa_iochannel *io, pa_native_options *o) {
4499 pa_native_connection *c;
4500 char pname[128];
4501 pa_client *client;
4502 pa_client_new_data data;
4503
4504 pa_assert(p);
4505 pa_assert(io);
4506 pa_assert(o);
4507
4508 if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) {
4509 pa_log_warn("Warning! Too many connections (%u), dropping incoming connection.", MAX_CONNECTIONS);
4510 pa_iochannel_free(io);
4511 return;
4512 }
4513
4514 pa_client_new_data_init(&data);
4515 data.module = o->module;
4516 data.driver = __FILE__;
4517 pa_iochannel_socket_peer_to_string(io, pname, sizeof(pname));
4518 pa_proplist_setf(data.proplist, PA_PROP_APPLICATION_NAME, "Native client (%s)", pname);
4519 pa_proplist_sets(data.proplist, "native-protocol.peer", pname);
4520 client = pa_client_new(p->core, &data);
4521 pa_client_new_data_done(&data);
4522
4523 if (!client)
4524 return;
4525
4526 c = pa_msgobject_new(pa_native_connection);
4527 c->parent.parent.free = native_connection_free;
4528 c->parent.process_msg = native_connection_process_msg;
4529 c->protocol = p;
4530 c->options = pa_native_options_ref(o);
4531 c->authorized = FALSE;
4532
4533 if (o->auth_anonymous) {
4534 pa_log_info("Client authenticated anonymously.");
4535 c->authorized = TRUE;
4536 }
4537
4538 if (!c->authorized &&
4539 o->auth_ip_acl &&
4540 pa_ip_acl_check(o->auth_ip_acl, pa_iochannel_get_recv_fd(io)) > 0) {
4541
4542 pa_log_info("Client authenticated by IP ACL.");
4543 c->authorized = TRUE;
4544 }
4545
4546 if (!c->authorized)
4547 c->auth_timeout_event = pa_core_rttime_new(p->core, pa_rtclock_now() + AUTH_TIMEOUT, auth_timeout, c);
4548 else
4549 c->auth_timeout_event = NULL;
4550
4551 c->is_local = pa_iochannel_socket_is_local(io);
4552 c->version = 8;
4553
4554 c->client = client;
4555 c->client->kill = client_kill_cb;
4556 c->client->send_event = client_send_event_cb;
4557 c->client->userdata = c;
4558
4559 c->pstream = pa_pstream_new(p->core->mainloop, io, p->core->mempool);
4560 pa_pstream_set_recieve_packet_callback(c->pstream, pstream_packet_callback, c);
4561 pa_pstream_set_recieve_memblock_callback(c->pstream, pstream_memblock_callback, c);
4562 pa_pstream_set_die_callback(c->pstream, pstream_die_callback, c);
4563 pa_pstream_set_drain_callback(c->pstream, pstream_drain_callback, c);
4564 pa_pstream_set_revoke_callback(c->pstream, pstream_revoke_callback, c);
4565 pa_pstream_set_release_callback(c->pstream, pstream_release_callback, c);
4566
4567 c->pdispatch = pa_pdispatch_new(p->core->mainloop, TRUE, command_table, PA_COMMAND_MAX);
4568
4569 c->record_streams = pa_idxset_new(NULL, NULL);
4570 c->output_streams = pa_idxset_new(NULL, NULL);
4571
4572 c->rrobin_index = PA_IDXSET_INVALID;
4573 c->subscription = NULL;
4574
4575 pa_idxset_put(p->connections, c, NULL);
4576
4577 #ifdef HAVE_CREDS
4578 if (pa_iochannel_creds_supported(io))
4579 pa_iochannel_creds_enable(io);
4580 #endif
4581
4582 pa_hook_fire(&p->hooks[PA_NATIVE_HOOK_CONNECTION_PUT], c);
4583 }
4584
4585 void pa_native_protocol_disconnect(pa_native_protocol *p, pa_module *m) {
4586 pa_native_connection *c;
4587 void *state = NULL;
4588
4589 pa_assert(p);
4590 pa_assert(m);
4591
4592 while ((c = pa_idxset_iterate(p->connections, &state, NULL)))
4593 if (c->options->module == m)
4594 native_connection_unlink(c);
4595 }
4596
4597 static pa_native_protocol* native_protocol_new(pa_core *c) {
4598 pa_native_protocol *p;
4599 pa_native_hook_t h;
4600
4601 pa_assert(c);
4602
4603 p = pa_xnew(pa_native_protocol, 1);
4604 PA_REFCNT_INIT(p);
4605 p->core = c;
4606 p->connections = pa_idxset_new(NULL, NULL);
4607
4608 p->servers = NULL;
4609
4610 p->extensions = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func);
4611
4612 for (h = 0; h < PA_NATIVE_HOOK_MAX; h++)
4613 pa_hook_init(&p->hooks[h], p);
4614
4615 pa_assert_se(pa_shared_set(c, "native-protocol", p) >= 0);
4616
4617 return p;
4618 }
4619
4620 pa_native_protocol* pa_native_protocol_get(pa_core *c) {
4621 pa_native_protocol *p;
4622
4623 if ((p = pa_shared_get(c, "native-protocol")))
4624 return pa_native_protocol_ref(p);
4625
4626 return native_protocol_new(c);
4627 }
4628
4629 pa_native_protocol* pa_native_protocol_ref(pa_native_protocol *p) {
4630 pa_assert(p);
4631 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4632
4633 PA_REFCNT_INC(p);
4634
4635 return p;
4636 }
4637
4638 void pa_native_protocol_unref(pa_native_protocol *p) {
4639 pa_native_connection *c;
4640 pa_native_hook_t h;
4641
4642 pa_assert(p);
4643 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4644
4645 if (PA_REFCNT_DEC(p) > 0)
4646 return;
4647
4648 while ((c = pa_idxset_first(p->connections, NULL)))
4649 native_connection_unlink(c);
4650
4651 pa_idxset_free(p->connections, NULL, NULL);
4652
4653 pa_strlist_free(p->servers);
4654
4655 for (h = 0; h < PA_NATIVE_HOOK_MAX; h++)
4656 pa_hook_done(&p->hooks[h]);
4657
4658 pa_hashmap_free(p->extensions, NULL, NULL);
4659
4660 pa_assert_se(pa_shared_remove(p->core, "native-protocol") >= 0);
4661
4662 pa_xfree(p);
4663 }
4664
4665 void pa_native_protocol_add_server_string(pa_native_protocol *p, const char *name) {
4666 pa_assert(p);
4667 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4668 pa_assert(name);
4669
4670 p->servers = pa_strlist_prepend(p->servers, name);
4671
4672 pa_hook_fire(&p->hooks[PA_NATIVE_HOOK_SERVERS_CHANGED], p->servers);
4673 }
4674
4675 void pa_native_protocol_remove_server_string(pa_native_protocol *p, const char *name) {
4676 pa_assert(p);
4677 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4678 pa_assert(name);
4679
4680 p->servers = pa_strlist_remove(p->servers, name);
4681
4682 pa_hook_fire(&p->hooks[PA_NATIVE_HOOK_SERVERS_CHANGED], p->servers);
4683 }
4684
4685 pa_hook *pa_native_protocol_hooks(pa_native_protocol *p) {
4686 pa_assert(p);
4687 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4688
4689 return p->hooks;
4690 }
4691
4692 pa_strlist *pa_native_protocol_servers(pa_native_protocol *p) {
4693 pa_assert(p);
4694 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4695
4696 return p->servers;
4697 }
4698
4699 int pa_native_protocol_install_ext(pa_native_protocol *p, pa_module *m, pa_native_protocol_ext_cb_t cb) {
4700 pa_assert(p);
4701 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4702 pa_assert(m);
4703 pa_assert(cb);
4704 pa_assert(!pa_hashmap_get(p->extensions, m));
4705
4706 pa_assert_se(pa_hashmap_put(p->extensions, m, (void*) (unsigned long) cb) == 0);
4707 return 0;
4708 }
4709
4710 void pa_native_protocol_remove_ext(pa_native_protocol *p, pa_module *m) {
4711 pa_assert(p);
4712 pa_assert(PA_REFCNT_VALUE(p) >= 1);
4713 pa_assert(m);
4714
4715 pa_assert_se(pa_hashmap_remove(p->extensions, m));
4716 }
4717
4718 pa_native_options* pa_native_options_new(void) {
4719 pa_native_options *o;
4720
4721 o = pa_xnew0(pa_native_options, 1);
4722 PA_REFCNT_INIT(o);
4723
4724 return o;
4725 }
4726
4727 pa_native_options* pa_native_options_ref(pa_native_options *o) {
4728 pa_assert(o);
4729 pa_assert(PA_REFCNT_VALUE(o) >= 1);
4730
4731 PA_REFCNT_INC(o);
4732
4733 return o;
4734 }
4735
4736 void pa_native_options_unref(pa_native_options *o) {
4737 pa_assert(o);
4738 pa_assert(PA_REFCNT_VALUE(o) >= 1);
4739
4740 if (PA_REFCNT_DEC(o) > 0)
4741 return;
4742
4743 pa_xfree(o->auth_group);
4744
4745 if (o->auth_ip_acl)
4746 pa_ip_acl_free(o->auth_ip_acl);
4747
4748 if (o->auth_cookie)
4749 pa_auth_cookie_unref(o->auth_cookie);
4750
4751 pa_xfree(o);
4752 }
4753
4754 int pa_native_options_parse(pa_native_options *o, pa_core *c, pa_modargs *ma) {
4755 pa_bool_t enabled;
4756 const char *acl;
4757
4758 pa_assert(o);
4759 pa_assert(PA_REFCNT_VALUE(o) >= 1);
4760 pa_assert(ma);
4761
4762 if (pa_modargs_get_value_boolean(ma, "auth-anonymous", &o->auth_anonymous) < 0) {
4763 pa_log("auth-anonymous= expects a boolean argument.");
4764 return -1;
4765 }
4766
4767 enabled = TRUE;
4768 if (pa_modargs_get_value_boolean(ma, "auth-group-enabled", &enabled) < 0) {
4769 pa_log("auth-group-enabled= expects a boolean argument.");
4770 return -1;
4771 }
4772
4773 pa_xfree(o->auth_group);
4774 o->auth_group = enabled ? pa_xstrdup(pa_modargs_get_value(ma, "auth-group", pa_in_system_mode() ? PA_ACCESS_GROUP : NULL)) : NULL;
4775
4776 #ifndef HAVE_CREDS
4777 if (o->auth_group)
4778 pa_log_warn("Authentication group configured, but not available on local system. Ignoring.");
4779 #endif
4780
4781 if ((acl = pa_modargs_get_value(ma, "auth-ip-acl", NULL))) {
4782 pa_ip_acl *ipa;
4783
4784 if (!(ipa = pa_ip_acl_new(acl))) {
4785 pa_log("Failed to parse IP ACL '%s'", acl);
4786 return -1;
4787 }
4788
4789 if (o->auth_ip_acl)
4790 pa_ip_acl_free(o->auth_ip_acl);
4791
4792 o->auth_ip_acl = ipa;
4793 }
4794
4795 enabled = TRUE;
4796 if (pa_modargs_get_value_boolean(ma, "auth-cookie-enabled", &enabled) < 0) {
4797 pa_log("auth-cookie-enabled= expects a boolean argument.");
4798 return -1;
4799 }
4800
4801 if (o->auth_cookie)
4802 pa_auth_cookie_unref(o->auth_cookie);
4803
4804 if (enabled) {
4805 const char *cn;
4806
4807 /* The new name for this is 'auth-cookie', for compat reasons
4808 * we check the old name too */
4809 if (!(cn = pa_modargs_get_value(ma, "auth-cookie", NULL)))
4810 if (!(cn = pa_modargs_get_value(ma, "cookie", NULL)))
4811 cn = PA_NATIVE_COOKIE_FILE;
4812
4813 if (!(o->auth_cookie = pa_auth_cookie_get(c, cn, PA_NATIVE_COOKIE_LENGTH)))
4814 return -1;
4815
4816 } else
4817 o->auth_cookie = NULL;
4818
4819 return 0;
4820 }
4821
4822 pa_pstream* pa_native_connection_get_pstream(pa_native_connection *c) {
4823 pa_native_connection_assert_ref(c);
4824
4825 return c->pstream;
4826 }