summaryrefslogtreecommitdiffstats
path: root/eval.c
diff options
context:
space:
mode:
authornobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2005-07-23 02:46:41 +0000
committernobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2005-07-23 02:46:41 +0000
commit5ec487529ebd4549d3a3e8dde339f396add6f590 (patch)
treedef78c73cdc98494c5ad9dd2e3df52a97f187a32 /eval.c
parent57fb7655357ccd8a0a72cb70f230fa44e743e14d (diff)
downloadruby-5ec487529ebd4549d3a3e8dde339f396add6f590.tar.gz
ruby-5ec487529ebd4549d3a3e8dde339f396add6f590.tar.xz
ruby-5ec487529ebd4549d3a3e8dde339f396add6f590.zip
* eval.c (rb_fd_select): the all three fd_sets must be long enough for
select. fixed: [ruby-talk:149059] git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@8826 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'eval.c')
-rw-r--r--eval.c26
1 files changed, 23 insertions, 3 deletions
diff --git a/eval.c b/eval.c
index 1b4559c67..ed2ebe6a7 100644
--- a/eval.c
+++ b/eval.c
@@ -9871,8 +9871,8 @@ rb_fd_zero(fds)
}
}
-void
-rb_fd_set(n, fds)
+static void
+rb_fd_resize(n, fds)
int n;
rb_fdset_t *fds;
{
@@ -9887,6 +9887,14 @@ rb_fd_set(n, fds)
memset((char *)fds->fdset + o, 0, m - o);
}
if (n >= fds->maxfd) fds->maxfd = n + 1;
+}
+
+void
+rb_fd_set(n, fds)
+ int n;
+ rb_fdset_t *fds;
+{
+ rb_fd_resize(n, fds);
FD_SET(n, fds->fdset);
}
@@ -9922,6 +9930,18 @@ rb_fd_copy(dst, src, max)
memcpy(dst->fdset, src, size);
}
+int
+rb_fd_select(n, readfds, writefds, exceptfds, timeout)
+ int n;
+ rb_fdset_t *readfds, *writefds, *exceptfds;
+ struct timeval *timeout;
+{
+ rb_fd_resize(n - 1, readfds);
+ rb_fd_resize(n - 1, writefds);
+ rb_fd_resize(n - 1, exceptfds);
+ return select(n, rb_fd_ptr(readfds), rb_fd_ptr(writefds), rb_fd_ptr(exceptfds), timeout);
+}
+
#undef FD_ZERO
#undef FD_SET
#undef FD_CLR
@@ -10786,7 +10806,7 @@ rb_thread_schedule()
delay_ptr = &delay_tv;
}
- n = select(max+1, rb_fd_ptr(&readfds), rb_fd_ptr(&writefds), rb_fd_ptr(&exceptfds), delay_ptr);
+ n = rb_fd_select(max+1, &readfds, &writefds, &exceptfds, delay_ptr);
if (n < 0) {
int e = errno;