public class UDPLocator
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected static org.slf4j.Logger |
logger |
protected int |
nextIndex |
protected java.lang.String |
nodeID
Current NodeID
|
protected int |
numberOfSubmittedPackets |
protected java.util.ArrayList<UDPReceiver> |
receivers |
protected java.util.concurrent.ScheduledExecutorService |
scheduler
Sender's executor
|
protected java.util.concurrent.ScheduledFuture<?> |
timer
Cancelable timer of sender
|
protected TcpTransporter |
transporter
Parent transporter
|
| Constructor and Description |
|---|
UDPLocator(java.lang.String nodeID,
TcpTransporter transporter,
java.util.concurrent.ScheduledExecutorService scheduler) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
void |
disconnect() |
protected void |
finalize() |
protected void |
send() |
protected void |
startReceivers(java.net.NetworkInterface ni,
java.lang.String udpMulticast,
boolean udpBroadcast) |
protected static final org.slf4j.Logger logger
protected final java.lang.String nodeID
protected final java.util.concurrent.ScheduledExecutorService scheduler
protected final TcpTransporter transporter
protected volatile int nextIndex
protected volatile int numberOfSubmittedPackets
protected final java.util.ArrayList<UDPReceiver> receivers
protected volatile java.util.concurrent.ScheduledFuture<?> timer
public UDPLocator(java.lang.String nodeID,
TcpTransporter transporter,
java.util.concurrent.ScheduledExecutorService scheduler)
public void connect()
throws java.lang.Exception
java.lang.Exceptionprotected void startReceivers(java.net.NetworkInterface ni,
java.lang.String udpMulticast,
boolean udpBroadcast)
throws java.lang.Exception
java.lang.Exceptionprotected void finalize()
throws java.lang.Throwable
finalize in class java.lang.Objectjava.lang.Throwablepublic void disconnect()
protected void send()