Class UnixSocketStreamTransportMapping.ServerThread

java.lang.Object

org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

org.snmp4j.transport.unix.UnixSocketStreamTransportMapping.ServerThread

All Implemented Interfaces:

Runnable, org.snmp4j.util.WorkerTask

Enclosing class:

UnixSocketStreamTransportMapping

protected class UnixSocketStreamTransportMapping.ServerThread
extends org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

Field Summary

Fields inherited from class org.snmp4j.transport.AbstractTransportServerThread

exitLatch, lastError, pending, selector, serverAddress, shutdown, ssc, stop, transportMapping

Method Summary

Modifier and Type	Method	Description
protected UnixDomainAddress	createIncomingAddress(SocketChannel socketChannel)
UnixSocketStreamTransportMapping.SocketEntry	createSocketEntry(UnixDomainAddress address, SocketChannel socketChannel, boolean useClientMode, org.snmp4j.TransportStateReference tmStateReference)
Throwable	getLastError()
protected ServerSocketChannel	getServerSocketChannel()
protected boolean	initListener(UnixDomainAddress address, Selector selector)
boolean	isStop()
boolean	join(long timeout)
protected SocketChannel	openSocketChannel(ProtocolFamily family)
protected void	processQueues()
protected boolean	readMessage(SelectionKey sk, SocketChannel socketChannel, UnixDomainAddress incomingAddress, UnixSocketStreamTransportMapping.SocketEntry socketEntry)
UnixSocketStreamTransportMapping.SocketEntry	removeSocketEntry(UnixDomainAddress incomingAddress)
void	run()
void	setStop(boolean stop)
void	shutdown()

Methods inherited from class org.snmp4j.transport.AbstractTransportServerThread

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

Methods inherited from class Object

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

Method Details

getLastError

public Throwable getLastError()

isStop

public boolean isStop()

setStop

public void setStop(boolean stop)

getServerSocketChannel

protected ServerSocketChannel getServerSocketChannel()

initListener

protected boolean initListener(UnixDomainAddress address,
 Selector selector)
                        throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

readMessage

protected boolean readMessage(SelectionKey sk,
 SocketChannel socketChannel,
 UnixDomainAddress incomingAddress,
 UnixSocketStreamTransportMapping.SocketEntry socketEntry)
                       throws IOException

Specified by:

readMessage in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

Throws:

IOException

processQueues

protected void processQueues()

Specified by:

processQueues in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

createSocketEntry

public UnixSocketStreamTransportMapping.SocketEntry createSocketEntry(UnixDomainAddress address,
 SocketChannel socketChannel,
 boolean useClientMode,
 org.snmp4j.TransportStateReference tmStateReference)

Specified by:

createSocketEntry in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

openSocketChannel

protected SocketChannel openSocketChannel(ProtocolFamily family)
                                   throws IOException

Specified by:

openSocketChannel in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

Throws:

IOException

removeSocketEntry

public UnixSocketStreamTransportMapping.SocketEntry removeSocketEntry(UnixDomainAddress incomingAddress)

Specified by:

removeSocketEntry in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

createIncomingAddress

protected UnixDomainAddress createIncomingAddress(SocketChannel socketChannel)
                                           throws IOException

Specified by:

createIncomingAddress in class org.snmp4j.transport.AbstractTransportServerThread<UnixDomainAddress, UnixSocketStreamTransportMapping.SocketEntry>

Throws:

IOException

shutdown

public void shutdown()

join

public boolean join(long timeout)
             throws InterruptedException

Throws:

InterruptedException