org.hd.d.pg2k.test.dev
Class SystemVariablesTest.LocalTunnelServer

java.lang.Object
  org.hd.d.pg2k.test.dev.SystemVariablesTest.LocalTunnelServer

Enclosing class:

SystemVariablesTest

static class SystemVariablesTest.LocalTunnelServer
extends java.lang.Object

Class to encapsulate "local" tunnel "server". Attaches to top of data pipeline and allows raw RPC to interact with that pipeline.

source

private final SimpleExhibitPipelineIF source

Upstream data source; never null.

alwaysUseCache

private final boolean alwaysUseCache

If true then always enable the RPC cache, else switch it off and on at random.

_RPC_cache

private final ExhibitDataTunnelSource.HIRPCCache _RPC_cache

An RPC cache-handler instance.

SystemVariablesTest.LocalTunnelServer

SystemVariablesTest.LocalTunnelServer(SimpleExhibitPipelineIF source)

Construct this with the data pipeline.

Parameters:

source - data source; never null.

SystemVariablesTest.LocalTunnelServer

SystemVariablesTest.LocalTunnelServer(SimpleExhibitPipelineIF source,
                                      boolean alwaysUseCache)

Construct this with the data pipeline.

Parameters:

source - data source; never null.

alwaysUseCache - if true then always enable the RPC cache, else switch it off and on at random

doRPCRaw

ExhibitDataTunnelSource.RawPacket doRPCRaw(ExhibitDataTunnelSource.RawPacket request)
                                     throws java.io.IOException

Perform RPC calls on the wrapped data source.

Parameters:

request - request packet; never null

Returns:

response packet; never null

Throws:

java.io.IOException - in case of I/O difficulties