- 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
-
Fields inherited from class org.snmp4j.transport.AbstractTcpServerThread
pending, selector, tcpTransportMapping
-
-
Constructor Summary
Constructors Constructor Description ServerThread()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
java.lang.Throwable
getLastError()
void
interrupt()
Interrupts this task.void
join()
Waits until this task has been finished.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()
TheWorkerPool
might call this method to hint the activeWorkTask
instance to complete execution as soon as possible.-
Methods inherited from class org.snmp4j.transport.AbstractTcpServerThread
closeChannel, connectChannel, connectSocketToSendMessage, writeData
-
-
-
-
Method Detail
-
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 interfacejava.lang.Runnable
- Specified by:
run
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
removeSocketEntry
public DefaultTcpTransportMapping.SocketEntry removeSocketEntry(TcpAddress incomingAddress)
- Specified by:
removeSocketEntry
in classAbstractTcpServerThread<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
-
close
public void close()
- Overrides:
close
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
terminate
public void terminate()
Description copied from interface:WorkerTask
TheWorkerPool
might call this method to hint the activeWorkTask
instance to complete execution as soon as possible.- Specified by:
terminate
in interfaceWorkerTask
- Overrides:
terminate
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
join
public void join()
Description copied from interface:WorkerTask
Waits until this task has been finished.- Specified by:
join
in interfaceWorkerTask
- Overrides:
join
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
interrupt
public void interrupt()
Description copied from interface:WorkerTask
Interrupts this task.- Specified by:
interrupt
in interfaceWorkerTask
- Overrides:
interrupt
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
- See Also:
Thread.interrupt()
-
-