final class NioUdpClient extends NioClient
Modifier and Type | Class and Description |
---|---|
private static class |
NioUdpClient.Transaction |
NioClient.KeyProcessor
Modifier and Type | Field and Description |
---|---|
private static int |
EPHEMERAL_RANGE |
private static int |
EPHEMERAL_START |
private static java.util.Queue<NioUdpClient.Transaction> |
pendingTransactions |
private static java.security.SecureRandom |
prng |
private static java.util.Queue<NioUdpClient.Transaction> |
registrationQueue |
Constructor and Description |
---|
NioUdpClient() |
Modifier and Type | Method and Description |
---|---|
private static void |
checkTransactionTimeouts() |
private static void |
closeUdp() |
private static void |
processPendingRegistrations() |
(package private) static java.util.concurrent.CompletableFuture<byte[]> |
sendrecv(java.net.InetSocketAddress local,
java.net.InetSocketAddress remote,
Message query,
byte[] data,
int max,
java.time.Duration timeout) |
close, runSelector, selector, setCloseTask, setPacketLogger, setRegistrationsTask, setTimeoutTask, verboseLog
private static final int EPHEMERAL_START
private static final int EPHEMERAL_RANGE
private static final java.security.SecureRandom prng
private static final java.util.Queue<NioUdpClient.Transaction> registrationQueue
private static final java.util.Queue<NioUdpClient.Transaction> pendingTransactions
private static void processPendingRegistrations()
private static void checkTransactionTimeouts()
static java.util.concurrent.CompletableFuture<byte[]> sendrecv(java.net.InetSocketAddress local, java.net.InetSocketAddress remote, Message query, byte[] data, int max, java.time.Duration timeout)
private static void closeUdp()