(8bba087ae567421cd574b5b5772fd3039ff39b4d)

Scheduler APIs. More...

#include "ruby/internal/config.h"
#include <errno.h>
#include "ruby/ruby.h"
#include "ruby/internal/dllexport.h"
#include "ruby/internal/arithmetic.h"

Include dependency graph for scheduler.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	rb_fiber_scheduler_blocking_operation_state

Macros
#define	RUBY_FIBER_SCHEDULER_VERSION 3

Typedefs
typedef struct rb_fiber_scheduler_blocking_operation	rb_fiber_scheduler_blocking_operation_t

Functions
static VALUE	rb_fiber_scheduler_io_result (ssize_t result, int error)
	Wrap a `ssize_t` and `int errno` into a single `VALUE`.

static ssize_t	rb_fiber_scheduler_io_result_apply (VALUE result)
	Apply an io result to the local thread, returning the value of the original system call that created it and updating `int errno`.

VALUE	rb_fiber_scheduler_get (void)
	Queries the current scheduler of the current thread that is calling this function.

VALUE	rb_fiber_scheduler_set (VALUE scheduler)
	Destructively assigns the passed scheduler to that of the current thread that is calling this function.

VALUE	rb_fiber_scheduler_current (void)
	Identical to rb_fiber_scheduler_get(), except it also returns RUBY_Qnil in case of a blocking fiber.

VALUE	rb_fiber_scheduler_current_for_thread (VALUE thread)
	Identical to rb_fiber_scheduler_current(), except it queries for that of the passed thread instead of the implicit current one.

VALUE	rb_fiber_scheduler_make_timeout (struct timeval *timeout)
	Converts the passed timeout to an expression that rb_fiber_scheduler_block() etc.

VALUE	rb_fiber_scheduler_close (VALUE scheduler)
	Closes the passed scheduler object.

VALUE	rb_fiber_scheduler_kernel_sleep (VALUE scheduler, VALUE duration)
	Non-blocking `sleep`.

VALUE	rb_fiber_scheduler_kernel_sleepv (VALUE scheduler, int argc, VALUE *argv)
	Identical to rb_fiber_scheduler_kernel_sleep(), except it can pass multiple arguments.

VALUE	rb_fiber_scheduler_process_wait (VALUE scheduler, rb_pid_t pid, int flags)
	Non-blocking `waitpid`.

VALUE	rb_fiber_scheduler_block (VALUE scheduler, VALUE blocker, VALUE timeout)
	Non-blocking wait for the passed "blocker", which is for instance `Thread.join` or `Mutex.lock`.

VALUE	rb_fiber_scheduler_unblock (VALUE scheduler, VALUE blocker, VALUE fiber)
	Wakes up a fiber previously blocked using rb_fiber_scheduler_block().

VALUE	rb_fiber_scheduler_io_wait (VALUE scheduler, VALUE io, VALUE events, VALUE timeout)
	Non-blocking version of rb_io_wait().

VALUE	rb_fiber_scheduler_io_wait_readable (VALUE scheduler, VALUE io)
	Non-blocking wait until the passed IO is ready for reading.

VALUE	rb_fiber_scheduler_io_wait_writable (VALUE scheduler, VALUE io)
	Non-blocking wait until the passed IO is ready for writing.

VALUE	rb_fiber_scheduler_io_select (VALUE scheduler, VALUE readables, VALUE writables, VALUE exceptables, VALUE timeout)
	Non-blocking version of `IO.select`.

VALUE	rb_fiber_scheduler_io_selectv (VALUE scheduler, int argc, VALUE *argv)
	Non-blocking version of `IO.select`, `argv` variant.

VALUE	rb_fiber_scheduler_io_read (VALUE scheduler, VALUE io, VALUE buffer, size_t length, size_t offset)
	Non-blocking read from the passed IO.

VALUE	rb_fiber_scheduler_io_write (VALUE scheduler, VALUE io, VALUE buffer, size_t length, size_t offset)
	Non-blocking write to the passed IO.

VALUE	rb_fiber_scheduler_io_pread (VALUE scheduler, VALUE io, rb_off_t from, VALUE buffer, size_t length, size_t offset)
	Non-blocking read from the passed IO at the specified offset.

VALUE	rb_fiber_scheduler_io_pwrite (VALUE scheduler, VALUE io, rb_off_t from, VALUE buffer, size_t length, size_t offset)
	Non-blocking write to the passed IO at the specified offset.

VALUE	rb_fiber_scheduler_io_read_memory (VALUE scheduler, VALUE io, void *base, size_t size, size_t length)
	Non-blocking read from the passed IO using a native buffer.

VALUE	rb_fiber_scheduler_io_write_memory (VALUE scheduler, VALUE io, const void *base, size_t size, size_t length)
	Non-blocking write to the passed IO using a native buffer.

VALUE	rb_fiber_scheduler_io_pread_memory (VALUE scheduler, VALUE io, rb_off_t from, void *base, size_t size, size_t length)
	Non-blocking pread from the passed IO using a native buffer.

VALUE	rb_fiber_scheduler_io_pwrite_memory (VALUE scheduler, VALUE io, rb_off_t from, const void *base, size_t size, size_t length)
	Non-blocking pwrite to the passed IO using a native buffer.

VALUE	rb_fiber_scheduler_io_close (VALUE scheduler, VALUE io)
	Non-blocking close the given IO.

VALUE	rb_fiber_scheduler_address_resolve (VALUE scheduler, VALUE hostname)
	Non-blocking DNS lookup.

rb_fiber_scheduler_blocking_operation_t *	rb_fiber_scheduler_blocking_operation_extract (VALUE self)
	Extract the blocking operation handle from a BlockingOperationRuby object.

int	rb_fiber_scheduler_blocking_operation_execute (rb_fiber_scheduler_blocking_operation_t *blocking_operation)
	Execute blocking operation from handle (GVL not required).

int	rb_fiber_scheduler_blocking_operation_cancel (rb_fiber_scheduler_blocking_operation_t *blocking_operation)
	Cancel a blocking operation.

VALUE	rb_fiber_scheduler_blocking_operation_wait (VALUE scheduler, void (function)(void ), void data, rb_unblock_function_t unblock_function, void data2, int flags, struct rb_fiber_scheduler_blocking_operation_state *state)
	Defer the execution of the passed function to the scheduler.

VALUE	rb_fiber_scheduler_fiber_interrupt (VALUE scheduler, VALUE fiber, VALUE exception)
	Interrupt a fiber by raising an exception.

VALUE	rb_fiber_scheduler_fiber (VALUE scheduler, int argc, VALUE *argv, int kw_splat)
	Create and schedule a non-blocking fiber.

Detailed Description

Scheduler APIs.

Author: Ruby developers ruby-.nosp@m.core.nosp@m.@ruby.nosp@m.-lan.nosp@m.g.org

Copyright: This file is a part of the programming language Ruby. Permission is hereby granted, to either redistribute and/or modify this file, provided that the conditions mentioned in the file COPYING are met. Consult the file for details.

Definition in file scheduler.h.

Macro Definition Documentation

◆ RUBY_FIBER_SCHEDULER_VERSION

#define RUBY_FIBER_SCHEDULER_VERSION 3

Definition at line 27 of file scheduler.h.

Typedef Documentation

◆ rb_fiber_scheduler_blocking_operation_t

typedef struct rb_fiber_scheduler_blocking_operation rb_fiber_scheduler_blocking_operation_t

Definition at line 404 of file scheduler.h.

Function Documentation

◆ rb_fiber_scheduler_address_resolve()

VALUE rb_fiber_scheduler_address_resolve	(	VALUE	scheduler,
		VALUE	hostname
	)

Non-blocking DNS lookup.

Parameters

[in]	scheduler	Target scheduler.
[in]	hostname	A host name to query.

Return values

RUBY_Qundef scheduler doesn't have #address_resolve.

Returns: otherwise What scheduler.address_resolve returns.

Definition at line 1021 of file scheduler.c.

◆ rb_fiber_scheduler_block()

VALUE rb_fiber_scheduler_block	(	VALUE	scheduler,
		VALUE	blocker,
		VALUE	timeout
	)

Non-blocking wait for the passed "blocker", which is for instance Thread.join or Mutex.lock.

Depending on scheduler implementation, this for instance switches to another fiber etc.

Parameters

[in]	scheduler	Target scheduler.
[in]	blocker	What blocks the current fiber.
[in]	timeout	Numeric timeout.

Returns: What scheduler.block returns.

Definition at line 627 of file scheduler.c.

◆ rb_fiber_scheduler_blocking_operation_cancel()

int rb_fiber_scheduler_blocking_operation_cancel ( rb_fiber_scheduler_blocking_operation_t * blocking_operation )

Cancel a blocking operation.

This function cancels a blocking operation. If the operation is queued, it just marks it as cancelled. If it's executing, it marks it as cancelled and calls the unblock function to interrupt the operation.

Parameters

blocking_operation The opaque struct pointer

Returns: 1 if unblock function was called, 0 if just marked cancelled, -1 on error

Note: Experimental.

Definition at line 1124 of file scheduler.c.

◆ rb_fiber_scheduler_blocking_operation_execute()

int rb_fiber_scheduler_blocking_operation_execute ( rb_fiber_scheduler_blocking_operation_t * blocking_operation )

Execute blocking operation from handle (GVL not required).

This function executes a blocking operation using the opaque handle obtained from rb_fiber_scheduler_blocking_operation_extract. It can be called from native threads without holding the GVL.

Parameters

[in] blocking_operation The opaque handle.

Returns: 0 on success, -1 on error.

Note: Experimental. Can be called from any thread without holding the GVL

Definition at line 203 of file scheduler.c.

◆ rb_fiber_scheduler_blocking_operation_extract()

rb_fiber_scheduler_blocking_operation_t * rb_fiber_scheduler_blocking_operation_extract ( VALUE self )

Extract the blocking operation handle from a BlockingOperationRuby object.

This function safely extracts the opaque handle from a BlockingOperation VALUE while holding the GVL. The returned pointer can be passed to worker threads and used with rb_fiber_scheduler_blocking_operation_execute.

Parameters

[in] self The BlockingOperation VALUE to extract from

Returns: The opaque struct pointer on success, NULL on error

Note: Experimental.

Definition at line 188 of file scheduler.c.

◆ rb_fiber_scheduler_blocking_operation_wait()

VALUE rb_fiber_scheduler_blocking_operation_wait	(	VALUE	scheduler,
		void ()(void *)	function,
		void *	data,
		rb_unblock_function_t *	unblock_function,
		void *	data2,
		int	flags,
		struct rb_fiber_scheduler_blocking_operation_state *	state
	)

Defer the execution of the passed function to the scheduler.

Parameters

[in]	scheduler	Target scheduler.
[in]	function	The function to run.
[in]	data	The data to pass to the function.
[in]	unblock_function	The unblock function to use to interrupt the operation.
[in]	data2	The data to pass to the unblock function.
[in]	flags	Flags passed to `rb_nogvl`.
[out]	state	The result and errno of the operation.

Return values

RUBY_Qundef scheduler doesn't have #blocking_operation_wait.

Returns: otherwise What scheduler.blocking_operation_wait returns.

Definition at line 1046 of file scheduler.c.

Referenced by rb_nogvl().

◆ rb_fiber_scheduler_close()

VALUE rb_fiber_scheduler_close ( VALUE scheduler )

Closes the passed scheduler object.

This expects the scheduler to wait for all fibers. Thus the scheduler's main loop tends to start here.

Parameters

[in] scheduler Target scheduler.

Returns: What scheduler.close returns.

Definition at line 484 of file scheduler.c.

◆ rb_fiber_scheduler_current()

VALUE rb_fiber_scheduler_current ( void )

Identical to rb_fiber_scheduler_get(), except it also returns RUBY_Qnil in case of a blocking fiber.

As blocking fibers do not participate schedulers' scheduling this function can be handy.

Return values

RUBY_Qnil	No scheduler is in effect.
otherwise	The scheduler that is in effect, if any.

Definition at line 463 of file scheduler.c.

Referenced by rb_io_wait(), rb_io_wait_readable(), rb_io_wait_writable(), rb_nogvl(), and rb_process_status_wait().

◆ rb_fiber_scheduler_current_for_thread()

VALUE rb_fiber_scheduler_current_for_thread ( VALUE thread )

Identical to rb_fiber_scheduler_current(), except it queries for that of the passed thread instead of the implicit current one.

Parameters

[in] thread Target thread.

Exceptions

rb_eTypeError `thread` is not a thread.

Return values

RUBY_Qnil	No scheduler is in effect in `thread`.
otherwise	The scheduler that is in effect in `thread`.

Definition at line 468 of file scheduler.c.

◆ rb_fiber_scheduler_fiber()

VALUE rb_fiber_scheduler_fiber	(	VALUE	scheduler,
		int	argc,
		VALUE *	argv,
		int	kw_splat
	)

Create and schedule a non-blocking fiber.

Parameters

[in]	scheduler	Target scheduler.
[in]	argc	Number of arguments in argv.
[in]	argv	Array of arguments to pass to the fiber.
[in]	kw_splat	Whether to expand last argument as keywords.

Returns: The created and scheduled fiber.

Definition at line 1109 of file scheduler.c.

◆ rb_fiber_scheduler_fiber_interrupt()

VALUE rb_fiber_scheduler_fiber_interrupt	(	VALUE	scheduler,
		VALUE	fiber,
		VALUE	exception
	)

Interrupt a fiber by raising an exception.

You can construct an exception using rb_make_exception.

This hook may be invoked by a different thread.

Parameters

[in]	scheduler	Target scheduler.
[in]	fiber	The fiber to interrupt.
[in]	exception	The exception to raise in the fiber.

Returns: What scheduler.fiber_interrupt returns.

Definition at line 1077 of file scheduler.c.

◆ rb_fiber_scheduler_get()

VALUE rb_fiber_scheduler_get ( void )

Queries the current scheduler of the current thread that is calling this function.

Return values

RUBY_Qnil	No scheduler has been set so far to this thread (which is the default).
otherwise	The scheduler that was last set for the current thread with rb_fiber_scheduler_set().

Definition at line 374 of file scheduler.c.

◆ rb_fiber_scheduler_io_close()

VALUE rb_fiber_scheduler_io_close	(	VALUE	scheduler,
		VALUE	io
	)

Non-blocking close the given IO.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to close.

Return values

RUBY_Qundef scheduler doesn't have #io_close.

Returns: otherwise What scheduler.io_close returns.

Definition at line 981 of file scheduler.c.

◆ rb_fiber_scheduler_io_pread()

VALUE rb_fiber_scheduler_io_pread	(	VALUE	scheduler,
		VALUE	io,
		rb_off_t	from,
		VALUE	buffer,
		size_t	length,
		size_t	offset
	)

Non-blocking read from the passed IO at the specified offset.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to read from.
[in]	from	The offset to read from.
[in]	buffer	The buffer to read to.
[in]	length	The minimum number of bytes to read.
[in]	offset	The offset in the buffer to read to.

Return values

RUBY_Qundef scheduler doesn't have #io_read.

Returns: otherwise What scheduler.io_read returns.

Definition at line 822 of file scheduler.c.

Referenced by rb_fiber_scheduler_io_pread_memory().

◆ rb_fiber_scheduler_io_pread_memory()

VALUE rb_fiber_scheduler_io_pread_memory	(	VALUE	scheduler,
		VALUE	io,
		rb_off_t	from,
		void *	base,
		size_t	size,
		size_t	length
	)

Non-blocking pread from the passed IO using a native buffer.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to read from.
[in]	from	The offset to read from.
[in]	base	The memory to read to.
[in]	size	Size of the memory.
[in]	length	The minimum number of bytes to read.

Return values

RUBY_Qundef scheduler doesn't have #io_read.

Returns: otherwise What scheduler.io_read returns.

Definition at line 957 of file scheduler.c.

◆ rb_fiber_scheduler_io_pwrite()

VALUE rb_fiber_scheduler_io_pwrite	(	VALUE	scheduler,
		VALUE	io,
		rb_off_t	from,
		VALUE	buffer,
		size_t	length,
		size_t	offset
	)

Non-blocking write to the passed IO at the specified offset.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to write to.
[in]	from	The offset to write to.
[in]	buffer	The buffer to write from.
[in]	length	The minimum number of bytes to write.
[in]	offset	The offset in the buffer to write from.

Return values

RUBY_Qundef scheduler doesn't have #io_write.

Returns: otherwise What scheduler.io_write returns.

Definition at line 915 of file scheduler.c.

Referenced by rb_fiber_scheduler_io_pwrite_memory().

◆ rb_fiber_scheduler_io_pwrite_memory()

VALUE rb_fiber_scheduler_io_pwrite_memory	(	VALUE	scheduler,
		VALUE	io,
		rb_off_t	from,
		const void *	base,
		size_t	size,
		size_t	length
	)

Non-blocking pwrite to the passed IO using a native buffer.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to write to.
[in]	from	The offset to write from.
[in]	base	The memory to write from.
[in]	size	Size of the memory.
[in]	length	The minimum number of bytes to write.

Return values

RUBY_Qundef scheduler doesn't have #io_write.

Returns: otherwise What scheduler.io_write returns.

Definition at line 969 of file scheduler.c.

◆ rb_fiber_scheduler_io_read()

VALUE rb_fiber_scheduler_io_read	(	VALUE	scheduler,
		VALUE	io,
		VALUE	buffer,
		size_t	length,
		size_t	offset
	)

Non-blocking read from the passed IO.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to read from.
[in]	buffer	The buffer to read to.
[in]	length	The minimum number of bytes to read.
[in]	offset	The offset in the buffer to read from.

Return values

RUBY_Qundef scheduler doesn't have #io_read.

Returns: otherwise What scheduler.io_read returns [-errno, size].

Definition at line 783 of file scheduler.c.

Referenced by rb_fiber_scheduler_io_read_memory().

◆ rb_fiber_scheduler_io_read_memory()

VALUE rb_fiber_scheduler_io_read_memory	(	VALUE	scheduler,
		VALUE	io,
		void *	base,
		size_t	size,
		size_t	length
	)

Non-blocking read from the passed IO using a native buffer.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to read from.
[in]	base	The memory to read to.
[in]	size	Size of the memory.
[in]	length	The minimum number of bytes to read.

Return values

RUBY_Qundef scheduler doesn't have #io_read.

Returns: otherwise What scheduler.io_read returns.

Definition at line 933 of file scheduler.c.

◆ rb_fiber_scheduler_io_result()

static VALUE rb_fiber_scheduler_io_result	(	ssize_t	result,
		int	error
	)

inlinestatic

Wrap a ssize_t and int errno into a single VALUE.

This interface should be used to safely capture results from system calls like read and write.

You should use rb_fiber_scheduler_io_result_apply to unpack the result of this value and update int errno.

You should not directly try to interpret the result value as it is considered an opaque representation. However, the general representation is an integer in the range of [-int errno, size_t size]. Linux generally restricts the result of system calls like read and write to <= 2^31 which means this will typically fit within a single FIXNUM.

Parameters

[in]	result	The result of the system call.
[in]	error	The value of `errno`.

Returns: A VALUE which contains the result and/or errno.

Definition at line 49 of file scheduler.h.

◆ rb_fiber_scheduler_io_result_apply()

static ssize_t rb_fiber_scheduler_io_result_apply ( VALUE result )

inlinestatic

Apply an io result to the local thread, returning the value of the original system call that created it and updating int errno.

You should not directly try to interpret the result value as it is considered an opaque representation.

Parameters

[in] result The VALUE which contains an errno and/or result size.

Postcondition: Updates int errno with the value if negative.

Returns: The original result of the system call.

Definition at line 71 of file scheduler.h.

◆ rb_fiber_scheduler_io_select()

VALUE rb_fiber_scheduler_io_select	(	VALUE	scheduler,
		VALUE	readables,
		VALUE	writables,
		VALUE	exceptables,
		VALUE	timeout
	)

Non-blocking version of IO.select.

It's possible that this will be emulated using a thread, so you should not rely on it for high performance.

Parameters

[in]	scheduler	Target scheduler.
[in]	readables	An array of readable objects.
[in]	writables	An array of writable objects.
[in]	exceptables	An array of objects that might encounter exceptional conditions.
[in]	timeout	Numeric timeout or nil.

Returns: What scheduler.io_select returns, normally a 3-tuple of arrays of ready objects.

Definition at line 730 of file scheduler.c.

◆ rb_fiber_scheduler_io_selectv()

VALUE rb_fiber_scheduler_io_selectv	(	VALUE	scheduler,
		int	argc,
		VALUE *	argv
	)

Non-blocking version of IO.select, argv variant.

Definition at line 739 of file scheduler.c.

Referenced by rb_fiber_scheduler_io_select().

◆ rb_fiber_scheduler_io_wait()

VALUE rb_fiber_scheduler_io_wait	(	VALUE	scheduler,
		VALUE	io,
		VALUE	events,
		VALUE	timeout
	)

Non-blocking version of rb_io_wait().

Depending on scheduler implementation, this for instance switches to another fiber etc.

The "events" here is a Ruby level integer, which is an OR-ed value of IO::READABLE, IO::WRITABLE, and IO::PRIORITY.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to wait.
[in]	events	An integer set of interests.
[in]	timeout	Numeric timeout.

Returns: What scheduler.io_wait returns.

Definition at line 695 of file scheduler.c.

Referenced by rb_fiber_scheduler_io_wait_readable(), rb_fiber_scheduler_io_wait_writable(), and rb_io_wait().

◆ rb_fiber_scheduler_io_wait_readable()

VALUE rb_fiber_scheduler_io_wait_readable	(	VALUE	scheduler,
		VALUE	io
	)

Non-blocking wait until the passed IO is ready for reading.

This is a special case of rb_fiber_scheduler_io_wait(), where the interest is IO::READABLE and timeout is never.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to wait.

Returns: What scheduler.io_wait returns.

Definition at line 709 of file scheduler.c.

Referenced by rb_io_wait_readable().

◆ rb_fiber_scheduler_io_wait_writable()

VALUE rb_fiber_scheduler_io_wait_writable	(	VALUE	scheduler,
		VALUE	io
	)

Non-blocking wait until the passed IO is ready for writing.

This is a special case of rb_fiber_scheduler_io_wait(), where the interest is IO::WRITABLE and timeout is never.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to wait.

Returns: What scheduler.io_wait returns.

Definition at line 715 of file scheduler.c.

Referenced by rb_io_wait_writable().

◆ rb_fiber_scheduler_io_write()

VALUE rb_fiber_scheduler_io_write	(	VALUE	scheduler,
		VALUE	io,
		VALUE	buffer,
		size_t	length,
		size_t	offset
	)

Non-blocking write to the passed IO.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to write to.
[in]	buffer	The buffer to write from.
[in]	length	The minimum number of bytes to write.
[in]	offset	The offset in the buffer to write from.

Return values

RUBY_Qundef scheduler doesn't have #io_write.

Returns: otherwise What scheduler.io_write returns [-errno, size].

Definition at line 875 of file scheduler.c.

Referenced by rb_fiber_scheduler_io_write_memory().

◆ rb_fiber_scheduler_io_write_memory()

VALUE rb_fiber_scheduler_io_write_memory	(	VALUE	scheduler,
		VALUE	io,
		const void *	base,
		size_t	size,
		size_t	length
	)

Non-blocking write to the passed IO using a native buffer.

Parameters

[in]	scheduler	Target scheduler.
[in]	io	An io object to write to.
[in]	base	The memory to write from.
[in]	size	Size of the memory.
[in]	length	The minimum number of bytes to write.

Return values

RUBY_Qundef scheduler doesn't have #io_write.

Returns: otherwise What scheduler.io_write returns.

Definition at line 945 of file scheduler.c.

◆ rb_fiber_scheduler_kernel_sleep()

VALUE rb_fiber_scheduler_kernel_sleep	(	VALUE	scheduler,
		VALUE	duration
	)

Non-blocking sleep.

Depending on scheduler implementation, this for instance switches to another fiber etc.

Parameters

[in]	scheduler	Target scheduler.
[in]	duration	Passed as-is to `scheduler.kernel_sleep`.

Returns: What scheduler.kernel_sleep returns.

Definition at line 527 of file scheduler.c.

◆ rb_fiber_scheduler_kernel_sleepv()

VALUE rb_fiber_scheduler_kernel_sleepv	(	VALUE	scheduler,
		int	argc,
		VALUE *	argv
	)

Identical to rb_fiber_scheduler_kernel_sleep(), except it can pass multiple arguments.

Parameters

[in]	scheduler	Target scheduler.
[in]	argc	Number of objects of `argv`.
[in]	argv	Passed as-is to `scheduler.kernel_sleep`

Returns: What scheduler.kernel_sleep returns.

Definition at line 533 of file scheduler.c.

◆ rb_fiber_scheduler_make_timeout()

VALUE rb_fiber_scheduler_make_timeout ( struct timeval * timeout )

Converts the passed timeout to an expression that rb_fiber_scheduler_block() etc.

expects.

Parameters

[in] timeout A duration (can be NULL).

Return values

RUBY_Qnil	No timeout (blocks indefinitely).
otherwise	A timeout object.

Definition at line 506 of file scheduler.c.

◆ rb_fiber_scheduler_process_wait()

VALUE rb_fiber_scheduler_process_wait	(	VALUE	scheduler,
		rb_pid_t	pid,
		int	flags
	)

Non-blocking waitpid.

Depending on scheduler implementation, this for instance switches to another fiber etc.

Parameters

[in]	scheduler	Target scheduler.
[in]	pid	Process ID to wait.
[in]	flags	Wait flags, e.g. `WUNTRACED`.

Returns: What scheduler.process_wait returns.

Definition at line 603 of file scheduler.c.

Referenced by rb_process_status_wait().

◆ rb_fiber_scheduler_set()

VALUE rb_fiber_scheduler_set ( VALUE scheduler )

Destructively assigns the passed scheduler to that of the current thread that is calling this function.

If the scheduler is set, non-blocking fibers (created by Fiber.new with blocking: false, or by Fiber.schedule) call that scheduler's hook methods on potentially blocking operations, and the current thread will call scheduler's #close method on finalisation (allowing the scheduler to properly manage all non-finished fibers). scheduler can be an object of any class corresponding to Fiber::Scheduler interface. Its implementation is up to the user.

Parameters

[in] scheduler The scheduler to set.

Exceptions

rb_eArgError `scheduler` does not conform the interface.

Postcondition: Current thread's scheduler is scheduler.

Definition at line 424 of file scheduler.c.

◆ rb_fiber_scheduler_unblock()

VALUE rb_fiber_scheduler_unblock	(	VALUE	scheduler,
		VALUE	blocker,
		VALUE	fiber
	)

Wakes up a fiber previously blocked using rb_fiber_scheduler_block().

This function may be called from a different thread.

Parameters

[in]	scheduler	Target scheduler.
[in]	blocker	What was awaited for.
[in]	fiber	What to unblock.

Returns: What scheduler.unblock returns.

Definition at line 646 of file scheduler.c.

(8bba087ae567421cd574b5b5772fd3039ff39b4d)

Data Structures

Macros

Typedefs

Functions

Detailed Description

Macro Definition Documentation

◆ RUBY_FIBER_SCHEDULER_VERSION

Typedef Documentation

◆ rb_fiber_scheduler_blocking_operation_t

Function Documentation

◆ rb_fiber_scheduler_address_resolve()

◆ rb_fiber_scheduler_block()

◆ rb_fiber_scheduler_blocking_operation_cancel()

◆ rb_fiber_scheduler_blocking_operation_execute()

◆ rb_fiber_scheduler_blocking_operation_extract()

◆ rb_fiber_scheduler_blocking_operation_wait()

◆ rb_fiber_scheduler_close()

◆ rb_fiber_scheduler_current()

◆ rb_fiber_scheduler_current_for_thread()

◆ rb_fiber_scheduler_fiber()

◆ rb_fiber_scheduler_fiber_interrupt()

◆ rb_fiber_scheduler_get()

◆ rb_fiber_scheduler_io_close()

◆ rb_fiber_scheduler_io_pread()

◆ rb_fiber_scheduler_io_pread_memory()

◆ rb_fiber_scheduler_io_pwrite()

◆ rb_fiber_scheduler_io_pwrite_memory()

◆ rb_fiber_scheduler_io_read()

◆ rb_fiber_scheduler_io_read_memory()

◆ rb_fiber_scheduler_io_result()

◆ rb_fiber_scheduler_io_result_apply()

◆ rb_fiber_scheduler_io_select()

◆ rb_fiber_scheduler_io_selectv()

◆ rb_fiber_scheduler_io_wait()

◆ rb_fiber_scheduler_io_wait_readable()

◆ rb_fiber_scheduler_io_wait_writable()

◆ rb_fiber_scheduler_io_write()

◆ rb_fiber_scheduler_io_write_memory()

◆ rb_fiber_scheduler_kernel_sleep()

◆ rb_fiber_scheduler_kernel_sleepv()

◆ rb_fiber_scheduler_make_timeout()

◆ rb_fiber_scheduler_process_wait()

◆ rb_fiber_scheduler_set()

◆ rb_fiber_scheduler_unblock()