Interface for io flags.

ioquatix · ioquatix · commit 8e74578a36b8 · 2022-03-18T01:17:21.000-04:00
diff --git a/include/ruby/io.h b/include/ruby/io.h
@@ -610,6 +610,14 @@ int rb_ioptr_descriptor(const rb_io_t *fptr);
  */
 VALUE rb_ioptr_tied_io_for_writing(const rb_io_t *fptr);
 
+/**
+ * Returns all the io mode flags, e.g. FMODE_SYNC.
+ *
+ * @param[in]   fptr                An IO fptr.
+ * @retval      enum rb_io_mode    The flags.
+ */
+enum rb_io_mode rb_ioptr_mode(const rb_io_t *fptr);
+
 RBIMPL_ATTR_NORETURN()
 void rb_ioptr_sys_fail(rb_io_t *fptr);
 
diff --git a/io.c b/io.c
@@ -2775,6 +2775,12 @@ rb_ioptr_tied_io_for_writing(const rb_io_t *fptr)
     return fptr->tied_io_for_writing;
 }
 
+enum rb_io_mode
+rb_ioptr_mode(const rb_io_t *fptr)
+{
+    return fptr->mode;
+}
+
 /*
  *  call-seq:
  *    pid -> integer or nil
diff --git a/spec/ruby/optional/capi/ext/io_spec.c b/spec/ruby/optional/capi/ext/io_spec.c
@@ -229,7 +229,7 @@ VALUE io_spec_rb_io_set_nonblock(VALUE self, VALUE io) {
   GetOpenFile(io, fp);
   rb_io_set_nonblock(fp);
 #ifdef F_GETFL
-  flags = fcntl(fp->fd, F_GETFL, 0);
+  flags = fcntl(io_spec_get_fd(io), F_GETFL, 0);
   return flags & O_NONBLOCK ? Qtrue : Qfalse;
 #else
   return Qfalse;
@@ -250,11 +250,12 @@ static VALUE io_spec_errno_set(VALUE self, VALUE val) {
 VALUE io_spec_mode_sync_flag(VALUE self, VALUE io) {
   rb_io_t *fp;
   GetOpenFile(io, fp);
-  if (fp->mode & FMODE_SYNC) {
-    return Qtrue;
-  } else {
-    return Qfalse;
-  }
+
+#ifdef RUBY_VERSION_IS_3_2
+  return RBOOL(rb_ioptr_mode(fp) & FMODE_SYNC);
+#else
+  return RBOOL(fp->mode & FMODE_SYNC);
+#endif
 }
 
 void Init_io_spec(void) {
