Module org.snmp4j

Package org.snmp4j.transport

Class DefaultTcpTransportMapping.ServerThread

java.lang.Object

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

org.snmp4j.transport.DefaultTcpTransportMapping.ServerThread

All Implemented Interfaces:

Runnable, WorkerTask

Enclosing class:

DefaultTcpTransportMapping

protected class DefaultTcpTransportMapping.ServerThread
extends AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	buf
private Throwable	lastError
private ServerSocketChannel	ssc
private boolean	stop

Fields inherited from class org.snmp4j.transport.AbstractTcpServerThread

pending, selector, tcpTransportMapping

Constructor Summary

Constructors

Constructor	Description
ServerThread()

Method Summary

Modifier and Type	Method	Description
void	close()
private void	dispatchMessage(TcpAddress incomingAddress, ByteBuffer byteBuffer, long bytesRead, Object sessionID)
Throwable	getLastError()
void	interrupt()	Interrupts this task.
void	join()	Waits until this task has been finished.
private void	processPending()
protected boolean	readMessage(SelectionKey sk, SocketChannel readChannel, TcpAddress incomingAddress)
protected void	readSnmpMessagePayload(SocketChannel readChannel, TcpAddress incomingAddress, DefaultTcpTransportMapping.SocketEntry entry, ByteBuffer byteBuffer)
DefaultTcpTransportMapping.SocketEntry	removeSocketEntry(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.

Methods inherited from class org.snmp4j.transport.AbstractTcpServerThread

closeChannel, connectChannel, connectSocketToSendMessage, writeData

Methods inherited from class java.lang.Object

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

Field Details

buf

protected byte[] buf

stop

private volatile boolean stop

lastError

private Throwable lastError

ssc

private ServerSocketChannel ssc

Constructor Details

ServerThread

public ServerThread()
             throws IOException

Throws:

IOException

Method Details

processPending

private void processPending()

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<DefaultTcpTransportMapping.SocketEntry>

removeSocketEntry

public DefaultTcpTransportMapping.SocketEntry removeSocketEntry(TcpAddress incomingAddress)

Specified by:

removeSocketEntry in class AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>

readMessage

protected boolean readMessage(SelectionKey sk,
 SocketChannel readChannel,
 TcpAddress incomingAddress)
                       throws IOException

Throws:

IOException

readSnmpMessagePayload

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

Throws:

IOException

dispatchMessage

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

close

public void close()

Overrides:

close in class AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>

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

Overrides:

terminate in class AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>

join

public void join()

Description copied from interface: WorkerTask

Waits until this task has been finished.

Specified by:

join in interface WorkerTask

Overrides:

join in class AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>

interrupt

public void interrupt()

Description copied from interface: WorkerTask

Interrupts this task.

Specified by:

interrupt in interface WorkerTask

Overrides:

interrupt in class AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>

See Also:

• Thread.interrupt()