Class TLSTM.ServerThread

java.lang.Object

org.snmp4j.transport.AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

org.snmp4j.transport.TLSTM.ServerThread

All Implemented Interfaces:

Runnable, WorkerTask

Enclosing class:

TLSTM

protected class TLSTM.ServerThread
extends AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

Since:

2.0

Version:

3.5.0

Author:

Frank Fock

Field Summary

Fields inherited from class AbstractTransportServerThread

exitLatch, lastError, pending, selector, serverAddress, shutdown, ssc, stop, transportMapping

Constructor Summary

Constructors

Constructor	Description
ServerThread()

Method Summary

Modifier and Type	Method	Description
protected TcpAddress	createIncomingAddress(SocketChannel sc)
TLSTM.SocketEntry	createSocketEntry(TcpAddress address, SocketChannel socketChannel, boolean useClientMode, TransportStateReference tmStateReference)
protected void	fireIncrementCounterSessionClose()
Throwable	getLastError()
boolean	join(long timeout)	Waits until this task has been finished or the specified timeout has elapsed.
protected SocketChannel	openSocketChannel(ProtocolFamily family)
protected void	processQueues()
protected boolean	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(TcpAddress address, byte[] message, TransportStateReference tmStateReference)
void	shutdown()	Gracefully shuts down this task.
protected void	writeMessage(TLSTM.SocketEntry entry, SocketChannel sc)

Methods inherited from class AbstractTransportServerThread

close, closeChannel, connectChannel, connectSocketToSendMessage, doServer, getSelector, interrupt, join, sendMessage, terminate, writeData

Methods inherited from class Object

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

Constructor Details

ServerThread

public ServerThread()
             throws IOException,
NoSuchAlgorithmException

Throws:

IOException

NoSuchAlgorithmException

Method Details

processQueues

protected void processQueues()

Specified by:

processQueues in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

createIncomingAddress

protected TcpAddress createIncomingAddress(SocketChannel sc)

Specified by:

createIncomingAddress in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

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(TcpAddress address,
 byte[] message,
 TransportStateReference tmStateReference)
                 throws IOException

Throws:

IOException

createSocketEntry

public TLSTM.SocketEntry createSocketEntry(TcpAddress address,
 SocketChannel socketChannel,
 boolean useClientMode,
 TransportStateReference tmStateReference)

Specified by:

createSocketEntry in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

openSocketChannel

protected SocketChannel openSocketChannel(ProtocolFamily family)
                                   throws IOException

Specified by:

openSocketChannel in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

removeSocketEntry

public TLSTM.SocketEntry removeSocketEntry(TcpAddress incomingAddress)

Specified by:

removeSocketEntry in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

readMessage

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

Specified by:

readMessage in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

Throws:

IOException

fireIncrementCounterSessionClose

protected void fireIncrementCounterSessionClose()

Overrides:

fireIncrementCounterSessionClose in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

writeMessage

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

Overrides:

writeMessage in class AbstractTransportServerThread<TcpAddress, TLSTM.SocketEntry>

Throws:

IOException

shutdown

public void shutdown()

Description copied from interface: WorkerTask

Gracefully shuts down this task. All pending operations should be finished, but no new operations should be accepted.

join

public boolean join(long timeout)
             throws InterruptedException

Description copied from interface: WorkerTask

Waits until this task has been finished or the specified timeout has elapsed.

Parameters:

timeout - the maximum time to wait in milliseconds.

Returns:

true if the task has been finished, false otherwise.

Throws:

InterruptedException - if the join has been interrupted by another thread.