kosaki	2011-04-30 20:15:15 +0900 (Sat, 30 Apr 2011)

  New Revision: 31394

  http://svn.ruby-lang.org/cgi-bin/viewvc.cgi?view=rev&revision=31394

  Log:
    * include/ruby/intern.h (rb_thread_select): mark as deprecated.
    
    * ext/io/wait/wait.c (wait_readable): use rb_thread_fd_select
      instead of rb_thread_select.
    * ext/socket/init.c (wait_connectable0): ditto.
    * ext/readline/readline.c (readline_event): ditto.
    * io.c (rb_io_wait_readable, wait_readable, rb_io_wait_writable,
      wait_writable): ditto.

  Modified files:
    trunk/ChangeLog
    trunk/ext/io/wait/wait.c
    trunk/ext/readline/readline.c
    trunk/ext/socket/init.c
    trunk/include/ruby/intern.h
    trunk/io.c

Index: include/ruby/intern.h
===================================================================
--- include/ruby/intern.h	(revision 31393)
+++ include/ruby/intern.h	(revision 31394)
@@ -369,7 +369,7 @@
 VALUE rb_thread_run(VALUE);
 VALUE rb_thread_kill(VALUE);
 VALUE rb_thread_create(VALUE (*)(ANYARGS), void*);
-int rb_thread_select(int, fd_set *, fd_set *, fd_set *, struct timeval *);
+DEPRECATED(int rb_thread_select(int, fd_set *, fd_set *, fd_set *, struct timeval *));
 int rb_thread_fd_select(int, rb_fdset_t *, rb_fdset_t *, rb_fdset_t *, struct timeval *);
 void rb_thread_wait_for(struct timeval);
 VALUE rb_thread_current(void);
Index: ChangeLog
===================================================================
--- ChangeLog	(revision 31393)
+++ ChangeLog	(revision 31394)
@@ -1,3 +1,14 @@
+Sat Apr 30 20:11:47 2011  KOSAKI Motohiro  <kosaki.motohiro@g...>
+
+	* include/ruby/intern.h (rb_thread_select): mark as deprecated.
+
+	* ext/io/wait/wait.c (wait_readable): use rb_thread_fd_select
+	  instead of rb_thread_select.
+	* ext/socket/init.c (wait_connectable0): ditto.
+	* ext/readline/readline.c (readline_event): ditto.
+	* io.c (rb_io_wait_readable, wait_readable, rb_io_wait_writable,
+	  wait_writable): ditto.
+
 Sat Apr 30 20:06:36 2011  KOSAKI Motohiro  <kosaki.motohiro@g...>
 
 	* thread.c (do_select): remove useless ifdef. time calculation
Index: io.c
===================================================================
--- io.c	(revision 31393)
+++ io.c	(revision 31394)
@@ -691,7 +691,7 @@
 {
     rb_fdset_t *rfds = (rb_fdset_t *)p;
 
-    return rb_thread_select(rb_fd_max(rfds), rb_fd_ptr(rfds), NULL, NULL, NULL);
+    return rb_thread_fd_select(rb_fd_max(rfds), rfds, NULL, NULL, NULL);
 }
 #endif
 
@@ -721,7 +721,7 @@
 	rb_ensure(wait_readable, (VALUE)&rfds,
 		  (VALUE (*)(VALUE))rb_fd_term, (VALUE)&rfds);
 #else
-	rb_thread_select(f + 1, rb_fd_ptr(&rfds), NULL, NULL, NULL);
+	rb_thread_fd_select(f + 1, &rfds, NULL, NULL, NULL);
 #endif
 	return TRUE;
 
@@ -736,7 +736,7 @@
 {
     rb_fdset_t *wfds = (rb_fdset_t *)p;
 
-    return rb_thread_select(rb_fd_max(wfds), NULL, rb_fd_ptr(wfds), NULL, NULL);
+    return rb_thread_fd_select(rb_fd_max(wfds), NULL, wfds, NULL, NULL);
 }
 #endif
 
@@ -766,7 +766,7 @@
 	rb_ensure(wait_writable, (VALUE)&wfds,
 		  (VALUE (*)(VALUE))rb_fd_term, (VALUE)&wfds);
 #else
-	rb_thread_select(f + 1, NULL, rb_fd_ptr(&wfds), NULL, NULL);
+	rb_thread_fd_select(f + 1, NULL, &wfds, NULL, NULL);
 #endif
 	return TRUE;
 
Index: ext/readline/readline.c
===================================================================
--- ext/readline/readline.c	(revision 31393)
+++ ext/readline/readline.c	(revision 31394)
@@ -145,11 +145,11 @@
 #if BUSY_WAIT
     rb_thread_schedule();
 #else
-    fd_set rset;
+    rb_fdset_t fds;
 
-    FD_ZERO(&rset);
-    FD_SET(fileno(rl_instream), &rset);
-    rb_thread_select(fileno(rl_instream) + 1, &rset, NULL, NULL, NULL);
+    rb_fd_init(fds);
+    rb_fd_set(fileno(rl_instream), &fds);
+    rb_thread_fd_select(fileno(rl_instream) + 1, &fds, NULL, NULL, NULL);
     return 0;
 #endif
 }
Index: ext/socket/init.c
===================================================================
--- ext/socket/init.c	(revision 31393)
+++ ext/socket/init.c	(revision 31394)
@@ -266,7 +266,7 @@
 	rb_fd_set(fd, fds_w);
 	rb_fd_set(fd, fds_e);
 
-	rb_thread_select(fd+1, 0, rb_fd_ptr(fds_w), rb_fd_ptr(fds_e), 0);
+	rb_thread_fd_select(fd+1, 0, fds_w, fds_e, 0);
 
 	if (rb_fd_isset(fd, fds_w)) {
 	    return 0;
Index: ext/io/wait/wait.c
===================================================================
--- ext/io/wait/wait.c	(revision 31393)
+++ ext/io/wait/wait.c	(revision 31394)
@@ -100,7 +100,7 @@
     struct wait_readable_arg *arg = (struct wait_readable_arg *)p;
     rb_fdset_t *fds = &arg->fds;
 
-    return (VALUE)rb_thread_select(rb_fd_max(fds), rb_fd_ptr(fds), NULL, NULL, arg->timeout);
+    return (VALUE)rb_thread_fd_select(rb_fd_max(fds), fds, NULL, NULL, arg->timeout);
 }
 #endif
 
@@ -143,7 +143,7 @@
     i = (int)rb_ensure(wait_readable, (VALUE)&arg,
 		       (VALUE (*)_((VALUE)))rb_fd_term, (VALUE)&arg.fds);
 #else
-    i = rb_thread_select(fd + 1, rb_fd_ptr(&arg.fds), NULL, NULL, arg.timeout);
+    i = rb_thread_fd_select(fd + 1, &arg.fds, NULL, NULL, arg.timeout);
 #endif
     if (i < 0)
 	rb_sys_fail(0);

--
ML: ruby-changes@q...
Info: http://www.atdot.net/~ko1/quickml/