io.apigee.trireme.kernel.handles

Class AbstractNIOHandle

java.lang.Object

io.apigee.trireme.kernel.handles.AbstractHandle

io.apigee.trireme.kernel.handles.AbstractNIOHandle

All Implemented Interfaces:

Handle

Direct Known Subclasses:

NIODatagramHandle, NIOSocketHandle

public abstract class AbstractNIOHandle
extends AbstractHandle

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractNIOHandle.QueuedWrite

Field Summary

Fields

Modifier and Type	Field and Description
protected int	queuedBytes
protected GenericNodeRuntime	runtime
protected java.nio.channels.SelectionKey	selKey
protected java.util.ArrayDeque<AbstractNIOHandle.QueuedWrite>	writeQueue
protected boolean	writeReady

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNIOHandle(GenericNodeRuntime runtime)

Method Summary

Modifier and Type	Method and Description
protected void	addInterest(int i)
protected void	clientSelected(java.nio.channels.SelectionKey key)
protected NetworkPolicy	getNetworkPolicy()
protected abstract void	processConnect()
protected abstract void	processReads()
protected abstract void	processWrites()
protected void	queueWrite(AbstractNIOHandle.QueuedWrite qw)
protected void	removeInterest(int i)

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

close, getReadHandler, getWritesOutstanding, setReadHandler, startReading, stopReading, write, write, writeHandle, writeHandle

Methods inherited from class java.lang.Object

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

Field Detail

runtime

protected final GenericNodeRuntime runtime

selKey

protected java.nio.channels.SelectionKey selKey

writeReady

protected boolean writeReady

writeQueue

protected final java.util.ArrayDeque<AbstractNIOHandle.QueuedWrite> writeQueue

queuedBytes

protected int queuedBytes

Constructor Detail

AbstractNIOHandle

protected AbstractNIOHandle(GenericNodeRuntime runtime)

Method Detail

getNetworkPolicy

protected NetworkPolicy getNetworkPolicy()

addInterest

protected void addInterest(int i)

removeInterest

protected void removeInterest(int i)

queueWrite

protected void queueWrite(AbstractNIOHandle.QueuedWrite qw)

clientSelected

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

processConnect

protected abstract void processConnect()

processWrites

protected abstract void processWrites()

processReads

protected abstract void processReads()