Package org.xbill.DNS

Class NioUdpClient

java.lang.Object

org.xbill.DNS.NioClient

org.xbill.DNS.NioUdpClient

All Implemented Interfaces:

UdpIoClient

final class NioUdpClient
extends NioClient
implements UdpIoClient

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	NioUdpClient.Transaction

Nested classes/interfaces inherited from class org.xbill.DNS.NioClient

NioClient.KeyProcessor

Field Summary

Fields

Modifier and Type	Field	Description
private final int	ephemeralRange
private final int	ephemeralStart
private final Queue<NioUdpClient.Transaction>	pendingTransactions
private final SecureRandom	prng
private final Queue<NioUdpClient.Transaction>	registrationQueue

Fields inherited from class org.xbill.DNS.NioClient

REGISTER_SHUTDOWN_HOOK_PROPERTY, SELECTOR_TIMEOUT_PROPERTY

Constructor Summary

Constructors

Constructor	Description
NioUdpClient()

Method Summary

Modifier and Type	Method	Description
private void	checkTransactionTimeouts()
private void	closeUdp()
private void	processPendingRegistrations(Selector selector)
CompletableFuture<byte[]>	sendAndReceiveUdp(InetSocketAddress local, InetSocketAddress remote, Message query, byte[] data, int max, Duration timeout)	Sends a query to a remote server and returns the answer.
private static void	silentCloseChannel(DatagramChannel channel)

Methods inherited from class org.xbill.DNS.NioClient

close, runSelector, selector, setCloseTask, setPacketLogger, setRegistrationsTask, setTimeoutTask, verboseLog, verboseLog

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ephemeralStart

private final int ephemeralStart

ephemeralRange

private final int ephemeralRange

prng

private final SecureRandom prng

registrationQueue

private final Queue<NioUdpClient.Transaction> registrationQueue

pendingTransactions

private final Queue<NioUdpClient.Transaction> pendingTransactions

Constructor Details

NioUdpClient

NioUdpClient()

Method Details

processPendingRegistrations

private void processPendingRegistrations(Selector selector)

checkTransactionTimeouts

private void checkTransactionTimeouts()

sendAndReceiveUdp

public CompletableFuture<byte[]> sendAndReceiveUdp(InetSocketAddress local,
 InetSocketAddress remote,
 Message query,
 byte[] data,
 int max,
 Duration timeout)

Description copied from interface: UdpIoClient

Sends a query to a remote server and returns the answer.

Specified by:

sendAndReceiveUdp in interface UdpIoClient

Parameters:

local - Address from which the connection is coming. may be null and the implementation must decide on the local address.

remote - Address that the connection should send the data to.

query - DNS message representation of the outbound query.

data - Raw byte representation of the outbound query.

max - Size of the response buffer.

timeout - Duration before the connection will time out and be closed.

Returns:

A CompletableFuture that will be completed with the byte value of the response.

silentCloseChannel

private static void silentCloseChannel(DatagramChannel channel)

closeUdp

private void closeUdp()