io.aeron.driver

Class DataPacketDispatcher

java.lang.Object

io.aeron.driver.DataPacketDispatcher

public class DataPacketDispatcher
extends java.lang.Object

Handling of dispatching data packets to PublicationImages streams.

All methods should be called from the Receiver thread.

Constructor Summary

Constructors

Constructor and Description
DataPacketDispatcher(DriverConductorProxy conductorProxy, Receiver receiver)

Method Summary

Modifier and Type	Method and Description
void	addPublicationImage(PublicationImage image)
void	addSubscription(int streamId)
void	addSubscription(int streamId, int sessionId)
int	onDataPacket(ReceiveChannelEndpoint channelEndpoint, DataHeaderFlyweight header, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress, int transportIndex)
void	onRttMeasurement(ReceiveChannelEndpoint channelEndpoint, RttMeasurementFlyweight header, java.net.InetSocketAddress srcAddress, int transportIndex)
void	onSetupMessage(ReceiveChannelEndpoint channelEndpoint, SetupFlyweight header, java.net.InetSocketAddress srcAddress, int transportIndex)
void	removeCoolDown(int sessionId, int streamId)
void	removePendingSetup(int sessionId, int streamId)
void	removePublicationImage(PublicationImage image)
void	removeSubscription(int streamId)
void	removeSubscription(int streamId, int sessionId)
boolean	shouldElicitSetupMessage()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataPacketDispatcher

public DataPacketDispatcher(DriverConductorProxy conductorProxy,
                            Receiver receiver)

Method Detail

addSubscription

public void addSubscription(int streamId)

addSubscription

public void addSubscription(int streamId,
                            int sessionId)

removeSubscription

public void removeSubscription(int streamId)

removeSubscription

public void removeSubscription(int streamId,
                               int sessionId)

addPublicationImage

public void addPublicationImage(PublicationImage image)

removePublicationImage

public void removePublicationImage(PublicationImage image)

removePendingSetup

public void removePendingSetup(int sessionId,
                               int streamId)

removeCoolDown

public void removeCoolDown(int sessionId,
                           int streamId)

onDataPacket

public int onDataPacket(ReceiveChannelEndpoint channelEndpoint,
                        DataHeaderFlyweight header,
                        org.agrona.concurrent.UnsafeBuffer buffer,
                        int length,
                        java.net.InetSocketAddress srcAddress,
                        int transportIndex)

onSetupMessage

public void onSetupMessage(ReceiveChannelEndpoint channelEndpoint,
                           SetupFlyweight header,
                           java.net.InetSocketAddress srcAddress,
                           int transportIndex)

onRttMeasurement

public void onRttMeasurement(ReceiveChannelEndpoint channelEndpoint,
                             RttMeasurementFlyweight header,
                             java.net.InetSocketAddress srcAddress,
                             int transportIndex)

shouldElicitSetupMessage

public boolean shouldElicitSetupMessage()