public final class DatagridWireHandler extends net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext> implements net.openhft.chronicle.network.ClientClosedProvider, net.openhft.chronicle.network.NetworkContextManager<DatagridWireNetworkContext>
Constructor and Description |
---|
DatagridWireHandler() |
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) |
checkWires, initialiseInWire, initialiseOutWire, isAcceptor, isAcceptor, nc, nc, onBytesWritten, onWrite, process, publish, publisher, publisher, wireType, wireType, writeData, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onReadComplete, onReadTime, onWriteTime, sendHeartBeat
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
protected void onInitialize()
onInitialize
in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>
public void onEndOfConnection(boolean heartbeatTimeOut)
onEndOfConnection
in interface net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext>
onEndOfConnection
in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>
protected void onRead(@NotNull @NotNull net.openhft.chronicle.wire.DocumentContext inDc, @NotNull @NotNull net.openhft.chronicle.wire.WireOut out)
onRead
in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>
public boolean hasClientClosed()
hasClientClosed
in interface net.openhft.chronicle.network.ClientClosedProvider
protected void performClose()
performClose
in class net.openhft.chronicle.network.WireTcpHandler<DatagridWireNetworkContext>
public long acquireCid(@NotNull @NotNull CharSequence csp)
csp
- the csp we wish to check for a cidpublic void storeObject(long cid, Object object)
public void removeCid(long cid)
public long createProxy(String type)
public long createProxy(String type, long token)
public CharSequence getCspForCid(long cid)
public void setCid(String csp, long cid)
Copyright © 2021. All rights reserved.