1517 lines
56 KiB
C
1517 lines
56 KiB
C
/*
|
|
* Shairport, an Apple Airplay receiver
|
|
* Copyright (c) James Laird 2013
|
|
* All rights reserved.
|
|
* Modifications (c) Mike Brady 2014--2017
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person
|
|
* obtaining a copy of this software and associated documentation
|
|
* files (the "Software"), to deal in the Software without
|
|
* restriction, including without limitation the rights to use,
|
|
* copy, modify, merge, publish, distribute, sublicense, and/or
|
|
* sell copies of the Software, and to permit persons to whom the
|
|
* Software is furnished to do so, subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be
|
|
* included in all copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
|
|
* OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
|
|
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
|
|
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
|
|
* OTHER DEALINGS IN THE SOFTWARE.
|
|
*/
|
|
|
|
#include <errno.h>
|
|
#include <fcntl.h>
|
|
#include <getopt.h>
|
|
#include <libconfig.h>
|
|
#include <libgen.h>
|
|
#include <memory.h>
|
|
#include <net/if.h>
|
|
#include <popt.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/types.h>
|
|
#include <sys/wait.h>
|
|
#include <unistd.h>
|
|
|
|
#include "config.h"
|
|
|
|
#ifdef HAVE_LIBMBEDTLS
|
|
#include <mbedtls/md5.h>
|
|
#endif
|
|
|
|
#ifdef HAVE_LIBPOLARSSL
|
|
#include <polarssl/md5.h>
|
|
#endif
|
|
|
|
#ifdef HAVE_LIBSSL
|
|
#include <openssl/md5.h>
|
|
#endif
|
|
|
|
#if defined(HAVE_DBUS)
|
|
#include <glib.h>
|
|
#endif
|
|
|
|
#ifdef HAVE_DBUS
|
|
#include "shairport-sync-dbus-service.h"
|
|
#endif
|
|
|
|
#include "common.h"
|
|
#include "mdns.h"
|
|
#include "rtp.h"
|
|
#include "rtsp.h"
|
|
|
|
#include <libdaemon/dexec.h>
|
|
#include <libdaemon/dfork.h>
|
|
#include <libdaemon/dlog.h>
|
|
#include <libdaemon/dpid.h>
|
|
#include <libdaemon/dsignal.h>
|
|
|
|
#ifdef CONFIG_CONVOLUTION
|
|
#include <FFTConvolver/convolver.h>
|
|
#endif
|
|
|
|
static int shutting_down = 0;
|
|
static char *appName = NULL;
|
|
char configuration_file_path[4096 + 1];
|
|
char actual_configuration_file_path[4096 + 1];
|
|
|
|
void shairport_shutdown() {
|
|
if (shutting_down)
|
|
return;
|
|
shutting_down = 1;
|
|
mdns_unregister();
|
|
rtsp_request_shutdown_stream();
|
|
if (config.output)
|
|
config.output->deinit();
|
|
}
|
|
|
|
static void sig_ignore(int foo, siginfo_t *bar, void *baz) {}
|
|
static void sig_shutdown(int foo, siginfo_t *bar, void *baz) {
|
|
debug(1, "shutdown requested...");
|
|
shairport_shutdown();
|
|
// daemon_log(LOG_NOTICE, "exit...");
|
|
daemon_retval_send(255);
|
|
daemon_pid_file_remove();
|
|
exit(0);
|
|
}
|
|
|
|
static void sig_child(int foo, siginfo_t *bar, void *baz) {
|
|
pid_t pid;
|
|
while ((pid = waitpid((pid_t)-1, 0, WNOHANG)) > 0) {
|
|
if (pid == mdns_pid && !shutting_down) {
|
|
die("MDNS child process died unexpectedly!");
|
|
}
|
|
}
|
|
}
|
|
|
|
static void sig_disconnect_audio_output(int foo, siginfo_t *bar, void *baz) {
|
|
debug(1, "disconnect audio output requested.");
|
|
set_requested_connection_state_to_output(0);
|
|
}
|
|
|
|
static void sig_connect_audio_output(int foo, siginfo_t *bar, void *baz) {
|
|
debug(1, "connect audio output requested.");
|
|
set_requested_connection_state_to_output(1);
|
|
}
|
|
|
|
// The following two functions are adapted slightly and with thanks from Jonathan Leffler's sample
|
|
// code at
|
|
// https://stackoverflow.com/questions/675039/how-can-i-create-directory-tree-in-c-linux
|
|
|
|
int do_mkdir(const char *path, mode_t mode) {
|
|
struct stat st;
|
|
int status = 0;
|
|
|
|
if (stat(path, &st) != 0) {
|
|
/* Directory does not exist. EEXIST for race condition */
|
|
if (mkdir(path, mode) != 0 && errno != EEXIST)
|
|
status = -1;
|
|
} else if (!S_ISDIR(st.st_mode)) {
|
|
errno = ENOTDIR;
|
|
status = -1;
|
|
}
|
|
|
|
return (status);
|
|
}
|
|
|
|
// mkpath - ensure all directories in path exist
|
|
// Algorithm takes the pessimistic view and works top-down to ensure
|
|
// each directory in path exists, rather than optimistically creating
|
|
// the last element and working backwards.
|
|
|
|
int mkpath(const char *path, mode_t mode) {
|
|
char *pp;
|
|
char *sp;
|
|
int status;
|
|
char *copypath = strdup(path);
|
|
|
|
status = 0;
|
|
pp = copypath;
|
|
while (status == 0 && (sp = strchr(pp, '/')) != 0) {
|
|
if (sp != pp) {
|
|
/* Neither root nor double slash in path */
|
|
*sp = '\0';
|
|
status = do_mkdir(copypath, mode);
|
|
*sp = '/';
|
|
}
|
|
pp = sp + 1;
|
|
}
|
|
if (status == 0)
|
|
status = do_mkdir(path, mode);
|
|
free(copypath);
|
|
return (status);
|
|
}
|
|
|
|
char *get_version_string() {
|
|
char *version_string = malloc(200);
|
|
if (version_string) {
|
|
strcpy(version_string, PACKAGE_VERSION);
|
|
#ifdef HAVE_LIBMBEDTLS
|
|
strcat(version_string, "-mbedTLS");
|
|
#endif
|
|
#ifdef HAVE_LIBPOLARSSL
|
|
strcat(version_string, "-PolarSSL");
|
|
#endif
|
|
#ifdef HAVE_LIBSSL
|
|
strcat(version_string, "-OpenSSL");
|
|
#endif
|
|
#ifdef CONFIG_TINYSVCMDNS
|
|
strcat(version_string, "-tinysvcmdns");
|
|
#endif
|
|
#ifdef CONFIG_AVAHI
|
|
strcat(version_string, "-Avahi");
|
|
#endif
|
|
#ifdef CONFIG_DNS_SD
|
|
strcat(version_string, "-dns_sd");
|
|
#endif
|
|
#ifdef CONFIG_ALSA
|
|
strcat(version_string, "-ALSA");
|
|
#endif
|
|
#ifdef CONFIG_SNDIO
|
|
strcat(version_string, "-sndio");
|
|
#endif
|
|
#ifdef CONFIG_AO
|
|
strcat(version_string, "-ao");
|
|
#endif
|
|
#ifdef CONFIG_PA
|
|
strcat(version_string, "-pa");
|
|
#endif
|
|
#ifdef CONFIG_SOUNDIO
|
|
strcat(version_string, "-soundio");
|
|
#endif
|
|
#ifdef CONFIG_DUMMY
|
|
strcat(version_string, "-dummy");
|
|
#endif
|
|
#ifdef CONFIG_STDOUT
|
|
strcat(version_string, "-stdout");
|
|
#endif
|
|
#ifdef CONFIG_PIPE
|
|
strcat(version_string, "-pipe");
|
|
#endif
|
|
#ifdef HAVE_LIBSOXR
|
|
strcat(version_string, "-soxr");
|
|
#endif
|
|
#ifdef CONFIG_CONVOLUTION
|
|
strcat(version_string, "-convolution");
|
|
#endif
|
|
#ifdef CONFIG_METADATA
|
|
strcat(version_string, "-metadata");
|
|
#endif
|
|
strcat(version_string, "-sysconfdir:");
|
|
strcat(version_string, SYSCONFDIR);
|
|
}
|
|
return version_string;
|
|
}
|
|
|
|
void print_version(void) {
|
|
char *version_string = get_version_string();
|
|
if (version_string) {
|
|
printf("%s\n", version_string);
|
|
free(version_string);
|
|
} else {
|
|
debug(1, "Can't print version string!");
|
|
}
|
|
}
|
|
|
|
void usage(char *progname) {
|
|
printf("Usage: %s [options...]\n", progname);
|
|
printf(" or: %s [options...] -- [audio output-specific options]\n", progname);
|
|
printf("\n");
|
|
printf("Options:\n");
|
|
printf(" -h, --help show this help.\n");
|
|
printf(" -d, --daemon daemonise.\n");
|
|
printf(" -j, --justDaemoniseNoPIDFile daemonise without a PID file.\n");
|
|
printf(" -V, --version show version information.\n");
|
|
printf(" -k, --kill kill the existing shairport daemon.\n");
|
|
printf(" -D, --disconnectFromOutput disconnect immediately from the output device.\n");
|
|
printf(" -R, --reconnectToOutput reconnect to the output device.\n");
|
|
printf(" -c, --configfile=FILE read configuration settings from FILE. Default is "
|
|
"/etc/shairport-sync.conf.\n");
|
|
|
|
printf("\n");
|
|
printf("The following general options are for backward compatibility. These and all new options "
|
|
"have settings in the configuration file, by default /etc/shairport-sync.conf:\n");
|
|
printf(" -v, --verbose -v print debug information; -vv more; -vvv lots.\n");
|
|
printf(" -p, --port=PORT set RTSP listening port.\n");
|
|
printf(" -a, --name=NAME set advertised name.\n");
|
|
// printf(" -A, --AirPlayLatency=FRAMES [Deprecated] Set the latency for audio sent from an "
|
|
// "AirPlay device.\n");
|
|
// printf(" The default is to set it automatically.\n");
|
|
// printf(" -i, --iTunesLatency=FRAMES [Deprecated] Set the latency for audio sent from iTunes
|
|
// "
|
|
// "10 or later.\n");
|
|
// printf(" The default is to set it automatically.\n");
|
|
printf(" -L, --latency=FRAMES [Deprecated] Set the latency for audio sent from an unknown "
|
|
"device.\n");
|
|
printf(" The default is to set it automatically.\n");
|
|
printf(" --forkedDaapdLatency=FRAMES [Deprecated] Set the latency for audio sent from "
|
|
"forked-daapd.\n");
|
|
printf(" The default is to set it automatically.\n");
|
|
printf(" -S, --stuffing=MODE set how to adjust current latency to match desired latency, "
|
|
"where \n");
|
|
printf(" \"basic\" (default) inserts or deletes audio frames from "
|
|
"packet frames with low processor overhead, and \n");
|
|
printf(" \"soxr\" uses libsoxr to minimally resample packet frames -- "
|
|
"moderate processor overhead.\n");
|
|
printf(
|
|
" \"soxr\" option only available if built with soxr support.\n");
|
|
printf(" -B, --on-start=PROGRAM run PROGRAM when playback is about to begin.\n");
|
|
printf(" -E, --on-stop=PROGRAM run PROGRAM when playback has ended.\n");
|
|
printf(" For -B and -E options, specify the full path to the program, "
|
|
"e.g. /usr/bin/logger.\n");
|
|
printf(" Executable scripts work, but must have #!/bin/sh (or "
|
|
"whatever) in the headline.\n");
|
|
printf(
|
|
" -w, --wait-cmd wait until the -B or -E programs finish before continuing.\n");
|
|
printf(" -o, --output=BACKEND select audio output method.\n");
|
|
printf(" -m, --mdns=BACKEND force the use of BACKEND to advertize the service.\n");
|
|
printf(" if no mdns provider is specified,\n");
|
|
printf(" shairport tries them all until one works.\n");
|
|
printf(" -r, --resync=THRESHOLD [Deprecated] resync if error exceeds this number of frames. "
|
|
"Set to 0 to "
|
|
"stop resyncing.\n");
|
|
printf(" -t, --timeout=SECONDS go back to idle mode from play mode after a break in "
|
|
"communications of this many seconds (default 120). Set to 0 never to exit play mode.\n");
|
|
printf(" --statistics print some interesting statistics -- output to the logfile "
|
|
"if running as a daemon.\n");
|
|
printf(" --tolerance=TOLERANCE [Deprecated] allow a synchronization error of TOLERANCE "
|
|
"frames (default "
|
|
"88) before trying to correct it.\n");
|
|
printf(" --password=PASSWORD require PASSWORD to connect. Default is not to require a "
|
|
"password.\n");
|
|
printf(" --logOutputLevel log the output level setting -- useful for setting maximum "
|
|
"volume.\n");
|
|
#ifdef CONFIG_METADATA
|
|
printf(" --metadata-pipename=PIPE send metadata to PIPE, e.g. "
|
|
"--metadata-pipename=/tmp/shairport-sync-metadata.\n");
|
|
printf(" The default is /tmp/shairport-sync-metadata.\n");
|
|
printf(" --get-coverart send cover art through the metadata pipe.\n");
|
|
#endif
|
|
printf("\n");
|
|
mdns_ls_backends();
|
|
printf("\n");
|
|
audio_ls_outputs();
|
|
}
|
|
|
|
int parse_options(int argc, char **argv) {
|
|
// there are potential memory leaks here -- it's called a second time, previously allocated
|
|
// strings will dangle.
|
|
char *raw_service_name = NULL; /* Used to pick up the service name before possibly expanding it */
|
|
char *stuffing = NULL; /* used for picking up the stuffing option */
|
|
signed char c; /* used for argument parsing */
|
|
int i = 0; /* used for tracking options */
|
|
int fResyncthreshold = (int)(config.resyncthreshold * 44100);
|
|
int fTolerance = (int)(config.tolerance * 44100);
|
|
poptContext optCon; /* context for parsing command-line options */
|
|
int daemonisewith = 0;
|
|
int daemonisewithout = 0;
|
|
struct poptOption optionsTable[] = {
|
|
{"verbose", 'v', POPT_ARG_NONE, NULL, 'v', NULL},
|
|
{"disconnectFromOutput", 'D', POPT_ARG_NONE, NULL, 0, NULL},
|
|
{"reconnectToOutput", 'R', POPT_ARG_NONE, NULL, 0, NULL},
|
|
{"kill", 'k', POPT_ARG_NONE, NULL, 0, NULL},
|
|
{"daemon", 'd', POPT_ARG_NONE, &daemonisewith, 0, NULL},
|
|
{"justDaemoniseNoPIDFile", 'j', POPT_ARG_NONE, &daemonisewithout, 0, NULL},
|
|
{"configfile", 'c', POPT_ARG_STRING, &config.configfile, 0, NULL},
|
|
{"statistics", 0, POPT_ARG_NONE, &config.statistics_requested, 0, NULL},
|
|
{"logOutputLevel", 0, POPT_ARG_NONE, &config.logOutputLevel, 0, NULL},
|
|
{"version", 'V', POPT_ARG_NONE, NULL, 0, NULL},
|
|
{"port", 'p', POPT_ARG_INT, &config.port, 0, NULL},
|
|
{"name", 'a', POPT_ARG_STRING, &raw_service_name, 0, NULL},
|
|
{"output", 'o', POPT_ARG_STRING, &config.output_name, 0, NULL},
|
|
{"on-start", 'B', POPT_ARG_STRING, &config.cmd_start, 0, NULL},
|
|
{"on-stop", 'E', POPT_ARG_STRING, &config.cmd_stop, 0, NULL},
|
|
{"wait-cmd", 'w', POPT_ARG_NONE, &config.cmd_blocking, 0, NULL},
|
|
{"mdns", 'm', POPT_ARG_STRING, &config.mdns_name, 0, NULL},
|
|
{"latency", 'L', POPT_ARG_INT, &config.userSuppliedLatency, 0, NULL},
|
|
{"AirPlayLatency", 'A', POPT_ARG_INT, &config.AirPlayLatency, 0, NULL},
|
|
{"iTunesLatency", 'i', POPT_ARG_INT, &config.iTunesLatency, 0, NULL},
|
|
{"forkedDaapdLatency", 'f', POPT_ARG_INT, &config.ForkedDaapdLatency, 0, NULL},
|
|
{"stuffing", 'S', POPT_ARG_STRING, &stuffing, 'S', NULL},
|
|
{"resync", 'r', POPT_ARG_INT, &fResyncthreshold, 0, NULL},
|
|
{"timeout", 't', POPT_ARG_INT, &config.timeout, 't', NULL},
|
|
{"password", 0, POPT_ARG_STRING, &config.password, 0, NULL},
|
|
{"tolerance", 'z', POPT_ARG_INT, &fTolerance, 0, NULL},
|
|
#ifdef CONFIG_METADATA
|
|
{"metadata-pipename", 'M', POPT_ARG_STRING, &config.metadata_pipename, 'M', NULL},
|
|
{"get-coverart", 'g', POPT_ARG_NONE, &config.get_coverart, 'g', NULL},
|
|
#endif
|
|
POPT_AUTOHELP{NULL, 0, 0, NULL, 0}};
|
|
|
|
// we have to parse the command line arguments to look for a config file
|
|
int optind;
|
|
optind = argc;
|
|
int j;
|
|
for (j = 0; j < argc; j++)
|
|
if (strcmp(argv[j], "--") == 0)
|
|
optind = j;
|
|
|
|
optCon = poptGetContext(NULL, optind, (const char **)argv, optionsTable, 0);
|
|
poptSetOtherOptionHelp(optCon, "[OPTIONS]* ");
|
|
|
|
/* Now do options processing just to get a debug level */
|
|
debuglev = 0;
|
|
while ((c = poptGetNextOpt(optCon)) >= 0) {
|
|
switch (c) {
|
|
case 'v':
|
|
debuglev++;
|
|
break;
|
|
case 'D':
|
|
inform("Warning: the option -D or --disconnectFromOutput is deprecated.");
|
|
break;
|
|
case 'R':
|
|
inform("Warning: the option -R or --reconnectToOutput is deprecated.");
|
|
break;
|
|
case 'A':
|
|
inform("Warning: the option -A or --AirPlayLatency is deprecated. This setting is now "
|
|
"automatically received from the AirPlay device.");
|
|
break;
|
|
case 'i':
|
|
inform("Warning: the option -i or --iTunesLatency is deprecated. This setting is now "
|
|
"automatically received from iTunes");
|
|
break;
|
|
case 'f':
|
|
inform("Warning: the option --forkedDaapdLatency is deprecated. This setting is now "
|
|
"automatically received from forkedDaapd");
|
|
break;
|
|
case 'r':
|
|
inform("Warning: the option -r or --resync is deprecated. Please use the "
|
|
"\"resync_threshold_in_seconds\" setting in the config file instead.");
|
|
break;
|
|
case 'z':
|
|
inform("Warning: the option --tolerance is deprecated. Please use the "
|
|
"\"drift_tolerance_in_seconds\" setting in the config file instead.");
|
|
break;
|
|
}
|
|
}
|
|
if (c < -1) {
|
|
die("%s: %s", poptBadOption(optCon, POPT_BADOPTION_NOALIAS), poptStrerror(c));
|
|
}
|
|
|
|
if ((daemonisewith) && (daemonisewithout))
|
|
die("Select either daemonize_with_pid_file or daemonize_without_pid_file -- you have selected "
|
|
"both!");
|
|
if ((daemonisewith) || (daemonisewithout)) {
|
|
config.daemonise = 1;
|
|
if (daemonisewith)
|
|
config.daemonise_store_pid = 1;
|
|
};
|
|
|
|
config.resyncthreshold = 1.0 * fResyncthreshold / 44100;
|
|
config.tolerance = 1.0 * fTolerance / 44100;
|
|
config.audio_backend_silent_lead_in_time = -1.0; // flag to indicate it has not been set
|
|
|
|
config_setting_t *setting;
|
|
const char *str = 0;
|
|
int value = 0;
|
|
double dvalue = 0.0;
|
|
|
|
// debug(1, "Looking for the configuration file \"%s\".", config.configfile);
|
|
|
|
config_init(&config_file_stuff);
|
|
|
|
char *config_file_real_path = realpath(config.configfile, NULL);
|
|
if (config_file_real_path == NULL) {
|
|
debug(2, "Can't resolve the configuration file \"%s\".", config.configfile);
|
|
} else {
|
|
debug(2, "Looking for configuration file at full path \"%s\"", config_file_real_path);
|
|
/* Read the file. If there is an error, report it and exit. */
|
|
if (config_read_file(&config_file_stuff, config_file_real_path)) {
|
|
// make config.cfg point to it
|
|
config.cfg = &config_file_stuff;
|
|
/* Get the Service Name. */
|
|
if (config_lookup_string(config.cfg, "general.name", &str)) {
|
|
raw_service_name = (char *)str;
|
|
}
|
|
int daemonisewithout = 0;
|
|
int daemonisewith = 0;
|
|
/* Get the Daemonize setting. */
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.daemonize_with_pid_file", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
daemonisewith = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
daemonisewith = 1;
|
|
else
|
|
die("Invalid daemonize_with_pid_file option choice \"%s\". It should be \"yes\" or "
|
|
"\"no\"");
|
|
}
|
|
|
|
/* Get the Just_Daemonize setting. */
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.daemonize_without_pid_file", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
daemonisewithout = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
daemonisewithout = 1;
|
|
else
|
|
die("Invalid daemonize_without_pid_file option choice \"%s\". It should be \"yes\" or "
|
|
"\"no\"");
|
|
}
|
|
if ((daemonisewith) && (daemonisewithout))
|
|
die("Select either daemonize_with_pid_file or daemonize_without_pid_file -- you have "
|
|
"selected both!");
|
|
if ((daemonisewith) || (daemonisewithout)) {
|
|
config.daemonise = 1;
|
|
if (daemonisewith)
|
|
config.daemonise_store_pid = 1;
|
|
}
|
|
/* Get the directory path for the pid file created when the program is daemonised. */
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.daemon_pid_dir", &str))
|
|
config.piddir = (char *)str;
|
|
|
|
/* Get the mdns_backend setting. */
|
|
if (config_lookup_string(config.cfg, "general.mdns_backend", &str))
|
|
config.mdns_name = (char *)str;
|
|
|
|
/* Get the output_backend setting. */
|
|
if (config_lookup_string(config.cfg, "general.output_backend", &str))
|
|
config.output_name = (char *)str;
|
|
|
|
/* Get the port setting. */
|
|
if (config_lookup_int(config.cfg, "general.port", &value)) {
|
|
if ((value < 0) || (value > 65535))
|
|
die("Invalid port number \"%sd\". It should be between 0 and 65535, default is 5000",
|
|
value);
|
|
else
|
|
config.port = value;
|
|
}
|
|
|
|
/* Get the udp port base setting. */
|
|
if (config_lookup_int(config.cfg, "general.udp_port_base", &value)) {
|
|
if ((value < 0) || (value > 65535))
|
|
die("Invalid port number \"%sd\". It should be between 0 and 65535, default is 6001",
|
|
value);
|
|
else
|
|
config.udp_port_base = value;
|
|
}
|
|
|
|
/* Get the udp port range setting. This is number of ports that will be tried for free ports ,
|
|
* starting at the port base. Only three ports are needed. */
|
|
if (config_lookup_int(config.cfg, "general.udp_port_range", &value)) {
|
|
if ((value < 0) || (value > 65535))
|
|
die("Invalid port range \"%sd\". It should be between 0 and 65535, default is 100",
|
|
value);
|
|
else
|
|
config.udp_port_range = value;
|
|
}
|
|
|
|
/* Get the password setting. */
|
|
if (config_lookup_string(config.cfg, "general.password", &str))
|
|
config.password = (char *)str;
|
|
|
|
if (config_lookup_string(config.cfg, "general.interpolation", &str)) {
|
|
if (strcasecmp(str, "basic") == 0)
|
|
config.packet_stuffing = ST_basic;
|
|
else if (strcasecmp(str, "soxr") == 0)
|
|
#ifdef HAVE_LIBSOXR
|
|
config.packet_stuffing = ST_soxr;
|
|
#else
|
|
die("The soxr option not available because this version of shairport-sync was built "
|
|
"without libsoxr "
|
|
"support. Change the \"general/interpolation\" setting in the configuration file.");
|
|
#endif
|
|
else
|
|
die("Invalid interpolation option choice. It should be \"basic\" or \"soxr\"");
|
|
}
|
|
|
|
/* Get the statistics setting. */
|
|
if (config_lookup_string(config.cfg, "general.statistics", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.statistics_requested = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.statistics_requested = 1;
|
|
else
|
|
die("Invalid statistics option choice \"%s\". It should be \"yes\" or \"no\"");
|
|
}
|
|
|
|
/* The old drift tolerance setting. */
|
|
if (config_lookup_int(config.cfg, "general.drift", &value)) {
|
|
inform("The drift setting is deprecated. Use "
|
|
"drift_tolerance_in_seconds instead");
|
|
config.tolerance = 1.0 * value / 44100;
|
|
}
|
|
|
|
/* The old resync setting. */
|
|
if (config_lookup_int(config.cfg, "general.resync_threshold", &value)) {
|
|
inform("The resync_threshold setting is deprecated. Use "
|
|
"resync_threshold_in_seconds instead");
|
|
config.resyncthreshold = 1.0 * value / 44100;
|
|
}
|
|
|
|
/* Get the drift tolerance setting. */
|
|
if (config_lookup_float(config.cfg, "general.drift_tolerance_in_seconds", &dvalue))
|
|
config.tolerance = dvalue;
|
|
|
|
/* Get the resync setting. */
|
|
if (config_lookup_float(config.cfg, "general.resync_threshold_in_seconds", &dvalue))
|
|
config.resyncthreshold = dvalue;
|
|
|
|
/* Get the verbosity setting. */
|
|
if (config_lookup_int(config.cfg, "general.log_verbosity", &value)) {
|
|
if ((value >= 0) && (value <= 3))
|
|
debuglev = value;
|
|
else
|
|
die("Invalid log verbosity setting option choice \"%d\". It should be between 0 and 3, "
|
|
"inclusive.",
|
|
value);
|
|
}
|
|
|
|
/* Get the ignore_volume_control setting. */
|
|
if (config_lookup_string(config.cfg, "general.ignore_volume_control", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.ignore_volume_control = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.ignore_volume_control = 1;
|
|
else
|
|
die("Invalid ignore_volume_control option choice \"%s\". It should be \"yes\" or \"no\"");
|
|
}
|
|
|
|
/* Get the optional volume_max_db setting. */
|
|
if (config_lookup_float(config.cfg, "general.volume_max_db", &dvalue)) {
|
|
// debug(1, "Max volume setting of %f dB", dvalue);
|
|
config.volume_max_db = dvalue;
|
|
config.volume_max_db_set = 1;
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "general.run_this_when_volume_is_set", &str)) {
|
|
config.cmd_set_volume = (char *)str;
|
|
}
|
|
|
|
/* Get the playback_mode setting */
|
|
if (config_lookup_string(config.cfg, "general.playback_mode", &str)) {
|
|
if (strcasecmp(str, "stereo") == 0)
|
|
config.playback_mode = ST_stereo;
|
|
else if (strcasecmp(str, "mono") == 0)
|
|
config.playback_mode = ST_mono;
|
|
else if (strcasecmp(str, "reverse stereo") == 0)
|
|
config.playback_mode = ST_reverse_stereo;
|
|
else if (strcasecmp(str, "both left") == 0)
|
|
config.playback_mode = ST_left_only;
|
|
else if (strcasecmp(str, "both right") == 0)
|
|
config.playback_mode = ST_right_only;
|
|
else
|
|
die("Invalid playback_mode choice \"%s\". It should be \"stereo\" (default), \"mono\", "
|
|
"\"reverse stereo\", \"both left\", \"both right\"");
|
|
}
|
|
|
|
/* Get the interface to listen on, if specified Default is all interfaces */
|
|
/* we keep the interface name and the index */
|
|
|
|
if (config_lookup_string(config.cfg, "general.interface", &str))
|
|
config.interface = strdup(str);
|
|
|
|
if (config_lookup_string(config.cfg, "general.interface", &str)) {
|
|
int specified_interface_found = 0;
|
|
|
|
struct if_nameindex *if_ni, *i;
|
|
|
|
if_ni = if_nameindex();
|
|
if (if_ni == NULL) {
|
|
debug(1, "Can't get a list of interface names.");
|
|
} else {
|
|
for (i = if_ni; !(i->if_index == 0 && i->if_name == NULL); i++) {
|
|
// printf("%u: %s\n", i->if_index, i->if_name);
|
|
if (strcmp(i->if_name, str) == 0) {
|
|
config.interface_index = i->if_index;
|
|
specified_interface_found = 1;
|
|
}
|
|
}
|
|
}
|
|
|
|
if_freenameindex(if_ni);
|
|
|
|
if (specified_interface_found == 0) {
|
|
inform(
|
|
"The mdns service interface \"%s\" was not found, so the setting has been ignored.",
|
|
config.interface);
|
|
free(config.interface);
|
|
config.interface = NULL;
|
|
config.interface_index = 0;
|
|
}
|
|
}
|
|
|
|
/* Get the regtype -- the service type and protocol, separated by a dot. Default is
|
|
* "_raop._tcp" */
|
|
if (config_lookup_string(config.cfg, "general.regtype", &str))
|
|
config.regtype = strdup(str);
|
|
|
|
/* Get the volume range, in dB, that should be used If not set, it means you just use the
|
|
* range set by the mixer. */
|
|
if (config_lookup_int(config.cfg, "general.volume_range_db", &value)) {
|
|
if ((value < 30) || (value > 150))
|
|
die("Invalid volume range \"%sd\". It should be between 30 and 150 dB. Zero means use "
|
|
"the mixer's native range",
|
|
value);
|
|
else
|
|
config.volume_range_db = value;
|
|
}
|
|
|
|
/* Get the alac_decoder setting. */
|
|
if (config_lookup_string(config.cfg, "general.alac_decoder", &str)) {
|
|
if (strcasecmp(str, "hammerton") == 0)
|
|
config.use_apple_decoder = 0;
|
|
else if (strcasecmp(str, "apple") == 0) {
|
|
if ((config.decoders_supported & 1 << decoder_apple_alac) != 0)
|
|
config.use_apple_decoder = 1;
|
|
else
|
|
inform("Support for the Apple ALAC decoder has not been compiled into this version of "
|
|
"Shairport Sync. The default decoder will be used.");
|
|
} else
|
|
die("Invalid alac_decoder option choice \"%s\". It should be \"hammerton\" or \"apple\"");
|
|
}
|
|
|
|
/* Get the default latency. Deprecated! */
|
|
if (config_lookup_int(config.cfg, "latencies.default", &value))
|
|
config.userSuppliedLatency = value;
|
|
|
|
/* Get the itunes latency. Deprecated! */
|
|
if (config_lookup_int(config.cfg, "latencies.itunes", &value))
|
|
config.iTunesLatency = value;
|
|
|
|
/* Get the AirPlay latency. Deprecated! */
|
|
if (config_lookup_int(config.cfg, "latencies.airplay", &value))
|
|
config.AirPlayLatency = value;
|
|
|
|
/* Get the forkedDaapd latency. Deprecated! */
|
|
if (config_lookup_int(config.cfg, "latencies.forkedDaapd", &value))
|
|
config.ForkedDaapdLatency = value;
|
|
|
|
#ifdef CONFIG_METADATA
|
|
/* Get the metadata setting. */
|
|
if (config_lookup_string(config.cfg, "metadata.enabled", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.metadata_enabled = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.metadata_enabled = 1;
|
|
else
|
|
die("Invalid metadata enabled option choice \"%s\". It should be \"yes\" or \"no\"");
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "metadata.include_cover_art", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.get_coverart = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.get_coverart = 1;
|
|
else
|
|
die("Invalid metadata include_cover_art option choice \"%s\". It should be \"yes\" or "
|
|
"\"no\"");
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "metadata.pipe_name", &str)) {
|
|
config.metadata_pipename = (char *)str;
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "metadata.socket_address", &str)) {
|
|
config.metadata_sockaddr = (char *)str;
|
|
}
|
|
if (config_lookup_int(config.cfg, "metadata.socket_port", &value)) {
|
|
config.metadata_sockport = value;
|
|
}
|
|
config.metadata_sockmsglength = 500;
|
|
if (config_lookup_int(config.cfg, "metadata.socket_msglength", &value)) {
|
|
config.metadata_sockmsglength = value < 500 ? 500 : value > 65000 ? 65000 : value;
|
|
}
|
|
|
|
#endif
|
|
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.run_this_before_play_begins", &str)) {
|
|
config.cmd_start = (char *)str;
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.run_this_after_play_ends", &str)) {
|
|
config.cmd_stop = (char *)str;
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.wait_for_completion", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.cmd_blocking = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.cmd_blocking = 1;
|
|
else
|
|
die("Invalid session control wait_for_completion option choice \"%s\". It should be "
|
|
"\"yes\" or \"no\"");
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.before_play_begins_returns_output",
|
|
&str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.cmd_start_returns_output = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.cmd_start_returns_output = 1;
|
|
else
|
|
die("Invalid session control before_play_begins_returns_output option choice \"%s\". It "
|
|
"should be "
|
|
"\"yes\" or \"no\"");
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "sessioncontrol.allow_session_interruption", &str)) {
|
|
config.dont_check_timeout = 0; // this is for legacy -- only set by -t 0
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.allow_session_interruption = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.allow_session_interruption = 1;
|
|
else
|
|
die("Invalid session control allow_interruption option choice \"%s\". It should be "
|
|
"\"yes\" "
|
|
"or \"no\"");
|
|
}
|
|
|
|
if (config_lookup_int(config.cfg, "sessioncontrol.session_timeout", &value)) {
|
|
config.timeout = value;
|
|
config.dont_check_timeout = 0; // this is for legacy -- only set by -t 0
|
|
}
|
|
|
|
#ifdef CONFIG_CONVOLUTION
|
|
|
|
if (config_lookup_string(config.cfg, "dsp.convolution", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.convolution = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.convolution = 1;
|
|
else
|
|
die("Invalid dsp.convolution. It should be \"yes\" or \"no\"");
|
|
}
|
|
|
|
if (config_lookup_float(config.cfg, "dsp.convolution_gain", &dvalue)) {
|
|
config.convolution_gain = dvalue;
|
|
if (dvalue > 10 || dvalue < -50)
|
|
die("Invalid value \"%f\" for dsp.convolution_gain. It should be between -50 and +10 dB",
|
|
dvalue);
|
|
}
|
|
|
|
config.convolution_max_length = 8192;
|
|
if (config_lookup_int(config.cfg, "dsp.convolution_max_length", &value)) {
|
|
config.convolution_max_length = value;
|
|
|
|
if (value < 1 || value > 200000)
|
|
die("dsp.convolution_max_length must be within 1 and 200000");
|
|
}
|
|
|
|
if (config_lookup_string(config.cfg, "dsp.convolution_ir_file", &str)) {
|
|
config.convolution_ir_file = str;
|
|
convolver_init(config.convolution_ir_file, config.convolution_max_length);
|
|
}
|
|
|
|
if (config.convolution && config.convolution_ir_file == NULL) {
|
|
die("Convolution enabled but no convolution_ir_file provided");
|
|
}
|
|
#endif
|
|
|
|
if (config_lookup_string(config.cfg, "dsp.loudness", &str)) {
|
|
if (strcasecmp(str, "no") == 0)
|
|
config.loudness = 0;
|
|
else if (strcasecmp(str, "yes") == 0)
|
|
config.loudness = 1;
|
|
else
|
|
die("Invalid dsp.convolution. It should be \"yes\" or \"no\"");
|
|
}
|
|
|
|
config.loudness_reference_volume_db = -20;
|
|
if (config_lookup_float(config.cfg, "dsp.loudness_reference_volume_db", &dvalue)) {
|
|
config.loudness_reference_volume_db = dvalue;
|
|
if (dvalue > 0 || dvalue < -100)
|
|
die("Invalid value \"%f\" for dsp.loudness_reference_volume_db. It should be between "
|
|
"-100 and 0",
|
|
dvalue);
|
|
}
|
|
|
|
if (config.loudness == 1 && config_lookup_string(config.cfg, "alsa.mixer_control_name", &str))
|
|
die("Loudness activated but hardware volume is active. You must remove "
|
|
"\"alsa.mixer_control_name\" to use the loudness filter.");
|
|
|
|
} else {
|
|
if (config_error_type(&config_file_stuff) == CONFIG_ERR_FILE_IO)
|
|
debug(1, "Error reading configuration file \"%s\": \"%s\".",
|
|
config_error_file(&config_file_stuff), config_error_text(&config_file_stuff));
|
|
else {
|
|
die("Line %d of the configuration file \"%s\":\n%s", config_error_line(&config_file_stuff),
|
|
config_error_file(&config_file_stuff), config_error_text(&config_file_stuff));
|
|
}
|
|
}
|
|
free(config_file_real_path);
|
|
}
|
|
|
|
// now, do the command line options again, but this time do them fully -- it's a unix convention
|
|
// that command line
|
|
// arguments have precedence over configuration file settings.
|
|
|
|
optind = argc;
|
|
for (j = 0; j < argc; j++)
|
|
if (strcmp(argv[j], "--") == 0)
|
|
optind = j;
|
|
|
|
optCon = poptGetContext(NULL, optind, (const char **)argv, optionsTable, 0);
|
|
poptSetOtherOptionHelp(optCon, "[OPTIONS]* ");
|
|
|
|
/* Now do options processing, get portname */
|
|
int tdebuglev = 0;
|
|
while ((c = poptGetNextOpt(optCon)) >= 0) {
|
|
switch (c) {
|
|
case 'v':
|
|
tdebuglev++;
|
|
break;
|
|
case 't':
|
|
if (config.timeout == 0) {
|
|
config.dont_check_timeout = 1;
|
|
config.allow_session_interruption = 1;
|
|
} else {
|
|
config.dont_check_timeout = 0;
|
|
config.allow_session_interruption = 0;
|
|
}
|
|
break;
|
|
#ifdef CONFIG_METADATA
|
|
case 'M':
|
|
config.metadata_enabled = 1;
|
|
break;
|
|
case 'g':
|
|
if (config.metadata_enabled == 0)
|
|
die("If you want to get cover art, you must also select the --metadata-pipename option.");
|
|
break;
|
|
#endif
|
|
case 'S':
|
|
if (strcmp(stuffing, "basic") == 0)
|
|
config.packet_stuffing = ST_basic;
|
|
else if (strcmp(stuffing, "soxr") == 0)
|
|
#ifdef HAVE_LIBSOXR
|
|
config.packet_stuffing = ST_soxr;
|
|
#else
|
|
die("The soxr option not available because this version of shairport-sync was built "
|
|
"without libsoxr "
|
|
"support. Change the -S option setting.");
|
|
#endif
|
|
else
|
|
die("Illegal stuffing option \"%s\" -- must be \"basic\" or \"soxr\"", stuffing);
|
|
break;
|
|
}
|
|
}
|
|
if (c < -1) {
|
|
die("%s: %s", poptBadOption(optCon, POPT_BADOPTION_NOALIAS), poptStrerror(c));
|
|
}
|
|
|
|
#ifdef CONFIG_METADATA
|
|
if ((config.metadata_enabled == 1) && (config.metadata_pipename == NULL))
|
|
config.metadata_pipename = strdup("/tmp/shairport-sync-metadata");
|
|
#endif
|
|
|
|
/* if the regtype hasn't been set, do it now */
|
|
if (config.regtype == NULL)
|
|
config.regtype = strdup("_raop._tcp");
|
|
|
|
if (tdebuglev != 0)
|
|
debuglev = tdebuglev;
|
|
|
|
/* if the Service Name wasn't specified, do it now */
|
|
|
|
if (raw_service_name == NULL)
|
|
raw_service_name = strdup("%H");
|
|
|
|
// now, do the substitutions in the service name
|
|
char hostname[100];
|
|
gethostname(hostname, 100);
|
|
char *i1 = str_replace(raw_service_name, "%h", hostname);
|
|
if ((hostname[0] >= 'a') && (hostname[0] <= 'z'))
|
|
hostname[0] = hostname[0] - 0x20; // convert a lowercase first letter into a capital letter
|
|
char *i2 = str_replace(i1, "%H", hostname);
|
|
char *i3 = str_replace(i2, "%v", PACKAGE_VERSION);
|
|
char *vs = get_version_string();
|
|
config.service_name = str_replace(i3, "%V", vs);
|
|
free(i1);
|
|
free(i2);
|
|
free(i3);
|
|
free(vs);
|
|
|
|
// now, check and calculate the pid directory
|
|
#ifdef USE_CUSTOM_PID_DIR
|
|
char *use_this_pid_dir = PIDDIR;
|
|
#else
|
|
char *use_this_pid_dir = "/var/run/shairport-sync";
|
|
#endif
|
|
// debug(1,"config.piddir \"%s\".",config.piddir);
|
|
if (config.piddir)
|
|
use_this_pid_dir = config.piddir;
|
|
if (use_this_pid_dir)
|
|
config.computed_piddir = strdup(use_this_pid_dir);
|
|
|
|
return optind + 1;
|
|
}
|
|
|
|
#if defined(HAVE_DBUS) || defined(HAVE_MPRIS)
|
|
GMainLoop *loop;
|
|
|
|
pthread_t dbus_thread;
|
|
void *dbus_thread_func(void *arg) {
|
|
loop = g_main_loop_new(NULL, FALSE);
|
|
g_main_loop_run(loop);
|
|
return NULL;
|
|
}
|
|
#endif
|
|
|
|
void signal_setup(void) {
|
|
// mask off all signals before creating threads.
|
|
// this way we control which thread gets which signals.
|
|
// for now, we don't care which thread gets the following.
|
|
sigset_t set;
|
|
sigfillset(&set);
|
|
sigdelset(&set, SIGINT);
|
|
sigdelset(&set, SIGTERM);
|
|
sigdelset(&set, SIGHUP);
|
|
sigdelset(&set, SIGSTOP);
|
|
sigdelset(&set, SIGCHLD);
|
|
sigdelset(&set, SIGUSR2);
|
|
pthread_sigmask(SIG_BLOCK, &set, NULL);
|
|
|
|
// SIGUSR1 is used to interrupt a thread if blocked in pselect
|
|
pthread_sigmask(SIG_SETMASK, NULL, &pselect_sigset);
|
|
sigdelset(&pselect_sigset, SIGUSR1);
|
|
|
|
// setting this to SIG_IGN would prevent signalling any threads.
|
|
struct sigaction sa;
|
|
memset(&sa, 0, sizeof(sa));
|
|
sa.sa_flags = SA_SIGINFO;
|
|
sa.sa_sigaction = &sig_ignore;
|
|
sigaction(SIGUSR1, &sa, NULL);
|
|
|
|
sa.sa_flags = SA_SIGINFO | SA_RESTART;
|
|
sa.sa_sigaction = &sig_shutdown;
|
|
sigaction(SIGINT, &sa, NULL);
|
|
sigaction(SIGTERM, &sa, NULL);
|
|
|
|
sa.sa_sigaction = &sig_disconnect_audio_output;
|
|
sigaction(SIGUSR2, &sa, NULL);
|
|
|
|
sa.sa_sigaction = &sig_connect_audio_output;
|
|
sigaction(SIGHUP, &sa, NULL);
|
|
|
|
sa.sa_sigaction = &sig_child;
|
|
sigaction(SIGCHLD, &sa, NULL);
|
|
}
|
|
|
|
// forked daemon lets the spawner know it's up and running OK
|
|
// should be called only once!
|
|
void shairport_startup_complete(void) {
|
|
if (config.daemonise) {
|
|
// daemon_ready();
|
|
}
|
|
}
|
|
|
|
const char *pid_file_proc(void) {
|
|
|
|
char fn[8192];
|
|
snprintf(fn, sizeof(fn), "%s/%s.pid", config.computed_piddir,
|
|
daemon_pid_file_ident ? daemon_pid_file_ident : "unknown");
|
|
// debug(1,"fn \"%s\".",fn);
|
|
return strdup(fn);
|
|
}
|
|
|
|
void exit_function() {
|
|
if (config.cfg)
|
|
config_destroy(config.cfg);
|
|
// probably should be freeing malloc'ed memory here, including strdup-created strings...
|
|
}
|
|
|
|
int main(int argc, char **argv) {
|
|
|
|
daemon_set_verbosity(LOG_DEBUG);
|
|
memset(&config, 0, sizeof(config)); // also clears all strings, BTW
|
|
atexit(exit_function);
|
|
|
|
// this is a bit weird, but apparently necessary
|
|
char *basec = strdup(argv[0]);
|
|
char *bname = basename(basec);
|
|
appName = strdup(bname);
|
|
if (appName == NULL)
|
|
die("can not allocate memory for the app name!");
|
|
free(basec);
|
|
|
|
// set defaults
|
|
|
|
// get thje endianness
|
|
union {
|
|
uint32_t u32;
|
|
uint8_t arr[4];
|
|
} xn;
|
|
|
|
xn.arr[0] = 0x44; /* Lowest-address byte */
|
|
xn.arr[1] = 0x33;
|
|
xn.arr[2] = 0x22;
|
|
xn.arr[3] = 0x11; /* Highest-address byte */
|
|
|
|
if (xn.u32 == 0x11223344)
|
|
endianness = SS_LITTLE_ENDIAN;
|
|
else if (xn.u32 == 0x33441122)
|
|
endianness = SS_PDP_ENDIAN;
|
|
else if (xn.u32 == 0x44332211)
|
|
endianness = SS_BIG_ENDIAN;
|
|
else
|
|
die("Can not recognise the endianness of the processor.");
|
|
|
|
// set non-zero / non-NULL default values here
|
|
// but note that audio back ends also have a chance to set defaults
|
|
|
|
strcpy(configuration_file_path, SYSCONFDIR);
|
|
// strcat(configuration_file_path, "/shairport-sync"); // thinking about adding a special
|
|
// shairport-sync directory
|
|
strcat(configuration_file_path, "/");
|
|
strcat(configuration_file_path, appName);
|
|
strcat(configuration_file_path, ".conf");
|
|
config.configfile = configuration_file_path;
|
|
|
|
config.statistics_requested = 0; // don't print stats in the log
|
|
config.latency = -1; // -1 means not set. 88200 works well. This is also reset in rtsp.c when play
|
|
// is about to start
|
|
config.userSuppliedLatency = 0; // zero means none supplied
|
|
config.iTunesLatency =
|
|
-1; // -1 means not supplied. 99400 seems to work pretty well for iTunes from Version 10 (?)
|
|
// upwards-- two left-ear headphones, one from the iMac jack, one
|
|
// from an NSLU2 running a cheap "3D Sound" USB Soundcard
|
|
config.AirPlayLatency =
|
|
-1; // -1 means not set. 88200 seems to work well for AirPlay -- Syncs sound and
|
|
// vision on AppleTV, but also used for iPhone/iPod/iPad sources
|
|
config.ForkedDaapdLatency = -1; // -1 means not set. 99400 seems to be right
|
|
config.resyncthreshold = 0.05; // 50 ms
|
|
config.timeout = 120; // this number of seconds to wait for [more] audio before switching to idle.
|
|
config.tolerance =
|
|
0.002; // this number of seconds of timing error before attempting to correct it.
|
|
config.buffer_start_fill = 220;
|
|
config.port = 5000;
|
|
config.packet_stuffing = ST_basic; // simple interpolation or deletion
|
|
// char hostname[100];
|
|
// gethostname(hostname, 100);
|
|
// config.service_name = malloc(20 + 100);
|
|
// snprintf(config.service_name, 20 + 100, "Shairport Sync on %s", hostname);
|
|
set_requested_connection_state_to_output(
|
|
1); // we expect to be able to connect to the output device
|
|
config.audio_backend_buffer_desired_length = 6615; // 0.15 seconds.
|
|
config.udp_port_base = 6001;
|
|
config.udp_port_range = 100;
|
|
config.output_format = SPS_FORMAT_S16; // default
|
|
config.output_rate = 44100; // default
|
|
config.decoders_supported =
|
|
1 << decoder_hammerton; // David Hammerton's decoder supported by default
|
|
#ifdef HAVE_APPLE_ALAC
|
|
config.decoders_supported += 1 << decoder_apple_alac;
|
|
#endif
|
|
|
|
// initialise random number generator
|
|
|
|
r64init(0);
|
|
|
|
// initialise the randomw number array
|
|
|
|
r64arrayinit();
|
|
|
|
/* Check if we are called with -V or --version parameter */
|
|
if (argc >= 2 && ((strcmp(argv[1], "-V") == 0) || (strcmp(argv[1], "--version") == 0))) {
|
|
print_version();
|
|
exit(1);
|
|
}
|
|
|
|
/* Check if we are called with -h or --help parameter */
|
|
if (argc >= 2 && ((strcmp(argv[1], "-h") == 0) || (strcmp(argv[1], "--help") == 0))) {
|
|
usage(argv[0]);
|
|
exit(1);
|
|
}
|
|
|
|
pid_t pid;
|
|
|
|
/* Reset signal handlers */
|
|
if (daemon_reset_sigs(-1) < 0) {
|
|
daemon_log(LOG_ERR, "Failed to reset all signal handlers: %s", strerror(errno));
|
|
return 1;
|
|
}
|
|
|
|
/* Unblock signals */
|
|
if (daemon_unblock_sigs(-1) < 0) {
|
|
daemon_log(LOG_ERR, "Failed to unblock all signals: %s", strerror(errno));
|
|
return 1;
|
|
}
|
|
|
|
// Point to a function to help locate where the PID file will go
|
|
// We always use this function because the default location
|
|
// is unsatisfactory. By default we want to use /var/run/shairport-sync/.
|
|
daemon_pid_file_proc = pid_file_proc;
|
|
|
|
/* Set indentification string for the daemon for both syslog and PID file */
|
|
daemon_pid_file_ident = daemon_log_ident = daemon_ident_from_argv0(argv[0]);
|
|
|
|
/* Check if we are called with -D or --disconnectFromOutput parameter */
|
|
if (argc >= 2 &&
|
|
((strcmp(argv[1], "-D") == 0) || (strcmp(argv[1], "--disconnectFromOutput") == 0))) {
|
|
if ((pid = daemon_pid_file_is_running()) >= 0) {
|
|
if (kill(pid, SIGUSR2) != 0) { // try to send the signal
|
|
daemon_log(LOG_WARNING,
|
|
"Failed trying to send disconnectFromOutput command to daemon pid: %d: %s", pid,
|
|
strerror(errno));
|
|
}
|
|
} else {
|
|
daemon_log(LOG_WARNING,
|
|
"Can't send a disconnectFromOutput request -- Failed to find daemon: %s",
|
|
strerror(errno));
|
|
}
|
|
exit(1);
|
|
}
|
|
|
|
/* Check if we are called with -R or --reconnectToOutput parameter */
|
|
if (argc >= 2 &&
|
|
((strcmp(argv[1], "-R") == 0) || (strcmp(argv[1], "--reconnectToOutput") == 0))) {
|
|
if ((pid = daemon_pid_file_is_running()) >= 0) {
|
|
if (kill(pid, SIGHUP) != 0) { // try to send the signal
|
|
daemon_log(LOG_WARNING,
|
|
"Failed trying to send reconnectToOutput command to daemon pid: %d: %s", pid,
|
|
strerror(errno));
|
|
}
|
|
} else {
|
|
daemon_log(LOG_WARNING, "Can't send a reconnectToOutput request -- Failed to find daemon: %s",
|
|
strerror(errno));
|
|
}
|
|
exit(1);
|
|
}
|
|
|
|
// parse arguments into config -- needed to locate pid_dir
|
|
int audio_arg = parse_options(argc, argv);
|
|
|
|
/* Check if we are called with -k or --kill parameter */
|
|
if (argc >= 2 && ((strcmp(argv[1], "-k") == 0) || (strcmp(argv[1], "--kill") == 0))) {
|
|
int ret;
|
|
|
|
/* Kill daemon with SIGTERM */
|
|
/* Check if the new function daemon_pid_file_kill_wait() is available, if it is, use it. */
|
|
if ((ret = daemon_pid_file_kill_wait(SIGTERM, 5)) < 0)
|
|
daemon_log(LOG_WARNING, "Failed to kill daemon: %s", strerror(errno));
|
|
else
|
|
daemon_pid_file_remove();
|
|
return ret < 0 ? 1 : 0;
|
|
}
|
|
|
|
/* If we are going to daemonise, check that the daemon is not running already.*/
|
|
if ((config.daemonise) && ((pid = daemon_pid_file_is_running()) >= 0)) {
|
|
daemon_log(LOG_ERR, "Daemon already running on PID file %u", pid);
|
|
return 1;
|
|
}
|
|
|
|
// mDNS supports maximum of 63-character names (we append 13).
|
|
if (strlen(config.service_name) > 50) {
|
|
warn("Supplied name too long (max 50 characters)");
|
|
config.service_name[50] = '\0'; // truncate it and carry on...
|
|
}
|
|
|
|
/* here, daemonise with libdaemon */
|
|
|
|
if (config.daemonise) {
|
|
/* Prepare for return value passing from the initialization procedure of the daemon process */
|
|
if (daemon_retval_init() < 0) {
|
|
daemon_log(LOG_ERR, "Failed to create pipe.");
|
|
return 1;
|
|
}
|
|
|
|
/* Do the fork */
|
|
if ((pid = daemon_fork()) < 0) {
|
|
|
|
/* Exit on error */
|
|
daemon_retval_done();
|
|
return 1;
|
|
|
|
} else if (pid) { /* The parent */
|
|
int ret;
|
|
|
|
/* Wait for 20 seconds for the return value passed from the daemon process */
|
|
if ((ret = daemon_retval_wait(20)) < 0) {
|
|
daemon_log(LOG_ERR, "Could not receive return value from daemon process: %s",
|
|
strerror(errno));
|
|
return 255;
|
|
}
|
|
|
|
switch (ret) {
|
|
case 0:
|
|
break;
|
|
case 1:
|
|
daemon_log(LOG_ERR,
|
|
"daemon failed to launch: could not close open file descriptors after forking.");
|
|
break;
|
|
case 2:
|
|
daemon_log(LOG_ERR, "daemon failed to launch: could not create PID file.");
|
|
break;
|
|
case 3:
|
|
daemon_log(LOG_ERR, "daemon failed to launch: could not create or access PID directory.");
|
|
break;
|
|
default:
|
|
daemon_log(LOG_ERR, "daemon failed to launch, error %i.", ret);
|
|
}
|
|
return ret;
|
|
} else { /* The daemon */
|
|
|
|
/* Close FDs */
|
|
if (daemon_close_all(-1) < 0) {
|
|
daemon_log(LOG_ERR, "Failed to close all file descriptors: %s", strerror(errno));
|
|
|
|
/* Send the error condition to the parent process */
|
|
daemon_retval_send(1);
|
|
goto finish;
|
|
}
|
|
|
|
/* Create the PID file if required */
|
|
if (config.daemonise_store_pid) {
|
|
/* Create the PID directory if required -- we don't really care about the result */
|
|
printf("PID directory is \"%s\".", config.computed_piddir);
|
|
int result = mkpath(config.computed_piddir, 0700);
|
|
if ((result != 0) && (result != -EEXIST)) {
|
|
// error creating or accessing the PID file directory
|
|
daemon_retval_send(3);
|
|
goto finish;
|
|
}
|
|
if (daemon_pid_file_create() < 0) {
|
|
daemon_log(LOG_ERR, "Could not create PID file (%s).", strerror(errno));
|
|
daemon_retval_send(2);
|
|
goto finish;
|
|
}
|
|
}
|
|
|
|
/* Send OK to parent process */
|
|
daemon_retval_send(0);
|
|
}
|
|
/* end libdaemon stuff */
|
|
}
|
|
|
|
signal_setup();
|
|
|
|
// make sure the program can create files that group and world can read
|
|
umask(S_IWGRP | S_IWOTH);
|
|
|
|
config.output = audio_get_output(config.output_name);
|
|
if (!config.output) {
|
|
audio_ls_outputs();
|
|
die("Invalid audio output specified!");
|
|
}
|
|
config.output->init(argc - audio_arg, argv + audio_arg);
|
|
|
|
// daemon_log(LOG_NOTICE, "startup");
|
|
|
|
switch (endianness) {
|
|
case SS_LITTLE_ENDIAN:
|
|
debug(2, "The processor is running little-endian.");
|
|
break;
|
|
case SS_BIG_ENDIAN:
|
|
debug(2, "The processor is running big-endian.");
|
|
break;
|
|
case SS_PDP_ENDIAN:
|
|
debug(2, "The processor is running pdp-endian.");
|
|
break;
|
|
}
|
|
|
|
/* Mess around with the latency options */
|
|
// Basically, we used to rely on static latencies -- 99400 for iTunes 10 or later and forkedDaapd,
|
|
// 88200 for everything else
|
|
// Nowadays we allow the source to set the latency, which works out at 99651 for iTunes 10 and
|
|
// forkedDaapd and 88220 for everything else
|
|
// What we want to do here is allow the source to set the latency unless the user has specified an
|
|
// non-standard latency.
|
|
// If the user has specified a standard latency, we suggest to them to stop doing it.
|
|
// If they specify a non-standard latency, we suggest the user to use the
|
|
// audio_backend_latency_offset instead.
|
|
|
|
if (config.AirPlayLatency != -1) {
|
|
if (config.AirPlayLatency == 88200) {
|
|
inform("It is not necessary to set the AirPlay latency to 88200 -- you should remove this "
|
|
"setting or configuration option, as it is deprecated.");
|
|
config.AirPlayLatency = -1;
|
|
} else {
|
|
inform("The AirPlay latency setting is deprecated, as Shairport Sync can now get the correct "
|
|
"latency from the source.");
|
|
inform("Please remove this setting and use the relevant audio_backend_latency_offset "
|
|
"setting, if necessary, to compensate for delays elsewhere.");
|
|
}
|
|
}
|
|
|
|
if (config.iTunesLatency != -1) {
|
|
if (config.iTunesLatency == 99400) {
|
|
inform("It is not necessary to set the iTunes latency to 99400 -- you should remove this "
|
|
"setting or configuration option, as it is deprecated and ignored.");
|
|
config.iTunesLatency = -1;
|
|
} else {
|
|
inform("The iTunes latency setting is deprecated, as Shairport Sync can now get the correct "
|
|
"latency from the source.");
|
|
inform("Please remove this setting and use the relevant audio_backend_latency_offset "
|
|
"setting, if necessary, to compensate for delays elsewhere.");
|
|
}
|
|
}
|
|
|
|
if (config.ForkedDaapdLatency != -1) {
|
|
if (config.ForkedDaapdLatency == 99400) {
|
|
inform("It is not necessary to set the forkedDaapd latency to 99400 -- you should remove "
|
|
"this setting or configuration option, as it is deprecated and ignored.");
|
|
config.ForkedDaapdLatency = -1;
|
|
} else {
|
|
inform("The forkedDaapd latency setting is deprecated, as Shairport Sync can now get the "
|
|
"correct latency from the source.");
|
|
inform("Please remove this setting and use the relevant audio_backend_latency_offset "
|
|
"setting, if necessary, to compensate for delays elsewhere.");
|
|
}
|
|
}
|
|
|
|
if (config.userSuppliedLatency) {
|
|
inform("The default latency setting is deprecated, as Shairport Sync can now get the correct "
|
|
"latency from the source.");
|
|
inform("Please remove this setting and use the relevant audio_backend_latency_offset setting, "
|
|
"if necessary, to compensate for delays elsewhere.");
|
|
}
|
|
|
|
/* print out version */
|
|
|
|
char *version_dbs = get_version_string();
|
|
if (version_dbs) {
|
|
debug(1, "Version: \"%s\"", version_dbs);
|
|
free(version_dbs);
|
|
} else {
|
|
debug(1, "Can't print the version information!");
|
|
}
|
|
|
|
/* Print out options */
|
|
debug(1, "statistics_requester status is %d.", config.statistics_requested);
|
|
debug(1, "daemon status is %d.", config.daemonise);
|
|
debug(1, "deamon pid file is \"%s\".", pid_file_proc());
|
|
debug(1, "rtsp listening port is %d.", config.port);
|
|
debug(1, "udp base port is %d.", config.udp_port_base);
|
|
debug(1, "udp port range is %d.", config.udp_port_range);
|
|
debug(1, "player name is \"%s\".", config.service_name);
|
|
debug(1, "backend is \"%s\".", config.output_name);
|
|
debug(1, "on-start action is \"%s\".", config.cmd_start);
|
|
debug(1, "on-stop action is \"%s\".", config.cmd_stop);
|
|
debug(1, "wait-cmd status is %d.", config.cmd_blocking);
|
|
debug(1, "on-start returns output is %d.", config.cmd_start_returns_output);
|
|
debug(1, "mdns backend \"%s\".", config.mdns_name);
|
|
debug(2, "userSuppliedLatency is %d.", config.userSuppliedLatency);
|
|
debug(2, "AirPlayLatency is %d.", config.AirPlayLatency);
|
|
debug(2, "iTunesLatency is %d.", config.iTunesLatency);
|
|
debug(2, "forkedDaapdLatency is %d.", config.ForkedDaapdLatency);
|
|
debug(1, "stuffing option is \"%d\" (0-basic, 1-soxr).", config.packet_stuffing);
|
|
debug(1, "resync time is %f seconds.", config.resyncthreshold);
|
|
debug(1, "allow a session to be interrupted: %d.", config.allow_session_interruption);
|
|
debug(1, "busy timeout time is %d.", config.timeout);
|
|
debug(1, "drift tolerance is %f seconds.", config.tolerance);
|
|
debug(1, "password is \"%s\".", config.password);
|
|
debug(1, "ignore_volume_control is %d.", config.ignore_volume_control);
|
|
if (config.volume_max_db_set)
|
|
debug(1, "volume_max_db is %d.", config.volume_max_db);
|
|
else
|
|
debug(1, "volume_max_db is not set");
|
|
debug(1, "playback_mode is %d (0-stereo, 1-mono, 1-reverse_stereo, 2-both_left, 3-both_right).",
|
|
config.playback_mode);
|
|
debug(1, "disable_synchronization is %d.", config.no_sync);
|
|
debug(1, "use_mmap_if_available is %d.", config.no_mmap ? 0 : 1);
|
|
debug(1, "output_rate is %d.", config.output_rate);
|
|
debug(1,
|
|
"output_format is %d (0-unknown, 1-S8, 2-U8, 3-S16, 4-S24, 5-S24_3LE, 6-S24_3BE, 7-S32).",
|
|
config.output_format);
|
|
debug(1, "audio backend desired buffer length is %f seconds.",
|
|
config.audio_backend_buffer_desired_length);
|
|
debug(1, "audio backend latency offset is %f seconds.", config.audio_backend_latency_offset);
|
|
debug(1, "audio backend silence lead-in time is %f seconds. A value -1.0 means use the default.",
|
|
config.audio_backend_silent_lead_in_time);
|
|
debug(1, "volume range in dB (zero means use the range specified by the mixer): %u.",
|
|
config.volume_range_db);
|
|
debug(1, "zeroconf regtype is \"%s\".", config.regtype);
|
|
debug(1, "decoders_supported field is %d.", config.decoders_supported);
|
|
debug(1, "use_apple_decoder is %d.", config.use_apple_decoder);
|
|
debug(1, "alsa_use_playback_switch_for_mute is %d.", config.alsa_use_playback_switch_for_mute);
|
|
if (config.interface)
|
|
debug(1, "mdns service interface \"%s\" requested.", config.interface);
|
|
else
|
|
debug(1, "no special mdns service interface was requested.");
|
|
char *realConfigPath = realpath(config.configfile, NULL);
|
|
if (realConfigPath) {
|
|
debug(1, "configuration file name \"%s\" resolves to \"%s\".", config.configfile,
|
|
realConfigPath);
|
|
free(realConfigPath);
|
|
} else {
|
|
debug(1, "configuration file name \"%s\" can not be resolved.", config.configfile);
|
|
}
|
|
#ifdef CONFIG_METADATA
|
|
debug(1, "metadata enabled is %d.", config.metadata_enabled);
|
|
debug(1, "metadata pipename is \"%s\".", config.metadata_pipename);
|
|
debug(1, "metadata socket address is \"%s\" port %d.", config.metadata_sockaddr,
|
|
config.metadata_sockport);
|
|
debug(1, "metadata socket packet size is \"%d\".", config.metadata_sockmsglength);
|
|
debug(1, "get-coverart is %d.", config.get_coverart);
|
|
#endif
|
|
|
|
#ifdef CONFIG_CONVOLUTION
|
|
debug(1, "convolution is %d.", config.convolution);
|
|
debug(1, "convolution IR file is \"%s\"", config.convolution_ir_file);
|
|
debug(1, "convolution max length %d", config.convolution_max_length);
|
|
debug(1, "convolution gain is %f", config.convolution_gain);
|
|
#endif
|
|
debug(1, "loudness is %d.", config.loudness);
|
|
debug(1, "loudness reference level is %f", config.loudness_reference_volume_db);
|
|
|
|
uint8_t ap_md5[16];
|
|
|
|
#ifdef HAVE_LIBSSL
|
|
MD5_CTX ctx;
|
|
MD5_Init(&ctx);
|
|
MD5_Update(&ctx, config.service_name, strlen(config.service_name));
|
|
MD5_Final(ap_md5, &ctx);
|
|
#endif
|
|
|
|
#ifdef HAVE_LIBMBEDTLS
|
|
mbedtls_md5_context tctx;
|
|
mbedtls_md5_starts(&tctx);
|
|
mbedtls_md5_update(&tctx, (unsigned char *)config.service_name, strlen(config.service_name));
|
|
mbedtls_md5_finish(&tctx, ap_md5);
|
|
#endif
|
|
|
|
#ifdef HAVE_LIBPOLARSSL
|
|
md5_context tctx;
|
|
md5_starts(&tctx);
|
|
md5_update(&tctx, (unsigned char *)config.service_name, strlen(config.service_name));
|
|
md5_finish(&tctx, ap_md5);
|
|
#endif
|
|
memcpy(config.hw_addr, ap_md5, sizeof(config.hw_addr));
|
|
#ifdef CONFIG_METADATA
|
|
metadata_init(); // create the metadata pipe if necessary
|
|
#endif
|
|
|
|
#ifdef HAVE_DBUS
|
|
// Start up DBUS services after initial settings are all made
|
|
debug(1, "Starting up D-Bus services");
|
|
pthread_create(&dbus_thread, NULL, &dbus_thread_func, NULL);
|
|
start_dbus_service();
|
|
#endif
|
|
|
|
daemon_log(LOG_INFO, "Successful Startup");
|
|
rtsp_listen_loop();
|
|
|
|
// should not reach this...
|
|
shairport_shutdown();
|
|
finish:
|
|
daemon_log(LOG_NOTICE, "Unexpected exit...");
|
|
daemon_retval_send(255);
|
|
daemon_pid_file_remove();
|
|
return 1;
|
|
}
|