psss / rpms / zsh

Forked from rpms/zsh 5 years ago
Clone
b84eb4b
 Src/builtin.c |  2 +-
b84eb4b
 Src/init.c    | 34 ++++++++++++++++++++++++++++++++--
b84eb4b
 2 files changed, 33 insertions(+), 3 deletions(-)
b84eb4b
b84eb4b
diff --git a/Src/builtin.c b/Src/builtin.c
b84eb4b
index 9358e8b..ee14f91 100644
b84eb4b
--- a/Src/builtin.c
b84eb4b
+++ b/Src/builtin.c
624aa08
@@ -5674,7 +5674,7 @@ bin_read(char *name, char **args, Options ops, UNUSED(int func))
cvsdist 92bd44f
 	if (!zleactive) {
cvsdist 92bd44f
 	    if (SHTTY == -1) {
cvsdist 92bd44f
 		/* need to open /dev/tty specially */
cvsdist 92bd44f
-		if ((SHTTY = open("/dev/tty", O_RDWR|O_NOCTTY)) != -1) {
cvsdist 92bd44f
+		if ((SHTTY = block_open("/dev/tty", O_RDWR|O_NOCTTY)) != -1) {
cvsdist 92bd44f
 		    haso = 1;
cvsdist 92bd44f
 		    oshout = shout;
cvsdist 92bd44f
 		    init_shout();
b84eb4b
diff --git a/Src/init.c b/Src/init.c
b84eb4b
index 102276a..238f6ed 100644
b84eb4b
--- a/Src/init.c
b84eb4b
+++ b/Src/init.c
10ded2c
@@ -545,7 +545,7 @@ init_io(void)
cvsdist 92bd44f
     if (isatty(0)) {
cvsdist 92bd44f
 	zsfree(ttystrname);
cvsdist 92bd44f
 	if ((ttystrname = ztrdup(ttyname(0)))) {
cvsdist 92bd44f
-	    SHTTY = movefd(open(ttystrname, O_RDWR | O_NOCTTY));
cvsdist 92bd44f
+	    SHTTY = movefd(block_open(ttystrname, O_RDWR | O_NOCTTY));
cvsdist 92bd44f
 #ifdef TIOCNXCL
cvsdist 92bd44f
 	    /*
cvsdist 92bd44f
 	     * See if the terminal claims to be busy.  If so, and fd 0
10ded2c
@@ -586,7 +586,7 @@ init_io(void)
cvsdist 92bd44f
 	ttystrname = ztrdup(ttyname(1));
cvsdist 92bd44f
     }
cvsdist 92bd44f
     if (SHTTY == -1 &&
cvsdist 92bd44f
-	(SHTTY = movefd(open("/dev/tty", O_RDWR | O_NOCTTY))) != -1) {
cvsdist 92bd44f
+	(SHTTY = movefd(block_open("/dev/tty", O_RDWR | O_NOCTTY))) != -1) {
cvsdist 92bd44f
 	zsfree(ttystrname);
cvsdist 92bd44f
 	ttystrname = ztrdup(ttyname(SHTTY));
cvsdist 92bd44f
     }
624aa08
@@ -1713,3 +1713,33 @@ zsh_main(UNUSED(int argc), char **argv)
da97c7b
 		    : "use 'logout' to logout.");
cvsdist 92bd44f
     }
cvsdist 92bd44f
 }
cvsdist 92bd44f
+
cvsdist 92bd44f
+/**/
cvsdist 92bd44f
+int
cvsdist 92bd44f
+block_open (const char *tty, int flags)
cvsdist 92bd44f
+{
cvsdist 92bd44f
+    int saved_errno;
cvsdist 92bd44f
+    int fd;
cvsdist 92bd44f
+
cvsdist 92bd44f
+    if ((flags & O_NONBLOCK) == 0) {
cvsdist 92bd44f
+	fd = open (tty, flags | O_NONBLOCK);
cvsdist 92bd44f
+	if (fd == -1)
cvsdist 92bd44f
+	    return fd;
cvsdist 92bd44f
+	flags = fcntl(fd, F_GETFL);
cvsdist 92bd44f
+	if (flags == -1)
cvsdist 92bd44f
+	    goto bad;
cvsdist 92bd44f
+	flags &= ~O_NONBLOCK;
cvsdist 92bd44f
+	if (fcntl(fd, F_SETFL, flags) == -1)
cvsdist 92bd44f
+	    goto bad;
cvsdist 92bd44f
+    }
cvsdist 92bd44f
+    else
cvsdist 92bd44f
+	fd = open (tty, flags);
cvsdist 92bd44f
+
cvsdist 92bd44f
+    return fd;
cvsdist 92bd44f
+
cvsdist 92bd44f
+bad:
cvsdist 92bd44f
+    saved_errno = errno;
cvsdist 92bd44f
+    close (fd);
cvsdist 92bd44f
+    errno = saved_errno;
cvsdist 92bd44f
+    return -1;
cvsdist 92bd44f
+}