019928
autofs-5.1.1 - log pipe read errors
019928
019928
From: Ian Kent <raven@themaw.net>
019928
019928
Log any unexpected pipe read (possible error) returns.
019928
019928
Signed-off-by: Ian Kent <raven@themaw.net>
019928
---
019928
 CHANGELOG          |    1 +
019928
 daemon/automount.c |   24 ++++++++++++++++++++----
019928
 2 files changed, 21 insertions(+), 4 deletions(-)
019928
019928
--- autofs-5.0.7.orig/CHANGELOG
019928
+++ autofs-5.0.7/CHANGELOG
019928
@@ -187,6 +187,7 @@
019928
 - gaurd against incorrect umount return.
019928
 - fix typo in autofs.conf.
019928
 - always set direct mounts catatonic at exit.
019928
+- log pipe read errors.
019928
 
019928
 25/07/2012 autofs-5.0.7
019928
 =======================
019928
--- autofs-5.0.7.orig/daemon/automount.c
019928
+++ autofs-5.0.7/daemon/automount.c
019928
@@ -968,6 +968,8 @@ static int get_pkt(struct autofs_point *
019928
 	struct pollfd fds[3];
019928
 	int pollfds = 3;
019928
 	char buf[MAX_ERR_BUF];
019928
+	size_t read;
019928
+	char *estr;
019928
 
019928
 	fds[0].fd = ap->pipefd;
019928
 	fds[0].events = POLLIN;
019928
@@ -980,7 +982,6 @@ static int get_pkt(struct autofs_point *
019928
 
019928
 	for (;;) {
019928
 		if (poll(fds, pollfds, -1) == -1) {
019928
-			char *estr;
019928
 			if (errno == EINTR)
019928
 				continue;
019928
 			estr = strerror_r(errno, buf, MAX_ERR_BUF);
019928
@@ -999,7 +1000,13 @@ static int get_pkt(struct autofs_point *
019928
 
019928
 			state_pipe = ap->state_pipe[0];
019928
 
019928
-			if (fullread(state_pipe, &next_state, read_size)) {
019928
+			read = fullread(state_pipe, &next_state, read_size);
019928
+			if (read) {
019928
+				estr = strerror_r(errno, buf, MAX_ERR_BUF);
019928
+				error(ap->logopt,
019928
+				      "read error on state pipe, "
019928
+				      "read %u, error %s",
019928
+				      read, estr);
019928
 				st_mutex_unlock();
019928
 				continue;
019928
 			}
019928
@@ -1010,8 +1017,17 @@ static int get_pkt(struct autofs_point *
019928
 				return -1;
019928
 		}
019928
 
019928
-		if (fds[0].revents & POLLIN)
019928
-			return fullread(ap->pipefd, pkt, kpkt_len);
019928
+		if (fds[0].revents & POLLIN) {
019928
+			read = fullread(ap->pipefd, pkt, kpkt_len);
019928
+			if (read) {
019928
+				estr = strerror_r(errno, buf, MAX_ERR_BUF);
019928
+				error(ap->logopt,
019928
+				      "read error on request pipe, "
019928
+				      "read %u, expected %u error %s",
019928
+				       read, kpkt_len, estr);
019928
+			}
019928
+			return read;
019928
+		}
019928
 
019928
 		if (fds[2].fd != -1 && fds[2].revents & POLLIN) {
019928
 			debug(ap->logopt, "message pending on control fifo.");