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.socket.RMISocket

Closes the local InputStream and the remote Source if one has been associated with this socket.

close() - Method in class com.healthmarketscience.rmiio.socket.RMISocket.Source

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

closeQuietly(Closeable) - Static method in class com.healthmarketscience.rmiio.RmiioUtil

Closes the given Closeable if non-null, swallowing any IOExceptions generated.

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.socket - package com.healthmarketscience.rmiio.socket

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.socket.RMISocket

Returns the InputStream which can be used to read data sent through the socket via the local Source which has been passed to the remote system.

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.socket.RMISocket

Returns the OutputStream of the remote Source, if one has been associated with this socket (thus allowing bi-directional communication).

getOutputStream() - Method in class com.healthmarketscience.rmiio.socket.RMISocket.Source

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

getRemoteSource() - Method in class com.healthmarketscience.rmiio.socket.RMISocket

Returns the remote Source associated with this socket, if any.

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

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

getSource() - Method in class com.healthmarketscience.rmiio.socket.RMISocket

Returns the local Source for this socket.

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 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.

RMISocket - Class in com.healthmarketscience.rmiio.socket

Utility class which can be used to simulate a socket-like connection over RMI.

RMISocket() - Constructor for class com.healthmarketscience.rmiio.socket.RMISocket

RMISocket(RMISocket.Source) - Constructor for class com.healthmarketscience.rmiio.socket.RMISocket

RMISocket.Source - Class in com.healthmarketscience.rmiio.socket

Serializable stub which must be passed to the remote system in order to enable it to send data through this socket.

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.

setChunkSize(Integer) - Method in class com.healthmarketscience.rmiio.socket.RMISocket.Source

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

setRemoteRetry(RemoteRetry) - Method in class com.healthmarketscience.rmiio.socket.RMISocket.Source

setRemoteSource(RMISocket.Source) - Method in class com.healthmarketscience.rmiio.socket.RMISocket

Associates a remote Source with this socket, allowing it to be bi-directional (at which point the RMISocket.getOutputStream() method may be called).

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 _