Module org.snmp4j

Package org.snmp4j.transport

Class AbstractTcpServerThread<S extends AbstractSocketEntry>

java.lang.Object

org.snmp4j.transport.AbstractTcpServerThread<S>

All Implemented Interfaces:

java.lang.Runnable, WorkerTask

Direct Known Subclasses:

DefaultTcpTransportMapping.ServerThread, TLSTM.ServerThread

public abstract class AbstractTcpServerThread<S extends AbstractSocketEntry>
extends java.lang.Object
implements WorkerTask

Field Summary

Fields

Modifier and Type	Field	Description
private static LogAdapter	logger
protected java.util.LinkedList<S>	pending
protected java.nio.channels.Selector	selector
protected boolean	stop
protected TcpTransportMapping<?>	tcpTransportMapping

Constructor Summary

Constructors

Constructor	Description
AbstractTcpServerThread(TcpTransportMapping<?> tcpTransportMapping)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	closeChannel(java.nio.channels.SelectableChannel channel)
protected void	connectChannel(java.nio.channels.SelectionKey sk, TcpAddress incomingAddress)
protected void	connectSocketToSendMessage(Address address, byte[] message, java.net.Socket s, S entry, java.util.Map<Address,S> sockets)
void	interrupt()	Interrupts this task.
void	join()	Waits until this task has been finished.
private void	queueNewMessage(S entry)
abstract S	removeSocketEntry(TcpAddress incomingAddress)
abstract void	run()
void	terminate()	The WorkerPool might call this method to hint the active WorkTask instance to complete execution as soon as possible.
protected TcpAddress	writeData(java.nio.channels.SelectionKey sk, TcpAddress incomingAddress)
private void	writeMessage(S entry, java.nio.channels.SocketChannel sc)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final LogAdapter logger

tcpTransportMapping

protected TcpTransportMapping<?> tcpTransportMapping

stop

protected volatile boolean stop

selector

protected java.nio.channels.Selector selector

pending

protected final java.util.LinkedList<S extends AbstractSocketEntry> pending

Constructor Detail

AbstractTcpServerThread

public AbstractTcpServerThread(TcpTransportMapping<?> tcpTransportMapping)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

connectSocketToSendMessage

protected void connectSocketToSendMessage(Address address,
                                          byte[] message,
                                          java.net.Socket s,
                                          S entry,
                                          java.util.Map<Address,S> sockets)

queueNewMessage

private void queueNewMessage(S entry)

run

public abstract void run()

Specified by:

run in interface java.lang.Runnable

removeSocketEntry

public abstract S removeSocketEntry(TcpAddress incomingAddress)

connectChannel

protected void connectChannel(java.nio.channels.SelectionKey sk,
                              TcpAddress incomingAddress)

writeData

protected TcpAddress writeData(java.nio.channels.SelectionKey sk,
                               TcpAddress incomingAddress)

closeChannel

protected void closeChannel(java.nio.channels.SelectableChannel channel)

writeMessage

private void writeMessage(S entry,
                          java.nio.channels.SocketChannel sc)
                   throws java.io.IOException

Throws:

java.io.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()