A B C D E F G H I L N O P R S T U V W _

A

abort() - Method in class com.healthmarketscience.rmiio.RemoteIteratorServer

Aborts the current transfer without closing this RemoteIteratorServer.

abort() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Aborts the current transfer without closing this RemoteStreamServer.

AbstractCloseableIOIterator<DataType> - Class in com.healthmarketscience.rmiio

Convenience base class for CloseableIOIterator implementations, especially suited for use as the local iterator for a RemoteIteratorServer instance.

AbstractCloseableIOIterator() - Constructor for class com.healthmarketscience.rmiio.AbstractCloseableIOIterator

adapt(Iterator<? extends T>) - Static method in class com.healthmarketscience.rmiio.RmiioUtil

Adapts an Iterator to the CloseableIOIterator interface.

addAll(IOIterator<DataType>) - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Sink

Convenience method for adding all the data from the given IOIterator to the Sink.

addNext(DataType) - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Sink

Adds the next object to the pipe.

ANY_PORT - Static variable in class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

constant indicating that export can use any port

available() - Method in class com.healthmarketscience.rmiio.DirectRemoteInputStream

available() - Method in class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

available() - Method in interface com.healthmarketscience.rmiio.RemoteInputStream

Returns the number of bytes that can be read from this stream without blocking.

available() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

available() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

available(RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

available() - Method in class com.healthmarketscience.rmiio.SerializableInputStream

available() - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

available() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

availableImpl() - Method in class com.healthmarketscience.rmiio.GZIPRemoteInputStream

availableImpl() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

Returns the number of bytes that can be read from this stream without blocking.

availableImpl() - Method in class com.healthmarketscience.rmiio.SimpleRemoteInputStream

B

backOff(int, Log) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Should delay for some implementation defined amount of time (to give the callee, network, etc.

backOff(int, Log) - Method in class com.healthmarketscience.rmiio.RemoteRetry.Never

backOff(int, Log) - Method in class com.healthmarketscience.rmiio.RemoteRetry.Simple

backOff(int, Log) - Method in class com.healthmarketscience.rmiio.RemoteRetry.SimpleAlways

bytesMoved(RemoteInputStreamServer, int, boolean) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

bytesMoved(RemoteOutputStreamServer, int, boolean) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

bytesMoved(StreamServerType, int, boolean) - Method in interface com.healthmarketscience.rmiio.RemoteStreamMonitor

Called when some bytes are transferred over the wire by the given stream.

bytesSkipped(RemoteInputStreamServer, long, boolean) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

bytesSkipped(RemoteOutputStreamServer, long, boolean) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

bytesSkipped(StreamServerType, long, boolean) - Method in interface com.healthmarketscience.rmiio.RemoteStreamMonitor

Called when some bytes are skipped for transfer over the wire by the given stream.

C

call(RemoteRetry.Caller<RetType>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which only throws RuntimeException.

call(RemoteRetry.Caller<RetType>, Log) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which only throws RuntimeException.

call(RemoteRetry.Caller<RetType>, Class<ExType1>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which throws RuntimeException and one user defined Exception.

call(RemoteRetry.Caller<RetType>, Log, Class<ExType1>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which throws RuntimeException and one user defined Exception.

call(RemoteRetry.Caller<RetType>, Class<ExType1>, Class<ExType2>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which throws RuntimeException and two user defined Exceptions.

call(RemoteRetry.Caller<RetType>, Log, Class<ExType1>, Class<ExType2>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which throws RuntimeException and two user defined Exceptions.

call(RemoteRetry.Caller<RetType>, Class<ExType1>, Class<ExType2>, Class<ExType3>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which throws RuntimeException and three user defined Exceptions.

call(RemoteRetry.Caller<RetType>, Log, Class<ExType1>, Class<ExType2>, Class<ExType3>) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Wrapper for RemoteRetry.callImpl(com.healthmarketscience.rmiio.RemoteRetry.Caller, org.apache.commons.logging.Log) which throws RuntimeException and three user defined Exceptions.

call() - Method in class com.healthmarketscience.rmiio.RemoteRetry.Caller

Makes a remote method call which returns a value.

call() - Method in class com.healthmarketscience.rmiio.RemoteRetry.VoidCaller

callImpl(RemoteRetry.Caller<RetType>, Log) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Implementation of the actual retry logic.

checkAborted() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Throws an IOException if the stream has been aborted.

clear() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Clears all remaining bytes from this buffer and releases all internal buffers.

close() - Method in class com.healthmarketscience.rmiio.AbstractCloseableIOIterator

close() - Method in class com.healthmarketscience.rmiio.CloseableIOIterator.Adapter

Deprecated.

close(boolean) - Method in class com.healthmarketscience.rmiio.DirectRemoteInputStream

close() - Method in class com.healthmarketscience.rmiio.DirectRemoteInputStream

close(boolean) - Method in class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

close(boolean) - Method in class com.healthmarketscience.rmiio.exporter.RemoteOutputStreamClientProxy

close() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Sink

Must be called regardless whether or not all data was added.

close(boolean) - Method in interface com.healthmarketscience.rmiio.RemoteInputStream

Closes the input stream and releases the resources for this server object.

close(boolean) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

close(boolean) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

close(boolean, RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

close() - Method in interface com.healthmarketscience.rmiio.RemoteIterator

Closes the iterator and releases the resources for the server object.

close() - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

close() - Method in class com.healthmarketscience.rmiio.RemoteIteratorServer

Forces this iterator server to close (if not already closed), will break any outstanding client interactions.

close(boolean) - Method in interface com.healthmarketscience.rmiio.RemoteOutputStream

Closes the output stream and releases the resources for this server object.

close(boolean) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

close(boolean) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

close(boolean, RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

close() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Forces this stream server to close (if not already closed), will break any outstanding client interactions.

close() - Method in class com.healthmarketscience.rmiio.SerializableInputStream

close() - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

close() - Method in class com.healthmarketscience.rmiio.SimpleRemoteIterator

close() - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

close() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

close() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

CloseableIOIterator<DataType> - Interface in com.healthmarketscience.rmiio

Convenience interface which combines IOIterator and Closeable.

CloseableIOIterator.Adapter<DataType> - Class in com.healthmarketscience.rmiio

Deprecated. use RmiioUtil.adapt(java.util.Iterator) instead

CloseableIOIterator.Adapter(Iterator<? extends DataType>) - Constructor for class com.healthmarketscience.rmiio.CloseableIOIterator.Adapter

Deprecated.

closed(RemoteInputStreamServer, boolean) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

closed(RemoteOutputStreamServer, boolean) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

closed(StreamServerType, boolean) - Method in interface com.healthmarketscience.rmiio.RemoteStreamMonitor

Called when the given stream is closed.

closeImpl() - Method in class com.healthmarketscience.rmiio.AbstractCloseableIOIterator

Does the actual closing of the local resources.

closeImpl() - Method in class com.healthmarketscience.rmiio.ConverterIOIterator

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.GZIPRemoteInputStream

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.GZIPRemoteOutputStream

closeImpl() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Source

closeImpl() - Method in class com.healthmarketscience.rmiio.LineIterator

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.RemoteIteratorServer

Cleans up any local resources after the underlying stream server is closed.

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Closes (possibly flushes) the underlying streams and cleans up any resources.

closeImpl(boolean) - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

closeIterator() - Method in class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

Closes any resources held by this iterator.

closeIterator() - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

Closes any resources held by this iterator.

closeIterator() - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorClient

closeIterator() - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

closeRead() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Indicates that the "reader" of this PipeBuffer is finished.

closeWrite() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Indicates that the "writer" of this PipeBuffer is finished.

com.healthmarketscience.rmiio - package com.healthmarketscience.rmiio

Provides classes for robust usage of RMI, primarily for streaming data.

com.healthmarketscience.rmiio.exporter - package com.healthmarketscience.rmiio.exporter

Provides classes for integrating the remote stream implementations into any RPC framework, not just RMI.

com.healthmarketscience.rmiio.util - package com.healthmarketscience.rmiio.util

Provides utility classes for working with RMI and streaming.

connect(PipeBuffer.OutputStreamAdapter) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

Shares the PipeBuffer between this InputStreamAdapter and the given OutputStreamAdapter.

connect(PipeBuffer.InputStreamAdapter) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

Calls PipeBuffer.InputStreamAdapter.connect(com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter) on the given InputStreamAdapter with this OutputStreamAdapter as the parameter.

convert(InType) - Method in class com.healthmarketscience.rmiio.ConverterIOIterator

Converts from the input type to the output type.

ConverterIOIterator<InType,OutType> - Class in com.healthmarketscience.rmiio

Useful almost concrete CloseableIOIterator implementation for the common situation where you need to convert data from one iterator into data in another iterator.

ConverterIOIterator(CloseableIOIterator<? extends InType>) - Constructor for class com.healthmarketscience.rmiio.ConverterIOIterator

create(InputStream, int) - Static method in class com.healthmarketscience.rmiio.util.InputStreamAdapter

create(OutputStream) - Static method in class com.healthmarketscience.rmiio.util.OutputStreamAdapter

createOutputStream() - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

Creates an OutputStream linked to this InputStream which can be used to write data as requested.

createPipeBuffer() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

Returns the PipeBuffer of this InputStreamAdapter, creating if necessary.

D

DEFAULT_CHUNK_SIZE - Static variable in class com.healthmarketscience.rmiio.RemoteInputStreamServer

default chunk size for shuffling data over the wire.

DEFAULT_CHUNK_SIZE - Static variable in class com.healthmarketscience.rmiio.RemoteOutputStreamClient

default chunk size for shuffling data over the wire.

DEFAULT_CHUNK_SIZE - Static variable in class com.healthmarketscience.rmiio.util.EncodingInputStream

initial size of the overflow buffer used when moving data from the internal _localOStream to the _localIStream.

DEFAULT_EXPORTER_CLASS_NAME - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

name of the default exporter implementation returned by RemoteStreamExporter.getInstance() if none is specified via system property

DEFAULT_NUM_MAX_RETRIES - Static variable in class com.healthmarketscience.rmiio.RemoteRetry.Simple

default number of times to retry

DEFAULT_PACKET_SIZE - Static variable in class com.healthmarketscience.rmiio.PacketInputStream

target size of packets returned from packet related methods

DEFAULT_PACKET_SIZE - Static variable in class com.healthmarketscience.rmiio.util.PipeBuffer

default target size of packets returned from packet related methods and internal buffer allocation

DEFAULT_QUEUE_SIZE - Static variable in class com.healthmarketscience.rmiio.IOIteratorPipe

DEFAULT_RESET_NUM_OBJECTS - Static variable in class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

Default value for the setting indicating how often the ObjectOutputStream should be reset

DEFAULT_RETRY - Static variable in interface com.healthmarketscience.rmiio.RemoteClient

The default retry policy used if none is specified by the client.

DEFAULT_RETRY - Static variable in class com.healthmarketscience.rmiio.RemoteOutputStreamClient

The default retry policy used by this class's wrappers if none is specified by the caller.

DefaultRemoteStreamExporter - Class in com.healthmarketscience.rmiio.exporter

Default concrete implementation of RemoteStreamExporter which exports the object for use with with standard RMI, via UnicastRemoteObject.

DefaultRemoteStreamExporter() - Constructor for class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

DefaultRemoteStreamExporter(int) - Constructor for class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

deserializeObject(ObjectInputStream) - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorClient

Reads the next object from the given input stream.

DirectRemoteInputStream - Class in com.healthmarketscience.rmiio

RemoteInputStream implementation which mimics the RemoteInputStream functionality while not actually causing any additional RMI invocations.

DirectRemoteInputStream(InputStream) - Constructor for class com.healthmarketscience.rmiio.DirectRemoteInputStream

DirectRemoteInputStream(InputStream, boolean) - Constructor for class com.healthmarketscience.rmiio.DirectRemoteInputStream

DirectRemoteInputStream(InputStream, boolean, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.DirectRemoteInputStream

DUMMY_MONITOR - Static variable in class com.healthmarketscience.rmiio.RemoteInputStreamServer

Default monitor for operations done by RemoteInputStreamServer which does nothing.

DUMMY_MONITOR - Static variable in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

Default monitor for operations done by RemoteOutputStreamServer which does nothing.

E

EMPTY_PACKET - Static variable in class com.healthmarketscience.rmiio.PacketInputStream

empty packet.

encode(int) - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

Writes some amount of data to the OutputStream linked to the EncodingInputStream calling this method.

encodeSkip(long) - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

Skips some amount of bytes in the encoding output.

EncodingInputStream - Class in com.healthmarketscience.rmiio.util

InputStream which facilitates generating a stream of data on demand through some programmatic action.

EncodingInputStream() - Constructor for class com.healthmarketscience.rmiio.util.EncodingInputStream

EncodingInputStream(int) - Constructor for class com.healthmarketscience.rmiio.util.EncodingInputStream

EncodingInputStream(int, boolean) - Constructor for class com.healthmarketscience.rmiio.util.EncodingInputStream

EncodingRemoteIteratorServer<DataType> - Class in com.healthmarketscience.rmiio

Base class for implementing the server side of a RemoteIterator where the objects need to be encoded on the fly.

EncodingRemoteIteratorServer() - Constructor for class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

EncodingRemoteIteratorServer(boolean) - Constructor for class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

EncodingRemoteIteratorServer(boolean, boolean) - Constructor for class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

EncodingRemoteIteratorServer(boolean, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

EncodingRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

EncodingRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, int) - Constructor for class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

export(StreamServerType) - Method in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

Exports the given stream server via the desired RPC framework and returns the "remote" instance (often some sort of serializable stub object).

export() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Convenience method which exports this object for use using the exporter retrieved from RemoteStreamExporter.getInstance().

exported(RemoteStreamExporter) - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Indicates to this object that it was exported remotely.

EXPORTER_PROPERTY - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

system property used by RemoteStreamExporter.getInstance() to determine which exporter implementation to return

exportImpl(RemoteStreamServer<?, ?>) - Method in class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

exportImpl(RemoteStreamServer<?, ?>) - Method in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

Called by RemoteStreamExporter.export(StreamServerType) to do the actual export work for the relevant RPC framework.

F

failure(RemoteInputStreamServer, Exception) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

failure(RemoteOutputStreamServer, Exception) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

failure(StreamServerType, Exception) - Method in interface com.healthmarketscience.rmiio.RemoteStreamMonitor

Called when an IOException is thrown by one of the stream methods.

finish(boolean, boolean) - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Cleans up after this stream.

flush() - Method in class com.healthmarketscience.rmiio.exporter.RemoteOutputStreamClientProxy

flush() - Method in interface com.healthmarketscience.rmiio.RemoteOutputStream

Flushes the output stream and forces as much as possible of any buffered bytes to be written out.

flush() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

flush() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

flush(RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

flush() - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

flushImpl() - Method in class com.healthmarketscience.rmiio.GZIPRemoteOutputStream

flushImpl() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

Flushes the underlying stream.

flushImpl() - Method in class com.healthmarketscience.rmiio.SimpleRemoteOutputStream

G

getAsSub() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

getAsSub() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

getAsSub() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Returns a handle to this object as a subclass instance.

getBuffer() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

getBuffer() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

getInputStream() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

Returns the real InputStream from which this stream is reading data

getInputStream() - Method in class com.healthmarketscience.rmiio.util.InputStreamAdapter

getInstance() - Static method in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

Returns the default RemoteStreamExporter to use.

getLock() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

getLock() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

getLock() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Returns a handle to the object used to lock the underlying stream operations for this remote stream.

getLog() - Method in class com.healthmarketscience.rmiio.RemoteWrapper

getMaxNumRetries() - Method in class com.healthmarketscience.rmiio.RemoteRetry.Simple

getNoDelay() - Method in class com.healthmarketscience.rmiio.PacketInputStream

getOutputStream() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

Returns the real OutputStream to which this stream is writing data

getOutputStream() - Method in class com.healthmarketscience.rmiio.util.OutputStreamAdapter

getPacketSize() - Method in class com.healthmarketscience.rmiio.PacketInputStream

getPacketSize() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

getPort() - Method in class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

getRemoteClass() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

getRemoteClass() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

getRemoteClass() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

getRemoteRetry() - Method in class com.healthmarketscience.rmiio.RemoteWrapper

getSink() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe

getSource() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe

getStub() - Method in class com.healthmarketscience.rmiio.RemoteWrapper

getTempBuffer() - Method in class com.healthmarketscience.rmiio.util.InputStreamAdapter

getThrowOnReadClose() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

getWrapper(Object) - Static method in class com.healthmarketscience.rmiio.RemoteWrapper

Gets the wrapper underlying a proxy created by a call to RemoteWrapper.wrap(java.lang.Class, R, com.healthmarketscience.rmiio.RemoteRetry, org.apache.commons.logging.Log).

GZIPRemoteInputStream - Class in com.healthmarketscience.rmiio

Concrete implementation of a RemoteInputStreamServer which sends compressed data in the GZIP format, which it will read from the underlying InputStream.

GZIPRemoteInputStream(InputStream) - Constructor for class com.healthmarketscience.rmiio.GZIPRemoteInputStream

GZIPRemoteInputStream(InputStream, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.GZIPRemoteInputStream

GZIPRemoteInputStream(InputStream, RemoteStreamMonitor<RemoteInputStreamServer>, int) - Constructor for class com.healthmarketscience.rmiio.GZIPRemoteInputStream

GZIPRemoteOutputStream - Class in com.healthmarketscience.rmiio

Concrete implementation of a RemoteOutputStreamServer which expects to receive compressed data, which it will write directly to the underlying OutputStream.

GZIPRemoteOutputStream(OutputStream) - Constructor for class com.healthmarketscience.rmiio.GZIPRemoteOutputStream

GZIPRemoteOutputStream(OutputStream, RemoteStreamMonitor<RemoteOutputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.GZIPRemoteOutputStream

H

hasNext() - Method in class com.healthmarketscience.rmiio.CloseableIOIterator.Adapter

Deprecated.

hasNext() - Method in class com.healthmarketscience.rmiio.ConverterIOIterator

hasNext() - Method in class com.healthmarketscience.rmiio.IOIterator.Adapter

Deprecated.

hasNext() - Method in interface com.healthmarketscience.rmiio.IOIterator

Returns true iff the iteration has more elements.

hasNext() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Source

hasNext() - Method in class com.healthmarketscience.rmiio.LineIterator

hasNext() - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

hasNext() - Method in class com.healthmarketscience.rmiio.SimpleRemoteIterator

hasRemaining() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

I

IN_AVAILABLE_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

IN_CLOSE_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

IN_READ_PACKET_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

IN_SKIP_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

IN_USING_COMPRESSION_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

INITIAL_INVALID_SEQUENCE_ID - Static variable in class com.healthmarketscience.rmiio.RemoteStreamServer

the initial sequence id for server methods which have not yet been invoked

INITIAL_VALID_SEQUENCE_ID - Static variable in class com.healthmarketscience.rmiio.RemoteStreamServer

the initial sequence id for client code which has not yet invoked any remote methods

initialize(InputStream) - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

Initializes the subclass with a handle to the underlying remote input stream.

initialize(InputStream) - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorClient

InputStreamAdapter - Class in com.healthmarketscience.rmiio.util

Utility class for optimizing different read strategies based on the type of the underlying InputStream.

invoke(int, Object...) - Method in class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

Invokes the given method name with the given parameters on the remote RemoteInputStreamServer and returns the results.

invoke(int, Object...) - Method in class com.healthmarketscience.rmiio.exporter.RemoteOutputStreamClientProxy

Invokes the given method name with the given parameters on the remote RemoteInputStreamServer and returns the results.

invoke(RemoteOutputStreamServer, int, Object[]) - Static method in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

Invokes the method with the given name and the given parameters on the given RemoteOutputStreamServer instance, returning the result.

invoke(RemoteInputStreamServer, int, Object[]) - Static method in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

Invokes the method with the given name and the given parameters on the given RemoteInputStreamServer instance, returning the result.

invoke(Object, Method, Object[]) - Method in class com.healthmarketscience.rmiio.RemoteWrapper

IOIterator<DataType> - Interface in com.healthmarketscience.rmiio

Interface which mimics the Iterator interface but allows IOExceptions to be thrown by the implementation.

IOIterator.Adapter<DataType> - Class in com.healthmarketscience.rmiio

Deprecated. use RmiioUtil.adapt(java.util.Iterator) instead

IOIterator.Adapter(Iterator<? extends DataType>) - Constructor for class com.healthmarketscience.rmiio.IOIterator.Adapter

Deprecated.

IOIteratorPipe<DataType> - Class in com.healthmarketscience.rmiio

A "pipe" implementation for IOIterators which is designed for use by two separate threads.

IOIteratorPipe() - Constructor for class com.healthmarketscience.rmiio.IOIteratorPipe

Constructs an IOIteratorPipe with the DEFAULT_QUEUE_SIZE internal queue size.

IOIteratorPipe(int) - Constructor for class com.healthmarketscience.rmiio.IOIteratorPipe

Constructs an IOIteratorPipe with the given internal queue size.

IOIteratorPipe.Sink - Class in com.healthmarketscience.rmiio

The Sink for this pipe.

IOIteratorPipe.Source - Class in com.healthmarketscience.rmiio

The Source for this pipe.

isClosed() - Method in class com.healthmarketscience.rmiio.RemoteIteratorServer

isClosed() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

isReadClosed() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

isWriteClosed() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

L

LineIterator - Class in com.healthmarketscience.rmiio

CloseableIOIterator that reads lines from a BufferedReader, optionally trimming whitespace and/or skipping blank lines.

LineIterator(BufferedReader, boolean, boolean) - Constructor for class com.healthmarketscience.rmiio.LineIterator

Creates a new LineIterator instance that will read lines from the given BufferedReader and return them from calls to next().

localBytesMoved(RemoteInputStreamServer, int) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

localBytesMoved(RemoteOutputStreamServer, int) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

localBytesMoved(StreamServerType, int) - Method in interface com.healthmarketscience.rmiio.RemoteStreamMonitor

Called when some bytes are moved to/from the local stream.

localBytesSkipped(RemoteInputStreamServer, long) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

localBytesSkipped(RemoteOutputStreamServer, long) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

localBytesSkipped(StreamServerType, long) - Method in interface com.healthmarketscience.rmiio.RemoteStreamMonitor

Called when some bytes from the local stream are skipped.

LOG - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

LOG - Static variable in class com.healthmarketscience.rmiio.RemoteInputStreamClient

LOG - Static variable in class com.healthmarketscience.rmiio.RemoteOutputStreamClient

LOG - Static variable in class com.healthmarketscience.rmiio.RemoteRetry

LOG - Static variable in class com.healthmarketscience.rmiio.RemoteStreamServer

N

NEVER - Static variable in class com.healthmarketscience.rmiio.RemoteRetry

instance of the RemoteRetry.Never retry strategy for general use.

next() - Method in class com.healthmarketscience.rmiio.AbstractCloseableIOIterator

next() - Method in class com.healthmarketscience.rmiio.CloseableIOIterator.Adapter

Deprecated.

next() - Method in class com.healthmarketscience.rmiio.IOIterator.Adapter

Deprecated.

next() - Method in interface com.healthmarketscience.rmiio.IOIterator

Returns the next element in the iteration.

next() - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

next() - Method in class com.healthmarketscience.rmiio.SimpleRemoteIterator

nextImpl() - Method in class com.healthmarketscience.rmiio.AbstractCloseableIOIterator

Does the actual work of the AbstractCloseableIOIterator.next() method.

nextImpl() - Method in class com.healthmarketscience.rmiio.ConverterIOIterator

nextImpl() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Source

nextImpl() - Method in class com.healthmarketscience.rmiio.LineIterator

O

OUT_CLOSE_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

OUT_FLUSH_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

OUT_USING_COMPRESSION_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

OUT_WRITE_PACKET_METHOD - Static variable in class com.healthmarketscience.rmiio.exporter.RemoteStreamServerInvokerHelper

OutputStreamAdapter - Class in com.healthmarketscience.rmiio.util

Utility class for optimizing different write strategies based on the type of the underlying OutputStream.

P

PacketInputStream - Class in com.healthmarketscience.rmiio

Adds support for packet based access to data from an InputStream.

PacketInputStream() - Constructor for class com.healthmarketscience.rmiio.PacketInputStream

PacketInputStream(int) - Constructor for class com.healthmarketscience.rmiio.PacketInputStream

PacketInputStream(int, boolean) - Constructor for class com.healthmarketscience.rmiio.PacketInputStream

PacketOutputStream - Class in com.healthmarketscience.rmiio

Adds support for packet based access to data from an OutputStream.

PacketOutputStream() - Constructor for class com.healthmarketscience.rmiio.PacketOutputStream

packetsAvailable() - Method in class com.healthmarketscience.rmiio.PacketInputStream

Returns the number of full packets which can be read without blocking.

packetsAvailable() - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

packetsAvailable() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

packetsAvailable() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

PipeBuffer - Class in com.healthmarketscience.rmiio.util

Utility class for implementing a pipe which will never block (at the expense of possibly utilizing more memory).

PipeBuffer() - Constructor for class com.healthmarketscience.rmiio.util.PipeBuffer

PipeBuffer(int) - Constructor for class com.healthmarketscience.rmiio.util.PipeBuffer

PipeBuffer.InputStreamAdapter - Class in com.healthmarketscience.rmiio.util

PacketInputStream implementation which reads from a PipeBuffer.

PipeBuffer.InputStreamAdapter() - Constructor for class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

PipeBuffer.InputStreamAdapter(int) - Constructor for class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

PipeBuffer.OutputStreamAdapter - Class in com.healthmarketscience.rmiio.util

PacketOutputStream implementation which writes to a PipeBuffer.

PipeBuffer.OutputStreamAdapter() - Constructor for class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

PipeBuffer.OutputStreamAdapter(boolean) - Constructor for class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

PORT_PROPERTY - Static variable in class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

system property used to determine the port to use for the default constructor.

R

read() - Method in class com.healthmarketscience.rmiio.SerializableInputStream

read(byte[]) - Method in class com.healthmarketscience.rmiio.SerializableInputStream

read(byte[], int, int) - Method in class com.healthmarketscience.rmiio.SerializableInputStream

read() - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

read(byte[]) - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

read(byte[], int, int) - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

read() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

read(byte[]) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

read(byte[], int, int) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

read(byte[], int, int) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Reads the given number of bytes into the given buffer starting at the given position.

read(InputStream) - Method in class com.healthmarketscience.rmiio.util.SingleByteAdapter

Calls InputStream.read(byte[],int,int) on the given InputStream using an internal buffer, and returns the relevant result (either the end of stream flag or the byte that was read).

readNextObject() - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

Reads the next object from the underlying input stream and returns it.

readNextObject() - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorClient

readPacket(int) - Method in class com.healthmarketscience.rmiio.DirectRemoteInputStream

readPacket(int) - Method in class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

readPacket() - Method in class com.healthmarketscience.rmiio.GZIPRemoteInputStream

readPacket() - Method in class com.healthmarketscience.rmiio.PacketInputStream

Gets the next "packet" from the internal buffer and returns it (if any).

readPacket(boolean) - Method in class com.healthmarketscience.rmiio.PacketInputStream

Gets the next "packet" from the internal buffer and returns it (if any).

readPacket(InputStream, byte[]) - Static method in class com.healthmarketscience.rmiio.PacketInputStream

Reads a packet of data from the given input stream.

readPacket(int) - Method in interface com.healthmarketscience.rmiio.RemoteInputStream

Reads the next chunk of data for this stream.

readPacket(int) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

readPacket() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

Reads the next packet of approximately RemoteInputStreamServer._chunkSize from the underlying stream and returns it.

readPacket(int) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

readPacket(int, RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

readPacket() - Method in class com.healthmarketscience.rmiio.SimpleRemoteInputStream

readPacket(boolean) - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

readPacket() - Method in class com.healthmarketscience.rmiio.util.InputStreamAdapter

Gets the next "packet" from the internal buffer and returns it (if any).

readPacket(boolean) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

readPacket() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Reads a packet of data from this buffer.

readTemp() - Method in class com.healthmarketscience.rmiio.util.InputStreamAdapter

Reads some number of bytes from the underlying stream and puts them in a buffer available from the InputStreamAdapter.getTempBuffer() call.

remaining() - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

RemoteClient - Interface in com.healthmarketscience.rmiio

Interface common to most remote client implementations.

RemoteInputStream - Interface in com.healthmarketscience.rmiio

Remote interface which allows exporting an InputStream-like interface over the network.

RemoteInputStreamClient - Class in com.healthmarketscience.rmiio

Utility which provides a wrapper InputStream for the client of a RemoteInputStream.

RemoteInputStreamClientProxy - Class in com.healthmarketscience.rmiio.exporter

Base RemoteInputStream implementation which translates each method invocation into a call to the RemoteInputStreamClientProxy.invoke(int, java.lang.Object...) method in a manner compatible with the RemoteStreamServerInvokerHelper invoke method for a RemoteInputStreamServer.

RemoteInputStreamClientProxy() - Constructor for class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

RemoteInputStreamMonitor - Class in com.healthmarketscience.rmiio

Implementation of RemoteStreamMonitor for RemoteInputStreamServers which does nothing.

RemoteInputStreamMonitor() - Constructor for class com.healthmarketscience.rmiio.RemoteInputStreamMonitor

RemoteInputStreamServer - Class in com.healthmarketscience.rmiio

Server implementation base class for a RemoteInputStream.

RemoteInputStreamServer(InputStream) - Constructor for class com.healthmarketscience.rmiio.RemoteInputStreamServer

RemoteInputStreamServer(InputStream, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.RemoteInputStreamServer

RemoteInputStreamServer(InputStream, RemoteStreamMonitor<RemoteInputStreamServer>, int) - Constructor for class com.healthmarketscience.rmiio.RemoteInputStreamServer

RemoteInputStreamWrapper - Class in com.healthmarketscience.rmiio

Wrapper for a RemoteInputStream stub which handles retry magic under the hood.

RemoteInputStreamWrapper(RemoteInputStream, RemoteRetry, Log) - Constructor for class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

RemoteIterator<DataType> - Interface in com.healthmarketscience.rmiio

Interface for streaming a read-only collection of objects using rmi.

RemoteIteratorClient<DataType> - Class in com.healthmarketscience.rmiio

Base class for implementing the client side of a RemoteIterator.

RemoteIteratorClient(RemoteIteratorServer<DataType>) - Constructor for class com.healthmarketscience.rmiio.RemoteIteratorClient

RemoteIteratorClient(RemoteIteratorServer<DataType>, RemoteStreamExporter) - Constructor for class com.healthmarketscience.rmiio.RemoteIteratorClient

RemoteIteratorServer<DataType> - Class in com.healthmarketscience.rmiio

Base class for implementing the server side of a RemoteIterator.

RemoteIteratorServer(InputStream) - Constructor for class com.healthmarketscience.rmiio.RemoteIteratorServer

RemoteIteratorServer(InputStream, boolean) - Constructor for class com.healthmarketscience.rmiio.RemoteIteratorServer

RemoteIteratorServer(InputStream, boolean, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.RemoteIteratorServer

RemoteIteratorServer(InputStream, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, int) - Constructor for class com.healthmarketscience.rmiio.RemoteIteratorServer

RemoteOutputStream - Interface in com.healthmarketscience.rmiio

Remote interface which allows exporting an OutputStream-like interface over the network.

RemoteOutputStreamClient - Class in com.healthmarketscience.rmiio

Utility which provides a wrapper OutputStream for the client of a RemoteOutputStream.

RemoteOutputStreamClientProxy - Class in com.healthmarketscience.rmiio.exporter

Base RemoteOutputStream implementation which translates each method invocation into a call to the RemoteOutputStreamClientProxy.invoke(int, java.lang.Object...) method in a manner compatible with the RemoteStreamServerInvokerHelper invoke method for a RemoteOutputStreamServer.

RemoteOutputStreamClientProxy() - Constructor for class com.healthmarketscience.rmiio.exporter.RemoteOutputStreamClientProxy

RemoteOutputStreamMonitor - Class in com.healthmarketscience.rmiio

Implementation of RemoteStreamMonitor for RemoteOutputStreamServers which does nothing.

RemoteOutputStreamMonitor() - Constructor for class com.healthmarketscience.rmiio.RemoteOutputStreamMonitor

RemoteOutputStreamServer - Class in com.healthmarketscience.rmiio

Server implementation base class for a RemoteOutputStream.

RemoteOutputStreamServer(OutputStream) - Constructor for class com.healthmarketscience.rmiio.RemoteOutputStreamServer

RemoteOutputStreamServer(OutputStream, RemoteStreamMonitor<RemoteOutputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.RemoteOutputStreamServer

RemoteOutputStreamWrapper - Class in com.healthmarketscience.rmiio

Wrapper for a RemoteOutputStream stub which handles retry magic under the hood.

RemoteOutputStreamWrapper(RemoteOutputStream, RemoteRetry, Log) - Constructor for class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

RemoteRetry - Class in com.healthmarketscience.rmiio

Utility class for automatically retrying remote method calls (which might fail for spurious reasons).

RemoteRetry() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry

RemoteRetry.Always - Class in com.healthmarketscience.rmiio

Simple implementation of RemoteRetry which always retries RemoteExceptions thrown from the remote method call.

RemoteRetry.Always() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.Always

RemoteRetry.Caller<RetType> - Class in com.healthmarketscience.rmiio

Utility type implemented by those atttempting to make remote method calls using this retry mechanism.

RemoteRetry.Caller() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.Caller

RemoteRetry.Never - Class in com.healthmarketscience.rmiio

Simple implementation of RemoteRetry which never retries.

RemoteRetry.Never() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.Never

RemoteRetry.Simple - Class in com.healthmarketscience.rmiio

Simple implementation of RemoteRetry which retries RemoteExceptions some number of times and uses the backoff strategy from RemoteRetry.simpleBackOff(int, org.apache.commons.logging.Log).

RemoteRetry.Simple() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.Simple

RemoteRetry.Simple(int) - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.Simple

RemoteRetry.SimpleAlways - Class in com.healthmarketscience.rmiio

Simple implementation of Always retry strategy which uses the backoff strategy from RemoteRetry.simpleBackOff(int, org.apache.commons.logging.Log).

RemoteRetry.SimpleAlways() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.SimpleAlways

RemoteRetry.VoidCaller - Class in com.healthmarketscience.rmiio

Simple subclass of Caller for use by remote method calls which do not need to return values.

RemoteRetry.VoidCaller() - Constructor for class com.healthmarketscience.rmiio.RemoteRetry.VoidCaller

RemoteStreamExporter - Class in com.healthmarketscience.rmiio.exporter

Base class for objects which manage exporting RemoteStreamServers.

RemoteStreamExporter() - Constructor for class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

RemoteStreamMonitor<StreamServerType> - Interface in com.healthmarketscience.rmiio

Interface for monitoring the progress of a remote stream, such as RemoteInputStream or RemoteOutputStream.

RemoteStreamServer<StreamServerType,StreamType> - Class in com.healthmarketscience.rmiio

Common base class for remote stream implementations which handles the basic status of the stream (whether or not it is exported, closed).

RemoteStreamServer(RemoteStreamMonitor<StreamServerType>) - Constructor for class com.healthmarketscience.rmiio.RemoteStreamServer

RemoteStreamServerInvokerHelper - Class in com.healthmarketscience.rmiio.exporter

Helper class for applying a "packaged" RemoteStreamServer invocation to the relevant server instance.

RemoteWrapper<RemoteType> - Class in com.healthmarketscience.rmiio

Base class for implementing remote stub wrappers with builtin retry policies.

RemoteWrapper(RemoteType, RemoteRetry, Log) - Constructor for class com.healthmarketscience.rmiio.RemoteWrapper

RmiioUtil - Class in com.healthmarketscience.rmiio

Utility methods for working with rmiio classes.

RUNTIME_CLASS - Static variable in class com.healthmarketscience.rmiio.RemoteRetry

RuntimeException class for overloading of exception types

S

SerializableInputStream - Class in com.healthmarketscience.rmiio

An additional layer around a RemoteInputStream which makes it Serializable and an InputStream.

SerializableInputStream(InputStream) - Constructor for class com.healthmarketscience.rmiio.SerializableInputStream

SerializableInputStream(RemoteInputStream) - Constructor for class com.healthmarketscience.rmiio.SerializableInputStream

SerializableOutputStream - Class in com.healthmarketscience.rmiio

An additional layer around a RemoteOutputStream which makes it Serializable and an OutputStream.

SerializableOutputStream(OutputStream) - Constructor for class com.healthmarketscience.rmiio.SerializableOutputStream

SerializableOutputStream(RemoteOutputStream) - Constructor for class com.healthmarketscience.rmiio.SerializableOutputStream

serializeObject(ObjectOutputStream, Object) - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

Writes the given object to the given output stream.

SerialRemoteIteratorClient<DataType> - Class in com.healthmarketscience.rmiio

Implementation of RemoteIteratorClient which uses java serialization to receive objects from the RemoteIteratorServer.

SerialRemoteIteratorClient(RemoteIteratorServer<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorClient

SerialRemoteIteratorClient(RemoteIteratorServer<DataType>, RemoteStreamExporter) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorClient

SerialRemoteIteratorServer<DataType> - Class in com.healthmarketscience.rmiio

Implementation of RemoteIteratorServer which uses java serialization to send objects to the RemoteIteratorClient.

SerialRemoteIteratorServer(Iterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, Iterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, Iterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, RemoteStreamMonitor<RemoteInputStreamServer>, Iterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, Iterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, int, Iterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(IOIterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, IOIterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, IOIterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, RemoteStreamMonitor<RemoteInputStreamServer>, IOIterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, IOIterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, int, IOIterator<DataType>) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

SerialRemoteIteratorServer(boolean, boolean, RemoteStreamMonitor<RemoteInputStreamServer>, int, IOIterator<DataType>, int) - Constructor for class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

setBuffer(PipeBuffer) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

setBuffer(PipeBuffer) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

setChunkSize(Integer) - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

May be called on the client-side in order to set the target chunk size used by the underlying implementation.

setFinished() - Method in class com.healthmarketscience.rmiio.IOIteratorPipe.Sink

Indicates that all objects have been successfully added to the pipe.

setRemoteRetry(RemoteRetry) - Method in interface com.healthmarketscience.rmiio.RemoteClient

Sets the client side RemoteRetry policy to use for the underlying remote communication layer.

setRemoteRetry(RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteIteratorClient

setRemoteRetry(RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteWrapper

Sets the client side RemoteRetry policy to use for the underlying remote communication layer.

setRemoteRetry(RemoteRetry) - Method in class com.healthmarketscience.rmiio.SerializableInputStream

setRemoteRetry(RemoteRetry) - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

setRemoteRetry(RemoteRetry) - Method in class com.healthmarketscience.rmiio.SimpleRemoteIterator

setThrowOnReadClose(boolean) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

Sets the throwOnReadClose flag.

shouldRetry(Throwable, int) - Method in class com.healthmarketscience.rmiio.RemoteRetry.Always

shouldRetry(Throwable, int) - Method in class com.healthmarketscience.rmiio.RemoteRetry.Never

shouldRetry(Throwable, int) - Method in class com.healthmarketscience.rmiio.RemoteRetry

Returns true if the caller should attempt to repeat the current remote method call given the number of previous reattempts.

shouldRetry(Throwable, int) - Method in class com.healthmarketscience.rmiio.RemoteRetry.Simple

SIMPLE - Static variable in class com.healthmarketscience.rmiio.RemoteRetry

instance of the RemoteRetry.Simple retry strategy for general use.

SIMPLE_ALWAYS - Static variable in class com.healthmarketscience.rmiio.RemoteRetry

instance of the RemoteRetry.SimpleAlways retry strategy for general use.

simpleBackOff(int, Log) - Static method in class com.healthmarketscience.rmiio.RemoteRetry

Implementation of a simple backoff strategy: First retry returns immediately Retries 1 - 30 wait that many seconds each time before returning (after 1st retry wait 1 second, after 2nd retry wait 2 seconds...) Retries > 30 wait 30 seconds each time before returning

SimpleRemoteInputStream - Class in com.healthmarketscience.rmiio

Concrete implementation of a RemoteInputStreamServer which sends uncompressed data, which it will read directly from the underlying InputStream.

SimpleRemoteInputStream(InputStream) - Constructor for class com.healthmarketscience.rmiio.SimpleRemoteInputStream

SimpleRemoteInputStream(InputStream, RemoteStreamMonitor<RemoteInputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.SimpleRemoteInputStream

SimpleRemoteInputStream(InputStream, RemoteStreamMonitor<RemoteInputStreamServer>, int) - Constructor for class com.healthmarketscience.rmiio.SimpleRemoteInputStream

SimpleRemoteIterator<DataType> - Class in com.healthmarketscience.rmiio

Trivial implementation of RemoteIterator for small collections.

SimpleRemoteIterator(Iterable<DataType>) - Constructor for class com.healthmarketscience.rmiio.SimpleRemoteIterator

SimpleRemoteOutputStream - Class in com.healthmarketscience.rmiio

Concrete implementation of a RemoteOutputStreamServer which expects to receive uncompressed data, which it will write directly to the underlying OutputStream.

SimpleRemoteOutputStream(OutputStream) - Constructor for class com.healthmarketscience.rmiio.SimpleRemoteOutputStream

SimpleRemoteOutputStream(OutputStream, RemoteStreamMonitor<RemoteOutputStreamServer>) - Constructor for class com.healthmarketscience.rmiio.SimpleRemoteOutputStream

SingleByteAdapter - Class in com.healthmarketscience.rmiio.util

Adapts a single byte read/write call to the corresponding call to a byte array read/write call.

SingleByteAdapter() - Constructor for class com.healthmarketscience.rmiio.util.SingleByteAdapter

skip(long, int) - Method in class com.healthmarketscience.rmiio.DirectRemoteInputStream

skip(long, int) - Method in class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

skip(long) - Method in class com.healthmarketscience.rmiio.GZIPRemoteInputStream

skip(long, int) - Method in interface com.healthmarketscience.rmiio.RemoteInputStream

Skips and discards up to the given number of bytes in the stream, and returns the actual number of bytes skipped.

skip(long, int) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

skip(long) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamServer

Skips at most the given amount of bytes in the underlying stream and returns the actual number of bytes skipped.

skip(long, int) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

skip(long, int, RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

skip(long) - Method in class com.healthmarketscience.rmiio.SerializableInputStream

skip(long) - Method in class com.healthmarketscience.rmiio.SimpleRemoteInputStream

skip(long) - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

skip(long) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.InputStreamAdapter

skip(long) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Skips the given number of bytes in this buffer.

T

throwIfClosed() - Method in class com.healthmarketscience.rmiio.util.EncodingInputStream

Throws an IOException if the stream is closed, otherwise, does nothing.

U

unexport(RemoteStreamServer<?, ?>) - Method in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

Unexports the given previously exported stream server from the desired RPC framework.

unexportImpl(RemoteStreamServer<?, ?>) - Method in class com.healthmarketscience.rmiio.exporter.DefaultRemoteStreamExporter

unexportImpl(RemoteStreamServer<?, ?>) - Method in class com.healthmarketscience.rmiio.exporter.RemoteStreamExporter

Called by RemoteStreamExporter.unexport(com.healthmarketscience.rmiio.RemoteStreamServer) to do the actual unexport work for the relevant RPC framework.

unreferenced() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.DirectRemoteInputStream

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.exporter.RemoteInputStreamClientProxy

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.exporter.RemoteOutputStreamClientProxy

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.GZIPRemoteInputStream

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.GZIPRemoteOutputStream

usingGZIPCompression() - Method in interface com.healthmarketscience.rmiio.RemoteInputStream

Returns true if the stream is using GZIP compression over the wire.

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

usingGZIPCompression(RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteInputStreamWrapper

usingGZIPCompression() - Method in interface com.healthmarketscience.rmiio.RemoteOutputStream

Returns true if the stream is using GZIP compression over the wire.

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

usingGZIPCompression(RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.SimpleRemoteInputStream

usingGZIPCompression() - Method in class com.healthmarketscience.rmiio.SimpleRemoteOutputStream

V

voidCall() - Method in class com.healthmarketscience.rmiio.RemoteRetry.VoidCaller

Makes a remote method call which returns no value.

W

wrap(RemoteInputStream) - Static method in class com.healthmarketscience.rmiio.RemoteInputStreamClient

Wraps a RemoteInputStream as an InputStream using the RemoteClient.DEFAULT_RETRY retry policy.

wrap(RemoteInputStream, RemoteRetry) - Static method in class com.healthmarketscience.rmiio.RemoteInputStreamClient

Wraps a RemoteInputStream as an InputStream using the given retry strategy.

wrap(RemoteOutputStream) - Static method in class com.healthmarketscience.rmiio.RemoteOutputStreamClient

Wraps a RemoteOutputStream as an OutputStream using the RemoteRetry.SIMPLE retry policy.

wrap(RemoteOutputStream, RemoteRetry) - Static method in class com.healthmarketscience.rmiio.RemoteOutputStreamClient

Wraps a RemoteOutputStream as an OutputStream using the given retry policy.

wrap(RemoteOutputStream, RemoteRetry, Integer) - Static method in class com.healthmarketscience.rmiio.RemoteOutputStreamClient

Wraps a RemoteOutputStream as an OutputStream using the given retry policy.

wrap(Class<R>, R, RemoteRetry, Log) - Static method in class com.healthmarketscience.rmiio.RemoteWrapper

Simple wrapper generator which creates a Proxy for the given remote interface.

write(int) - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

write(byte[]) - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

write(byte[], int, int) - Method in class com.healthmarketscience.rmiio.SerializableOutputStream

write(int) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

write(byte[]) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

write(byte[], int, int) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

write(byte[], int, int) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Writes the given number of bytes from the given buffer starting at the given position.

write(int, OutputStream) - Method in class com.healthmarketscience.rmiio.util.SingleByteAdapter

Calls OutputStream.write(byte[],int,int) on the given OutputStream using an internal buffer with the given byte written to it.

writeNextObject() - Method in class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

If there are more objects in the iteration, writes an object to the _localOStream and returns true, otherwise returns false.

writeNextObject() - Method in class com.healthmarketscience.rmiio.SerialRemoteIteratorServer

writePacket(byte[], int) - Method in class com.healthmarketscience.rmiio.exporter.RemoteOutputStreamClientProxy

writePacket(byte[]) - Method in class com.healthmarketscience.rmiio.GZIPRemoteOutputStream

writePacket(byte[]) - Method in class com.healthmarketscience.rmiio.PacketOutputStream

Puts the given "packet" into the output stream.

writePacket(byte[], int) - Method in interface com.healthmarketscience.rmiio.RemoteOutputStream

Writes the next chunk of data to this stream.

writePacket(byte[], int) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

writePacket(byte[]) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

Writes the given packet to the underlying stream.

writePacket(byte[], int) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

writePacket(byte[], int, RemoteRetry) - Method in class com.healthmarketscience.rmiio.RemoteOutputStreamWrapper

writePacket(byte[]) - Method in class com.healthmarketscience.rmiio.SimpleRemoteOutputStream

writePacket(byte[]) - Method in class com.healthmarketscience.rmiio.util.OutputStreamAdapter

Puts the given "packet" into the output stream.

writePacket(byte[]) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer.OutputStreamAdapter

writePacket(byte[], int, int) - Method in class com.healthmarketscience.rmiio.util.PipeBuffer

Writes a packet of data to this buffer, where the initial data in the packet will start at the given position and have the given length.

writeReplace() - Method in class com.healthmarketscience.rmiio.RemoteStreamServer

Manages serialization for all remote stream instances by returning the result of a call to RemoteStreamServer.export() on this instance as a Serializable replacement for an instance of this class.

_

_chunkSize - Variable in class com.healthmarketscience.rmiio.RemoteInputStreamServer

the target chunk size for data packets sent over the wire

_in - Variable in class com.healthmarketscience.rmiio.RemoteInputStreamServer

the real input stream from which we are reading data

_localIStream - Variable in class com.healthmarketscience.rmiio.RemoteIteratorServer

InputStream which is used by the RemoteInputStreamServer to read the objects.

_localOStream - Variable in class com.healthmarketscience.rmiio.EncodingRemoteIteratorServer

the OutputStream which subclasses should use to write out an object during a call to writeNextObject() (and possibly closeIterator()).

_log - Variable in class com.healthmarketscience.rmiio.RemoteWrapper

the log which will be used by the retry facility when making the remote calls

_monitor - Variable in class com.healthmarketscience.rmiio.RemoteStreamServer

the monitor which is following our progress

_out - Variable in class com.healthmarketscience.rmiio.RemoteOutputStreamServer

the real output stream to which we are writing data

_retry - Variable in class com.healthmarketscience.rmiio.RemoteWrapper

the retry policy we are using for our remote calls

_stub - Variable in class com.healthmarketscience.rmiio.RemoteWrapper

the handle to the remote interface which will do the real work of the remote method calls

A B C D E F G H I L N O P R S T U V W _