software.chronicle.datagrid.internal.server

Class DatagridWireHandler

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

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

software.chronicle.datagrid.internal.server.DatagridWireHandler

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext>, net.openhft.chronicle.network.ClientClosedProvider, net.openhft.chronicle.network.NetworkContextManager<DatagridWireNetworkContext>

public final class DatagridWireHandler
extends net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>
implements net.openhft.chronicle.network.ClientClosedProvider, net.openhft.chronicle.network.NetworkContextManager<DatagridWireNetworkContext>

Field Summary

Fields inherited from class net.openhft.chronicle.network.WireTcpHandler

outWire, wireType

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

INIT

Constructor Summary

Constructors

Constructor and Description
DatagridWireHandler()

Method Summary

Modifier and Type	Method and Description
long	acquireCid(@NotNull CharSequence csp) create a new cid if one does not already exist for this csp
long	createProxy(String type)
long	createProxy(String type, long token)
CharSequence	getCspForCid(long cid)
boolean	hasClientClosed()
void	onEndOfConnection(boolean heartbeatTimeOut)
protected void	onInitialize()
protected void	onRead(@NotNull net.openhft.chronicle.wire.DocumentContext inDc, @NotNull net.openhft.chronicle.wire.WireOut out)
protected void	performClose()
void	removeCid(long cid)
void	setCid(String csp, long cid)
void	storeObject(long cid, Object object)

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

checkWires, initialiseInWire, initialiseOutWire, isAcceptor, isAcceptor, nc, nc, onBytesWritten, onWrite, process, publish, publisher, publisher, wireType, wireType, writeData, writeData

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

close, isClosed

Methods inherited from class java.lang.Object

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

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

nc, nc

Methods inherited from interface net.openhft.chronicle.network.api.TcpHandler

onReadComplete, onReadTime, onWriteTime, sendHeartBeat

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

referenceId, referenceName, temporary

Constructor Detail

DatagridWireHandler

public DatagridWireHandler()

Method Detail

onInitialize

protected void onInitialize()

Specified by:

onInitialize in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>

onEndOfConnection

public void onEndOfConnection(boolean heartbeatTimeOut)

Specified by:

onEndOfConnection in interface net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext>

Overrides:

onEndOfConnection in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>

onRead

protected void onRead(@NotNull
                      @NotNull net.openhft.chronicle.wire.DocumentContext inDc,
                      @NotNull
                      @NotNull net.openhft.chronicle.wire.WireOut out)

Specified by:

onRead in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>

hasClientClosed

public boolean hasClientClosed()

Specified by:

hasClientClosed in interface net.openhft.chronicle.network.ClientClosedProvider

performClose

protected void performClose()

Overrides:

performClose in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>

acquireCid

public long acquireCid(@NotNull
                       @NotNull CharSequence csp)

create a new cid if one does not already exist for this csp

Parameters:

csp - the csp we wish to check for a cid

Returns:

the cid for this csp

storeObject

public void storeObject(long cid,
                        Object object)

removeCid

public void removeCid(long cid)

createProxy

public long createProxy(String type)

createProxy

public long createProxy(String type,
                        long token)

getCspForCid

public CharSequence getCspForCid(long cid)

setCid

public void setCid(String csp,
                   long cid)