X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=gui.c;h=31987c46570197411624958ea03a6c9ddac25a85;hb=f8591e80c0dcc02c7193a2a7d2961e361cbdebc7;hp=5b44819c05afc074fadca3a5a7d5c1ece9fe8b8f;hpb=ef81b9f4f0fa6a26043c68d429c0deeb7c949351;p=paraslash.git

diff --git a/gui.c b/gui.c
index 5b44819c..31987c46 100644
--- a/gui.c
+++ b/gui.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 1998-2009 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 1998-2010 Andre Noll <maan@systemlinux.org>
  *
  * Licensed under the GPL v2. For licencing details see COPYING.
  */
@@ -708,12 +708,15 @@ print:
 	return 1;
 }
 
-static int read_audiod_pipe(int fd)
+static int read_audiod_pipe(fd_set *rfds)
 {
 	static char *buf;
 	static int bufsize, loaded;
-	int ret;
+	int ret, ret2;
+	size_t sz;
 
+	if (audiod_pipe < 0)
+		return 0;
 	if (loaded >= bufsize) {
 		if (bufsize > 1000 * 1000) {
 			loaded = 0;
@@ -723,14 +726,18 @@ static int read_audiod_pipe(int fd)
 		buf = para_realloc(buf, bufsize);
 	}
 	assert(loaded < bufsize);
-	ret = read(fd, buf + loaded, bufsize - loaded);
-	if (ret <= 0)
-		return ret;
-	loaded += ret;
-	ret = for_each_stat_item(buf, loaded, update_item);
-	if (ret < 0)
-		return ret;
-	loaded = ret;
+	ret = read_nonblock(audiod_pipe, buf + loaded, bufsize - loaded,
+		rfds, &sz);
+	loaded += sz;
+	ret2 = for_each_stat_item(buf, loaded, update_item);
+	if (ret < 0 || ret2 < 0) {
+		loaded = 0;
+		return ret2 < 0? ret2 : ret;
+	}
+	sz = ret2; /* what is left */
+	if (sz > 0 && sz < loaded)
+		memmove(buf, buf + loaded - sz, sz);
+	loaded = sz;
 	return 1;
 }
 
@@ -929,7 +936,7 @@ static int do_select(int mode)
 {
 	fd_set rfds;
 	int ret;
-	int max_fileno, cp_numread = 1;
+	int max_fileno;
 	char command_buf[4096] = "";
 	int cbo = 0; /* command buf offset */
 	struct timeval tv;
@@ -953,46 +960,41 @@ repeat:
 	if (ret <= 0)
 		goto check_return; /* skip fd checks */
 	/* signals */
-	if (FD_ISSET(signal_pipe, &rfds)) {
-		int sig_nr = para_next_signal();
-		if (sig_nr > 0)
-			handle_signal(sig_nr);
-	}
+	ret = para_next_signal(&rfds);
+	if (ret > 0)
+		handle_signal(ret);
 	/* read command pipe if ready */
-	if (command_pipe >= 0 && mode == COMMAND_MODE &&
-			FD_ISSET(command_pipe, &rfds)) {
-		cp_numread = read(command_pipe, command_buf + cbo,
-			sizeof(command_buf) - 1 - cbo);
-		if (cp_numread >= 0)
-			cbo += cp_numread;
-		else {
-			if (cp_numread < 0)
-				PARA_ERROR_LOG("read error (%d)", cp_numread);
+	if (command_pipe >= 0 && mode == COMMAND_MODE) {
+		size_t sz;
+		ret = read_nonblock(command_pipe, command_buf + cbo,
+			sizeof(command_buf) - 1 - cbo, &rfds, &sz);
+		cbo += sz;
+		sz = cbo;
+		cbo = for_each_line(command_buf, cbo, &add_output_line, NULL);
+		if (sz != cbo)
+			wrefresh(bot.win);
+		if (ret < 0) {
+			PARA_NOTICE_LOG("closing command pipe: %s",
+				para_strerror(-ret));
 			close(command_pipe);
 			command_pipe = -1;
+			return 0;
 		}
 	}
-	if (audiod_pipe >= 0 && FD_ISSET(audiod_pipe, &rfds))
-		if (read_audiod_pipe(audiod_pipe) <= 0) {
-			close(audiod_pipe);
-			audiod_pipe = -1;
-			clear_all_items();
-			free(stat_content[SI_BASENAME]);
-			stat_content[SI_BASENAME] =
-				para_strdup("audiod not running!?");
-			print_all_items();
-		}
+	ret = read_audiod_pipe(&rfds);
+	if (ret < 0) {
+		PARA_NOTICE_LOG("closing audiod pipe: %s\n", para_strerror(-ret));
+		close(audiod_pipe);
+		audiod_pipe = -1;
+		clear_all_items();
+		free(stat_content[SI_BASENAME]);
+		stat_content[SI_BASENAME] =
+			para_strdup("stat command terminated!?");
+		print_all_items();
+	}
 check_return:
 	switch (mode) {
 	case COMMAND_MODE:
-		if (cp_numread <= 0 && !cbo) /* command complete */
-			return 0;
-		if (cbo)
-			cbo = for_each_line(command_buf, cbo,
-				&add_output_line, NULL);
-		if (cp_numread <= 0)
-			cbo = 0;
-		wrefresh(bot.win);
 		ret = wgetch(top.win);
 		if (ret != ERR && ret != KEY_RESIZE) {
 			if (command_pipe) {
@@ -1348,31 +1350,30 @@ static void handle_command(int c)
 
 	/* first check user's key bindings */
 	for (i = 0; i < conf.key_map_given; ++i) {
-		char tmp[MAXLINE], *handler, *arg;
+		char *tmp, *handler, *arg;
 
-		strcpy(tmp, conf.key_map_arg[i]);
-		if (!split_key_map(tmp, &handler, &arg))
+		tmp = para_strdup(conf.key_map_arg[i]);
+		if (!split_key_map(tmp, &handler, &arg)) {
+			free(tmp);
 			return;
-		if (!strcmp(tmp, km_keyname(c))) {
-			if (*handler == 'd') {
-				display_cmd(arg);
-				return;
-			}
-			if (*handler == 'x') {
-				external_cmd(arg);
-				return;
-			}
-			if (*handler == 'p') {
-				client_cmd_cmdline(arg);
-				return;
-			}
-			if (*handler == 'i') {
-				int num = find_cmd_byname(arg);
-				if (num >= 0)
-					command_list[num].handler();
-				return;
-			}
 		}
+		if (strcmp(tmp, km_keyname(c))) {
+			free(tmp);
+			continue;
+		}
+		if (*handler == 'd')
+			display_cmd(arg);
+		else if (*handler == 'x')
+			external_cmd(arg);
+		else if (*handler == 'p')
+			client_cmd_cmdline(arg);
+		else if (*handler == 'i') {
+			int num = find_cmd_byname(arg);
+			if (num >= 0)
+				command_list[num].handler();
+		}
+		free(tmp);
+		return;
 	}
 	/* not found, check internal key bindings */
 	for (i = 0; command_list[i].handler; i++) {