io.aeron.driver.media

Class DataTransportPoller

java.lang.Object

org.agrona.nio.TransportPoller

io.aeron.driver.media.UdpTransportPoller

io.aeron.driver.media.DataTransportPoller

All Implemented Interfaces:

java.lang.AutoCloseable

public class DataTransportPoller
extends UdpTransportPoller

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
DataTransportPoller()

Method Summary

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

Methods inherited from class org.agrona.nio.TransportPoller

selectNowWithoutProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

DataTransportPoller

public DataTransportPoller()

Method Detail

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class org.agrona.nio.TransportPoller

pollTransports

public int pollTransports()

Description copied from class: UdpTransportPoller

Explicit event loop processing as a poll

Specified by:

pollTransports in class UdpTransportPoller

Returns:

the number of frames processed.

registerForRead

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

Description copied from class: UdpTransportPoller

Register channel for read.

Specified by:

registerForRead in class UdpTransportPoller

Parameters:

transport - to associate with read

Returns:

SelectionKey for registration for cancel

registerForRead

public java.nio.channels.SelectionKey registerForRead(ReceiveChannelEndpoint channelEndpoint,
                                                      UdpChannelTransport transport,
                                                      int transportIndex)

cancelRead

public void cancelRead(UdpChannelTransport transport)

Description copied from class: UdpTransportPoller

Cancel previous registration.

Specified by:

cancelRead in class UdpTransportPoller

Parameters:

transport - to cancel read for

cancelRead

public void cancelRead(ReceiveChannelEndpoint channelEndpoint,
                       UdpChannelTransport transport)