Package com.illumon.iris.db.v2.locations.protocol

Class TableDataProtocol.RemoteClient

java.lang.Object

io.deephaven.enterprise.niowrapper.sched.NullIOHandler

io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer

io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer

com.illumon.iris.db.v2.locations.protocol.TableDataProtocol.RemoteClient

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, TableDataProtocol.Client, AbstractPeer, IOHandler

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.RemoteClient
extends AbstractReadaheadRemotePeer
implements TableDataProtocol.Client

Field Summary

Fields inherited from class io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer

clock, peerId

Constructor Summary

Constructors

Constructor	Description
RemoteClient(int peerId, String name, IOJob job, com.fishlib.io.logger.Logger log, PooledMessage.Pool pool, com.fishlib.base.clock.Clock clock)

Method Summary

Modifier and Type	Method	Description
com.fishlib.base.log.LogOutput	append(@NotNull com.fishlib.base.log.LogOutput logOutput)
protected void	dispatch(boolean bufferComplete)	Dispatch the most-recently parsed message.
void	endJob(@NotNull IOJob job)	Every peer has to react to the loss of a connection.
void	initialize(@NotNull TableDataProtocol.RequestHandler requestHandler)
protected void	parse(@NotNull WObjectReader reader)	Parse an incoming message, and remember its contents for the next call to dispatch.
void	sendColumnFileData(long requestKey, long startOffset, int length, @NotNull Message data)
void	sendColumnFileSize(long requestKey, long columnFileSize)
void	sendColumnLocationExistence(long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)
void	sendRequestCompletion(long requestKey)
void	sendRequestRejection(long requestKey, @NotNull TableDataProtocol.RequestRejectionType requestRejectionType, @NotNull CharSequence rejectText)
void	sendTableLocationAdded(long requestKey, @NotNull TableLocationKey locationKey)
void	sendTableLocationRemoved(long requestKey, @NotNull TableLocationKey locationKey)
void	sendTableLocationUpdate(long requestKey, @NotNull TableLocationState locationState)
String	toString()	for logging

Methods inherited from class io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer

getPeerId, handleIncoming

Methods inherited from class io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer

addMessage, flush, flush, getByteCount, getJob, getLog, getOutput, getReader, getWriter, isShutdown, maybeFlush, maybeFlush, shutdown

Methods inherited from class io.deephaven.enterprise.niowrapper.sched.NullIOHandler

handleEOF, handleError, handleOutgoing, handleTimeout, startJob

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.comm.impl.nio.AbstractPeer

flush, flush, getPeerId, isShutdown, maybeFlush, maybeFlush, shutdown

Constructor Details

RemoteClient

public RemoteClient(int peerId,
 String name,
 IOJob job,
 com.fishlib.io.logger.Logger log,
 PooledMessage.Pool pool,
 com.fishlib.base.clock.Clock clock)

Method Details

initialize

public void initialize(@NotNull
 @NotNull TableDataProtocol.RequestHandler requestHandler)

parse

protected void parse(@NotNull
 @NotNull WObjectReader reader)
              throws IOException

Description copied from class: AbstractReadaheadRemotePeer

Parse an incoming message, and remember its contents for the next call to dispatch. The caller has checked that the reader has an entire message immediately available to it according to the message envelope, so any IOExceptions should not be handled.

Specified by:

parse in class AbstractReadaheadRemotePeer

Throws:

IOException

dispatch

protected void dispatch(boolean bufferComplete)

Description copied from class: AbstractReadaheadRemotePeer

Dispatch the most-recently parsed message.

Specified by:

dispatch in class AbstractReadaheadRemotePeer

endJob

public void endJob(@NotNull
 @NotNull IOJob job)

Description copied from class: AbstractRemotePeer

Every peer has to react to the loss of a connection. TODO: We are losing the Message cached in our MessageSequenceSink on disconnect. We need to tell the MessageSequenceSink to clean up (close() and finish() are already used for other things - perhaps shutDown()?)

Specified by:

endJob in interface IOHandler

Specified by:

endJob in class AbstractRemotePeer

sendRequestRejection

public void sendRequestRejection(long requestKey,
 @NotNull
 @NotNull TableDataProtocol.RequestRejectionType requestRejectionType,
 @NotNull
 @NotNull CharSequence rejectText)
                          throws IOException

Specified by:

sendRequestRejection in interface TableDataProtocol.Client

Throws:

IOException

sendRequestCompletion

public void sendRequestCompletion(long requestKey)
                           throws IOException

Specified by:

sendRequestCompletion in interface TableDataProtocol.Client

Throws:

IOException

sendTableLocationAdded

public void sendTableLocationAdded(long requestKey,
 @NotNull
 @NotNull TableLocationKey locationKey)
                            throws IOException

Specified by:

sendTableLocationAdded in interface TableDataProtocol.Client

Throws:

IOException

sendTableLocationUpdate

public void sendTableLocationUpdate(long requestKey,
 @NotNull
 @NotNull TableLocationState locationState)
                             throws IOException

Specified by:

sendTableLocationUpdate in interface TableDataProtocol.Client

Throws:

IOException

sendColumnLocationExistence

public void sendColumnLocationExistence(long requestKey,
 boolean exists,
 boolean littleEndianByteOrder,
 boolean symbolTableExists)
                                 throws IOException

Specified by:

sendColumnLocationExistence in interface TableDataProtocol.Client

Throws:

IOException

sendColumnFileSize

public void sendColumnFileSize(long requestKey,
 long columnFileSize)
                        throws IOException

Specified by:

sendColumnFileSize in interface TableDataProtocol.Client

Throws:

IOException

sendColumnFileData

public void sendColumnFileData(long requestKey,
 long startOffset,
 int length,
 @NotNull
 @NotNull Message data)
                        throws IOException

Specified by:

sendColumnFileData in interface TableDataProtocol.Client

Throws:

IOException

sendTableLocationRemoved

public void sendTableLocationRemoved(long requestKey,
 @NotNull
 @NotNull TableLocationKey locationKey)
                              throws IOException

Specified by:

sendTableLocationRemoved in interface TableDataProtocol.Client

Throws:

IOException

toString

public String toString()

Description copied from class: AbstractRemotePeer

for logging

Overrides:

toString in class AbstractRemotePeer

append

public com.fishlib.base.log.LogOutput append(@NotNull
 @NotNull com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable

Overrides:

append in class AbstractRemotePeer