Module org.snmp4j.transport.unix

Package org.snmp4j.transport.unix

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

lastError, pending, selector, serverAddress, 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 boolean	initListener(UnixDomainAddress address, Selector selector)
boolean	isStop()
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)

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 java.lang.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)

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