org.jruby.util.io

Class BlockingIO

java.lang.Object

org.jruby.util.io.BlockingIO

public class BlockingIO
extends java.lang.Object

A Utility class to emulate blocking I/O operations on non-blocking channels.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockingIO.Condition
(package private) static class	BlockingIO.IOChannel
(package private) static class	BlockingIO.IOSelector

Field Summary

Fields

Modifier and Type	Field and Description
private static java.util.Map<java.nio.channels.spi.SelectorProvider,BlockingIO.IOSelector>	selectors

Constructor Summary

Constructors

Constructor and Description
BlockingIO()

Method Summary

Modifier and Type	Method and Description
static void	awaitReadable(java.nio.channels.ReadableByteChannel channel)
static void	awaitWritable(java.nio.channels.WritableByteChannel channel)
static int	blockingRead(java.nio.channels.ReadableByteChannel channel, java.nio.ByteBuffer buf)
static int	blockingWrite(java.nio.channels.WritableByteChannel channel, java.nio.ByteBuffer buf)
private static BlockingIO.IOSelector	getSelector(java.nio.channels.Channel channel)
private static BlockingIO.IOSelector	getSelector(java.nio.channels.spi.SelectorProvider provider)
static BlockingIO.Condition	newCondition(java.nio.channels.Channel channel, int ops)
static BlockingIO.Condition	newCondition(java.nio.channels.Channel channel, int ops, java.lang.Object monitor)
static int	read(java.nio.channels.ReadableByteChannel channel, java.nio.ByteBuffer buf, boolean blocking)
static void	waitForIO(java.nio.channels.Channel channel, int op)
static int	write(java.nio.channels.WritableByteChannel channel, java.nio.ByteBuffer buf, boolean blocking)

Methods inherited from class java.lang.Object

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

Field Detail

selectors

private static final java.util.Map<java.nio.channels.spi.SelectorProvider,BlockingIO.IOSelector> selectors

Constructor Detail

BlockingIO

public BlockingIO()

Method Detail

getSelector

private static BlockingIO.IOSelector getSelector(java.nio.channels.spi.SelectorProvider provider)
                                          throws java.io.IOException

Throws:

java.io.IOException

getSelector

private static BlockingIO.IOSelector getSelector(java.nio.channels.Channel channel)
                                          throws java.io.IOException

Throws:

java.io.IOException

newCondition

public static final BlockingIO.Condition newCondition(java.nio.channels.Channel channel,
                                                      int ops,
                                                      java.lang.Object monitor)
                                               throws java.io.IOException

Throws:

java.io.IOException

newCondition

public static final BlockingIO.Condition newCondition(java.nio.channels.Channel channel,
                                                      int ops)
                                               throws java.io.IOException

Throws:

java.io.IOException

waitForIO

public static void waitForIO(java.nio.channels.Channel channel,
                             int op)
                      throws java.lang.InterruptedException,
                             java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

awaitReadable

public static void awaitReadable(java.nio.channels.ReadableByteChannel channel)
                          throws java.lang.InterruptedException,
                                 java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

awaitWritable

public static void awaitWritable(java.nio.channels.WritableByteChannel channel)
                          throws java.lang.InterruptedException,
                                 java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

read

public static int read(java.nio.channels.ReadableByteChannel channel,
                       java.nio.ByteBuffer buf,
                       boolean blocking)
                throws java.io.IOException

Throws:

java.io.IOException

write

public static int write(java.nio.channels.WritableByteChannel channel,
                        java.nio.ByteBuffer buf,
                        boolean blocking)
                 throws java.io.IOException

Throws:

java.io.IOException

blockingRead

public static int blockingRead(java.nio.channels.ReadableByteChannel channel,
                               java.nio.ByteBuffer buf)
                        throws java.io.IOException

Throws:

java.io.IOException

blockingWrite

public static int blockingWrite(java.nio.channels.WritableByteChannel channel,
                                java.nio.ByteBuffer buf)
                         throws java.io.IOException

Throws:

java.io.IOException