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:

java.lang.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 java.lang.Throwable	lastError
private java.nio.channels.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, 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()
protected boolean	readMessage(java.nio.channels.SelectionKey sk, java.nio.channels.SocketChannel readChannel, TcpAddress incomingAddress)
protected void	readSnmpMessagePayload(java.nio.channels.SocketChannel readChannel, TcpAddress incomingAddress, DefaultTcpTransportMapping.SocketEntry entry, java.nio.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 Detail

buf

protected byte[] buf

stop

private volatile boolean stop

lastError

private java.lang.Throwable lastError

ssc

private java.nio.channels.ServerSocketChannel ssc

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

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(java.nio.channels.SelectionKey sk,
                              java.nio.channels.SocketChannel readChannel,
                              TcpAddress incomingAddress)
                       throws java.io.IOException

Throws:

java.io.IOException

readSnmpMessagePayload

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

Throws:

java.io.IOException

dispatchMessage

private void dispatchMessage(TcpAddress incomingAddress,
                             java.nio.ByteBuffer byteBuffer,
                             long bytesRead,
                             java.lang.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()