software.chronicle.datagrid.cluster

Class DatagridWireNetworkContext

java.lang.Object

net.openhft.chronicle.core.io.AbstractCloseable

net.openhft.chronicle.network.VanillaNetworkContext<DatagridWireNetworkContext>

software.chronicle.datagrid.cluster.DatagridWireNetworkContext

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.CloseableTracer, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>, net.openhft.chronicle.network.NetworkContext<DatagridWireNetworkContext>

public final class DatagridWireNetworkContext
extends net.openhft.chronicle.network.VanillaNetworkContext<DatagridWireNetworkContext>
implements net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DatagridWireNetworkContext.ConnectionDetails
static class	DatagridWireNetworkContext.Factory

Field Summary

Fields inherited from class net.openhft.chronicle.core.io.AbstractCloseable

CHECK_THREAD_SAFETY, WARN_NS

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
DatagridWireNetworkContext(@NotNull Asset asset, String clusterName, net.openhft.chronicle.network.TcpEventHandler.SocketReader socketReader)

Method Summary

Modifier and Type	Method and Description
net.openhft.chronicle.network.ConnectionListener	acquireConnectionListener()
DatagridClusterContext	clusterContext()
net.openhft.chronicle.core.threads.EventLoop	eventLoop()
byte	getLocalHostIdentifier()
net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext>	handler()
void	onHandlerChanged(net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> handler)
@NotNull Asset	rootAsset()
net.openhft.chronicle.network.TcpEventHandler.SocketReader	socketReader()
@NotNull String	toString()

Methods inherited from class net.openhft.chronicle.network.VanillaNetworkContext

heartbeatListener, heartbeatListener, heartbeatTimeoutMs, heartbeatTimeoutMs, isAcceptor, isAcceptor, networkStatsListener, networkStatsListener, performClose, serverThreadingStrategy, serverThreadingStrategy, sessionDetails, sessionDetails, shouldPerformCloseInBackground, socketChannel, socketChannel, socketReconnector, socketReconnector, threadSafetyCheck, throwExceptionIfClosedInSetter, wireOutPublisher, wireOutPublisher, wireType, wireType

Methods inherited from class net.openhft.chronicle.core.io.AbstractCloseable

assertCloseablesClosed, clearUsedByThread, close, createdHere, disableCloseableTracing, enableCloseableTracing, isClosed, isClosing, isInUserThread, performCloseInBackground, referenceId, resetUsedByThread, shouldWaitForClosed, throwExceptionIfClosed, unmonitor, waitForClosed, warnAndCloseIfNotClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.openhft.chronicle.network.NetworkContext

addConnectionListener, heartbeatListener, heartbeatListener, heartbeatTimeoutMs, heartbeatTimeoutMs, isAcceptor, isAcceptor, isUnchecked, networkStatsListener, networkStatsListener, newCid, serverThreadingStrategy, serverThreadingStrategy, sessionDetails, sessionDetails, socketChannel, socketChannel, socketReconnector, socketReconnector, wireOutPublisher, wireOutPublisher, wireType, wireType

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

close, closeQuietly, closeQuietly, notifyClosing

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosed, isClosing, throwExceptionIfClosed

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

referenceName, temporary

Constructor Detail

DatagridWireNetworkContext

public DatagridWireNetworkContext(@NotNull
                                  @NotNull Asset asset,
                                  String clusterName,
                                  net.openhft.chronicle.network.TcpEventHandler.SocketReader socketReader)

Method Detail

handler

public net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> handler()

rootAsset

@NotNull
public @NotNull Asset rootAsset()

onHandlerChanged

public void onHandlerChanged(net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> handler)

Specified by:

onHandlerChanged in interface net.openhft.chronicle.network.NetworkContext<DatagridWireNetworkContext>

Overrides:

onHandlerChanged in class net.openhft.chronicle.network.VanillaNetworkContext<DatagridWireNetworkContext>

eventLoop

public net.openhft.chronicle.core.threads.EventLoop eventLoop()

Specified by:

eventLoop in interface net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>

getLocalHostIdentifier

public byte getLocalHostIdentifier()

Specified by:

getLocalHostIdentifier in interface net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>

clusterContext

public DatagridClusterContext clusterContext()

Specified by:

clusterContext in interface net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>

socketReader

public net.openhft.chronicle.network.TcpEventHandler.SocketReader socketReader()

acquireConnectionListener

public net.openhft.chronicle.network.ConnectionListener acquireConnectionListener()

Specified by:

acquireConnectionListener in interface net.openhft.chronicle.network.NetworkContext<DatagridWireNetworkContext>

toString

@NotNull
public @NotNull String toString()

Overrides:

toString in class net.openhft.chronicle.core.io.AbstractCloseable