java.lang.Object
org.snmp4j.transport.AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
org.snmp4j.transport.DefaultTcpTransportMapping.ServerThread
- All Implemented Interfaces:
Runnable
,WorkerTask
- Enclosing class:
- DefaultTcpTransportMapping
protected class DefaultTcpTransportMapping.ServerThread
extends AbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
Field Summary
FieldsFields inherited from class org.snmp4j.transport.AbstractTcpServerThread
pending, selector, tcpTransportMapping
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
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, DefaultTcpTransportMapping.SocketEntry entry, ByteBuffer byteBuffer)
removeSocketEntry(TcpAddress incomingAddress)
void
run()
void
sendMessage(Address address, byte[] message, TransportStateReference tmStateReference)
void
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
-
Field Details
-
buf
protected byte[] buf
-
-
Constructor Details
-
ServerThread
- Throws:
IOException
-
-
Method Details
-
getLastError
-
sendMessage
public void sendMessage(Address address, byte[] message, TransportStateReference tmStateReference) throws IOException- Throws:
IOException
-
run
public void run()- Specified by:
run
in interfaceRunnable
- Specified by:
run
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
removeSocketEntry
- Specified by:
removeSocketEntry
in classAbstractTcpServerThread<DefaultTcpTransportMapping.SocketEntry>
-
readMessage
protected boolean readMessage(SelectionKey sk, SocketChannel readChannel, TcpAddress incomingAddress) throws IOException- Throws:
IOException
-
readSnmpMessagePayload
protected void readSnmpMessagePayload(SocketChannel readChannel, TcpAddress incomingAddress, DefaultTcpTransportMapping.SocketEntry entry, ByteBuffer byteBuffer) throws IOException- Throws:
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()
-