1 #ifndef foointernalhfoo
2 #define foointernalhfoo
5 This file is part of PulseAudio.
7 Copyright 2004-2006 Lennart Poettering
8 Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
10 PulseAudio is free software; you can redistribute it and/or modify
11 it under the terms of the GNU Lesser General Public License as published
12 by the Free Software Foundation; either version 2.1 of the License,
13 or (at your option) any later version.
15 PulseAudio is distributed in the hope that it will be useful, but
16 WITHOUT ANY WARRANTY; without even the implied warranty of
17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
18 General Public License for more details.
20 You should have received a copy of the GNU Lesser General Public License
21 along with PulseAudio; if not, write to the Free Software
22 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
26 #include <pulse/mainloop-api.h>
27 #include <pulse/context.h>
28 #include <pulse/stream.h>
29 #include <pulse/operation.h>
30 #include <pulse/subscribe.h>
31 #include <pulse/ext-device-manager.h>
32 #include <pulse/ext-device-restore.h>
33 #include <pulse/ext-stream-restore.h>
35 #include <pulsecore/socket-client.h>
36 #include <pulsecore/pstream.h>
37 #include <pulsecore/pdispatch.h>
38 #include <pulsecore/llist.h>
39 #include <pulsecore/native-common.h>
40 #include <pulsecore/strlist.h>
41 #include <pulsecore/mcalign.h>
42 #include <pulsecore/memblockq.h>
43 #include <pulsecore/hashmap.h>
44 #include <pulsecore/refcnt.h>
45 #include <pulsecore/time-smoother.h>
47 #include <pulsecore/dbus-util.h>
50 #include "client-conf.h"
52 #define DEFAULT_TIMEOUT (30)
58 pa_dbus_wrap_connection *system_bus;
59 pa_dbus_wrap_connection *session_bus;
62 pa_proplist *proplist;
63 pa_mainloop_api* mainloop;
65 pa_socket_client *client;
67 pa_pdispatch *pdispatch;
69 pa_hashmap *record_streams, *playback_streams;
70 PA_LLIST_HEAD(pa_stream, streams);
71 PA_LLIST_HEAD(pa_operation, operations);
77 pa_context_state_t state;
79 pa_context_notify_cb_t state_callback;
81 pa_context_subscribe_cb_t subscribe_callback;
82 void *subscribe_userdata;
83 pa_context_event_cb_t event_callback;
90 pa_bool_t server_specified:1;
92 pa_bool_t do_autospawn:1;
93 pa_bool_t use_rtclock:1;
94 pa_bool_t filter_added:1;
95 pa_spawn_api spawn_api;
97 pa_strlist *server_list;
101 pa_client_conf *conf;
103 uint32_t client_index;
105 /* Extension specific data */
107 pa_ext_device_manager_subscribe_cb_t callback;
109 } ext_device_manager;
111 pa_ext_device_restore_subscribe_cb_t callback;
113 } ext_device_restore;
115 pa_ext_stream_restore_subscribe_cb_t callback;
117 } ext_stream_restore;
120 #define PA_MAX_WRITE_INDEX_CORRECTIONS 32
122 typedef struct pa_index_correction {
126 pa_bool_t absolute:1;
128 } pa_index_correction;
130 #define PA_MAX_FORMATS (PA_ENCODING_MAX)
134 PA_LLIST_FIELDS(pa_stream);
137 pa_mainloop_api *mainloop;
139 uint32_t direct_on_input;
141 pa_stream_direction_t direction;
142 pa_stream_state_t state;
143 pa_stream_flags_t flags;
145 pa_sample_spec sample_spec;
146 pa_channel_map channel_map;
148 pa_format_info *req_formats[PA_MAX_FORMATS];
149 pa_format_info *format;
151 pa_proplist *proplist;
153 pa_bool_t channel_valid:1;
154 pa_bool_t suspended:1;
156 pa_bool_t timing_info_valid:1;
157 pa_bool_t auto_timing_update_requested:1;
161 uint32_t stream_index;
163 int64_t requested_bytes;
164 pa_buffer_attr buffer_attr;
166 uint32_t device_index;
170 pa_memblock *write_memblock;
172 int64_t latest_underrun_at_index;
175 pa_memchunk peek_memchunk;
177 pa_memblockq *record_memblockq;
179 /* Store latest latency info */
180 pa_timing_info timing_info;
182 /* Use to make sure that time advances monotonically */
183 pa_usec_t previous_time;
185 /* time updates with tags older than these are invalid */
186 uint32_t write_index_not_before;
187 uint32_t read_index_not_before;
189 /* Data about individual timing update corrections */
190 pa_index_correction write_index_corrections[PA_MAX_WRITE_INDEX_CORRECTIONS];
191 int current_write_index_correction;
193 /* Latency interpolation stuff */
194 pa_time_event *auto_timing_update_event;
195 pa_usec_t auto_timing_interval_usec;
197 pa_smoother *smoother;
200 pa_stream_notify_cb_t state_callback;
201 void *state_userdata;
202 pa_stream_request_cb_t read_callback;
204 pa_stream_request_cb_t write_callback;
205 void *write_userdata;
206 pa_stream_notify_cb_t overflow_callback;
207 void *overflow_userdata;
208 pa_stream_notify_cb_t underflow_callback;
209 void *underflow_userdata;
210 pa_stream_notify_cb_t latency_update_callback;
211 void *latency_update_userdata;
212 pa_stream_notify_cb_t moved_callback;
213 void *moved_userdata;
214 pa_stream_notify_cb_t suspended_callback;
215 void *suspended_userdata;
216 pa_stream_notify_cb_t started_callback;
217 void *started_userdata;
218 pa_stream_event_cb_t event_callback;
219 void *event_userdata;
220 pa_stream_notify_cb_t buffer_attr_callback;
221 void *buffer_attr_userdata;
224 typedef void (*pa_operation_cb_t)(void);
226 struct pa_operation {
232 PA_LLIST_FIELDS(pa_operation);
234 pa_operation_state_t state;
236 pa_operation_cb_t callback;
238 void *private; /* some operations might need this */
241 void pa_command_request(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
242 void pa_command_stream_killed(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
243 void pa_command_subscribe_event(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
244 void pa_command_overflow_or_underflow(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
245 void pa_command_stream_suspended(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
246 void pa_command_stream_moved(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
247 void pa_command_stream_started(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
248 void pa_command_stream_event(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
249 void pa_command_client_event(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
250 void pa_command_stream_buffer_attr(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
252 pa_operation *pa_operation_new(pa_context *c, pa_stream *s, pa_operation_cb_t callback, void *userdata);
253 void pa_operation_done(pa_operation *o);
255 void pa_create_stream_callback(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
256 void pa_stream_disconnect_callback(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
257 void pa_context_simple_ack_callback(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
258 void pa_stream_simple_ack_callback(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata);
260 void pa_context_fail(pa_context *c, int error);
261 int pa_context_set_error(pa_context *c, int error);
262 void pa_context_set_state(pa_context *c, pa_context_state_t st);
263 int pa_context_handle_error(pa_context *c, uint32_t command, pa_tagstruct *t, pa_bool_t fail);
264 pa_operation* pa_context_send_simple_command(pa_context *c, uint32_t command, void (*internal_callback)(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata), void (*cb)(void), void *userdata);
266 void pa_stream_set_state(pa_stream *s, pa_stream_state_t st);
268 pa_tagstruct *pa_tagstruct_command(pa_context *c, uint32_t command, uint32_t *tag);
270 #define PA_CHECK_VALIDITY(context, expression, error) \
273 return -pa_context_set_error((context), (error)); \
277 #define PA_CHECK_VALIDITY_RETURN_ANY(context, expression, error, value) \
279 if (!(expression)) { \
280 pa_context_set_error((context), (error)); \
285 #define PA_CHECK_VALIDITY_RETURN_NULL(context, expression, error) \
286 PA_CHECK_VALIDITY_RETURN_ANY(context, expression, error, NULL)
288 #define PA_FAIL(context, error) \
290 return -pa_context_set_error((context), (error)); \
293 #define PA_FAIL_RETURN_ANY(context, error, value) \
295 pa_context_set_error((context), (error)); \
299 #define PA_FAIL_RETURN_NULL(context, error) \
300 PA_FAIL_RETURN_ANY(context, error, NULL)
302 void pa_ext_device_manager_command(pa_context *c, uint32_t tag, pa_tagstruct *t);
303 void pa_ext_device_restore_command(pa_context *c, uint32_t tag, pa_tagstruct *t);
304 void pa_ext_stream_restore_command(pa_context *c, uint32_t tag, pa_tagstruct *t);
306 void pa_format_info_free2(pa_format_info *f, void *userdata);
307 pa_format_info* pa_format_info_from_sample_spec(pa_sample_spec *ss, pa_channel_map *map);
308 pa_bool_t pa_format_info_to_sample_spec(pa_format_info *f, pa_sample_spec *ss, pa_channel_map *map);
309 pa_bool_t pa_format_info_to_sample_spec_fake(pa_format_info *f, pa_sample_spec *ss);
310 pa_bool_t pa_format_info_get_prop_int(pa_format_info *f, const char *key, int *v);
311 pa_bool_t pa_format_info_get_prop_string(pa_format_info *f, const char *key, char **v);
313 pa_bool_t pa_mainloop_is_our_api(pa_mainloop_api*m);