io.aeron.driver.media

Class UdpTransportPoller

java.lang.Object

org.agrona.nio.TransportPoller

io.aeron.driver.media.UdpTransportPoller

All Implemented Interfaces:

java.lang.AutoCloseable

Direct Known Subclasses:

ControlTransportPoller, DataTransportPoller

public abstract class UdpTransportPoller
extends org.agrona.nio.TransportPoller

Encapsulates the polling of a number of UdpChannelTransports using whatever means provides the lowest latency.

Field Summary

Fields inherited from class org.agrona.nio.TransportPoller

ITERATION_THRESHOLD, PUBLIC_SELECTED_KEYS_FIELD, SELECTED_KEYS_FIELD, selectedKeySet, selector

Constructor Summary

Constructors

Constructor and Description
UdpTransportPoller()

Method Summary

Modifier and Type	Method and Description
abstract void	cancelRead(UdpChannelTransport transport) Cancel previous registration.
abstract int	pollTransports() Explicit event loop processing as a poll
abstract java.nio.channels.SelectionKey	registerForRead(UdpChannelTransport transport) Register channel for read.

Methods inherited from class org.agrona.nio.TransportPoller

close, selectNowWithoutProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

UdpTransportPoller

public UdpTransportPoller()

Method Detail

pollTransports

public abstract int pollTransports()

Explicit event loop processing as a poll

Returns:

the number of frames processed.

registerForRead

public abstract java.nio.channels.SelectionKey registerForRead(UdpChannelTransport transport)

Register channel for read.

Parameters:

transport - to associate with read

Returns:

SelectionKey for registration for cancel

cancelRead

public abstract void cancelRead(UdpChannelTransport transport)

Cancel previous registration.

Parameters:

transport - to cancel read for