X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audioc.c;h=8d8ad35f1e8c2080816d9da7ccf9e6a5a0363205;hp=968f84b6fcd3c6960b2dbf4e2009297e8fd1028c;hb=a87d4a87ac7418084eb78f0bcb3accff1388df3a;hpb=adbf9f09c9bf2a680c61b1ef3541c04f1cde97cf

diff --git a/audioc.c b/audioc.c
index 968f84b6..8d8ad35f 100644
--- a/audioc.c
+++ b/audioc.c
@@ -22,19 +22,29 @@
 #include "para.h"
 #include "net.h"
 #include "string.h"
+#include "fd.h"
+#include "error.h"
+
+INIT_AUDIOC_ERRLISTS;
 
 struct gengetopt_args_info conf;
 char *tmpfifo;
-enum {E_SYNTAX, E_READ, E_WRITE, E_SOCKET, E_INIT_SOCK_ADDR, E_CONNECT, E_CREDENTIALS, E_SELECT, E_OVERRUN};
 
 
-void para_log(__unused int ll, __unused const char* fmt,...) /* no logging */
+/*
+ * client log function
+ */
+void para_log(int ll, const char* fmt,...)
 {
-}
+	va_list argp;
 
-/* audioc does not use encryption */
-void (*crypt_function_recv)(unsigned long len, const unsigned char *indata, unsigned char *outdata) = NULL;
-void (*crypt_function_send)(unsigned long len, const unsigned char *indata, unsigned char *outdata) = NULL;
+	/* 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);
+}
 
 static char *concat_args(const int argc, char * const *argv)
 {
@@ -50,7 +60,7 @@ static char *concat_args(const int argc, char * const *argv)
 static char *configfile_exists(void)
 {
 	static char *config_file;
-        struct stat statbuf;
+	struct stat statbuf;
 
 
 	if (!config_file) {
@@ -58,7 +68,7 @@ static char *configfile_exists(void)
 		config_file = make_message("%s/.paraslash/audioc.conf", home);
 		free(home);
 	}
-        if (!stat(config_file, &statbuf))
+	if (!stat(config_file, &statbuf))
 		return config_file;
 	return NULL;
 }
@@ -66,7 +76,7 @@ static char *configfile_exists(void)
 int main(int argc, char *argv[])
 {
 	struct sockaddr_un unix_addr;
-	int ret = -E_SYNTAX, fd, loaded = 0;
+	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();
 
@@ -96,19 +106,20 @@ int main(int argc, char *argv[])
 		tmpsocket_name = make_message("%s/.paraslash/audioc_sock.%s.%s",
 			home, hn, randname);
 
-	ret = -E_SOCKET;
-	fd = create_pf_socket(tmpsocket_name, &unix_addr, S_IRUSR | S_IWUSR);
+	ret = create_pf_socket(tmpsocket_name, &unix_addr, S_IRUSR | S_IWUSR);
 	unlink(tmpsocket_name);
-	if (fd < 0)
+	if (ret < 0)
 		goto out;
+	fd = ret;
 	ret = -E_INIT_SOCK_ADDR;
 	if (init_unix_addr(&unix_addr, socket_name) < 0)
 		goto out;
-	ret = - E_CONNECT;
+	ret = - E_AUDIOC_CONNECT;
 	if (connect(fd, (struct sockaddr *)&unix_addr, UNIX_PATH_MAX) < 0)
 		goto out;
-	ret = -E_CREDENTIALS;
-	if (send_cred_buffer(fd, args) < 0)
+	fprintf(stderr, "loaded: %d\n", loaded);
+	ret = send_cred_buffer(fd, args);
+	if (ret < 0)
 		goto out;
 	for (;;) {
 		int max_fileno = -1, check_write = 0;
@@ -118,28 +129,23 @@ int main(int argc, char *argv[])
 		FD_ZERO(&wfd);
 		if (loaded && loaded > 10000)
 			fprintf(stderr, "loaded: %d\n", loaded);
-		if (loaded < conf.bufsize_arg) {
-			FD_SET(fd, &rfd);
-			max_fileno = MAX(max_fileno, fd);
-		}
+		if (loaded < conf.bufsize_arg)
+			para_fd_set(fd, &rfd, &max_fileno);
 		if (loaded > 0) {
-			FD_SET(STDOUT_FILENO, &wfd);
-			max_fileno = MAX(max_fileno, STDOUT_FILENO);
+			para_fd_set(STDOUT_FILENO, &wfd, &max_fileno);
 			check_write = 1;
 		}
-		ret = -E_OVERRUN;
+		ret = -E_AUDIOC_OVERRUN;
 		if (max_fileno < 0)
 			goto out;
-		ret = select(max_fileno + 1, &rfd, &wfd, NULL, NULL);
-		if (ret < 0) {
-			ret = -E_SELECT;
+		ret = para_select(max_fileno + 1, &rfd, &wfd, NULL);
+		if (ret < 0)
 			goto out;
-		}
 		if (loaded < conf.bufsize_arg && FD_ISSET(fd, &rfd)) {
-			len = recv_bin_buffer(fd, buf + loaded, 
+			len = recv_bin_buffer(fd, buf + loaded,
 				conf.bufsize_arg - loaded);
 			if (len <= 0) {
-				ret = len < 0? -E_READ : 0;
+				ret = len < 0? -E_AUDIOC_READ : 0;
 				goto out;
 			}
 			loaded += len;
@@ -147,7 +153,7 @@ int main(int argc, char *argv[])
 		if (check_write && FD_ISSET(STDOUT_FILENO, &wfd)) {
 			ret = write(STDOUT_FILENO, buf, loaded);
 			if (ret < 0) {
-				ret = -E_WRITE;
+				ret = -E_AUDIOC_WRITE;
 				goto out;
 			}
 			loaded -= ret;
@@ -156,5 +162,7 @@ int main(int argc, char *argv[])
 out:
 	if (!ret && loaded && buf)
 		ret = write(STDOUT_FILENO, buf, loaded);
-	return ret < 0? -ret : EXIT_SUCCESS;
+	if (ret < 0)
+		PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret));
+	return ret < 0? EXIT_FAILURE : EXIT_SUCCESS;
 }