File 0009-select_internal-add-additional-argument-fo... of Package ruby2.5

Overview Repositories Revisions Requests Users Attributes Meta

File 0009-select_internal-add-additional-argument-for-poll-err.patch of Package ruby2.5 (Revision 31a757ed9f944744f83a4abf31b7dca2)

Currently displaying revision 31a757ed9f944744f83a4abf31b7dca2 , Show latest

From b737f488b775c736e56fe16e564c04b4e37239ea Mon Sep 17 00:00:00 2001
From: Michal Suchanek <msuchanek@suse.de>
Date: Mon, 3 Feb 2020 19:26:58 +0100
Subject: [PATCH 09/11] 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 557819154953..0134e387e1b1 100644
--- a/io.c
+++ b/io.c
@@ -8906,7 +8906,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;
@@ -8923,7 +8923,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;
 	}
@@ -8969,7 +8969,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++;
 
@@ -8979,10 +8997,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);
@@ -8991,7 +9010,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);
 	    }
 	}
@@ -9029,6 +9048,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 */
 }
 
@@ -9043,7 +9081,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 0009-select_internal-add-additional-argument-for-poll-err.patch of Package ruby2.5 (Revision 31a757ed9f944744f83a4abf31b7dca2)

Places