X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audioc.c;h=a8f88e315403955fbc04539595ad19236e13c9f2;hp=0f4c5c5084d8dbf31c726ae6d3e5ccf67bcb7d29;hb=06372eab260c4d2cba43bfef0d668744aa6c1216;hpb=6570e0e4433a5e5d7987697716a1f993c96eb1bb;ds=sidebyside diff --git a/audioc.c b/audioc.c index 0f4c5c50..a8f88e31 100644 --- a/audioc.c +++ b/audioc.c @@ -1,52 +1,29 @@ /* - * Copyright (C) 2005-2006 Andre Noll + * Copyright (C) 2005-2008 Andre Noll * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA. + * Licensed under the GPL v2. For licencing details see COPYING. */ /** \file audioc.c the client program used to connect to para_audiod */ +#include +#include + #include "audioc.cmdline.h" #include "para.h" +#include "error.h" #include "net.h" #include "string.h" #include "fd.h" -#include "error.h" INIT_AUDIOC_ERRLISTS; +/** the gengetopt structure containing command line args */ struct audioc_args_info conf; -char *tmpfifo; - -/* - * client log function - */ -void para_log(int ll, const char* fmt,...) -{ - va_list argp; - - /* ignore log message if loglevel is not high enough */ - if (ll < conf.loglevel_arg) - return; - va_start(argp, fmt); - vfprintf(stderr, fmt, argp); - va_end(argp); -} +INIT_STDERR_LOGGING(conf.loglevel_arg); -static char *concat_args(const int argc, char * const *argv) +static char *concat_args(unsigned argc, char * const *argv) { int i; char *buf = NULL; for (i = 0; i < argc; i++) { @@ -73,19 +50,39 @@ static char *configfile_exists(void) return NULL; } +/** + * the client program to connect to para_audiod + * + * \param argc usual argument count + * \param argv usual argument vector + * + * It creates a temporary local socket in order to communicate with para_audiod. + * Authentication consists in sending a ucred buffer that contains the user id. + * + * Any output received through the local socket is sent to stdout. + * + * \return EXIT_SUCCESS or EXIT_FAILURE + * + * \sa send_cred_buffer(), para_audioc(1), para_audiod(1). + */ int main(int argc, char *argv[]) { - struct sockaddr_un unix_addr; - int ret = -E_AUDIOC_SYNTAX, fd, loaded = 0; - char *cf, *socket_name, *randname = para_tmpname(), *tmpsocket_name = NULL, - *buf = NULL, *hn = para_hostname(), *args, *home = para_homedir(); - + int ret = -E_AUDIOC_SYNTAX, fd; + char *cf, *buf = NULL, *args; + size_t bufsize, loaded = 0; if (audioc_cmdline_parser(argc, argv, &conf)) goto out; + HANDLE_VERSION_FLAG("audioc", conf); cf = configfile_exists(); if (cf) { - if (audioc_cmdline_parser_configfile(cf, &conf, 0, 0, 0)) { + struct audioc_cmdline_parser_params params = { + .override = 0, + .initialize = 0, + .check_required = 0, + .check_ambiguity = 0 + }; + if (audioc_cmdline_parser_config_file(cf, &conf, ¶ms)) { fprintf(stderr, "parse error in config file\n"); exit(EXIT_FAILURE); } @@ -93,29 +90,27 @@ int main(int argc, char *argv[]) args = conf.inputs_num? concat_args(conf.inputs_num, conf.inputs) : para_strdup("stat"); - buf = para_malloc(conf.bufsize_arg); - if (conf.socket_given) - socket_name = para_strdup(conf.socket_arg); - else - socket_name = make_message( - "/var/paraslash/audiod_socket.%s", hn); - if (conf.tmpdir_given) - tmpsocket_name = make_message("%s/audioc.sock.%s.%s", - conf.tmpdir_arg, hn, randname); - else - tmpsocket_name = make_message("%s/.paraslash/audioc_sock.%s.%s", - home, hn, randname); + bufsize = conf.bufsize_arg; + buf = para_malloc(bufsize); + + if (conf.socket_given) { + ret = create_remote_socket(conf.socket_arg); + } else { + char *hn = para_hostname(), + *socket_name = make_message("/var/paraslash/audiod_socket.%s", hn); - ret = create_pf_socket(tmpsocket_name, &unix_addr, S_IRUSR | S_IWUSR); - unlink(tmpsocket_name); + ret = create_remote_socket(socket_name); + free(hn); + free(socket_name); + } if (ret < 0) goto out; fd = ret; - ret = -E_INIT_SOCK_ADDR; - if (init_unix_addr(&unix_addr, socket_name) < 0) + ret = mark_fd_nonblocking(fd); + if (ret < 0) goto out; - ret = - E_AUDIOC_CONNECT; - if (connect(fd, (struct sockaddr *)&unix_addr, UNIX_PATH_MAX) < 0) + ret = mark_fd_nonblocking(STDOUT_FILENO); + if (ret < 0) goto out; ret = send_cred_buffer(fd, args); if (ret < 0) @@ -126,7 +121,7 @@ int main(int argc, char *argv[]) fd_set rfd, wfd; FD_ZERO(&rfd); FD_ZERO(&wfd); - if (loaded < conf.bufsize_arg) + if (loaded < bufsize) para_fd_set(fd, &rfd, &max_fileno); if (loaded > 0) { para_fd_set(STDOUT_FILENO, &wfd, &max_fileno); @@ -138,9 +133,9 @@ int main(int argc, char *argv[]) ret = para_select(max_fileno + 1, &rfd, &wfd, NULL); if (ret < 0) goto out; - if (loaded < conf.bufsize_arg && FD_ISSET(fd, &rfd)) { + if (loaded < bufsize && FD_ISSET(fd, &rfd)) { len = recv_bin_buffer(fd, buf + loaded, - conf.bufsize_arg - loaded); + bufsize - loaded); if (len <= 0) { ret = len < 0? -E_AUDIOC_READ : 0; goto out; @@ -160,6 +155,6 @@ out: if (!ret && loaded && buf) ret = write(STDOUT_FILENO, buf, loaded); if (ret < 0) - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); return ret < 0? EXIT_FAILURE : EXIT_SUCCESS; }