Support `IO#pread` / `IO#pwrite` using fiber scheduler. (#7594)

* Skip test if non-blocking file IO is not supported.

1 files changed, 22 insertions, 5 deletions

diff --git a/io_buffer.c b/io_buffer.c
index 2fc7ac8a80..4a08811185 100644
--- a/io_buffer.c
+++ b/io_buffer.c
@@ -1001,17 +1001,23 @@ rb_io_buffer_lock(VALUE self)
     return self;
 }
 
-VALUE
-rb_io_buffer_unlock(VALUE self)
+static void
+io_buffer_unlock(struct rb_io_buffer *data)
 {
-    struct rb_io_buffer *data = NULL;
-    TypedData_Get_Struct(self, struct rb_io_buffer, &rb_io_buffer_type, data);
-
     if (!(data->flags & RB_IO_BUFFER_LOCKED)) {
         rb_raise(rb_eIOBufferLockedError, "Buffer not locked!");
     }
 
     data->flags &= ~RB_IO_BUFFER_LOCKED;
+}
+
+VALUE
+rb_io_buffer_unlock(VALUE self)
+{
+    struct rb_io_buffer *data = NULL;
+    TypedData_Get_Struct(self, struct rb_io_buffer, &rb_io_buffer_type, data);
+
+    io_buffer_unlock(data);
 
     return self;
 }
@@ -1123,6 +1129,17 @@ rb_io_buffer_free(VALUE self)
     return self;
 }
 
+VALUE rb_io_buffer_free_locked(VALUE self)
+{
+    struct rb_io_buffer *data = NULL;
+    TypedData_Get_Struct(self, struct rb_io_buffer, &rb_io_buffer_type, data);
+
+    io_buffer_unlock(data);
+    io_buffer_free(data);
+
+    return self;
+}
+
 // Validate that access to the buffer is within bounds, assuming you want to
 // access length bytes from the specified offset.
 static inline void