Top Description Inners Fields Constructors Methods

org.jruby.util.io

public Class SelectExecutor

Class Inheritance

extends Object

java.lang.Object
org.jruby.util.io.SelectExecutor

Imports

jnr.enxio.channels.NativeSelectorProvider, org.jruby.Ruby, .RubyArray, .RubyIO, .RubyThread, org.jruby.api.Create, org.jruby.runtime.ThreadContext, org.jruby.runtime.builtin.IRubyObject, org.jruby.util.TypeConverter, java.io.IOException, java.nio.ByteBuffer, java.nio.channels.Pipe, .SelectableChannel, .SelectionKey, .Selector, java.nio.channels.spi.SelectorProvider, java.util.ArrayList, .Collections, .List, java.util.concurrent.Callable, .ExecutionException, .Future

Created by headius on 6/3/14.

Nested and Inner Type Summary

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

Field Summary

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

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
private int	doSelect(ThreadContext context)
private boolean	fdIsSet(List<SelectionKey> fds, ChannelFD fd, final 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)
public IRubyObject	go(ThreadContext context)
private int	maxReadReadySize()
private int	maxWriteReadySize()
private static SelectionKey	registerSelect(Selector selector, ChannelFD attachment, SelectableChannel channel, int ops)
pack-priv IRubyObject	selectCall(ThreadContext context)
pack-priv IRubyObject	selectEnd(ThreadContext context)
pack-priv IRubyObject	selectInternal(ThreadContext context)
private int	threadFdSelect(ThreadContext context)
private SelectionKey	trySelectRead(ThreadContext context, ChannelFD fd)
private SelectionKey	trySelectWrite(ThreadContext context, ChannelFD fd)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

enxioSelectors	back to summary
pack-priv List<SelectExecutor.ENXIOSelector> enxioSelectors

errorKeyList	back to summary
pack-priv List<SelectionKey> errorKeyList

except	back to summary
pack-priv final IRubyObject except

mainSelector	back to summary
pack-priv Selector mainSelector

pendingReadFDs	back to summary
pack-priv List<ChannelFD> pendingReadFDs

read	back to summary
pack-priv final IRubyObject read

READ_ACCEPT_OPS	back to summary
public static final int READ_ACCEPT_OPS

readKeyList	back to summary
pack-priv List<SelectionKey> readKeyList

runtime	back to summary
pack-priv final Ruby runtime

selectors	back to summary
pack-priv List<Selector> selectors

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

timeout	back to summary
pack-priv Long timeout

unselectableReadFDs	back to summary
pack-priv List<ChannelFD> unselectableReadFDs

unselectableWriteFDs	back to summary
pack-priv List<ChannelFD> unselectableWriteFDs

write	back to summary
pack-priv final IRubyObject write

WRITE_CONNECT_OPS	back to summary
public static final int WRITE_CONNECT_OPS

writeKeyList	back to summary
pack-priv List<SelectionKey> writeKeyList

Constructor Detail

SelectExecutor	back to summary
public SelectExecutor(IRubyObject read, IRubyObject write, IRubyObject except, Long timeout)

Method Detail

doSelect	back to summary
private int doSelect(ThreadContext context)

fdIsSet	back to summary
private boolean fdIsSet(List<SelectionKey> fds, ChannelFD fd, final int operations)

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

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

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

go	back to summary
public IRubyObject go(ThreadContext context)

maxReadReadySize	back to summary
private int maxReadReadySize()

maxWriteReadySize	back to summary
private int maxWriteReadySize()

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

selectCall	back to summary
pack-priv IRubyObject selectCall(ThreadContext context) throws IOException

selectEnd	back to summary
pack-priv IRubyObject selectEnd(ThreadContext context) throws IOException

selectInternal	back to summary
pack-priv IRubyObject selectInternal(ThreadContext context) throws IOException

threadFdSelect	back to summary
private int threadFdSelect(ThreadContext context)

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

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

org.jruby.util.io back to summary

private final Class SelectExecutor.ENXIOSelector

Class Inheritance

extends Object
implements Callable<Object>

java.lang.Object
org.jruby.util.io.SelectExecutor.ENXIOSelector

All Implemented Interfaces

java.util.concurrent.Callable

Field Summary

Modifier and Type	Field and Description
private final Pipe	pipe
private final Selector	selector

Constructor Summary

Access	Constructor and Description
private	ENXIOSelector(Selector selector, Pipe pipe)

Method Summary

Modifier and Type	Method and Description
public Object	call() Implements java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so.
public void	cleanup()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

pipe	back to summary
private final Pipe pipe

selector	back to summary
private final Selector selector

Constructor Detail

ENXIOSelector	back to summary
private ENXIOSelector(Selector selector, Pipe pipe)

Method Detail

call	back to summary
public Object call() throws Exception Implements java.util.concurrent.Callable.call. Doc from java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so. Returns:Object computed result Exceptions Exception: if unable to compute a result

call

back to summary

public Object call() throws Exception

Implements java.util.concurrent.Callable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:Object

computed result

Exceptions

Exception:: if unable to compute a result

cleanup	back to summary
public void cleanup() throws IOException