4 This file is part of PulseAudio.
6 PulseAudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as published
8 by the Free Software Foundation; either version 2 of the License,
9 or (at your option) any later version.
11 PulseAudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
31 #include <pulse/utf8.h>
32 #include <pulse/xmalloc.h>
34 #include <pulsecore/source-output.h>
35 #include <pulsecore/namereg.h>
36 #include <pulsecore/core-subscribe.h>
37 #include <pulsecore/log.h>
38 #include <pulsecore/sample-util.h>
42 #define CHECK_VALIDITY_RETURN_NULL(condition) \
48 pa_source
* pa_source_new(
53 const pa_sample_spec
*spec
,
54 const pa_channel_map
*map
) {
65 CHECK_VALIDITY_RETURN_NULL(pa_sample_spec_valid(spec
));
68 map
= pa_channel_map_init_auto(&tmap
, spec
->channels
, PA_CHANNEL_MAP_DEFAULT
);
70 CHECK_VALIDITY_RETURN_NULL(map
&& pa_channel_map_valid(map
));
71 CHECK_VALIDITY_RETURN_NULL(map
->channels
== spec
->channels
);
72 CHECK_VALIDITY_RETURN_NULL(!driver
|| pa_utf8_valid(driver
));
73 CHECK_VALIDITY_RETURN_NULL(pa_utf8_valid(name
) && *name
);
75 s
= pa_xnew(pa_source
, 1);
77 if (!(name
= pa_namereg_register(core
, name
, PA_NAMEREG_SOURCE
, s
, fail
))) {
84 s
->state
= PA_SOURCE_RUNNING
;
85 s
->name
= pa_xstrdup(name
);
86 s
->description
= NULL
;
87 s
->driver
= pa_xstrdup(driver
);
90 s
->sample_spec
= *spec
;
91 s
->channel_map
= *map
;
93 s
->outputs
= pa_idxset_new(NULL
, NULL
);
96 pa_cvolume_reset(&s
->sw_volume
, spec
->channels
);
97 pa_cvolume_reset(&s
->hw_volume
, spec
->channels
);
103 s
->get_latency
= NULL
;
105 s
->set_hw_volume
= NULL
;
106 s
->get_hw_volume
= NULL
;
107 s
->set_hw_mute
= NULL
;
108 s
->get_hw_mute
= NULL
;
111 r
= pa_idxset_put(core
->sources
, s
, &s
->index
);
112 assert(s
->index
!= PA_IDXSET_INVALID
&& r
>= 0);
114 pa_sample_spec_snprint(st
, sizeof(st
), spec
);
115 pa_log_info(__FILE__
": created %u \"%s\" with sample spec \"%s\"", s
->index
, s
->name
, st
);
117 pa_subscription_post(core
, PA_SUBSCRIPTION_EVENT_SOURCE
| PA_SUBSCRIPTION_EVENT_NEW
, s
->index
);
122 void pa_source_disconnect(pa_source
*s
) {
123 pa_source_output
*o
, *j
= NULL
;
126 assert(s
->state
== PA_SOURCE_RUNNING
);
128 pa_namereg_unregister(s
->core
, s
->name
);
130 while ((o
= pa_idxset_first(s
->outputs
, NULL
))) {
132 pa_source_output_kill(o
);
136 pa_idxset_remove_by_data(s
->core
->sources
, s
, NULL
);
138 s
->get_latency
= NULL
;
140 s
->get_hw_volume
= NULL
;
141 s
->set_hw_volume
= NULL
;
142 s
->set_hw_mute
= NULL
;
143 s
->get_hw_mute
= NULL
;
145 s
->state
= PA_SOURCE_DISCONNECTED
;
146 pa_subscription_post(s
->core
, PA_SUBSCRIPTION_EVENT_SOURCE
| PA_SUBSCRIPTION_EVENT_REMOVE
, s
->index
);
149 static void source_free(pa_source
*s
) {
153 if (s
->state
!= PA_SOURCE_DISCONNECTED
)
154 pa_source_disconnect(s
);
156 pa_log_info(__FILE__
": freed %u \"%s\"", s
->index
, s
->name
);
158 pa_idxset_free(s
->outputs
, NULL
, NULL
);
161 pa_xfree(s
->description
);
166 void pa_source_unref(pa_source
*s
) {
174 pa_source
* pa_source_ref(pa_source
*s
) {
182 void pa_source_notify(pa_source
*s
) {
190 static int do_post(void *p
, PA_GCC_UNUSED
uint32_t idx
, PA_GCC_UNUSED
int *del
, void*userdata
) {
191 pa_source_output
*o
= p
;
192 const pa_memchunk
*chunk
= userdata
;
197 pa_source_output_push(o
, chunk
);
201 void pa_source_post(pa_source
*s
, const pa_memchunk
*chunk
) {
208 if (s
->sw_muted
|| !pa_cvolume_is_norm(&s
->sw_volume
)) {
209 pa_memchunk vchunk
= *chunk
;
211 pa_memblock_ref(vchunk
.memblock
);
212 pa_memchunk_make_writable(&vchunk
, s
->core
->memblock_stat
, 0);
214 pa_silence_memchunk(&vchunk
, &s
->sample_spec
);
216 pa_volume_memchunk(&vchunk
, &s
->sample_spec
, &s
->sw_volume
);
217 pa_idxset_foreach(s
->outputs
, do_post
, &vchunk
);
218 pa_memblock_unref(vchunk
.memblock
);
220 pa_idxset_foreach(s
->outputs
, do_post
, (void*) chunk
);
225 void pa_source_set_owner(pa_source
*s
, pa_module
*m
) {
233 pa_subscription_post(s
->core
, PA_SUBSCRIPTION_EVENT_SOURCE
|PA_SUBSCRIPTION_EVENT_CHANGE
, s
->index
);
236 pa_usec_t
pa_source_get_latency(pa_source
*s
) {
243 return s
->get_latency(s
);
246 void pa_source_set_volume(pa_source
*s
, pa_mixer_t m
, const pa_cvolume
*volume
) {
253 if (m
== PA_MIXER_HARDWARE
&& s
->set_hw_volume
)
258 if (pa_cvolume_equal(v
, volume
))
263 if (v
== &s
->hw_volume
)
264 if (s
->set_hw_volume(s
) < 0)
265 s
->sw_volume
= *volume
;
267 pa_subscription_post(s
->core
, PA_SUBSCRIPTION_EVENT_SOURCE
|PA_SUBSCRIPTION_EVENT_CHANGE
, s
->index
);
270 const pa_cvolume
*pa_source_get_volume(pa_source
*s
, pa_mixer_t m
) {
274 if (m
== PA_MIXER_HARDWARE
&& s
->set_hw_volume
) {
276 if (s
->get_hw_volume
)
279 return &s
->hw_volume
;
281 return &s
->sw_volume
;
284 void pa_source_set_mute(pa_source
*s
, pa_mixer_t m
, int mute
) {
290 if (m
== PA_MIXER_HARDWARE
&& s
->set_hw_mute
)
300 if (t
== &s
->hw_muted
)
301 if (s
->set_hw_mute(s
) < 0)
302 s
->sw_muted
= !!mute
;
304 pa_subscription_post(s
->core
, PA_SUBSCRIPTION_EVENT_SOURCE
|PA_SUBSCRIPTION_EVENT_CHANGE
, s
->index
);
307 int pa_source_get_mute(pa_source
*s
, pa_mixer_t m
) {
311 if (m
== PA_MIXER_HARDWARE
&& s
->set_hw_mute
) {
321 void pa_source_set_description(pa_source
*s
, const char *description
) {
325 if (!description
&& !s
->description
)
328 if (description
&& s
->description
&& !strcmp(description
, s
->description
))
331 pa_xfree(s
->description
);
332 s
->description
= pa_xstrdup(description
);
334 pa_subscription_post(s
->core
, PA_SUBSCRIPTION_EVENT_SOURCE
|PA_SUBSCRIPTION_EVENT_CHANGE
, s
->index
);