kg.apc.io

Class SocketChannelWithTimeouts

java.lang.Object

java.nio.channels.spi.AbstractInterruptibleChannel

java.nio.channels.SelectableChannel

java.nio.channels.spi.AbstractSelectableChannel

java.nio.channels.SocketChannel

kg.apc.io.SocketChannelWithTimeouts

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, GatheringByteChannel, InterruptibleChannel, NetworkChannel, ReadableByteChannel, ScatteringByteChannel, WritableByteChannel

public class SocketChannelWithTimeouts
extends SocketChannel

SocketChannel with timeouts. This class performs blocking operations for connect and IO. Make note that some of methods are not implemeted yet. Also selector usage kills scalability

Field Summary

Fields

Modifier and Type	Field and Description
protected SelectionKey	channelKey
protected Selector	selector
protected SocketChannel	socketChannel

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SocketChannelWithTimeouts()

Method Summary

Modifier and Type	Method and Description
SocketChannel	bind(SocketAddress socketAddress)
boolean	connect(SocketAddress remote)
boolean	finishConnect()
SocketAddress	getLocalAddress()
<T> T	getOption(SocketOption<T> socketOption)
SocketAddress	getRemoteAddress()
protected void	implCloseSelectableChannel()
protected void	implConfigureBlocking(boolean block)
boolean	isConnected()
boolean	isConnectionPending()
static SocketChannel	open()
int	read(ByteBuffer dst)
long	read(ByteBuffer[] dsts, int offset, int length)
void	setConnectTimeout(int t)
<T> SocketChannel	setOption(SocketOption<T> socketOption, T t)
void	setReadTimeout(int t)
SocketChannel	shutdownInput()
SocketChannel	shutdownOutput()
Socket	socket()
Set<SocketOption<?>>	supportedOptions()
int	write(ByteBuffer src)
long	write(ByteBuffer[] srcs, int offset, int length)

Methods inherited from class java.nio.channels.SocketChannel

open, read, validOps, write

Methods inherited from class java.nio.channels.spi.AbstractSelectableChannel

blockingLock, configureBlocking, implCloseChannel, isBlocking, isRegistered, keyFor, provider, register

Methods inherited from class java.nio.channels.SelectableChannel

register

Methods inherited from class java.nio.channels.spi.AbstractInterruptibleChannel

begin, close, end, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.Channel

close, isOpen

Field Detail

socketChannel

protected SocketChannel socketChannel

selector

protected Selector selector

channelKey

protected SelectionKey channelKey

Constructor Detail

SocketChannelWithTimeouts

protected SocketChannelWithTimeouts()
                             throws IOException

Throws:

IOException

Method Detail

open

public static SocketChannel open()
                          throws IOException

Throws:

IOException

bind

public SocketChannel bind(SocketAddress socketAddress)
                   throws IOException

Specified by:

bind in interface NetworkChannel

Overrides:

bind in class SocketChannel

Throws:

IOException

getLocalAddress

public SocketAddress getLocalAddress()
                              throws IOException

Specified by:

getLocalAddress in interface NetworkChannel

Specified by:

getLocalAddress in class SocketChannel

Throws:

IOException

setOption

public <T> SocketChannel setOption(SocketOption<T> socketOption,
                                   T t)
                            throws IOException

Specified by:

setOption in interface NetworkChannel

Specified by:

setOption in class SocketChannel

Throws:

IOException

getOption

public <T> T getOption(SocketOption<T> socketOption)
                throws IOException

Throws:

IOException

supportedOptions

public Set<SocketOption<?>> supportedOptions()

shutdownInput

public SocketChannel shutdownInput()
                            throws IOException

Specified by:

shutdownInput in class SocketChannel

Throws:

IOException

shutdownOutput

public SocketChannel shutdownOutput()
                             throws IOException

Specified by:

shutdownOutput in class SocketChannel

Throws:

IOException

connect

public boolean connect(SocketAddress remote)
                throws IOException

Specified by:

connect in class SocketChannel

Throws:

IOException

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Specified by:

read in class SocketChannel

Throws:

IOException

read

public long read(ByteBuffer[] dsts,
                 int offset,
                 int length)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Specified by:

read in class SocketChannel

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Specified by:

write in class SocketChannel

Throws:

IOException

write

public long write(ByteBuffer[] srcs,
                  int offset,
                  int length)
           throws IOException

Specified by:

write in interface GatheringByteChannel

Specified by:

write in class SocketChannel

Throws:

IOException

implCloseSelectableChannel

protected void implCloseSelectableChannel()
                                   throws IOException

Specified by:

implCloseSelectableChannel in class AbstractSelectableChannel

Throws:

IOException

implConfigureBlocking

protected void implConfigureBlocking(boolean block)
                              throws IOException

Specified by:

implConfigureBlocking in class AbstractSelectableChannel

Throws:

IOException

socket

public Socket socket()

Specified by:

socket in class SocketChannel

isConnected

public boolean isConnected()

Specified by:

isConnected in class SocketChannel

isConnectionPending

public boolean isConnectionPending()

Specified by:

isConnectionPending in class SocketChannel

finishConnect

public boolean finishConnect()
                      throws IOException

Specified by:

finishConnect in class SocketChannel

Throws:

IOException

setConnectTimeout

public void setConnectTimeout(int t)

setReadTimeout

public void setReadTimeout(int t)

getRemoteAddress

public SocketAddress getRemoteAddress()
                               throws IOException

Specified by:

getRemoteAddress in class SocketChannel

Throws:

IOException