]> code.delx.au - pulseaudio/blob - src/daemon/main.c
add message about hrtimers, and initialize pa_core::high_priority
[pulseaudio] / src / daemon / main.c
1 /* $Id$ */
2
3 /***
4 This file is part of PulseAudio.
5
6 Copyright 2004-2006 Lennart Poettering
7 Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
8
9 PulseAudio is free software; you can redistribute it and/or modify
10 it under the terms of the GNU Lesser General Public License as published
11 by the Free Software Foundation; either version 2 of the License,
12 or (at your option) any later version.
13
14 PulseAudio is distributed in the hope that it will be useful, but
15 WITHOUT ANY WARRANTY; without even the implied warranty of
16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 General Public License for more details.
18
19 You should have received a copy of the GNU Lesser General Public License
20 along with PulseAudio; if not, write to the Free Software
21 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
22 USA.
23 ***/
24
25 #ifdef HAVE_CONFIG_H
26 #include <config.h>
27 #endif
28
29 #include <unistd.h>
30 #include <errno.h>
31 #include <string.h>
32 #include <stdlib.h>
33 #include <stdio.h>
34 #include <signal.h>
35 #include <stddef.h>
36 #include <assert.h>
37 #include <ltdl.h>
38 #include <limits.h>
39 #include <fcntl.h>
40 #include <unistd.h>
41 #include <locale.h>
42 #include <sys/types.h>
43
44 #include <liboil/liboil.h>
45
46 #ifdef HAVE_SYS_IOCTL_H
47 #include <sys/ioctl.h>
48 #endif
49
50 #ifdef HAVE_PWD_H
51 #include <pwd.h>
52 #endif
53 #ifdef HAVE_GRP_H
54 #include <grp.h>
55 #endif
56
57 #ifdef HAVE_LIBWRAP
58 #include <syslog.h>
59 #include <tcpd.h>
60 #endif
61
62 #include "../pulsecore/winsock.h"
63
64 #include <pulse/mainloop.h>
65 #include <pulse/mainloop-signal.h>
66 #include <pulse/timeval.h>
67 #include <pulse/xmalloc.h>
68
69 #include <pulsecore/core-error.h>
70 #include <pulsecore/core.h>
71 #include <pulsecore/memblock.h>
72 #include <pulsecore/module.h>
73 #include <pulsecore/cli-command.h>
74 #include <pulsecore/log.h>
75 #include <pulsecore/core-util.h>
76 #include <pulsecore/sioman.h>
77 #include <pulsecore/cli-text.h>
78 #include <pulsecore/pid.h>
79 #include <pulsecore/namereg.h>
80 #include <pulsecore/random.h>
81 #include <pulsecore/rtsig.h>
82
83 #include "cmdline.h"
84 #include "cpulimit.h"
85 #include "daemon-conf.h"
86 #include "dumpmodules.h"
87 #include "caps.h"
88
89 #ifdef HAVE_LIBWRAP
90 /* Only one instance of these variables */
91 int allow_severity = LOG_INFO;
92 int deny_severity = LOG_WARNING;
93 #endif
94
95 #ifdef HAVE_OSS
96 /* padsp looks for this symbol in the running process and disables
97 * itself if it finds it and it is set to 7 (which is actually a bit
98 * mask). For details see padsp. */
99 int __padsp_disabled__ = 7;
100 #endif
101
102 #ifdef OS_IS_WIN32
103
104 static void message_cb(pa_mainloop_api*a, pa_time_event*e, PA_GCC_UNUSED const struct timeval *tv, void *userdata) {
105 MSG msg;
106 struct timeval tvnext;
107
108 while(PeekMessage(&msg, NULL, 0, 0, PM_REMOVE)) {
109 if (msg.message == WM_QUIT)
110 raise(SIGTERM);
111 else {
112 TranslateMessage(&msg);
113 DispatchMessage(&msg);
114 }
115 }
116
117 pa_timeval_add(pa_gettimeofday(&tvnext), 100000);
118 a->time_restart(e, &tvnext);
119 }
120
121 #endif
122
123 static void signal_callback(pa_mainloop_api*m, PA_GCC_UNUSED pa_signal_event *e, int sig, void *userdata) {
124 pa_log_info("Got signal %s.", pa_strsignal(sig));
125
126 switch (sig) {
127 #ifdef SIGUSR1
128 case SIGUSR1:
129 pa_module_load(userdata, "module-cli", NULL);
130 break;
131 #endif
132
133 #ifdef SIGUSR2
134 case SIGUSR2:
135 pa_module_load(userdata, "module-cli-protocol-unix", NULL);
136 break;
137 #endif
138
139 #ifdef SIGHUP
140 case SIGHUP: {
141 char *c = pa_full_status_string(userdata);
142 pa_log_notice("%s", c);
143 pa_xfree(c);
144 return;
145 }
146 #endif
147
148 case SIGINT:
149 case SIGTERM:
150 default:
151 pa_log_info("Exiting.");
152 m->quit(m, 1);
153 break;
154 }
155 }
156
157 static void close_pipe(int p[2]) {
158 if (p[0] != -1)
159 close(p[0]);
160 if (p[1] != -1)
161 close(p[1]);
162 p[0] = p[1] = -1;
163 }
164
165 #define set_env(key, value) putenv(pa_sprintf_malloc("%s=%s", (key), (value)))
166
167 #if defined(HAVE_PWD_H) && defined(HAVE_GRP_H)
168
169 static int change_user(void) {
170 struct passwd *pw;
171 struct group * gr;
172 int r;
173
174 /* This function is called only in system-wide mode. It creates a
175 * runtime dir in /var/run/ with proper UID/GID and drops privs
176 * afterwards. */
177
178 if (!(pw = getpwnam(PA_SYSTEM_USER))) {
179 pa_log("Failed to find user '%s'.", PA_SYSTEM_USER);
180 return -1;
181 }
182
183 if (!(gr = getgrnam(PA_SYSTEM_GROUP))) {
184 pa_log("Failed to find group '%s'.", PA_SYSTEM_GROUP);
185 return -1;
186 }
187
188 pa_log_info("Found user '%s' (UID %lu) and group '%s' (GID %lu).",
189 PA_SYSTEM_USER, (unsigned long) pw->pw_uid,
190 PA_SYSTEM_GROUP, (unsigned long) gr->gr_gid);
191
192 if (pw->pw_gid != gr->gr_gid) {
193 pa_log("GID of user '%s' and of group '%s' don't match.", PA_SYSTEM_USER, PA_SYSTEM_GROUP);
194 return -1;
195 }
196
197 if (strcmp(pw->pw_dir, PA_SYSTEM_RUNTIME_PATH) != 0)
198 pa_log_warn("Warning: home directory of user '%s' is not '%s', ignoring.", PA_SYSTEM_USER, PA_SYSTEM_RUNTIME_PATH);
199
200 if (pa_make_secure_dir(PA_SYSTEM_RUNTIME_PATH, 0755, pw->pw_uid, gr->gr_gid) < 0) {
201 pa_log("Failed to create '%s': %s", PA_SYSTEM_RUNTIME_PATH, pa_cstrerror(errno));
202 return -1;
203 }
204
205 if (initgroups(PA_SYSTEM_USER, gr->gr_gid) != 0) {
206 pa_log("Failed to change group list: %s", pa_cstrerror(errno));
207 return -1;
208 }
209
210 #if defined(HAVE_SETRESGID)
211 r = setresgid(gr->gr_gid, gr->gr_gid, gr->gr_gid);
212 #elif defined(HAVE_SETEGID)
213 if ((r = setgid(gr->gr_gid)) >= 0)
214 r = setegid(gr->gr_gid);
215 #elif defined(HAVE_SETREGID)
216 r = setregid(gr->gr_gid, gr->gr_gid);
217 #else
218 #error "No API to drop priviliges"
219 #endif
220
221 if (r < 0) {
222 pa_log("Failed to change GID: %s", pa_cstrerror(errno));
223 return -1;
224 }
225
226 #if defined(HAVE_SETRESUID)
227 r = setresuid(pw->pw_uid, pw->pw_uid, pw->pw_uid);
228 #elif defined(HAVE_SETEUID)
229 if ((r = setuid(pw->pw_uid)) >= 0)
230 r = seteuid(pw->pw_uid);
231 #elif defined(HAVE_SETREUID)
232 r = setreuid(pw->pw_uid, pw->pw_uid);
233 #else
234 #error "No API to drop priviliges"
235 #endif
236
237 if (r < 0) {
238 pa_log("Failed to change UID: %s", pa_cstrerror(errno));
239 return -1;
240 }
241
242 set_env("USER", PA_SYSTEM_USER);
243 set_env("LOGNAME", PA_SYSTEM_GROUP);
244 set_env("HOME", PA_SYSTEM_RUNTIME_PATH);
245
246 /* Relevant for pa_runtime_path() */
247 set_env("PULSE_RUNTIME_PATH", PA_SYSTEM_RUNTIME_PATH);
248 set_env("PULSE_CONFIG_PATH", PA_SYSTEM_RUNTIME_PATH);
249
250 pa_log_info("Successfully dropped root privileges.");
251
252 return 0;
253 }
254
255 #else /* HAVE_PWD_H && HAVE_GRP_H */
256
257 static int change_user(void) {
258 pa_log("System wide mode unsupported on this platform.");
259 return -1;
260 }
261
262 #endif /* HAVE_PWD_H && HAVE_GRP_H */
263
264 static int create_runtime_dir(void) {
265 char fn[PATH_MAX];
266
267 pa_runtime_path(NULL, fn, sizeof(fn));
268
269 /* This function is called only when the daemon is started in
270 * per-user mode. We create the runtime directory somewhere in
271 * /tmp/ with the current UID/GID */
272
273 if (pa_make_secure_dir(fn, 0700, (uid_t)-1, (gid_t)-1) < 0) {
274 pa_log("Failed to create '%s': %s", fn, pa_cstrerror(errno));
275 return -1;
276 }
277
278 return 0;
279 }
280
281 #ifdef HAVE_SYS_RESOURCE_H
282
283 static void set_one_rlimit(const pa_rlimit *r, int resource, const char *name) {
284 struct rlimit rl;
285 assert(r);
286
287 if (!r->is_set)
288 return;
289
290 rl.rlim_cur = rl.rlim_max = r->value;
291
292 if (setrlimit(resource, &rl) < 0)
293 pa_log_warn("setrlimit(%s, (%u, %u)) failed: %s", name, (unsigned) r->value, (unsigned) r->value, pa_cstrerror(errno));
294 }
295
296 static void set_all_rlimits(const pa_daemon_conf *conf) {
297 set_one_rlimit(&conf->rlimit_as, RLIMIT_AS, "RLIMIT_AS");
298 set_one_rlimit(&conf->rlimit_core, RLIMIT_CORE, "RLIMIT_CORE");
299 set_one_rlimit(&conf->rlimit_data, RLIMIT_DATA, "RLIMIT_DATA");
300 set_one_rlimit(&conf->rlimit_fsize, RLIMIT_FSIZE, "RLIMIT_FSIZE");
301 set_one_rlimit(&conf->rlimit_nofile, RLIMIT_NOFILE, "RLIMIT_NOFILE");
302 set_one_rlimit(&conf->rlimit_stack, RLIMIT_STACK, "RLIMIT_STACK");
303 #ifdef RLIMIT_NPROC
304 set_one_rlimit(&conf->rlimit_nproc, RLIMIT_NPROC, "RLIMIT_NPROC");
305 #endif
306 #ifdef RLIMIT_MEMLOCK
307 set_one_rlimit(&conf->rlimit_memlock, RLIMIT_MEMLOCK, "RLIMIT_MEMLOCK");
308 #endif
309 }
310 #endif
311
312 int main(int argc, char *argv[]) {
313 pa_core *c = NULL;
314 pa_strbuf *buf = NULL;
315 pa_daemon_conf *conf = NULL;
316 pa_mainloop *mainloop = NULL;
317
318 char *s;
319 int r, retval = 1, d = 0;
320 int daemon_pipe[2] = { -1, -1 };
321 int suid_root, real_root;
322 int valid_pid_file = 0;
323
324 gid_t gid = (gid_t) -1;
325
326 #ifdef OS_IS_WIN32
327 pa_time_event *timer;
328 struct timeval tv;
329 #endif
330
331 #ifdef HAVE_GETUID
332 real_root = getuid() == 0;
333 suid_root = !real_root && geteuid() == 0;
334 #else
335 real_root = 0;
336 suid_root = 0;
337 #endif
338
339 if (suid_root) {
340 /* Drop all capabilities except CAP_SYS_NICE */
341 pa_limit_caps();
342
343 /* Drop priviliges, but keep CAP_SYS_NICE */
344 pa_drop_root();
345
346 /* After dropping root, the effective set is reset, hence,
347 * let's raise it again */
348 pa_limit_caps();
349
350 /* When capabilities are not supported we will not be able to
351 * aquire RT sched anymore. But yes, that's the way it is. It
352 * is just too risky tun let PA run as root all the time. */
353 }
354
355 setlocale(LC_ALL, "");
356
357 if (suid_root && (pa_own_uid_in_group(PA_REALTIME_GROUP, &gid) <= 0 || gid >= 1000)) {
358 pa_log_warn("WARNING: called SUID root, but not in group '"PA_REALTIME_GROUP"'.");
359 pa_drop_caps();
360 pa_drop_root();
361 suid_root = real_root = 0;
362 }
363
364 LTDL_SET_PRELOADED_SYMBOLS();
365
366 r = lt_dlinit();
367 assert(r == 0);
368
369 #ifdef OS_IS_WIN32
370 {
371 WSADATA data;
372 WSAStartup(MAKEWORD(2, 0), &data);
373 }
374 #endif
375
376 pa_random_seed();
377
378 pa_log_set_ident("pulseaudio");
379
380 conf = pa_daemon_conf_new();
381
382 if (pa_daemon_conf_load(conf, NULL) < 0)
383 goto finish;
384
385 if (pa_daemon_conf_env(conf) < 0)
386 goto finish;
387
388 if (pa_cmdline_parse(conf, argc, argv, &d) < 0) {
389 pa_log("failed to parse command line.");
390 goto finish;
391 }
392
393 pa_log_set_maximal_level(conf->log_level);
394 pa_log_set_target(conf->auto_log_target ? PA_LOG_STDERR : conf->log_target, NULL);
395
396 if (conf->high_priority && conf->cmd == PA_CMD_DAEMON)
397 pa_raise_priority();
398
399 if (suid_root && (conf->cmd != PA_CMD_DAEMON || !conf->high_priority)) {
400 pa_drop_caps();
401 pa_drop_root();
402 }
403
404 if (conf->dl_search_path)
405 lt_dlsetsearchpath(conf->dl_search_path);
406
407 switch (conf->cmd) {
408 case PA_CMD_DUMP_MODULES:
409 pa_dump_modules(conf, argc-d, argv+d);
410 retval = 0;
411 goto finish;
412
413 case PA_CMD_DUMP_CONF: {
414 s = pa_daemon_conf_dump(conf);
415 fputs(s, stdout);
416 pa_xfree(s);
417 retval = 0;
418 goto finish;
419 }
420
421 case PA_CMD_HELP :
422 pa_cmdline_help(argv[0]);
423 retval = 0;
424 goto finish;
425
426 case PA_CMD_VERSION :
427 printf(PACKAGE_NAME" "PACKAGE_VERSION"\n");
428 retval = 0;
429 goto finish;
430
431 case PA_CMD_CHECK: {
432 pid_t pid;
433
434 if (pa_pid_file_check_running(&pid) < 0) {
435 pa_log_info("daemon not running");
436 } else {
437 pa_log_info("daemon running as PID %u", pid);
438 retval = 0;
439 }
440
441 goto finish;
442
443 }
444 case PA_CMD_KILL:
445
446 if (pa_pid_file_kill(SIGINT, NULL) < 0)
447 pa_log("failed to kill daemon.");
448 else
449 retval = 0;
450
451 goto finish;
452
453 default:
454 assert(conf->cmd == PA_CMD_DAEMON);
455 }
456
457 if (real_root && !conf->system_instance) {
458 pa_log_warn("This program is not intended to be run as root (unless --system is specified).");
459 } else if (!real_root && conf->system_instance) {
460 pa_log("Root priviliges required.");
461 goto finish;
462 }
463
464 if (conf->daemonize) {
465 pid_t child;
466 int tty_fd;
467
468 if (pa_stdio_acquire() < 0) {
469 pa_log("failed to acquire stdio.");
470 goto finish;
471 }
472
473 #ifdef HAVE_FORK
474 if (pipe(daemon_pipe) < 0) {
475 pa_log("failed to create pipe.");
476 goto finish;
477 }
478
479 if ((child = fork()) < 0) {
480 pa_log("fork() failed: %s", pa_cstrerror(errno));
481 goto finish;
482 }
483
484 if (child != 0) {
485 /* Father */
486
487 close(daemon_pipe[1]);
488 daemon_pipe[1] = -1;
489
490 if (pa_loop_read(daemon_pipe[0], &retval, sizeof(retval), NULL) != sizeof(retval)) {
491 pa_log("read() failed: %s", pa_cstrerror(errno));
492 retval = 1;
493 }
494
495 if (retval)
496 pa_log("daemon startup failed.");
497 else
498 pa_log_info("daemon startup successful.");
499
500 goto finish;
501 }
502
503 close(daemon_pipe[0]);
504 daemon_pipe[0] = -1;
505 #endif
506
507 if (conf->auto_log_target)
508 pa_log_set_target(PA_LOG_SYSLOG, NULL);
509
510 #ifdef HAVE_SETSID
511 setsid();
512 #endif
513 #ifdef HAVE_SETPGID
514 setpgid(0,0);
515 #endif
516
517 #ifndef OS_IS_WIN32
518 close(0);
519 close(1);
520 close(2);
521
522 open("/dev/null", O_RDONLY);
523 open("/dev/null", O_WRONLY);
524 open("/dev/null", O_WRONLY);
525 #else
526 FreeConsole();
527 #endif
528
529 #ifdef SIGTTOU
530 signal(SIGTTOU, SIG_IGN);
531 #endif
532 #ifdef SIGTTIN
533 signal(SIGTTIN, SIG_IGN);
534 #endif
535 #ifdef SIGTSTP
536 signal(SIGTSTP, SIG_IGN);
537 #endif
538
539 #ifdef TIOCNOTTY
540 if ((tty_fd = open("/dev/tty", O_RDWR)) >= 0) {
541 ioctl(tty_fd, TIOCNOTTY, (char*) 0);
542 close(tty_fd);
543 }
544 #endif
545 }
546
547 pa_assert(chdir("/") == 0);
548 umask(0022);
549
550 if (conf->system_instance) {
551 if (change_user() < 0)
552 goto finish;
553 } else if (create_runtime_dir() < 0)
554 goto finish;
555
556 if (conf->use_pid_file) {
557 if (pa_pid_file_create() < 0) {
558 pa_log("pa_pid_file_create() failed.");
559 #ifdef HAVE_FORK
560 if (conf->daemonize)
561 pa_loop_write(daemon_pipe[1], &retval, sizeof(retval), NULL);
562 #endif
563 goto finish;
564 }
565
566 valid_pid_file = 1;
567 }
568
569 #ifdef HAVE_SYS_RESOURCE_H
570 set_all_rlimits(conf);
571 #endif
572
573 #ifdef SIGPIPE
574 signal(SIGPIPE, SIG_IGN);
575 #endif
576
577 if (!pa_rtclock_hrtimer())
578 pa_log_debug("Fresh high-resolution timers available! Bon appetit!");
579 else
580 pa_log_info("Dude, your kernel stinks! The chef's recommendation today is Linux with high-resolution timers enabled!");
581
582 pa_rtsig_configure(SIGRTMIN+10, SIGRTMAX);
583
584 mainloop = pa_mainloop_new();
585 assert(mainloop);
586
587 if (!(c = pa_core_new(pa_mainloop_get_api(mainloop), !conf->disable_shm))) {
588 pa_log("pa_core_new() failed.");
589 goto finish;
590 }
591
592 c->is_system_instance = !!conf->system_instance;
593 c->high_priority = !!conf->high_priority;
594 c->default_sample_spec = conf->default_sample_spec;
595 c->default_n_fragments = conf->default_n_fragments;
596 c->default_fragment_size_msec = conf->default_fragment_size_msec;
597
598 pa_assert_se(pa_signal_init(pa_mainloop_get_api(mainloop)) == 0);
599 pa_signal_new(SIGINT, signal_callback, c);
600 pa_signal_new(SIGTERM, signal_callback, c);
601
602 #ifdef SIGUSR1
603 pa_signal_new(SIGUSR1, signal_callback, c);
604 #endif
605 #ifdef SIGUSR2
606 pa_signal_new(SIGUSR2, signal_callback, c);
607 #endif
608 #ifdef SIGHUP
609 pa_signal_new(SIGHUP, signal_callback, c);
610 #endif
611
612 #ifdef OS_IS_WIN32
613 timer = pa_mainloop_get_api(mainloop)->time_new(
614 pa_mainloop_get_api(mainloop), pa_gettimeofday(&tv), message_cb, NULL);
615 assert(timer);
616 #endif
617
618 if (conf->daemonize)
619 c->running_as_daemon = 1;
620
621 oil_init();
622
623 if (!conf->no_cpu_limit) {
624 r = pa_cpu_limit_init(pa_mainloop_get_api(mainloop));
625 assert(r == 0);
626 }
627
628 buf = pa_strbuf_new();
629 if (conf->default_script_file)
630 r = pa_cli_command_execute_file(c, conf->default_script_file, buf, &conf->fail);
631
632 if (r >= 0)
633 r = pa_cli_command_execute(c, conf->script_commands, buf, &conf->fail);
634 pa_log_error("%s", s = pa_strbuf_tostring_free(buf));
635 pa_xfree(s);
636
637 if (r < 0 && conf->fail) {
638 pa_log("failed to initialize daemon.");
639 #ifdef HAVE_FORK
640 if (conf->daemonize)
641 pa_loop_write(daemon_pipe[1], &retval, sizeof(retval), NULL);
642 #endif
643 } else if (!c->modules || pa_idxset_size(c->modules) == 0) {
644 pa_log("daemon startup without any loaded modules, refusing to work.");
645 #ifdef HAVE_FORK
646 if (conf->daemonize)
647 pa_loop_write(daemon_pipe[1], &retval, sizeof(retval), NULL);
648 #endif
649 } else {
650
651 retval = 0;
652 #ifdef HAVE_FORK
653 if (conf->daemonize)
654 pa_loop_write(daemon_pipe[1], &retval, sizeof(retval), NULL);
655 #endif
656
657 c->disallow_module_loading = conf->disallow_module_loading;
658 c->exit_idle_time = conf->exit_idle_time;
659 c->module_idle_time = conf->module_idle_time;
660 c->scache_idle_time = conf->scache_idle_time;
661 c->resample_method = conf->resample_method;
662
663 if (c->default_sink_name &&
664 pa_namereg_get(c, c->default_sink_name, PA_NAMEREG_SINK, 1) == NULL) {
665 pa_log_error("%s : Fatal error. Default sink name (%s) does not exist in name register.", __FILE__, c->default_sink_name);
666 retval = 1;
667 } else {
668 pa_log_info("Daemon startup complete.");
669 if (pa_mainloop_run(mainloop, &retval) < 0)
670 retval = 1;
671 pa_log_info("Daemon shutdown initiated.");
672 }
673 }
674
675 #ifdef OS_IS_WIN32
676 pa_mainloop_get_api(mainloop)->time_free(timer);
677 #endif
678
679 pa_core_unref(c);
680
681 if (!conf->no_cpu_limit)
682 pa_cpu_limit_done();
683
684 pa_signal_done();
685
686 pa_log_info("Daemon terminated.");
687
688 finish:
689
690 if (mainloop)
691 pa_mainloop_free(mainloop);
692
693 if (conf)
694 pa_daemon_conf_free(conf);
695
696 if (valid_pid_file)
697 pa_pid_file_remove();
698
699 close_pipe(daemon_pipe);
700
701 #ifdef OS_IS_WIN32
702 WSACleanup();
703 #endif
704
705 lt_dlexit();
706
707 return retval;
708 }