From 9046186065ff483386dfe27fe6f69e14b05cd938 Mon Sep 17 00:00:00 2001 From: Hiroshi SHIBATA Date: Wed, 12 Nov 2025 19:26:47 +0900 Subject: [PATCH 01/16] [ruby/rubygems] Added test-unit-ruby-core for assert_ractor https://github.com/ruby/rubygems/commit/be579a9c8c --- tool/bundler/dev_gems.rb | 1 + tool/bundler/dev_gems.rb.lock | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/tool/bundler/dev_gems.rb b/tool/bundler/dev_gems.rb index 0039a42171aa41..91ac5628f1f30c 100644 --- a/tool/bundler/dev_gems.rb +++ b/tool/bundler/dev_gems.rb @@ -3,6 +3,7 @@ source "https://rubygems.org" gem "test-unit", "~> 3.0" +gem "test-unit-ruby-core" gem "rake", "~> 13.1" gem "rb_sys" diff --git a/tool/bundler/dev_gems.rb.lock b/tool/bundler/dev_gems.rb.lock index 7f73c43f4cc1dd..f2a5245ede239a 100644 --- a/tool/bundler/dev_gems.rb.lock +++ b/tool/bundler/dev_gems.rb.lock @@ -59,6 +59,8 @@ GEM compact_index (~> 0.15.0) test-unit (3.6.7) power_assert + test-unit-ruby-core (1.0.13) + test-unit turbo_tests (2.2.5) parallel_tests (>= 3.3.0, < 5) rspec (>= 3.10) @@ -88,6 +90,7 @@ DEPENDENCIES rspec-mocks (~> 3.12) rubygems-generate_index (~> 1.1) test-unit (~> 3.0) + test-unit-ruby-core turbo_tests (~> 2.2.3) CHECKSUMS @@ -122,6 +125,7 @@ CHECKSUMS rspec-support (3.13.2) sha256=cea3a2463fd9b84b9dcc9685efd80ea701aa8f7b3decb3b3ce795ed67737dbec rubygems-generate_index (1.1.3) sha256=3571424322666598e9586a906485e1543b617f87644913eaf137d986a3393f5c test-unit (3.6.7) sha256=c342bb9f7334ea84a361b43c20b063f405c0bf3c7dbe3ff38f61a91661d29221 + test-unit-ruby-core (1.0.13) sha256=0c08e61b3b97060028a47d8fc4827de077fdbfc26ef80b4afd9035b9e15ecc5b turbo_tests (2.2.5) sha256=3fa31497d12976d11ccc298add29107b92bda94a90d8a0a5783f06f05102509f BUNDLED WITH From 41a2b2c85e7c865d84f139bf1828b9578d925e8e Mon Sep 17 00:00:00 2001 From: Hiroshi SHIBATA Date: Wed, 12 Nov 2025 19:27:14 +0900 Subject: [PATCH 02/16] [ruby/rubygems] Inject assert_ractor if TestGemPackageTarHeaderRactor is running under the ruby/rubygems repo https://github.com/ruby/rubygems/commit/47f41ce2df --- test/rubygems/test_gem_package_tar_header_ractor.rb | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/test/rubygems/test_gem_package_tar_header_ractor.rb b/test/rubygems/test_gem_package_tar_header_ractor.rb index 6f417f43f90cd2..d758d3dac23097 100644 --- a/test/rubygems/test_gem_package_tar_header_ractor.rb +++ b/test/rubygems/test_gem_package_tar_header_ractor.rb @@ -1,6 +1,12 @@ # frozen_string_literal: true + require_relative "package/tar_test_case" +unless Gem::Package::TarTestCase.instance_methods.include?(:assert_ractor) + require "core_assertions" + Gem::Package::TarTestCase.include Test::Unit::CoreAssertions +end + class TestGemPackageTarHeaderRactor < Gem::Package::TarTestCase ASSERT_HEADERS_EQUAL = <<~RUBY def assert_headers_equal(expected, actual) From 3d554a586b5263c52de87aa58ab2f25f78ede30c Mon Sep 17 00:00:00 2001 From: Hiroshi SHIBATA Date: Wed, 12 Nov 2025 20:24:44 +0900 Subject: [PATCH 03/16] [ruby/rubygems] Support ruby_3_4 branch with assert_ractor argument https://github.com/ruby/rubygems/commit/da0a14801a --- test/rubygems/test_gem_package_tar_header_ractor.rb | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/test/rubygems/test_gem_package_tar_header_ractor.rb b/test/rubygems/test_gem_package_tar_header_ractor.rb index d758d3dac23097..49ea6daf234bee 100644 --- a/test/rubygems/test_gem_package_tar_header_ractor.rb +++ b/test/rubygems/test_gem_package_tar_header_ractor.rb @@ -71,10 +71,12 @@ def assert_headers_equal(expected, actual) } tar_header = Gem::Package::TarHeader.new header + # Move this require to arguments of assert_ractor after Ruby 4.0 or updating core_assertions.rb at Ruby 3.4. + require "stringio" RUBY def test_decode_in_ractor - assert_ractor(ASSERT_HEADERS_EQUAL + SETUP + <<~RUBY, require: ["rubygems/package", "stringio"]) + assert_ractor(ASSERT_HEADERS_EQUAL + SETUP + <<~RUBY, require: "rubygems/package") new_header = Ractor.new(tar_header.to_s) do |str| Gem::Package::TarHeader.from StringIO.new str end.value @@ -84,7 +86,7 @@ def test_decode_in_ractor end def test_encode_in_ractor - assert_ractor(ASSERT_HEADERS_EQUAL + SETUP + <<~RUBY, require: ["rubygems/package", "stringio"]) + assert_ractor(ASSERT_HEADERS_EQUAL + SETUP + <<~RUBY, require: "rubygems/package") header_bytes = tar_header.to_s new_header_bytes = Ractor.new(header_bytes) do |str| From 82ecbbc918e9d6ae3add30dd68e26d56be8c88e7 Mon Sep 17 00:00:00 2001 From: Hiroshi SHIBATA Date: Wed, 12 Nov 2025 20:49:23 +0900 Subject: [PATCH 04/16] [ruby/rubygems] Workaround for test failure of ruby_3_4 branch https://github.com/ruby/rubygems/commit/d7bc3a6d82 --- test/rubygems/test_gem_package_tar_header_ractor.rb | 2 ++ 1 file changed, 2 insertions(+) diff --git a/test/rubygems/test_gem_package_tar_header_ractor.rb b/test/rubygems/test_gem_package_tar_header_ractor.rb index 49ea6daf234bee..07dce46f887d3b 100644 --- a/test/rubygems/test_gem_package_tar_header_ractor.rb +++ b/test/rubygems/test_gem_package_tar_header_ractor.rb @@ -73,6 +73,8 @@ def assert_headers_equal(expected, actual) tar_header = Gem::Package::TarHeader.new header # Move this require to arguments of assert_ractor after Ruby 4.0 or updating core_assertions.rb at Ruby 3.4. require "stringio" + # Remove this after Ruby 4.0 or updating core_assertions.rb at Ruby 3.4. + class Ractor; alias value take; end RUBY def test_decode_in_ractor From edb8296b991a0d6e2522511835315b10b846aef2 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 22:19:08 +0900 Subject: [PATCH 05/16] Make alias `Ractor#value` only if undefined `Ractor#value` replaces `Ractor#take`; if the former is defined the latter is undefined, and vice versa. --- test/rubygems/test_gem_package_tar_header_ractor.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/rubygems/test_gem_package_tar_header_ractor.rb b/test/rubygems/test_gem_package_tar_header_ractor.rb index 07dce46f887d3b..bcd8ab6ad9a603 100644 --- a/test/rubygems/test_gem_package_tar_header_ractor.rb +++ b/test/rubygems/test_gem_package_tar_header_ractor.rb @@ -74,7 +74,7 @@ def assert_headers_equal(expected, actual) # Move this require to arguments of assert_ractor after Ruby 4.0 or updating core_assertions.rb at Ruby 3.4. require "stringio" # Remove this after Ruby 4.0 or updating core_assertions.rb at Ruby 3.4. - class Ractor; alias value take; end + class Ractor; alias value take unless method_defined?(:value); end RUBY def test_decode_in_ractor From 4adb79f8aaddba977eac52600dffa5b5610ced39 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Tue, 4 Nov 2025 18:03:47 +0900 Subject: [PATCH 06/16] [ruby/io-wait] Deprecate `IO#nread` and `IO#ready?` To use these methods, busy loop is necessary somewhere. Use other method to wait instead. https://github.com/ruby/io-wait/commit/8ff4821cea --- ext/io/wait/wait.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ext/io/wait/wait.c b/ext/io/wait/wait.c index bec04cb727e054..d9653e9c34b1a3 100644 --- a/ext/io/wait/wait.c +++ b/ext/io/wait/wait.c @@ -83,6 +83,7 @@ io_nread(VALUE io) int len; ioctl_arg n; + rb_category_warn(RB_WARN_CATEGORY_DEPRECATED, "IO#nread is deprecated; use wait_readable instead"); GetOpenFile(io, fptr); rb_io_check_char_readable(fptr); len = rb_io_read_pending(fptr); @@ -142,6 +143,7 @@ io_ready_p(VALUE io) struct timeval tv = {0, 0}; #endif + rb_category_warn(RB_WARN_CATEGORY_DEPRECATED, "IO#ready? is deprecated; use wait_readable instead"); GetOpenFile(io, fptr); rb_io_check_char_readable(fptr); if (rb_io_read_pending(fptr)) return Qtrue; From b072c3995995ad70387378127a6984b9485a0a25 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 17:28:13 +0900 Subject: [PATCH 07/16] [ruby/io-wait] Bump up to 0.3.6 https://github.com/ruby/io-wait/commit/bf41116ff5 --- ext/io/wait/io-wait.gemspec | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ext/io/wait/io-wait.gemspec b/ext/io/wait/io-wait.gemspec index 3d75aab9c19b09..e54c2dbcaf69af 100644 --- a/ext/io/wait/io-wait.gemspec +++ b/ext/io/wait/io-wait.gemspec @@ -1,4 +1,4 @@ -_VERSION = "0.3.5" +_VERSION = "0.3.6" Gem::Specification.new do |spec| spec.name = "io-wait" From efd98451f37a9b689de9a27d26318ca5e312ee07 Mon Sep 17 00:00:00 2001 From: git Date: Wed, 12 Nov 2025 13:24:14 +0000 Subject: [PATCH 08/16] Update default gems list at b072c3995995ad70387378127a6984 [ci skip] --- NEWS.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/NEWS.md b/NEWS.md index e33408054ea5e4..71852ac613fe03 100644 --- a/NEWS.md +++ b/NEWS.md @@ -197,7 +197,7 @@ The following default gems are updated. * fileutils 1.8.0 * io-console 0.8.1 * io-nonblock 0.3.2 -* io-wait 0.3.5 +* io-wait 0.3.6 * json 2.16.0 * net-http 0.7.0 * openssl 4.0.0.pre From b1c578d83e59b74d7f327103025e05beb08528c7 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 17:29:28 +0900 Subject: [PATCH 09/16] [ruby/io-wait] Start 0.4.0 https://github.com/ruby/io-wait/commit/f5c81139dd --- ext/io/wait/io-wait.gemspec | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ext/io/wait/io-wait.gemspec b/ext/io/wait/io-wait.gemspec index e54c2dbcaf69af..4a791319378208 100644 --- a/ext/io/wait/io-wait.gemspec +++ b/ext/io/wait/io-wait.gemspec @@ -1,4 +1,4 @@ -_VERSION = "0.3.6" +_VERSION = "0.4.0.dev" Gem::Specification.new do |spec| spec.name = "io-wait" From b70f5afb68253eb25cf5f8f2fdfbf01dae1d05d3 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Tue, 4 Nov 2025 21:42:54 +0900 Subject: [PATCH 10/16] [ruby/io-wait] Remove `IO#nread` and `IO#ready? https://github.com/ruby/io-wait/commit/1decadc7f9 --- ext/io/wait/extconf.rb | 17 +---- ext/io/wait/wait.c | 94 --------------------------- test/io/wait/test_io_wait.rb | 30 --------- test/io/wait/test_io_wait_uncommon.rb | 15 ----- 4 files changed, 1 insertion(+), 155 deletions(-) diff --git a/ext/io/wait/extconf.rb b/ext/io/wait/extconf.rb index e97efa179d29c7..c199463ee765f5 100644 --- a/ext/io/wait/extconf.rb +++ b/ext/io/wait/extconf.rb @@ -1,21 +1,6 @@ # frozen_string_literal: false require 'mkmf' -target = "io/wait" have_func("rb_io_wait", "ruby/io.h") have_func("rb_io_descriptor", "ruby/io.h") -unless macro_defined?("DOSISH", "#include ") - have_header(ioctl_h = "sys/ioctl.h") or ioctl_h = nil - fionread = %w[sys/ioctl.h sys/filio.h sys/socket.h].find do |h| - have_macro("FIONREAD", [h, ioctl_h].compact) - end - if fionread - $defs << "-DFIONREAD_HEADER=\"<#{fionread}>\"" - create_makefile(target) - end -else - if have_func("rb_w32_ioctlsocket", "ruby.h") - have_func("rb_w32_is_socket", "ruby.h") - create_makefile(target) - end -end +create_makefile("io/wait") diff --git a/ext/io/wait/wait.c b/ext/io/wait/wait.c index d9653e9c34b1a3..23d37e1d3d38d0 100644 --- a/ext/io/wait/wait.c +++ b/ext/io/wait/wait.c @@ -14,32 +14,6 @@ #include "ruby.h" #include "ruby/io.h" -#include -#if defined(HAVE_UNISTD_H) && (defined(__sun)) -#include -#endif -#if defined(HAVE_SYS_IOCTL_H) -#include -#endif -#if defined(FIONREAD_HEADER) -#include FIONREAD_HEADER -#endif - -#ifdef HAVE_RB_W32_IOCTLSOCKET -#define ioctl ioctlsocket -#define ioctl_arg u_long -#define ioctl_arg2num(i) ULONG2NUM(i) -#else -#define ioctl_arg int -#define ioctl_arg2num(i) INT2NUM(i) -#endif - -#ifdef HAVE_RB_W32_IS_SOCKET -#define FIONREAD_POSSIBLE_P(fd) rb_w32_is_socket(fd) -#else -#define FIONREAD_POSSIBLE_P(fd) ((void)(fd),Qtrue) -#endif - #ifndef HAVE_RB_IO_WAIT static struct timeval * get_timeout(int argc, VALUE *argv, struct timeval *timerec) @@ -66,41 +40,6 @@ wait_for_single_fd(rb_io_t *fptr, int events, struct timeval *tv) } #endif -/* - * call-seq: - * io.nread -> int - * - * Returns number of bytes that can be read without blocking. - * Returns zero if no information available. - * - * You must require 'io/wait' to use this method. - */ - -static VALUE -io_nread(VALUE io) -{ - rb_io_t *fptr; - int len; - ioctl_arg n; - - rb_category_warn(RB_WARN_CATEGORY_DEPRECATED, "IO#nread is deprecated; use wait_readable instead"); - GetOpenFile(io, fptr); - rb_io_check_char_readable(fptr); - len = rb_io_read_pending(fptr); - if (len > 0) return INT2FIX(len); - -#ifdef HAVE_RB_IO_DESCRIPTOR - int fd = rb_io_descriptor(io); -#else - int fd = fptr->fd; -#endif - - if (!FIONREAD_POSSIBLE_P(fd)) return INT2FIX(0); - if (ioctl(fd, FIONREAD, &n)) return INT2FIX(0); - if (n > 0) return ioctl_arg2num(n); - return INT2FIX(0); -} - #ifdef HAVE_RB_IO_WAIT static VALUE io_wait_event(VALUE io, int event, VALUE timeout, int return_io) @@ -125,36 +64,6 @@ io_wait_event(VALUE io, int event, VALUE timeout, int return_io) } #endif -/* - * call-seq: - * io.ready? -> truthy or falsy - * - * Returns a truthy value if input available without blocking, or a - * falsy value. - * - * You must require 'io/wait' to use this method. - */ - -static VALUE -io_ready_p(VALUE io) -{ - rb_io_t *fptr; -#ifndef HAVE_RB_IO_WAIT - struct timeval tv = {0, 0}; -#endif - - rb_category_warn(RB_WARN_CATEGORY_DEPRECATED, "IO#ready? is deprecated; use wait_readable instead"); - GetOpenFile(io, fptr); - rb_io_check_char_readable(fptr); - if (rb_io_read_pending(fptr)) return Qtrue; - -#ifndef HAVE_RB_IO_WAIT - return wait_for_single_fd(fptr, RB_WAITFD_IN, &tv) ? Qtrue : Qfalse; -#else - return io_wait_event(io, RUBY_IO_READABLE, RB_INT2NUM(0), 1); -#endif -} - /* Ruby 3.2+ can define these methods. This macro indicates that case. */ #ifndef RUBY_IO_WAIT_METHODS @@ -424,9 +333,6 @@ Init_wait(void) RB_EXT_RACTOR_SAFE(true); #endif - rb_define_method(rb_cIO, "nread", io_nread, 0); - rb_define_method(rb_cIO, "ready?", io_ready_p, 0); - #ifndef RUBY_IO_WAIT_METHODS rb_define_method(rb_cIO, "wait", io_wait, -1); diff --git a/test/io/wait/test_io_wait.rb b/test/io/wait/test_io_wait.rb index 445363714c0912..ffe3b1f760a626 100644 --- a/test/io/wait/test_io_wait.rb +++ b/test/io/wait/test_io_wait.rb @@ -4,9 +4,6 @@ require 'timeout' require 'socket' -# For `IO#ready?` and `IO#nread`: -require 'io/wait' - class TestIOWait < Test::Unit::TestCase def setup @@ -22,33 +19,6 @@ def teardown @w.close unless @w.closed? end - def test_nread - assert_equal 0, @r.nread - @w.syswrite "." - sleep 0.1 - assert_equal 1, @r.nread - end - - def test_nread_buffered - @w.syswrite ".\n!" - assert_equal ".\n", @r.gets - assert_equal 1, @r.nread - end - - def test_ready? - omit 'unstable on MinGW' if /mingw/ =~ RUBY_PLATFORM - assert_not_predicate @r, :ready?, "shouldn't ready, but ready" - @w.syswrite "." - sleep 0.1 - assert_predicate @r, :ready?, "should ready, but not" - end - - def test_buffered_ready? - @w.syswrite ".\n!" - assert_equal ".\n", @r.gets - assert_predicate @r, :ready? - end - def test_wait omit 'unstable on MinGW' if /mingw/ =~ RUBY_PLATFORM assert_nil @r.wait(0) diff --git a/test/io/wait/test_io_wait_uncommon.rb b/test/io/wait/test_io_wait_uncommon.rb index 0f97ac35d9124e..15b13b51b1001a 100644 --- a/test/io/wait/test_io_wait_uncommon.rb +++ b/test/io/wait/test_io_wait_uncommon.rb @@ -76,14 +76,6 @@ def test_wait_writable_null check_dev(IO::NULL, :wait_writable) end - def test_after_ungetc_ready? - check_dev(IO::NULL, mode: "r") {|fp| - assert_respond_to fp, :ready? - fp.ungetc(?a) - assert_predicate fp, :ready? - } - end - def test_after_ungetc_wait_readable check_dev(IO::NULL, mode: "r") {|fp| fp.ungetc(?a) @@ -91,13 +83,6 @@ def test_after_ungetc_wait_readable } end - def test_after_ungetc_in_text_ready? - check_dev(IO::NULL, mode: "rt") {|fp| - fp.ungetc(?a) - assert_predicate fp, :ready? - } - end - def test_after_ungetc_in_text_wait_readable check_dev(IO::NULL, mode: "rt") {|fp| fp.ungetc(?a) From 34eb73d8e58db3edc55abe184f9e6f566d8873d0 Mon Sep 17 00:00:00 2001 From: git Date: Wed, 12 Nov 2025 13:49:05 +0000 Subject: [PATCH 11/16] Update default gems list at b70f5afb68253eb25cf5f8f2fdfbf0 [ci skip] --- NEWS.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/NEWS.md b/NEWS.md index 71852ac613fe03..96da441a627813 100644 --- a/NEWS.md +++ b/NEWS.md @@ -197,7 +197,7 @@ The following default gems are updated. * fileutils 1.8.0 * io-console 0.8.1 * io-nonblock 0.3.2 -* io-wait 0.3.6 +* io-wait 0.4.0.dev * json 2.16.0 * net-http 0.7.0 * openssl 4.0.0.pre From ab13ece69a061f9c52b7fa69fe9fdeaa31df9441 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 21:17:24 +0900 Subject: [PATCH 12/16] [ruby/io-wait] Drop support for ruby 2.7 https://github.com/ruby/io-wait/commit/dad4c70f2a --- ext/io/wait/extconf.rb | 1 - ext/io/wait/wait.c | 90 +----------------------------------------- 2 files changed, 2 insertions(+), 89 deletions(-) diff --git a/ext/io/wait/extconf.rb b/ext/io/wait/extconf.rb index c199463ee765f5..16d3f6369b62dd 100644 --- a/ext/io/wait/extconf.rb +++ b/ext/io/wait/extconf.rb @@ -1,6 +1,5 @@ # frozen_string_literal: false require 'mkmf' -have_func("rb_io_wait", "ruby/io.h") have_func("rb_io_descriptor", "ruby/io.h") create_makefile("io/wait") diff --git a/ext/io/wait/wait.c b/ext/io/wait/wait.c index 23d37e1d3d38d0..e439f45a29bfea 100644 --- a/ext/io/wait/wait.c +++ b/ext/io/wait/wait.c @@ -14,33 +14,9 @@ #include "ruby.h" #include "ruby/io.h" -#ifndef HAVE_RB_IO_WAIT -static struct timeval * -get_timeout(int argc, VALUE *argv, struct timeval *timerec) -{ - VALUE timeout = Qnil; - rb_check_arity(argc, 0, 1); - if (!argc || NIL_P(timeout = argv[0])) { - return NULL; - } - else { - *timerec = rb_time_interval(timeout); - return timerec; - } -} - -static int -wait_for_single_fd(rb_io_t *fptr, int events, struct timeval *tv) -{ - int i = rb_wait_for_single_fd(fptr->fd, events, tv); - if (i < 0) - rb_sys_fail(0); - rb_io_check_closed(fptr); - return (i & events); -} -#endif +#ifndef RUBY_IO_WAIT_METHODS +/* Ruby 3.2+ can define these methods. This macro indicates that case. */ -#ifdef HAVE_RB_IO_WAIT static VALUE io_wait_event(VALUE io, int event, VALUE timeout, int return_io) { @@ -62,10 +38,6 @@ io_wait_event(VALUE io, int event, VALUE timeout, int return_io) return Qfalse; } } -#endif - -/* Ruby 3.2+ can define these methods. This macro indicates that case. */ -#ifndef RUBY_IO_WAIT_METHODS /* * call-seq: @@ -83,30 +55,16 @@ static VALUE io_wait_readable(int argc, VALUE *argv, VALUE io) { rb_io_t *fptr; -#ifndef HAVE_RB_IO_WAIT - struct timeval timerec; - struct timeval *tv; -#endif GetOpenFile(io, fptr); rb_io_check_char_readable(fptr); -#ifndef HAVE_RB_IO_WAIT - tv = get_timeout(argc, argv, &timerec); -#endif if (rb_io_read_pending(fptr)) return Qtrue; -#ifndef HAVE_RB_IO_WAIT - if (wait_for_single_fd(fptr, RB_WAITFD_IN, tv)) { - return io; - } - return Qnil; -#else rb_check_arity(argc, 0, 1); VALUE timeout = (argc == 1 ? argv[0] : Qnil); return io_wait_event(io, RUBY_IO_READABLE, timeout, 1); -#endif } /* @@ -123,29 +81,16 @@ static VALUE io_wait_writable(int argc, VALUE *argv, VALUE io) { rb_io_t *fptr; -#ifndef HAVE_RB_IO_WAIT - struct timeval timerec; - struct timeval *tv; -#endif GetOpenFile(io, fptr); rb_io_check_writable(fptr); -#ifndef HAVE_RB_IO_WAIT - tv = get_timeout(argc, argv, &timerec); - if (wait_for_single_fd(fptr, RB_WAITFD_OUT, tv)) { - return io; - } - return Qnil; -#else rb_check_arity(argc, 0, 1); VALUE timeout = (argc == 1 ? argv[0] : Qnil); return io_wait_event(io, RUBY_IO_WRITABLE, timeout, 1); -#endif } -#ifdef HAVE_RB_IO_WAIT /* * call-seq: * io.wait_priority -> truthy or falsy @@ -172,7 +117,6 @@ io_wait_priority(int argc, VALUE *argv, VALUE io) return io_wait_event(io, RUBY_IO_PRIORITY, timeout, 1); } -#endif static int wait_mode_sym(VALUE mode) @@ -208,7 +152,6 @@ wait_mode_sym(VALUE mode) return 0; } -#ifdef HAVE_RB_IO_WAIT static inline rb_io_event_t io_event_from_value(VALUE value) { @@ -218,7 +161,6 @@ io_event_from_value(VALUE value) return events; } -#endif /* * call-seq: @@ -246,31 +188,6 @@ io_event_from_value(VALUE value) static VALUE io_wait(int argc, VALUE *argv, VALUE io) { -#ifndef HAVE_RB_IO_WAIT - rb_io_t *fptr; - struct timeval timerec; - struct timeval *tv = NULL; - int event = 0; - int i; - - GetOpenFile(io, fptr); - for (i = 0; i < argc; ++i) { - if (SYMBOL_P(argv[i])) { - event |= wait_mode_sym(argv[i]); - } - else { - *(tv = &timerec) = rb_time_interval(argv[i]); - } - } - /* rb_time_interval() and might_mode() might convert the argument */ - rb_io_check_closed(fptr); - if (!event) event = RB_WAITFD_IN; - if ((event & RB_WAITFD_IN) && rb_io_read_pending(fptr)) - return Qtrue; - if (wait_for_single_fd(fptr, event, tv)) - return io; - return Qnil; -#else VALUE timeout = Qundef; rb_io_event_t events = 0; int i, return_io = 0; @@ -317,7 +234,6 @@ io_wait(int argc, VALUE *argv, VALUE io) } return io_wait_event(io, events, timeout, return_io); -#endif } #endif /* RUBY_IO_WAIT_METHODS */ @@ -338,8 +254,6 @@ Init_wait(void) rb_define_method(rb_cIO, "wait_readable", io_wait_readable, -1); rb_define_method(rb_cIO, "wait_writable", io_wait_writable, -1); -#ifdef HAVE_RB_IO_WAIT rb_define_method(rb_cIO, "wait_priority", io_wait_priority, -1); #endif -#endif } From b4b0cd4a498679c27de1a1ed1add58a0e920b614 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 21:30:01 +0900 Subject: [PATCH 13/16] [ruby/io-wait] Drop support for ruby 3.0 https://github.com/ruby/io-wait/commit/62626dae8c --- ext/io/wait/extconf.rb | 1 - ext/io/wait/io-wait.gemspec | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/ext/io/wait/extconf.rb b/ext/io/wait/extconf.rb index 16d3f6369b62dd..00c455a45c8f6f 100644 --- a/ext/io/wait/extconf.rb +++ b/ext/io/wait/extconf.rb @@ -1,5 +1,4 @@ # frozen_string_literal: false require 'mkmf' -have_func("rb_io_descriptor", "ruby/io.h") create_makefile("io/wait") diff --git a/ext/io/wait/io-wait.gemspec b/ext/io/wait/io-wait.gemspec index 4a791319378208..895063a372f02a 100644 --- a/ext/io/wait/io-wait.gemspec +++ b/ext/io/wait/io-wait.gemspec @@ -10,7 +10,7 @@ Gem::Specification.new do |spec| spec.description = %q{Waits until IO is readable or writable without blocking.} spec.homepage = "https://github.com/ruby/io-wait" spec.licenses = ["Ruby", "BSD-2-Clause"] - spec.required_ruby_version = Gem::Requirement.new(">= 3.0") + spec.required_ruby_version = Gem::Requirement.new(">= 3.1") spec.metadata["homepage_uri"] = spec.homepage spec.metadata["source_code_uri"] = spec.homepage From ff4f9b88515babb34985521339b1410608c78589 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 21:32:04 +0900 Subject: [PATCH 14/16] [ruby/io-wait] Drop support for ruby 3.1 https://github.com/ruby/io-wait/commit/33efb55d0e --- ext/io/wait/io-wait.gemspec | 2 +- ext/io/wait/wait.c | 230 ------------------------------------ 2 files changed, 1 insertion(+), 231 deletions(-) diff --git a/ext/io/wait/io-wait.gemspec b/ext/io/wait/io-wait.gemspec index 895063a372f02a..ef46fbca0f6930 100644 --- a/ext/io/wait/io-wait.gemspec +++ b/ext/io/wait/io-wait.gemspec @@ -10,7 +10,7 @@ Gem::Specification.new do |spec| spec.description = %q{Waits until IO is readable or writable without blocking.} spec.homepage = "https://github.com/ruby/io-wait" spec.licenses = ["Ruby", "BSD-2-Clause"] - spec.required_ruby_version = Gem::Requirement.new(">= 3.1") + spec.required_ruby_version = Gem::Requirement.new(">= 3.2") spec.metadata["homepage_uri"] = spec.homepage spec.metadata["source_code_uri"] = spec.homepage diff --git a/ext/io/wait/wait.c b/ext/io/wait/wait.c index e439f45a29bfea..86b7d25e96a583 100644 --- a/ext/io/wait/wait.c +++ b/ext/io/wait/wait.c @@ -14,229 +14,6 @@ #include "ruby.h" #include "ruby/io.h" -#ifndef RUBY_IO_WAIT_METHODS -/* Ruby 3.2+ can define these methods. This macro indicates that case. */ - -static VALUE -io_wait_event(VALUE io, int event, VALUE timeout, int return_io) -{ - VALUE result = rb_io_wait(io, RB_INT2NUM(event), timeout); - - if (!RB_TEST(result)) { - return Qnil; - } - - int mask = RB_NUM2INT(result); - - if (mask & event) { - if (return_io) - return io; - else - return result; - } - else { - return Qfalse; - } -} - -/* - * call-seq: - * io.wait_readable -> truthy or falsy - * io.wait_readable(timeout) -> truthy or falsy - * - * Waits until IO is readable and returns a truthy value, or a falsy - * value when times out. Returns a truthy value immediately when - * buffered data is available. - * - * You must require 'io/wait' to use this method. - */ - -static VALUE -io_wait_readable(int argc, VALUE *argv, VALUE io) -{ - rb_io_t *fptr; - - GetOpenFile(io, fptr); - rb_io_check_char_readable(fptr); - - if (rb_io_read_pending(fptr)) return Qtrue; - - rb_check_arity(argc, 0, 1); - VALUE timeout = (argc == 1 ? argv[0] : Qnil); - - return io_wait_event(io, RUBY_IO_READABLE, timeout, 1); -} - -/* - * call-seq: - * io.wait_writable -> truthy or falsy - * io.wait_writable(timeout) -> truthy or falsy - * - * Waits until IO is writable and returns a truthy value or a falsy - * value when times out. - * - * You must require 'io/wait' to use this method. - */ -static VALUE -io_wait_writable(int argc, VALUE *argv, VALUE io) -{ - rb_io_t *fptr; - - GetOpenFile(io, fptr); - rb_io_check_writable(fptr); - - rb_check_arity(argc, 0, 1); - VALUE timeout = (argc == 1 ? argv[0] : Qnil); - - return io_wait_event(io, RUBY_IO_WRITABLE, timeout, 1); -} - -/* - * call-seq: - * io.wait_priority -> truthy or falsy - * io.wait_priority(timeout) -> truthy or falsy - * - * Waits until IO is priority and returns a truthy value or a falsy - * value when times out. Priority data is sent and received using - * the Socket::MSG_OOB flag and is typically limited to streams. - * - * You must require 'io/wait' to use this method. - */ -static VALUE -io_wait_priority(int argc, VALUE *argv, VALUE io) -{ - rb_io_t *fptr = NULL; - - RB_IO_POINTER(io, fptr); - rb_io_check_char_readable(fptr); - - if (rb_io_read_pending(fptr)) return Qtrue; - - rb_check_arity(argc, 0, 1); - VALUE timeout = argc == 1 ? argv[0] : Qnil; - - return io_wait_event(io, RUBY_IO_PRIORITY, timeout, 1); -} - -static int -wait_mode_sym(VALUE mode) -{ - if (mode == ID2SYM(rb_intern("r"))) { - return RB_WAITFD_IN; - } - if (mode == ID2SYM(rb_intern("read"))) { - return RB_WAITFD_IN; - } - if (mode == ID2SYM(rb_intern("readable"))) { - return RB_WAITFD_IN; - } - if (mode == ID2SYM(rb_intern("w"))) { - return RB_WAITFD_OUT; - } - if (mode == ID2SYM(rb_intern("write"))) { - return RB_WAITFD_OUT; - } - if (mode == ID2SYM(rb_intern("writable"))) { - return RB_WAITFD_OUT; - } - if (mode == ID2SYM(rb_intern("rw"))) { - return RB_WAITFD_IN|RB_WAITFD_OUT; - } - if (mode == ID2SYM(rb_intern("read_write"))) { - return RB_WAITFD_IN|RB_WAITFD_OUT; - } - if (mode == ID2SYM(rb_intern("readable_writable"))) { - return RB_WAITFD_IN|RB_WAITFD_OUT; - } - rb_raise(rb_eArgError, "unsupported mode: %"PRIsVALUE, mode); - return 0; -} - -static inline rb_io_event_t -io_event_from_value(VALUE value) -{ - int events = RB_NUM2INT(value); - - if (events <= 0) rb_raise(rb_eArgError, "Events must be positive integer!"); - - return events; -} - -/* - * call-seq: - * io.wait(events, timeout) -> event mask, false or nil - * io.wait(*event_symbols[, timeout]) -> self, true, or false - * - * Waits until the IO becomes ready for the specified events and returns the - * subset of events that become ready, or a falsy value when times out. - * - * The events can be a bit mask of +IO::READABLE+, +IO::WRITABLE+ or - * +IO::PRIORITY+. - * - * Returns an event mask (truthy value) immediately when buffered data is - * available. - * - * The second form: if one or more event symbols (+:read+, +:write+, or - * +:read_write+) are passed, the event mask is the bit OR of the bitmask - * corresponding to those symbols. In this form, +timeout+ is optional, the - * order of the arguments is arbitrary, and returns +io+ if any of the - * events is ready. - * - * You must require 'io/wait' to use this method. - */ - -static VALUE -io_wait(int argc, VALUE *argv, VALUE io) -{ - VALUE timeout = Qundef; - rb_io_event_t events = 0; - int i, return_io = 0; - - if (argc != 2 || (RB_SYMBOL_P(argv[0]) || RB_SYMBOL_P(argv[1]))) { - /* We'd prefer to return the actual mask, but this form would return the io itself: */ - return_io = 1; - - /* Slow/messy path: */ - for (i = 0; i < argc; i += 1) { - if (RB_SYMBOL_P(argv[i])) { - events |= wait_mode_sym(argv[i]); - } - else if (timeout == Qundef) { - rb_time_interval(timeout = argv[i]); - } - else { - rb_raise(rb_eArgError, "timeout given more than once"); - } - } - - if (timeout == Qundef) timeout = Qnil; - - if (events == 0) { - events = RUBY_IO_READABLE; - } - } - else /* argc == 2 and neither are symbols */ { - /* This is the fast path: */ - events = io_event_from_value(argv[0]); - timeout = argv[1]; - } - - if (events & RUBY_IO_READABLE) { - rb_io_t *fptr = NULL; - RB_IO_POINTER(io, fptr); - - if (rb_io_read_pending(fptr)) { - /* This was the original behaviour: */ - if (return_io) return Qtrue; - /* New behaviour always returns an event mask: */ - else return RB_INT2NUM(RUBY_IO_READABLE); - } - } - - return io_wait_event(io, events, timeout, return_io); -} - -#endif /* RUBY_IO_WAIT_METHODS */ /* * IO wait methods @@ -249,11 +26,4 @@ Init_wait(void) RB_EXT_RACTOR_SAFE(true); #endif -#ifndef RUBY_IO_WAIT_METHODS - rb_define_method(rb_cIO, "wait", io_wait, -1); - - rb_define_method(rb_cIO, "wait_readable", io_wait_readable, -1); - rb_define_method(rb_cIO, "wait_writable", io_wait_writable, -1); - rb_define_method(rb_cIO, "wait_priority", io_wait_priority, -1); -#endif } From 6a055451843d28b9d75f581328cbdf6f03bea343 Mon Sep 17 00:00:00 2001 From: Nobuyoshi Nakada Date: Wed, 12 Nov 2025 23:23:02 +0900 Subject: [PATCH 15/16] [ruby/io-wait] No method definition is always ractor-safe https://github.com/ruby/io-wait/commit/44b68fc51b --- ext/io/wait/wait.c | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/ext/io/wait/wait.c b/ext/io/wait/wait.c index 86b7d25e96a583..22f372aa9a50ee 100644 --- a/ext/io/wait/wait.c +++ b/ext/io/wait/wait.c @@ -11,19 +11,11 @@ **********************************************************************/ -#include "ruby.h" -#include "ruby/io.h" - - /* - * IO wait methods + * IO wait methods are built in ruby now, just for backward compatibility. */ void Init_wait(void) { -#ifdef HAVE_RB_EXT_RACTOR_SAFE - RB_EXT_RACTOR_SAFE(true); -#endif - } From 35783854244f8dc6a9f7fb4dfae752f8361c66bd Mon Sep 17 00:00:00 2001 From: Koichi Sasada Date: Thu, 13 Nov 2025 02:27:30 +0900 Subject: [PATCH 16/16] include ruby.h to avoid load failures ``` .../io/wait.so: undefined symbol: ruby_abi_version - ruby_abi_version ``` --- ext/io/wait/wait.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ext/io/wait/wait.c b/ext/io/wait/wait.c index 22f372aa9a50ee..f27d7c11e5db48 100644 --- a/ext/io/wait/wait.c +++ b/ext/io/wait/wait.c @@ -15,6 +15,8 @@ * IO wait methods are built in ruby now, just for backward compatibility. */ +#include "ruby.h" + void Init_wait(void) {