io.apigee.trireme.kernel.handles

Class NIOSocketHandle

java.lang.Object

io.apigee.trireme.kernel.handles.AbstractHandle

io.apigee.trireme.kernel.handles.AbstractNIOHandle

io.apigee.trireme.kernel.handles.NIOSocketHandle

All Implemented Interfaces:

Handle, SocketHandle

public class NIOSocketHandle
extends AbstractNIOHandle
implements SocketHandle

Node's own script modules use this internal module to implement the guts of async TCP.

Nested Class Summary

Nested classes/interfaces inherited from class io.apigee.trireme.kernel.handles.AbstractNIOHandle

AbstractNIOHandle.QueuedWrite

Field Summary

Fields

Modifier and Type	Field and Description
static int	READ_BUFFER_SIZE

Fields inherited from class io.apigee.trireme.kernel.handles.AbstractNIOHandle

queuedBytes, runtime, selKey, writeQueue, writeReady

Constructor Summary

Constructors

Constructor and Description
NIOSocketHandle(GenericNodeRuntime runtime)
NIOSocketHandle(GenericNodeRuntime runtime, java.nio.channels.SocketChannel clientChannel)

Method Summary

Modifier and Type	Method and Description
void	bind(java.lang.String address, int port)
void	close()
void	connect(java.lang.String host, int port, IOCompletionHandler<java.lang.Integer> handler)
java.net.InetSocketAddress	getPeerName()
IOCompletionHandler<java.nio.ByteBuffer>	getReadHandler()
java.net.InetSocketAddress	getSockName()
int	getWritesOutstanding()
boolean	isServerChannel()
void	listen(int backlog, IOCompletionHandler<AbstractHandle> handler)
protected void	processConnect()
protected void	processReads()
protected void	processWrites()
protected void	serverSelected(java.nio.channels.SelectionKey key)
void	setKeepAlive(boolean nd)
void	setNoDelay(boolean nd)
void	setReadHandler(IOCompletionHandler<java.nio.ByteBuffer> h)
void	shutdown(IOCompletionHandler<java.lang.Integer> handler)
void	startReading(IOCompletionHandler<java.nio.ByteBuffer> handler)
void	stopReading()
int	write(java.nio.ByteBuffer buf, IOCompletionHandler<java.lang.Integer> handler)

Methods inherited from class io.apigee.trireme.kernel.handles.AbstractNIOHandle

addInterest, clientSelected, getNetworkPolicy, queueWrite, removeInterest

Methods inherited from class io.apigee.trireme.kernel.handles.AbstractHandle

write, writeHandle, writeHandle

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.apigee.trireme.kernel.handles.Handle

write, writeHandle, writeHandle

Field Detail

READ_BUFFER_SIZE

public static final int READ_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

NIOSocketHandle

public NIOSocketHandle(GenericNodeRuntime runtime)

NIOSocketHandle

public NIOSocketHandle(GenericNodeRuntime runtime,
                       java.nio.channels.SocketChannel clientChannel)
                throws java.io.IOException,
                       OSException

Throws:

java.io.IOException

OSException

Method Detail

isServerChannel

public boolean isServerChannel()

close

public void close()

Specified by:

close in interface Handle

Specified by:

close in class AbstractHandle

getReadHandler

public IOCompletionHandler<java.nio.ByteBuffer> getReadHandler()

Specified by:

getReadHandler in interface Handle

Overrides:

getReadHandler in class AbstractHandle

setReadHandler

public void setReadHandler(IOCompletionHandler<java.nio.ByteBuffer> h)

Specified by:

setReadHandler in interface Handle

Overrides:

setReadHandler in class AbstractHandle

bind

public void bind(java.lang.String address,
                 int port)
          throws OSException

Specified by:

bind in interface SocketHandle

Throws:

OSException

listen

public void listen(int backlog,
                   IOCompletionHandler<AbstractHandle> handler)
            throws OSException

Specified by:

listen in interface SocketHandle

Throws:

OSException

serverSelected

protected void serverSelected(java.nio.channels.SelectionKey key)

write

public int write(java.nio.ByteBuffer buf,
                 IOCompletionHandler<java.lang.Integer> handler)

Specified by:

write in interface Handle

Overrides:

write in class AbstractHandle

shutdown

public void shutdown(IOCompletionHandler<java.lang.Integer> handler)

Specified by:

shutdown in interface SocketHandle

getWritesOutstanding

public int getWritesOutstanding()

Specified by:

getWritesOutstanding in interface Handle

Overrides:

getWritesOutstanding in class AbstractHandle

startReading

public void startReading(IOCompletionHandler<java.nio.ByteBuffer> handler)

Specified by:

startReading in interface Handle

Overrides:

startReading in class AbstractHandle

stopReading

public void stopReading()

Specified by:

stopReading in interface Handle

Overrides:

stopReading in class AbstractHandle

connect

public void connect(java.lang.String host,
                    int port,
                    IOCompletionHandler<java.lang.Integer> handler)
             throws OSException

Specified by:

connect in interface SocketHandle

Throws:

OSException

processConnect

protected void processConnect()

Specified by:

processConnect in class AbstractNIOHandle

processWrites

protected void processWrites()

Specified by:

processWrites in class AbstractNIOHandle

processReads

protected void processReads()

Specified by:

processReads in class AbstractNIOHandle

getSockName

public java.net.InetSocketAddress getSockName()

Specified by:

getSockName in interface SocketHandle

getPeerName

public java.net.InetSocketAddress getPeerName()

Specified by:

getPeerName in interface SocketHandle

setNoDelay

public void setNoDelay(boolean nd)
                throws OSException

Specified by:

setNoDelay in interface SocketHandle

Throws:

OSException

setKeepAlive

public void setKeepAlive(boolean nd)
                  throws OSException

Specified by:

setKeepAlive in interface SocketHandle

Throws:

OSException