org.snmp4j.transport

Class DefaultTcpTransportMapping.ServerThread

java.lang.Object

org.snmp4j.transport.DefaultTcpTransportMapping.ServerThread

All Implemented Interfaces:

java.lang.Runnable, WorkerTask

Enclosing class:

DefaultTcpTransportMapping

class DefaultTcpTransportMapping.ServerThread
extends java.lang.Object
implements WorkerTask

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	buf
private java.lang.Throwable	lastError
private java.util.LinkedList<DefaultTcpTransportMapping.SocketEntry>	pending
private java.nio.channels.Selector	selector
private java.nio.channels.ServerSocketChannel	ssc
private boolean	stop

Constructor Summary

Constructors

Constructor and Description
ServerThread()

Method Summary

Modifier and Type	Method and Description
void	close()
private void	closeChannel(java.nio.channels.SelectableChannel channel)
private void	connectChannel(java.nio.channels.SelectionKey sk, TcpAddress incomingAddress)
private void	dispatchMessage(TcpAddress incomingAddress, java.nio.ByteBuffer byteBuffer, long bytesRead, java.lang.Object sessionID)
java.lang.Throwable	getLastError()
void	interrupt() Interrupts this task.
void	join() Waits until this task has been finished.
private void	processPending()
private void	readMessage(java.nio.channels.SelectionKey sk, java.nio.channels.SocketChannel readChannel, TcpAddress incomingAddress)
void	run()
void	sendMessage(Address address, byte[] message, TransportStateReference tmStateReference)
void	terminate() The WorkerPool might call this method to hint the active WorkTask instance to complete execution as soon as possible.
private TcpAddress	writeData(java.nio.channels.SelectionKey sk, TcpAddress incomingAddress)
private void	writeMessage(DefaultTcpTransportMapping.SocketEntry entry, java.nio.channels.SocketChannel sc)

Methods inherited from class java.lang.Object

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

Field Detail

buf

private byte[] buf

stop

private volatile boolean stop

lastError

private java.lang.Throwable lastError

ssc

private java.nio.channels.ServerSocketChannel ssc

selector

private java.nio.channels.Selector selector

pending

private java.util.LinkedList<DefaultTcpTransportMapping.SocketEntry> pending

Constructor Detail

ServerThread

public ServerThread()
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

processPending

private void processPending()

getLastError

public java.lang.Throwable getLastError()

sendMessage

public void sendMessage(Address address,
                        byte[] message,
                        TransportStateReference tmStateReference)
                 throws java.io.IOException

Throws:

java.io.IOException

run

public void run()

Specified by:

run in interface java.lang.Runnable

connectChannel

private void connectChannel(java.nio.channels.SelectionKey sk,
                            TcpAddress incomingAddress)

writeData

private TcpAddress writeData(java.nio.channels.SelectionKey sk,
                             TcpAddress incomingAddress)

closeChannel

private void closeChannel(java.nio.channels.SelectableChannel channel)

readMessage

private void readMessage(java.nio.channels.SelectionKey sk,
                         java.nio.channels.SocketChannel readChannel,
                         TcpAddress incomingAddress)
                  throws java.io.IOException

Throws:

java.io.IOException

dispatchMessage

private void dispatchMessage(TcpAddress incomingAddress,
                             java.nio.ByteBuffer byteBuffer,
                             long bytesRead,
                             java.lang.Object sessionID)

writeMessage

private void writeMessage(DefaultTcpTransportMapping.SocketEntry entry,
                          java.nio.channels.SocketChannel sc)
                   throws java.io.IOException

Throws:

java.io.IOException

close

public void close()

terminate

public void terminate()

Description copied from interface: WorkerTask

The WorkerPool might call this method to hint the active WorkTask instance to complete execution as soon as possible.

Specified by:

terminate in interface WorkerTask

join

public void join()

Description copied from interface: WorkerTask

Waits until this task has been finished.

Specified by:

join in interface WorkerTask

interrupt

public void interrupt()

Description copied from interface: WorkerTask

Interrupts this task.

Specified by:

interrupt in interface WorkerTask

See Also:

Thread.interrupt()