org.jruby.util.io

Class SelectBlob

java.lang.Object

org.jruby.util.io.SelectBlob

public class SelectBlob
extends java.lang.Object

This is a reimplementation of MRI's IO#select logic. It has been rewritten from an earlier version in JRuby to improve performance and readability. This version avoids allocating a selector or any data structures to hold data about the channels/IOs being selected unless absolutely necessary. It also uses simple boolean arrays to track characteristics like whether an IO is pending or unselectable, rather than maintaining Set structures. It avoids hitting Java Integration code to get IO objects out of the incoming Array. Finally, it tries to build a minimal number of data structures an reuse them as much as possible.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	SelectBlob.ENXIOSelector

Field Summary

Fields

Modifier and Type	Field and Description
private static int	CANCELLED_OPS
(package private) java.util.Collection<SelectBlob.ENXIOSelector>	enxioSelectors
(package private) RubyArray	errorResults
(package private) java.nio.channels.Selector	mainSelector
(package private) boolean[]	pendingReads
private static int	READ_ACCEPT_OPS
(package private) RubyArray	readArray
(package private) java.lang.Boolean[]	readBlocking
(package private) RubyIO[]	readIOs
(package private) RubyArray	readResults
(package private) int	readSize
(package private) Ruby	runtime
(package private) int	selectedReads
(package private) int	selectedWrites
(package private) java.util.Map<java.nio.channels.spi.SelectorProvider,java.nio.channels.Selector>	selectors
(package private) boolean[]	unselectableReads
(package private) boolean[]	unselectableWrites
private static int	WRITE_CONNECT_OPS
(package private) RubyArray	writeArray
(package private) java.lang.Boolean[]	writeBlocking
(package private) RubyIO[]	writeIOs
(package private) RubyArray	writeResults
(package private) int	writeSize

Constructor Summary

Constructors

Constructor and Description
SelectBlob()

Method Summary

Modifier and Type	Method and Description
private static boolean	cancelReady(int ops)
private static void	checkArrayType(Ruby runtime, IRubyObject obj)
private IRubyObject	constructResults(Ruby runtime)
private void	doSelect(Ruby runtime, boolean has_timeout, long timeout)
private int	fastSearch(java.lang.Object[] ary, java.lang.Object obj)
private RubyArray	getErrorResults()
private boolean[]	getPendingReads()
private java.lang.Boolean[]	getReadBlocking()
private RubyArray	getReadResults()
private java.nio.channels.Selector	getSelector(ThreadContext context, java.nio.channels.SelectableChannel channel)
private static long	getTimeoutFromArg(IRubyObject timeArg, Ruby runtime)
private boolean[]	getUnselectableReads()
private boolean[]	getUnselectableWrites()
private java.lang.Boolean[]	getWriteBlocking()
private RubyArray	getWriteResults()
IRubyObject	goForIt(ThreadContext context, Ruby runtime, IRubyObject[] args)
private void	processPendingAndUnselectable()
private void	processReads(Ruby runtime, IRubyObject[] args, ThreadContext context)
private void	processSelectedKeys(Ruby runtime)
private void	processWrites(Ruby runtime, IRubyObject[] args, ThreadContext context)
private static boolean	readAcceptReady(int ops)
private static boolean	ready(int ops, int mask)
private static boolean	registerSelect(ThreadContext context, java.nio.channels.Selector selector, java.util.Map<java.lang.Character,java.lang.Integer> obj, RubyIO ioObj, int ops)
private void	saveBufferedRead(RubyIO ioObj, int i)
private void	saveReadBlocking(RubyIO ioObj, int i)
private RubyIO	saveReadIO(int i, ThreadContext context)
private void	saveWriteBlocking(RubyIO ioObj, int i)
private RubyIO	saveWriteIO(int i, ThreadContext context)
private void	tidyUp()
private void	trySelectRead(ThreadContext context, java.util.Map<java.lang.Character,java.lang.Integer> attachment, RubyIO ioObj)
private void	trySelectWrite(ThreadContext context, java.util.Map<java.lang.Character,java.lang.Integer> attachment, RubyIO ioObj)
private static boolean	writeConnectReady(int ops)
private static boolean	writeReady(int ops)

Methods inherited from class java.lang.Object

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

Field Detail

READ_ACCEPT_OPS

private static final int READ_ACCEPT_OPS

See Also:

Constant Field Values

WRITE_CONNECT_OPS

private static final int WRITE_CONNECT_OPS

See Also:

Constant Field Values

CANCELLED_OPS

private static final int CANCELLED_OPS

See Also:

Constant Field Values

runtime

Ruby runtime

readArray

RubyArray readArray

readSize

int readSize

readIOs

RubyIO[] readIOs

unselectableReads

boolean[] unselectableReads

pendingReads

boolean[] pendingReads

readBlocking

java.lang.Boolean[] readBlocking

selectedReads

int selectedReads

writeArray

RubyArray writeArray

writeSize

int writeSize

writeIOs

RubyIO[] writeIOs

unselectableWrites

boolean[] unselectableWrites

writeBlocking

java.lang.Boolean[] writeBlocking

selectedWrites

int selectedWrites

mainSelector

java.nio.channels.Selector mainSelector

selectors

java.util.Map<java.nio.channels.spi.SelectorProvider,java.nio.channels.Selector> selectors

enxioSelectors

java.util.Collection<SelectBlob.ENXIOSelector> enxioSelectors

readResults

RubyArray readResults

writeResults

RubyArray writeResults

errorResults

RubyArray errorResults

Constructor Detail

SelectBlob

public SelectBlob()

Method Detail

goForIt

public IRubyObject goForIt(ThreadContext context,
                           Ruby runtime,
                           IRubyObject[] args)

processReads

private void processReads(Ruby runtime,
                          IRubyObject[] args,
                          ThreadContext context)
                   throws BadDescriptorException,
                          java.io.IOException

Throws:

BadDescriptorException

java.io.IOException

saveReadIO

private RubyIO saveReadIO(int i,
                          ThreadContext context)

saveReadBlocking

private void saveReadBlocking(RubyIO ioObj,
                              int i)

saveBufferedRead

private void saveBufferedRead(RubyIO ioObj,
                              int i)
                       throws BadDescriptorException

Throws:

BadDescriptorException

trySelectRead

private void trySelectRead(ThreadContext context,
                           java.util.Map<java.lang.Character,java.lang.Integer> attachment,
                           RubyIO ioObj)
                    throws java.io.IOException

Throws:

java.io.IOException

processWrites

private void processWrites(Ruby runtime,
                           IRubyObject[] args,
                           ThreadContext context)
                    throws java.io.IOException

Throws:

java.io.IOException

saveWriteIO

private RubyIO saveWriteIO(int i,
                           ThreadContext context)

saveWriteBlocking

private void saveWriteBlocking(RubyIO ioObj,
                               int i)

trySelectWrite

private void trySelectWrite(ThreadContext context,
                            java.util.Map<java.lang.Character,java.lang.Integer> attachment,
                            RubyIO ioObj)
                     throws java.io.IOException

Throws:

java.io.IOException

getTimeoutFromArg

private static long getTimeoutFromArg(IRubyObject timeArg,
                                      Ruby runtime)

doSelect

private void doSelect(Ruby runtime,
                      boolean has_timeout,
                      long timeout)
               throws java.io.IOException

Throws:

java.io.IOException

ready

private static boolean ready(int ops,
                             int mask)

readAcceptReady

private static boolean readAcceptReady(int ops)

writeConnectReady

private static boolean writeConnectReady(int ops)

cancelReady

private static boolean cancelReady(int ops)

writeReady

private static boolean writeReady(int ops)

processSelectedKeys

private void processSelectedKeys(Ruby runtime)
                          throws java.io.IOException

Throws:

java.io.IOException

processPendingAndUnselectable

private void processPendingAndUnselectable()

tidyUp

private void tidyUp()
             throws java.io.IOException

Throws:

java.io.IOException

getReadResults

private RubyArray getReadResults()

getWriteResults

private RubyArray getWriteResults()

getErrorResults

private RubyArray getErrorResults()

getSelector

private java.nio.channels.Selector getSelector(ThreadContext context,
                                               java.nio.channels.SelectableChannel channel)
                                        throws java.io.IOException

Throws:

java.io.IOException

getReadBlocking

private java.lang.Boolean[] getReadBlocking()

getWriteBlocking

private java.lang.Boolean[] getWriteBlocking()

getUnselectableReads

private boolean[] getUnselectableReads()

getUnselectableWrites

private boolean[] getUnselectableWrites()

getPendingReads

private boolean[] getPendingReads()

constructResults

private IRubyObject constructResults(Ruby runtime)

fastSearch

private int fastSearch(java.lang.Object[] ary,
                       java.lang.Object obj)

checkArrayType

private static void checkArrayType(Ruby runtime,
                                   IRubyObject obj)

registerSelect

private static boolean registerSelect(ThreadContext context,
                                      java.nio.channels.Selector selector,
                                      java.util.Map<java.lang.Character,java.lang.Integer> obj,
                                      RubyIO ioObj,
                                      int ops)
                               throws java.io.IOException

Throws:

java.io.IOException