io.aeron.driver.media

Class ControlTransportPoller

java.lang.Object

org.agrona.nio.TransportPoller

io.aeron.driver.media.UdpTransportPoller

io.aeron.driver.media.ControlTransportPoller

All Implemented Interfaces:

java.lang.AutoCloseable

public class ControlTransportPoller
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
ControlTransportPoller()

Method Summary

Modifier and Type	Method and Description
void	cancelRead(SendChannelEndpoint transport)
void	cancelRead(UdpChannelTransport transport) Cancel previous registration.
void	close()
int	pollTransports() Explicit event loop processing as a poll
java.nio.channels.SelectionKey	registerForRead(SendChannelEndpoint transport)
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

ControlTransportPoller

public ControlTransportPoller()

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(SendChannelEndpoint transport)

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(SendChannelEndpoint transport)