Project

General

Profile

Actions

Bug #20723

closed

`IO#close` is broken on Ruby 3.3+ when using the Fiber scheduler.

Added by ioquatix (Samuel Williams) 3 months ago. Updated about 2 months ago.

Status:
Closed
Target version:
-
ruby -v:
Backport:
[ruby-core:119124]

Description

The following program seems to work okay on Ruby 3.2 but hangs on Ruby 3.3:

#!/usr/bin/env ruby

require 'bundler/inline'

gemfile do
  source 'https://rubygems.org'
  gem 'async'
end

require 'socket'

def close_while_reading(io)
  thread = Thread.new do
    Thread.current.report_on_exception = false
    io.wait_readable
  end
  
  # Wait until the thread is blocked on read:
  Thread.pass until thread.status == "sleep"
  
  Async do
    io.close
  end
  
  thread.join
end

begin
  client, server = Socket.pair(:UNIX, :STREAM)
  close_while_reading(client)
rescue => error
  $stderr.puts error.full_message
end

Updated by kjtsanaktsidis (KJ Tsanaktsidis) 3 months ago

Sorry about this. I think https://github.com/ruby/ruby/pull/11614 is the smallest diff that will fix the issue (and this should probably be backported to 3.3).

Separately to that, I wonder if we need to wrap up some common function for "wake up this fiber, either with the fiber scheduler or with the thread directly". We've implemented this logic in a number of places... but let's keep that refactor out of the fix PR (since it shouldn't be backported).

Actions #4

Updated by kjtsanaktsidis (KJ Tsanaktsidis) 3 months ago

  • Status changed from Open to Closed

Applied in changeset git|e08d5239b68ad61a731f4938cf963e37a5e88c25.


Ensure fiber scheduler is woken up when close interrupts read

If one thread is reading and another closes that socket, the close
blocks waiting for the read to abort cleanly. This ensures that Ruby is
totally done with the file descriptor BEFORE we tell the OS to close
and potentially re-use it.

When the read is correctly terminated, the close should be unblocked.
That currently works if closing is happening on a thread, but if it's
happening on a fiber with a fiber scheduler, it does NOT work.

This patch ensures that if the close happened in a fiber scheduled
thread, that the scheduler is notified that the fiber is unblocked.

[Bug #20723]

Updated by kjtsanaktsidis (KJ Tsanaktsidis) 3 months ago

Backport PR for 3.3 - https://github.com/ruby/ruby/pull/11664

No backport for 3.2 is required because this locking around close didn't exist there.

Updated by k0kubun (Takashi Kokubun) about 2 months ago

  • Backport changed from 3.3: REQUIRED to 3.3: DONE
Actions

Also available in: Atom PDF

Like0
Like0Like0Like0Like0Like0Like0