File 0002-select_internal-add-additional-argument-fo... of Package ruby2.6

Overview Repositories Revisions Requests Users Attributes Meta

File 0002-select_internal-add-additional-argument-for-poll-err.patch of Package ruby2.6 (Revision fc69d03738d24f390881d6f9a8242751)

Currently displaying revision fc69d03738d24f390881d6f9a8242751 , Show latest

From 9466007e899c44feb691fb32ad312cbabd5acb70 Mon Sep 17 00:00:00 2001
From: Michal Suchanek <msuchanek@suse.de>
Date: Mon, 3 Feb 2020 19:26:58 +0100
Subject: [PATCH 2/4] select_internal: add additional argument for poll() error
 fd list

Signed-off-by: Michal Suchanek <msuchanek@suse.de>
---
 io.c | 50 ++++++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 44 insertions(+), 6 deletions(-)

diff --git a/io.c b/io.c
index 6fc9a260ff2f..118a5084a73c 100644
--- a/io.c
+++ b/io.c
@@ -9023,7 +9023,7 @@ rb_f_backquote(VALUE obj, VALUE str)
 #endif
 
 static VALUE
-select_internal(VALUE read, VALUE write, VALUE except, struct timeval *tp, rb_fdset_t *fds)
+select_internal(VALUE read, VALUE write, VALUE except, VALUE error, struct timeval *tp, rb_fdset_t *fds)
 {
     VALUE res, list;
     rb_fdset_t *rp, *wp, *ep, *erp;
@@ -9040,7 +9040,7 @@ select_internal(VALUE read, VALUE write, VALUE except, struct timeval *tp, rb_fd
 	    rb_fd_set(fptr->fd, &fds[0]);
 	    if (READ_DATA_PENDING(fptr) || READ_CHAR_PENDING(fptr)) { /* check for buffered data */
 		pending++;
-		rb_fd_set(fptr->fd, &fds[3]);
+		rb_fd_set(fptr->fd, &fds[4]);
 	    }
 	    if (max < fptr->fd) max = fptr->fd;
 	}
@@ -9086,7 +9086,25 @@ select_internal(VALUE read, VALUE write, VALUE except, struct timeval *tp, rb_fd
 	ep = 0;
     }
 
-    erp = 0;
+    if (!NIL_P(error)) {
+	Check_Type(error, T_ARRAY);
+	for (i=0; i<RARRAY_LEN(error); i++) {
+            VALUE io = rb_io_get_io(RARRAY_AREF(error, i));
+            VALUE write_io = GetWriteIO(io);
+	    GetOpenFile(io, fptr);
+	    rb_fd_set(fptr->fd, &fds[3]);
+	    if (max < fptr->fd) max = fptr->fd;
+            if (io != write_io) {
+                GetOpenFile(write_io, fptr);
+                rb_fd_set(fptr->fd, &fds[3]);
+                if (max < fptr->fd) max = fptr->fd;
+            }
+	}
+	erp = &fds[3];
+    }
+    else {
+	erp = 0;
+    }
 
     max++;
 
@@ -9096,10 +9114,11 @@ select_internal(VALUE read, VALUE write, VALUE except, struct timeval *tp, rb_fd
     }
     if (!pending && n == 0) return Qnil; /* returns nil on timeout */
 
-    res = rb_ary_new2(3);
+    res = rb_ary_new2(4);
     rb_ary_push(res, rp?rb_ary_new():rb_ary_new2(0));
     rb_ary_push(res, wp?rb_ary_new():rb_ary_new2(0));
     rb_ary_push(res, ep?rb_ary_new():rb_ary_new2(0));
+    rb_ary_push(res, erp?rb_ary_new():rb_ary_new2(0));
 
     if (rp) {
 	list = RARRAY_AREF(res, 0);
@@ -9108,7 +9127,7 @@ select_internal(VALUE read, VALUE write, VALUE except, struct timeval *tp, rb_fd
 	    VALUE io = rb_io_get_io(obj);
 	    GetOpenFile(io, fptr);
 	    if (rb_fd_isset(fptr->fd, &fds[0]) ||
-		rb_fd_isset(fptr->fd, &fds[3])) {
+		rb_fd_isset(fptr->fd, &fds[4])) {
 		rb_ary_push(list, obj);
 	    }
 	}
@@ -9146,6 +9165,25 @@ select_internal(VALUE read, VALUE write, VALUE except, struct timeval *tp, rb_fd
 	}
     }
 
+    if (erp) {
+	list = RARRAY_AREF(res, 3);
+	for (i=0; i< RARRAY_LEN(error); i++) {
+	    VALUE obj = rb_ary_entry(error, i);
+	    VALUE io = rb_io_get_io(obj);
+	    VALUE write_io = GetWriteIO(io);
+	    GetOpenFile(io, fptr);
+	    if (rb_fd_isset(fptr->fd, &fds[3])) {
+		rb_ary_push(list, obj);
+	    }
+	    else if (io != write_io) {
+		GetOpenFile(write_io, fptr);
+		if (rb_fd_isset(fptr->fd, &fds[3])) {
+		    rb_ary_push(list, obj);
+		}
+	    }
+	}
+    }
+
     return res;			/* returns an empty array on interrupt */
 }
 
@@ -9160,7 +9198,7 @@ select_call(VALUE arg)
 {
     struct select_args *p = (struct select_args *)arg;
 
-    return select_internal(p->read, p->write, p->except, p->timeout, p->fdsets);
+    return select_internal(p->read, p->write, p->except, p->error, p->timeout, p->fdsets);
 }
 
 static VALUE
-- 
2.23.0

Places

File 0002-select_internal-add-additional-argument-for-poll-err.patch of Package ruby2.6 (Revision fc69d03738d24f390881d6f9a8242751)

Places