2 This file is part of PulseAudio.
4 Copyright 2004-2006 Lennart Poettering
5 Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
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.
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.
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
31 #include <pulse/rtclock.h>
32 #include <pulse/timeval.h>
33 #include <pulse/xmalloc.h>
35 #include <pulsecore/module.h>
36 #include <pulsecore/sink.h>
37 #include <pulsecore/source.h>
38 #include <pulsecore/namereg.h>
39 #include <pulsecore/core-rtclock.h>
40 #include <pulsecore/core-util.h>
41 #include <pulsecore/core-scache.h>
42 #include <pulsecore/core-subscribe.h>
43 #include <pulsecore/shared.h>
44 #include <pulsecore/random.h>
45 #include <pulsecore/log.h>
46 #include <pulsecore/macro.h>
50 PA_DEFINE_PUBLIC_CLASS(pa_core
, pa_msgobject
);
52 static int core_process_msg(pa_msgobject
*o
, int code
, void *userdata
, int64_t offset
, pa_memchunk
*chunk
) {
53 pa_core
*c
= PA_CORE(o
);
55 pa_core_assert_ref(c
);
59 case PA_CORE_MESSAGE_UNLOAD_MODULE
:
60 pa_module_unload(c
, userdata
, TRUE
);
68 static void core_free(pa_object
*o
);
70 pa_core
* pa_core_new(pa_mainloop_api
*m
, pa_bool_t shared
, size_t shm_size
) {
78 if (!(pool
= pa_mempool_new(shared
, shm_size
))) {
79 pa_log_warn("failed to allocate shared memory pool. Falling back to a normal memory pool.");
85 if (!(pool
= pa_mempool_new(shared
, shm_size
))) {
86 pa_log("pa_mempool_new() failed.");
91 c
= pa_msgobject_new(pa_core
);
92 c
->parent
.parent
.free
= core_free
;
93 c
->parent
.process_msg
= core_process_msg
;
95 c
->state
= PA_CORE_STARTUP
;
98 c
->clients
= pa_idxset_new(NULL
, NULL
);
99 c
->cards
= pa_idxset_new(NULL
, NULL
);
100 c
->sinks
= pa_idxset_new(NULL
, NULL
);
101 c
->sources
= pa_idxset_new(NULL
, NULL
);
102 c
->sink_inputs
= pa_idxset_new(NULL
, NULL
);
103 c
->source_outputs
= pa_idxset_new(NULL
, NULL
);
104 c
->modules
= pa_idxset_new(NULL
, NULL
);
105 c
->scache
= pa_idxset_new(NULL
, NULL
);
107 c
->namereg
= pa_hashmap_new(pa_idxset_string_hash_func
, pa_idxset_string_compare_func
);
108 c
->shared
= pa_hashmap_new(pa_idxset_string_hash_func
, pa_idxset_string_compare_func
);
110 c
->default_source
= NULL
;
111 c
->default_sink
= NULL
;
113 c
->default_sample_spec
.format
= PA_SAMPLE_S16NE
;
114 c
->default_sample_spec
.rate
= 44100;
115 c
->default_sample_spec
.channels
= 2;
116 pa_channel_map_init_extend(&c
->default_channel_map
, c
->default_sample_spec
.channels
, PA_CHANNEL_MAP_DEFAULT
);
117 c
->default_n_fragments
= 4;
118 c
->default_fragment_size_msec
= 25;
120 c
->module_defer_unload_event
= NULL
;
121 c
->scache_auto_unload_event
= NULL
;
123 c
->subscription_defer_event
= NULL
;
124 PA_LLIST_HEAD_INIT(pa_subscription
, c
->subscriptions
);
125 PA_LLIST_HEAD_INIT(pa_subscription_event
, c
->subscription_event_queue
);
126 c
->subscription_event_last
= NULL
;
129 pa_silence_cache_init(&c
->silence_cache
);
131 c
->exit_event
= NULL
;
133 c
->exit_idle_time
= -1;
134 c
->scache_idle_time
= 20;
136 c
->flat_volumes
= TRUE
;
137 c
->disallow_module_loading
= FALSE
;
138 c
->disallow_exit
= FALSE
;
139 c
->running_as_daemon
= FALSE
;
140 c
->realtime_scheduling
= FALSE
;
141 c
->realtime_priority
= 5;
142 c
->disable_remixing
= FALSE
;
143 c
->disable_lfe_remixing
= FALSE
;
144 c
->resample_method
= PA_RESAMPLER_SPEEX_FLOAT_BASE
+ 3;
146 for (j
= 0; j
< PA_CORE_HOOK_MAX
; j
++)
147 pa_hook_init(&c
->hooks
[j
], c
);
149 pa_random(&c
->cookie
, sizeof(c
->cookie
));
152 pa_check_signal_is_blocked(SIGPIPE
);
155 pa_core_check_idle(c
);
157 c
->state
= PA_CORE_RUNNING
;
162 static void core_free(pa_object
*o
) {
163 pa_core
*c
= PA_CORE(o
);
167 c
->state
= PA_CORE_SHUTDOWN
;
169 pa_module_unload_all(c
);
170 pa_scache_free_all(c
);
172 pa_assert(pa_idxset_isempty(c
->scache
));
173 pa_idxset_free(c
->scache
, NULL
, NULL
);
175 pa_assert(pa_idxset_isempty(c
->modules
));
176 pa_idxset_free(c
->modules
, NULL
, NULL
);
178 pa_assert(pa_idxset_isempty(c
->clients
));
179 pa_idxset_free(c
->clients
, NULL
, NULL
);
181 pa_assert(pa_idxset_isempty(c
->cards
));
182 pa_idxset_free(c
->cards
, NULL
, NULL
);
184 pa_assert(pa_idxset_isempty(c
->sinks
));
185 pa_idxset_free(c
->sinks
, NULL
, NULL
);
187 pa_assert(pa_idxset_isempty(c
->sources
));
188 pa_idxset_free(c
->sources
, NULL
, NULL
);
190 pa_assert(pa_idxset_isempty(c
->source_outputs
));
191 pa_idxset_free(c
->source_outputs
, NULL
, NULL
);
193 pa_assert(pa_idxset_isempty(c
->sink_inputs
));
194 pa_idxset_free(c
->sink_inputs
, NULL
, NULL
);
196 pa_assert(pa_hashmap_isempty(c
->namereg
));
197 pa_hashmap_free(c
->namereg
, NULL
, NULL
);
199 pa_assert(pa_hashmap_isempty(c
->shared
));
200 pa_hashmap_free(c
->shared
, NULL
, NULL
);
202 pa_subscription_free_all(c
);
205 c
->mainloop
->time_free(c
->exit_event
);
207 pa_assert(!c
->default_source
);
208 pa_assert(!c
->default_sink
);
210 pa_silence_cache_done(&c
->silence_cache
);
211 pa_mempool_free(c
->mempool
);
213 for (j
= 0; j
< PA_CORE_HOOK_MAX
; j
++)
214 pa_hook_done(&c
->hooks
[j
]);
219 static void exit_callback(pa_mainloop_api
*m
, pa_time_event
*e
, const struct timeval
*t
, void *userdata
) {
220 pa_core
*c
= userdata
;
221 pa_assert(c
->exit_event
== e
);
223 pa_log_info("We are idle, quitting...");
224 pa_core_exit(c
, TRUE
, 0);
227 void pa_core_check_idle(pa_core
*c
) {
230 if (!c
->exit_event
&&
231 c
->exit_idle_time
>= 0 &&
232 pa_idxset_size(c
->clients
) == 0) {
234 c
->exit_event
= pa_core_rttime_new(c
, pa_rtclock_now() + c
->exit_idle_time
* PA_USEC_PER_SEC
, exit_callback
, c
);
236 } else if (c
->exit_event
&& pa_idxset_size(c
->clients
) > 0) {
237 c
->mainloop
->time_free(c
->exit_event
);
238 c
->exit_event
= NULL
;
242 int pa_core_exit(pa_core
*c
, pa_bool_t force
, int retval
) {
245 if (c
->disallow_exit
&& !force
)
248 c
->mainloop
->quit(c
->mainloop
, retval
);
252 void pa_core_maybe_vacuum(pa_core
*c
) {
255 if (!pa_idxset_isempty(c
->sink_inputs
) ||
256 !pa_idxset_isempty(c
->source_outputs
))
259 pa_log_debug("Hmm, no streams around, trying to vacuum.");
260 pa_mempool_vacuum(c
->mempool
);
263 pa_time_event
* pa_core_rttime_new(pa_core
*c
, pa_usec_t usec
, pa_time_event_cb_t cb
, void *userdata
) {
267 pa_assert(c
->mainloop
);
269 return c
->mainloop
->time_new(c
->mainloop
, pa_timeval_rtstore(&tv
, usec
, TRUE
), cb
, userdata
);
272 void pa_core_rttime_restart(pa_core
*c
, pa_time_event
*e
, pa_usec_t usec
) {
276 pa_assert(c
->mainloop
);
278 c
->mainloop
->time_restart(e
, pa_timeval_rtstore(&tv
, usec
, TRUE
));