- java.lang.Object
-
- org.snmp4j.transport.DTLSTM.HandshakeTask
-
- All Implemented Interfaces:
java.lang.Runnable
,WorkerTask
- Enclosing class:
- DTLSTM
class DTLSTM.HandshakeTask extends java.lang.Object implements WorkerTask
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
endLoops
private long
handshakeTimeout
private java.lang.Object
joinLock
private int
maxRetries
private java.net.SocketAddress
peerAddr
private java.net.DatagramPacket
receivedPacket
private int
retries
private java.net.DatagramSocket
socket
private DTLSTM.SocketEntry
socketEntry
-
Constructor Summary
Constructors Constructor Description HandshakeTask(DTLSTM.SocketEntry socketEntry, java.net.DatagramSocket socket, java.net.SocketAddress peerAddr, java.net.DatagramPacket receivedPacket, long handshakeTimeout, int maxRetries)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
interrupt()
Interrupts this task.void
join()
Waits until this task has been finished.void
run()
private void
stopLoops()
void
terminate()
TheWorkerPool
might call this method to hint the activeWorkTask
instance to complete execution as soon as possible.
-
-
-
Field Detail
-
endLoops
private boolean endLoops
-
joinLock
private final java.lang.Object joinLock
-
socketEntry
private final DTLSTM.SocketEntry socketEntry
-
socket
private final java.net.DatagramSocket socket
-
peerAddr
private final java.net.SocketAddress peerAddr
-
receivedPacket
private final java.net.DatagramPacket receivedPacket
-
handshakeTimeout
private final long handshakeTimeout
-
maxRetries
private final int maxRetries
-
retries
private int retries
-
-
Constructor Detail
-
HandshakeTask
public HandshakeTask(DTLSTM.SocketEntry socketEntry, java.net.DatagramSocket socket, java.net.SocketAddress peerAddr, java.net.DatagramPacket receivedPacket, long handshakeTimeout, int maxRetries)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
stopLoops
private void stopLoops()
-
terminate
public void terminate()
TheWorkerPool
might call this method to hint the activeWorkTask
instance to complete execution as soon as possible.- Specified by:
terminate
in interfaceWorkerTask
-
join
public void join() throws java.lang.InterruptedException
Waits until this task has been finished.- Specified by:
join
in interfaceWorkerTask
- Throws:
java.lang.InterruptedException
- if the join has been interrupted by another thread.
-
interrupt
public void interrupt()
Interrupts this task.- Specified by:
interrupt
in interfaceWorkerTask
- See Also:
Thread.interrupt()
-
-