mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
2c9375ba69
modification of rb_thread_fd_select(). based on a patch by Eric Wong. [Bug #5306] [ruby-core:39435] * thread.c (rb_fd_rcopy): New. for reverse fd copy. * test/-ext-/old_thread_select/test_old_thread_select.rb (test_old_select_false_positive): test for bug5306. * ext/-test-/old_thread_select/old_thread_select.c (fdset2array): New. convert fdsets to array. * ext/-test-/old_thread_select/old_thread_select.c (old_thread_select): return 'read', 'write', 'except' argument of rb_thread_select() to ruby script. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@33256 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
75 lines
1.4 KiB
C
75 lines
1.4 KiB
C
/* test case for deprecated C API */
|
|
#include "ruby/ruby.h"
|
|
#include "ruby/io.h"
|
|
|
|
static fd_set * array2fdset(fd_set *fds, VALUE ary, int *max)
|
|
{
|
|
long i;
|
|
|
|
if (NIL_P(ary))
|
|
return NULL;
|
|
|
|
FD_ZERO(fds);
|
|
Check_Type(ary, T_ARRAY);
|
|
for (i = 0; i < RARRAY_LEN(ary); i++) {
|
|
VALUE val = RARRAY_PTR(ary)[i];
|
|
int fd;
|
|
|
|
Check_Type(val, T_FIXNUM);
|
|
fd = FIX2INT(val);
|
|
if (fd >= *max)
|
|
*max = fd + 1;
|
|
FD_SET(fd, fds);
|
|
}
|
|
|
|
return fds;
|
|
}
|
|
|
|
static void fdset2array(VALUE dst, fd_set *fds, int max)
|
|
{
|
|
int i;
|
|
|
|
rb_ary_clear(dst);
|
|
|
|
for (i = 0; i < max; i++) {
|
|
if (FD_ISSET(i, fds))
|
|
rb_ary_push(dst, INT2NUM(i));
|
|
}
|
|
}
|
|
|
|
static VALUE
|
|
old_thread_select(VALUE klass, VALUE r, VALUE w, VALUE e, VALUE timeout)
|
|
{
|
|
struct timeval tv;
|
|
struct timeval *tvp = NULL;
|
|
fd_set rfds, wfds, efds;
|
|
fd_set *rp, *wp, *ep;
|
|
int rc;
|
|
int max = 0;
|
|
|
|
if (!NIL_P(timeout)) {
|
|
tv = rb_time_timeval(timeout);
|
|
tvp = &tv;
|
|
}
|
|
rp = array2fdset(&rfds, r, &max);
|
|
wp = array2fdset(&wfds, w, &max);
|
|
ep = array2fdset(&efds, e, &max);
|
|
rc = rb_thread_select(max, rp, wp, ep, tvp);
|
|
if (rc == -1)
|
|
rb_sys_fail("rb_wait_for_single_fd");
|
|
|
|
if (rp)
|
|
fdset2array(r, &rfds, max);
|
|
if (wp)
|
|
fdset2array(w, &wfds, max);
|
|
if (ep)
|
|
fdset2array(e, &efds, max);
|
|
return INT2NUM(rc);
|
|
}
|
|
|
|
void
|
|
Init_old_thread_select(void)
|
|
{
|
|
rb_define_singleton_method(rb_cIO, "old_thread_select",
|
|
old_thread_select, 4);
|
|
}
|