Package com.illumon.iris.db.tables.remote

Class RemoteTableHandleManager

java.lang.Object

com.illumon.iris.db.tables.remote.RemoteTableHandleManager

All Implemented Interfaces:

com.fishlib.net.api.CommandHandler

public class RemoteTableHandleManager
extends Object
implements com.fishlib.net.api.CommandHandler

Exposes proxies to remote tables exported by an ExportedTableHandleManager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RemoteTableHandleManager.CloseableViewportColumn

Constructor Summary

Constructors

Constructor	Description
RemoteTableHandleManager(QueryProcessorConnection processorConnection, com.fishlib.io.logger.Logger log)

Method Summary

Modifier and Type	Method	Description
void	addCloseColumn(RemoteTableHandleManager.CloseableViewportColumn column)
QueryProcessorConnection	getProcessorConnection()
void	handleClientDeath(com.fishlib.net.api.ClientEntry client)
void	handleCommand(com.fishlib.net.api.ClientEntry client, com.fishlib.base.Command comm)
Object	invokeRemotely(int id, Method method, Object[] args)
Object	invokeRemotelyAsync(int id, Method method, Object[] args)
void	onDisconnect()
void	onDisconnecting()
void	processPreemptiveDeltaUpdate(int handleId, DeltaUpdates deltaUpdates)
void	processPreemptiveSnapshot(int handleId, PreemptiveUpdatesTable.SnapshotType snapshotType, InitialSnapshot snapshot)
void	releaseTableHandle(RemoteTableHandle handle)
void	removeCloseColumn(RemoteTableHandleManager.CloseableViewportColumn columnToRemove)
Table	resolveTableProxy(ExportedTableDescriptorMessage descriptorMessage)
void	wakeCloserThread()

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteTableHandleManager

public RemoteTableHandleManager(QueryProcessorConnection processorConnection, com.fishlib.io.logger.Logger log)

Method Details

getProcessorConnection

public QueryProcessorConnection getProcessorConnection()

resolveTableProxy

public Table resolveTableProxy(ExportedTableDescriptorMessage descriptorMessage)

releaseTableHandle

public void releaseTableHandle(RemoteTableHandle handle)

handleCommand

public void handleCommand(com.fishlib.net.api.ClientEntry client, com.fishlib.base.Command comm)

Specified by:

handleCommand in interface com.fishlib.net.api.CommandHandler

handleClientDeath

public void handleClientDeath(com.fishlib.net.api.ClientEntry client)

Specified by:

handleClientDeath in interface com.fishlib.net.api.CommandHandler

invokeRemotely

public Object invokeRemotely(int id, Method method, Object[] args)

invokeRemotelyAsync

public Object invokeRemotelyAsync(int id, Method method, Object[] args)

processPreemptiveSnapshot

public void processPreemptiveSnapshot(int handleId, PreemptiveUpdatesTable.SnapshotType snapshotType, InitialSnapshot snapshot)

processPreemptiveDeltaUpdate

public void processPreemptiveDeltaUpdate(int handleId, DeltaUpdates deltaUpdates)

addCloseColumn

public void addCloseColumn(RemoteTableHandleManager.CloseableViewportColumn column)

removeCloseColumn

public void removeCloseColumn(RemoteTableHandleManager.CloseableViewportColumn columnToRemove)

wakeCloserThread

public void wakeCloserThread()

onDisconnecting

public void onDisconnecting()

onDisconnect

public void onDisconnect()