com.inductiveautomation.ignition.common.nio

Class AbstractNioManager

java.lang.Object

com.inductiveautomation.ignition.common.nio.AbstractNioManager

All Implemented Interfaces:

NioManager, java.lang.Runnable

public abstract class AbstractNioManager
extends java.lang.Object
implements NioManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractNioManager.NioIdentifier
static class	AbstractNioManager.NioServerIdentifier

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<NioCallback,java.nio.ByteBuffer>	buffers
protected java.util.Queue<ChangeRequest>	changeRequestQueue
protected ExecutionManager	executionManager
protected java.util.Map<AbstractNioManager.NioIdentifier,java.nio.channels.SocketChannel>	identifiers
protected org.apache.log4j.Logger	log
protected java.util.Map<java.nio.channels.SocketChannel,NioCallback>	nioCallbacks
protected java.lang.Class<?>	ownerClass
protected java.util.Map<java.nio.channels.SocketChannel,java.util.Queue<com.inductiveautomation.ignition.common.nio.AbstractNioManager.QueuedByteBuffer>>	pendingData
protected java.nio.channels.Selector	selector

Method Summary

Modifier and Type	Method and Description
protected void	accept(java.nio.channels.SelectionKey key)
protected void	closeChannel(java.nio.channels.ServerSocketChannel channel)
protected void	closeChannel(java.nio.channels.SocketChannel channel)
void	disconnect(AbstractNioManager.NioIdentifier identifier)
protected void	finishConnect(java.nio.channels.SelectionKey key)
protected void	removeCallbacks(java.nio.channels.SocketChannel channel)
void	run()
void	send(java.nio.ByteBuffer buffer, AbstractNioManager.NioIdentifier identifier)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

pendingData

@GuardedBy(value="pendingData")
protected final java.util.Map<java.nio.channels.SocketChannel,java.util.Queue<com.inductiveautomation.ignition.common.nio.AbstractNioManager.QueuedByteBuffer>> pendingData

changeRequestQueue

@GuardedBy(value="changeRequestQueue")
protected final java.util.Queue<ChangeRequest> changeRequestQueue

buffers

protected final java.util.Map<NioCallback,java.nio.ByteBuffer> buffers

nioCallbacks

protected final java.util.Map<java.nio.channels.SocketChannel,NioCallback> nioCallbacks

identifiers

protected final java.util.Map<AbstractNioManager.NioIdentifier,java.nio.channels.SocketChannel> identifiers

executionManager

protected final ExecutionManager executionManager

ownerClass

protected final java.lang.Class<?> ownerClass

log

protected final org.apache.log4j.Logger log

selector

protected final java.nio.channels.Selector selector

Method Detail

shutdown

public void shutdown()

Specified by:

shutdown in interface NioManager

send

public void send(java.nio.ByteBuffer buffer,
                 AbstractNioManager.NioIdentifier identifier)

Specified by:

send in interface NioManager

disconnect

public void disconnect(AbstractNioManager.NioIdentifier identifier)

Specified by:

disconnect in interface NioManager

run

public void run()

Specified by:

run in interface java.lang.Runnable

finishConnect

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

accept

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

removeCallbacks

protected void removeCallbacks(java.nio.channels.SocketChannel channel)

closeChannel

protected void closeChannel(java.nio.channels.SocketChannel channel)

closeChannel

protected void closeChannel(java.nio.channels.ServerSocketChannel channel)