Package org.snmp4j.transport

Class DefaultTcpTransportMapping.ServerThread

java.lang.Object

org.snmp4j.transport.DefaultTcpTransportMapping.ServerThread

All Implemented Interfaces:

Runnable, WorkerTask

Enclosing class:

DefaultTcpTransportMapping

protected class DefaultTcpTransportMapping.ServerThread
extends Object
implements WorkerTask

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	buf
protected Selector	selector

Constructor Summary

Constructors

Constructor	Description
ServerThread()

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	connectSocketToSendMessage(Address address, byte[] message, SocketChannel socketChannel, org.snmp4j.transport.DefaultTcpTransportMapping.SocketEntry entry, Map<Address,org.snmp4j.transport.DefaultTcpTransportMapping.SocketEntry> sockets)
Throwable	getLastError()
void	interrupt()	Interrupts this task.
void	join()	Waits until this task has been finished.
protected boolean	readMessage(SelectionKey sk, SocketChannel readChannel, TcpAddress incomingAddress)
protected void	readSnmpMessagePayload(SocketChannel readChannel, TcpAddress incomingAddress, org.snmp4j.transport.DefaultTcpTransportMapping.SocketEntry entry, ByteBuffer byteBuffer)
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 java.lang.Object

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

Field Details

buf

protected byte[] buf

selector

protected Selector selector

Constructor Details

ServerThread

public ServerThread()
             throws IOException

Throws:

IOException

Method Details

connectSocketToSendMessage

protected void connectSocketToSendMessage(Address address,
 byte[] message,
 SocketChannel socketChannel,
 org.snmp4j.transport.DefaultTcpTransportMapping.SocketEntry entry,
 Map<Address,org.snmp4j.transport.DefaultTcpTransportMapping.SocketEntry> sockets)
                                   throws ClosedChannelException

Throws:

ClosedChannelException

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

readMessage

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

Throws:

IOException

readSnmpMessagePayload

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

Throws:

IOException

close

public void close()

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

join

public void join()

Description copied from interface: WorkerTask

Waits until this task has been finished.

Specified by:

join in interface WorkerTask

interrupt

public void interrupt()

Description copied from interface: WorkerTask

Interrupts this task.

Specified by:

interrupt in interface WorkerTask

See Also:

• Thread.interrupt()