Module org.snmp4j

Package org.snmp4j.transport

Class TLSTM.ServerThread

java.lang.Object

org.snmp4j.transport.AbstractTcpServerThread<TLSTM.SocketEntry>

org.snmp4j.transport.TLSTM.ServerThread

All Implemented Interfaces:

Runnable, WorkerTask

Enclosing class:

TLSTM

class TLSTM.ServerThread
extends AbstractTcpServerThread<TLSTM.SocketEntry>

Field Summary

Fields

Modifier and Type	Field	Description
private final BlockingQueue<TLSTM.SocketEntry>	inQueue
private Throwable	lastError
private final BlockingQueue<TLSTM.SocketEntry>	outQueue
private ServerSocketChannel	ssc

Fields inherited from class org.snmp4j.transport.AbstractTcpServerThread

pending, selector, stop, tcpTransportMapping

Constructor Summary

Constructors

Constructor	Description
ServerThread()

Method Summary

Modifier and Type	Method	Description
private void	closeChannelAndRemoveSocket(TLSTM.SocketEntry entry, IOException ioException)
private void	dispatchMessage(TcpAddress incomingAddress, ByteBuffer byteBuffer, long bytesRead, Object sessionID, TransportStateReference tmStateReference)
Throwable	getLastError()
private boolean	isConnectionClosed(TLSTM.SocketEntry entry, IOException ioException)
private void	processPending()
private void	processQueues()
private void	readMessage(SelectionKey sk, SocketChannel readChannel, TcpAddress incomingAddress, TLSTM.SocketEntry session)
TLSTM.SocketEntry	removeSocketEntry(TcpAddress incomingAddress)
void	run()
boolean	runDelegatedTasks(SSLEngineResult result, TLSTM.SocketEntry entry)	If the result indicates that we have outstanding tasks to do, go ahead and run them in this thread.
void	sendMessage(Address address, byte[] message, TransportStateReference tmStateReference)
protected TcpAddress	writeData(SelectionKey sk, TcpAddress incomingAddress)
private void	writeMessage(TLSTM.SocketEntry entry, SocketChannel sc)

Methods inherited from class org.snmp4j.transport.AbstractTcpServerThread

close, closeChannel, connectChannel, connectSocketToSendMessage, interrupt, join, terminate

Methods inherited from class java.lang.Object

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

Field Details

lastError

private Throwable lastError

ssc

private ServerSocketChannel ssc

outQueue

private final BlockingQueue<TLSTM.SocketEntry> outQueue

inQueue

private final BlockingQueue<TLSTM.SocketEntry> inQueue

Constructor Details

ServerThread

public ServerThread()
             throws IOException,
NoSuchAlgorithmException

Throws:

IOException

NoSuchAlgorithmException

Method Details

processQueues

private void processQueues()

isConnectionClosed

private boolean isConnectionClosed(TLSTM.SocketEntry entry,
 IOException ioException)

closeChannelAndRemoveSocket

private void closeChannelAndRemoveSocket(TLSTM.SocketEntry entry,
 IOException ioException)

processPending

private void processPending()

runDelegatedTasks

public boolean runDelegatedTasks(SSLEngineResult result,
 TLSTM.SocketEntry entry)
                          throws IOException

If the result indicates that we have outstanding tasks to do, go ahead and run them in this thread.

Parameters:

result - the SSLEngine wrap/unwrap result.

entry - the session to use.

Returns:

true if processing of delegated tasks has been finished, false otherwise.

Throws:

IOException

getLastError

public Throwable getLastError()

sendMessage

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

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class AbstractTcpServerThread<TLSTM.SocketEntry>

removeSocketEntry

public TLSTM.SocketEntry removeSocketEntry(TcpAddress incomingAddress)

Specified by:

removeSocketEntry in class AbstractTcpServerThread<TLSTM.SocketEntry>

writeData

protected TcpAddress writeData(SelectionKey sk,
 TcpAddress incomingAddress)

Overrides:

writeData in class AbstractTcpServerThread<TLSTM.SocketEntry>

readMessage

private void readMessage(SelectionKey sk,
 SocketChannel readChannel,
 TcpAddress incomingAddress,
 TLSTM.SocketEntry session)
                  throws IOException

Throws:

IOException

dispatchMessage

private void dispatchMessage(TcpAddress incomingAddress,
 ByteBuffer byteBuffer,
 long bytesRead,
 Object sessionID,
 TransportStateReference tmStateReference)

writeMessage

private void writeMessage(TLSTM.SocketEntry entry,
 SocketChannel sc)
                   throws IOException

Throws:

IOException