Class DefaultTcpTransportMapping.ServerThread

java.lang.Object

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

org.snmp4j.transport.DefaultTcpTransportMapping.ServerThread

All Implemented Interfaces:

Runnable, WorkerTask

Enclosing class:

DefaultTcpTransportMapping

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

Version:

3.0

Author:

Frank Fock

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	buf

Fields inherited from class AbstractTransportServerThread

exitLatch, 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)
protected DefaultTcpTransportMapping.SocketEntry	createSocketEntry(TcpAddress address, SocketChannel socketChannel, boolean useClientMode, TransportStateReference tmStateReference)
Throwable	getLastError()
void	join()	Waits until this task has been finished.
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, DefaultTcpTransportMapping.SocketEntry socketEntry)
protected void	readSnmpMessagePayload(SocketChannel readChannel, TcpAddress incomingAddress, DefaultTcpTransportMapping.SocketEntry entry, ByteBuffer byteBuffer)
DefaultTcpTransportMapping.SocketEntry	removeSocketEntry(TcpAddress incomingAddress)
void	run()
void	shutdown()	Gracefully shuts down this task.

Methods inherited from class AbstractTransportServerThread

close, closeChannel, connectChannel, connectSocketToSendMessage, doServer, fireIncrementCounterSessionClose, getSelector, interrupt, sendMessage, terminate, writeData, writeMessage

Methods inherited from class Object

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

Field Details

buf

protected byte[] buf

Constructor Details

ServerThread

public ServerThread()
             throws IOException

Throws:

IOException

Method Details

getLastError

public Throwable getLastError()

createSocketEntry

protected DefaultTcpTransportMapping.SocketEntry createSocketEntry(TcpAddress address,
 SocketChannel socketChannel,
 boolean useClientMode,
 TransportStateReference tmStateReference)

Specified by:

createSocketEntry in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

openSocketChannel

protected SocketChannel openSocketChannel(ProtocolFamily family)
                                   throws IOException

Specified by:

openSocketChannel in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

readMessage

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

Specified by:

readMessage in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

Throws:

IOException

processQueues

protected void processQueues()

Specified by:

processQueues in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

removeSocketEntry

public DefaultTcpTransportMapping.SocketEntry removeSocketEntry(TcpAddress incomingAddress)

Specified by:

removeSocketEntry in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

createIncomingAddress

protected TcpAddress createIncomingAddress(SocketChannel sc)
                                    throws IOException

Specified by:

createIncomingAddress in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

Throws:

IOException

readSnmpMessagePayload

protected void readSnmpMessagePayload(SocketChannel readChannel,
 TcpAddress incomingAddress,
 DefaultTcpTransportMapping.SocketEntry entry,
 ByteBuffer byteBuffer)
                               throws IOException

Throws:

IOException

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.

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 void join()
          throws InterruptedException

Description copied from interface: WorkerTask

Waits until this task has been finished.

Specified by:

join in interface WorkerTask

Overrides:

join in class AbstractTransportServerThread<TcpAddress, DefaultTcpTransportMapping.SocketEntry>

Throws:

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