Package org.jruby.util.io

Class SelectExecutor

java.lang.Object

org.jruby.util.io.SelectExecutor

public class SelectExecutor
extends Object

Created by headius on 6/3/14.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	SelectExecutor.ENXIOSelector

Field Summary

Fields

Modifier and Type	Field	Description
(package private) List<SelectExecutor.ENXIOSelector>	enxioSelectors
(package private) List<SelectionKey>	errorKeyList
(package private) final IRubyObject	except
(package private) Selector	mainSelector
(package private) List<ChannelFD>	pendingReadFDs
(package private) final IRubyObject	read
static final int	READ_ACCEPT_OPS
(package private) List<SelectionKey>	readKeyList
(package private) final Ruby	runtime
(package private) List<Selector>	selectors
private static final RubyThread.Task<SelectExecutor,Integer>	SelectTask
(package private) Long	timeout
(package private) List<ChannelFD>	unselectableReadFDs
(package private) List<ChannelFD>	unselectableWriteFDs
(package private) final IRubyObject	write
static final int	WRITE_CONNECT_OPS
(package private) List<SelectionKey>	writeKeyList

Constructor Summary

Constructors

Constructor	Description
SelectExecutor(IRubyObject read, IRubyObject write, IRubyObject except, Long timeout)

Method Summary

Modifier and Type	Method	Description
private int	doSelect(ThreadContext context)
private boolean	fdIsSet(List<SelectionKey> fds, ChannelFD fd, int operations)
private void	fdSetRead(ThreadContext context, ChannelFD fd, int maxSize)
private void	fdSetWrite(ThreadContext context, ChannelFD fd, int maxSize)
private Selector	getSelector(ThreadContext context, SelectableChannel channel)
IRubyObject	go(ThreadContext context)
private int	maxReadReadySize()
private int	maxWriteReadySize()
private static SelectionKey	registerSelect(Selector selector, ChannelFD attachment, SelectableChannel channel, int ops)
(package private) IRubyObject	selectCall(ThreadContext context)
(package private) IRubyObject	selectEnd(ThreadContext context)
(package private) IRubyObject	selectInternal(ThreadContext context)
private int	threadFdSelect(ThreadContext context)
private SelectionKey	trySelectRead(ThreadContext context, ChannelFD fd)
private SelectionKey	trySelectWrite(ThreadContext context, ChannelFD fd)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

SelectTask

private static final RubyThread.Task<SelectExecutor,Integer> SelectTask

read

final IRubyObject read

write

final IRubyObject write

except

final IRubyObject except

readKeyList

List<SelectionKey> readKeyList

writeKeyList

List<SelectionKey> writeKeyList

errorKeyList

List<SelectionKey> errorKeyList

unselectableReadFDs

List<ChannelFD> unselectableReadFDs

unselectableWriteFDs

List<ChannelFD> unselectableWriteFDs

pendingReadFDs

List<ChannelFD> pendingReadFDs

mainSelector

Selector mainSelector

selectors

List<Selector> selectors

enxioSelectors

List<SelectExecutor.ENXIOSelector> enxioSelectors

timeout

Long timeout

runtime

final Ruby runtime

READ_ACCEPT_OPS

public static final int READ_ACCEPT_OPS

See Also:

• Constant Field Values

WRITE_CONNECT_OPS

public static final int WRITE_CONNECT_OPS

See Also:

• Constant Field Values

Constructor Details

SelectExecutor

public SelectExecutor(IRubyObject read,
 IRubyObject write,
 IRubyObject except,
 Long timeout)

Method Details

go

public IRubyObject go(ThreadContext context)

selectCall

IRubyObject selectCall(ThreadContext context)
                throws IOException

Throws:

IOException

selectEnd

IRubyObject selectEnd(ThreadContext context)
               throws IOException

Throws:

IOException

selectInternal

IRubyObject selectInternal(ThreadContext context)
                    throws IOException

Throws:

IOException

maxReadReadySize

private int maxReadReadySize()

maxWriteReadySize

private int maxWriteReadySize()

fdSetRead

private void fdSetRead(ThreadContext context,
 ChannelFD fd,
 int maxSize)
                throws IOException

Throws:

IOException

fdSetWrite

private void fdSetWrite(ThreadContext context,
 ChannelFD fd,
 int maxSize)
                 throws IOException

Throws:

IOException

fdIsSet

private boolean fdIsSet(List<SelectionKey> fds,
 ChannelFD fd,
 int operations)

trySelectRead

private SelectionKey trySelectRead(ThreadContext context,
 ChannelFD fd)
                            throws IOException

Throws:

IOException

trySelectWrite

private SelectionKey trySelectWrite(ThreadContext context,
 ChannelFD fd)
                             throws IOException

Throws:

IOException

getSelector

private Selector getSelector(ThreadContext context,
 SelectableChannel channel)
                      throws IOException

Throws:

IOException

registerSelect

private static SelectionKey registerSelect(Selector selector,
 ChannelFD attachment,
 SelectableChannel channel,
 int ops)
                                    throws IOException

Throws:

IOException

threadFdSelect

private int threadFdSelect(ThreadContext context)
                    throws IOException

Throws:

IOException

doSelect

private int doSelect(ThreadContext context)