io.aeron.driver

Class DriverConductor

java.lang.Object

io.aeron.driver.DriverConductor

All Implemented Interfaces:

org.agrona.concurrent.Agent

public class DriverConductor
extends java.lang.Object
implements org.agrona.concurrent.Agent

Driver Conductor that takes commands from publishers and subscribers and orchestrates the media driver.

Constructor Summary

Constructors

Constructor and Description
DriverConductor(MediaDriver.Context ctx)

Method Summary

Modifier and Type	Method and Description
int	doWork()
void	onChannelEndpointError(long statusIndicatorId, java.lang.Exception error)
void	onClose()
void	onCreatePublicationImage(int sessionId, int streamId, int initialTermId, int activeTermId, int initialTermOffset, int termBufferLength, int senderMtuLength, int transportIndex, java.net.InetSocketAddress controlAddress, java.net.InetSocketAddress sourceAddress, ReceiveChannelEndpoint channelEndpoint)
java.lang.String	roleName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.agrona.concurrent.Agent

onStart

Constructor Detail

DriverConductor

public DriverConductor(MediaDriver.Context ctx)

Method Detail

onClose

public void onClose()

Specified by:

onClose in interface org.agrona.concurrent.Agent

roleName

public java.lang.String roleName()

Specified by:

roleName in interface org.agrona.concurrent.Agent

doWork

public int doWork()

Specified by:

doWork in interface org.agrona.concurrent.Agent

onCreatePublicationImage

public void onCreatePublicationImage(int sessionId,
                                     int streamId,
                                     int initialTermId,
                                     int activeTermId,
                                     int initialTermOffset,
                                     int termBufferLength,
                                     int senderMtuLength,
                                     int transportIndex,
                                     java.net.InetSocketAddress controlAddress,
                                     java.net.InetSocketAddress sourceAddress,
                                     ReceiveChannelEndpoint channelEndpoint)

onChannelEndpointError

public void onChannelEndpointError(long statusIndicatorId,
                                   java.lang.Exception error)