A B C D E F G H I J K L M N O P Q R S T U V W Y Z _

R

RabinFingerprint - class ostore.dataobj.RabinFingerprint.
Given an InputStream, creates blocks delimited by markers chosen for their Rabin fingerprint.
RabinFingerprint.BufEl - class ostore.dataobj.RabinFingerprint.BufEl.
 
RabinFingerprint.BufEl(BufferElement) - Constructor for class ostore.dataobj.RabinFingerprint.BufEl
 
RabinFingerprint() - Constructor for class ostore.dataobj.RabinFingerprint
Computes some constants to be used later.
rand - Static variable in class ostore.cache.BDBTest
 
rand - Variable in class ostore.network.SimpleTest
 
RandomAccessFileInputBuffer - class ostore.util.RandomAccessFileInputBuffer.
For use in testing only; not efficient at all, and not completely implemented either.
RandomAccessFileInputBuffer(RandomAccessFile) - Constructor for class ostore.util.RandomAccessFileInputBuffer
 
RandomAccessFileOutputBuffer - class ostore.util.RandomAccessFileOutputBuffer.
For use in testing only; not efficient at all, and not completely implemented either.
RandomAccessFileOutputBuffer(RandomAccessFile) - Constructor for class ostore.util.RandomAccessFileOutputBuffer
 
RandomExponential - class ostore.util.RandomExponential.
A utility class for generating random values from a negative exponential distribution.
RandomExponential(double) - Constructor for class ostore.util.RandomExponential
 
RandomExponential(double, long) - Constructor for class ostore.util.RandomExponential
 
Range - class ostore.dataobj.Range.
A contiguous range of bytes in a data btree.
Range(InputBuffer) - Constructor for class ostore.dataobj.Range
Creates a Range from its QuickSerializable form.
Range(long, long) - Constructor for class ostore.dataobj.Range
Creates a Range
rates - Variable in class ostore.dispatch.TrieNode
Contains the pass rates for the SinkIFs.
RawNativeRSASignature_PKCS1_SHA1 - class ostore.security.RawNativeRSASignature_PKCS1_SHA1.
A signature class not encumbered by the horrendous design decisions of the Java Signature interface.
RawNativeRSASignature_PKCS1_SHA1() - Constructor for class ostore.security.RawNativeRSASignature_PKCS1_SHA1
Constructor for an Any_RSA_PKCS1Signature.
RBLD - Static variable in class ostore.dispatch.Signal
The code for Signal.RebuildSignal.
rcvcnt - Variable in class ostore.archive.TputGenerateFragsTest
 
rcvcnt - Variable in class ostore.network.TputTest
 
rcvcnt - Variable in class ostore.network.SimpleTest
 
rcvcnt - Variable in class ostore.network.LatTest
 
read - Variable in class ostore.read.ReplicaReadResp
The portion of the Replica that was successfully read, or null.
read - Variable in class ostore.read.ReadResp
The portion of the DataObject that was successfully read, or null.
READ - Static variable in class ostore.apps.traces.TraceIterator
 
READ_ERROR - Static variable in class ostore.read.ReadResp
An error code that indicates a request failed because some portion of the requested data could not be read.
READ_ERROR - Static variable in class ostore.replica.ReplicaResp
An error code that indicates a request failed because some portion of the requested data could not be read.
READ_REQUEST - Static variable in class ostore.util.DebugFlags
 
READ_STAGE - Static variable in class ostore.util.StageId
 
READ_STAGE - Static variable in class ostore.util.DebugFlags
 
read_topology_info(String, String) - Method in class ostore.network.MultiplexedNetwork
 
read(InputStream) - Static method in class ostore.util.QSIO
Read in the QuickSerializable stored in the specified InputStream.
read(int, int, DataCache) - Method in class ostore.dataobj.DataObject
 
read(int, int, DataObjectReadException, DataCache) - Method in class ostore.dataobj.DataObject
 
read(RandomAccessFile, long) - Static method in class ostore.util.QSIO
Read in the QuickSerializable stored in the specified RandomAccessFile.
read(Selection, DataCache) - Method in class ostore.dataobj.DataObject
 
read(Selection, DataCache, DataObjectReadException) - Method in class ostore.dataobj.DataObject
 
read(String) - Static method in class ostore.util.QSIO
Read in the QuickSerializable stored in the named file.
readIndex(KeyedSelection, DataCache, DataObjectReadException) - Method in class ostore.dataobj.DataObject
 
ReadLatencyMicroBenchmark - class ostore.apps.test.ReadLatencyMicroBenchmark.
The ReadLatencyMicroBenchmark reports the results of a simple microbenchmark that performs a number of replace operations on a single data object.
ReadLatencyMicroBenchmark() - Constructor for class ostore.apps.test.ReadLatencyMicroBenchmark
 
readPath(BtreeKey, HandleStore, DataCache) - Method in class ostore.dataobj.Btree
 
ReadReq - class ostore.read.ReadReq.
A superclass for events sent from the ReplicaStage to the ReadStage requesting the latter to read a portion of a DataObject.
ReadReq(InputBuffer) - Constructor for class ostore.read.ReadReq
Constructs a ReadReq from its serialized form.
ReadReq(VID, SecureHash, Selection, byte) - Constructor for class ostore.read.ReadReq
Constructs a new ReadReq.
ReadResp - class ostore.read.ReadResp.
A superclass for events sent from the ReadStage to the ReplicaStage responding to ReadReq events.
ReadResp(InputBuffer) - Constructor for class ostore.read.ReadResp
Constructs a ReadResp from its serialized form.
ReadResp(ReadReq, Selection, Selection, int) - Constructor for class ostore.read.ReadResp
Constructs a new ReadResp for the specified ReadReq.
readSlice(int, int, DataCache) - Method in class ostore.dataobj.DataObject
 
readSlice(int, int, DataObjectReadSliceException, DataCache) - Method in class ostore.dataobj.DataObject
 
ReadStage - class ostore.read.ReadStage.
The ReadStage performs the read satisfying a ReadReq event.
ReadStage() - Constructor for class ostore.read.ReadStage
 
ReadTputMicroBenchmark - class ostore.apps.test.ReadTputMicroBenchmark.
The ReplaceMicroBenchmark reports the results of a simple microbenchmark that performs a number of replace operations on a single data object.
ReadTputMicroBenchmark.EventTrigger - class ostore.apps.test.ReadTputMicroBenchmark.EventTrigger.
 
ReadTputMicroBenchmark() - Constructor for class ostore.apps.test.ReadTputMicroBenchmark
 
ReadUnsatisfiableException - exception ostore.dataobj.ReadUnsatisfiableException.
A DataObject may throw a ReadUnsatisfiableException if an attempt is made to read a range not contained in the data object.
ReadWriteTest - class ostore.apps.test.ReadWriteTest.
The ReadWriteTest is a simple OceanStore application that alternately writes data into a data object and then read data from the data object.
ReadWriteTest() - Constructor for class ostore.apps.test.ReadWriteTest
 
ReadWriteTestRemote - class ostore.apps.test.ReadWriteTestRemote.
 
ReadWriteTestRemote() - Constructor for class ostore.apps.test.ReadWriteTestRemote
 
reason - Variable in class ostore.inner.UpdateReject
 
reason - Variable in class ostore.inner.LatestHeartbeatReject
 
reason - Variable in class ostore.inner.CreateObjectReject
 
REASON_BAD_SIG - Static variable in class ostore.inner.UpdateReject
 
REASON_BAD_SIG - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_BAD_SIG - Static variable in class ostore.inner.CreateObjectReject
 
REASON_DUP_GUID - Static variable in class ostore.client.OSCreateObjectResult
 
REASON_DUPLICATE - Static variable in class ostore.inner.UpdateReject
 
REASON_DUPLICATE - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_DUPLICATE_AGUID - Static variable in class ostore.inner.CreateObjectReject
 
REASON_NO_2PC - Static variable in class ostore.inner.UpdateReject
 
REASON_NO_PERMISSION - Static variable in class ostore.inner.UpdateReject
 
REASON_NO_PERMISSION - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_NO_PERMISSION - Static variable in class ostore.inner.CreateObjectReject
 
REASON_NOT_IR - Static variable in class ostore.inner.UpdateReject
 
REASON_NOT_IR - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_OLD_TIMESTAMP - Static variable in class ostore.inner.UpdateReject
 
REASON_OLD_TIMESTAMP - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_OTHER - Static variable in class ostore.inner.UpdateReject
 
REASON_OTHER - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_OTHER - Static variable in class ostore.inner.CreateObjectReject
 
REASON_STR - Static variable in class ostore.inner.CreateObjectReject
 
REASON_SUCCESS - Static variable in class ostore.client.OSCreateObjectResult
 
REASON_TIMEOUT - Static variable in class ostore.client.OSCreateObjectResult
 
reason_to_string - Static variable in class ostore.inner.UpdateReject
 
REASON_UNKNOWN_SIG - Static variable in class ostore.inner.UpdateReject
 
REASON_UNKNOWN_SIG - Static variable in class ostore.inner.LatestHeartbeatReject
 
REASON_UNKNOWN_SIG - Static variable in class ostore.inner.CreateObjectReject
 
reasons - Static variable in class ostore.inner.LatestHeartbeatReject
 
recalculate() - Method in class ostore.introspect.SemanticDistanceModel
 
recalculate() - Method in class ostore.oil.Screen
Processes the recent event stream.
recalculate() - Method in interface ostore.oil.Model
Process recently recorded observations.
recalculate() - Method in class ostore.oil.HMM
Updates the internal model parameters using the EM algorithm.
recalculate(Distance, Distance) - Method in class ostore.introspect.WeightedAvgFilter
 
recalculate(Distance, Distance) - Method in interface ostore.introspect.SemanticDistanceModel.Filter
Update the age of the model as a function of the previous_age value and the increment amount of time since the last call to this function.
recalculate(SemanticDistanceModel.Tuple, Distance, Distance) - Method in class ostore.introspect.WeightedAvgFilter
 
recalculate(SemanticDistanceModel.Tuple, Distance, Distance) - Method in interface ostore.introspect.SemanticDistanceModel.Filter
Recalcualate the semantic distance and weight of a tuple given the tuple's contents (distance and previous weight) the new observed value.
recalculate(SemanticDistanceModel.Tuple, Distance, Set) - Method in class ostore.introspect.WeightedAvgFilter
 
recalculate(SemanticDistanceModel.Tuple, Distance, Set) - Method in interface ostore.introspect.SemanticDistanceModel.Filter
Recalculate the semantic distance given the old distance and the new observed values (in order).
recalculation_maxobs - Variable in class ostore.introspect.SDMBuilder
The number of events to observe before recalculating model parameters.
recalculation_period - Variable in class ostore.introspect.SDMBuilder
The time (ms) between RebuildSignals are received.
recalculation_period - Variable in class ostore.oil.HMMBuilder
The number of events to observe before recalculating model parameters.
recalculation_signal - Variable in class ostore.introspect.SDMBuilder
Recalculate the model when we get a Signal.RBLD (meaning the machine is "not busy")
receivedAllAcks(double) - Method in class ostore.archive.FragmentBucket
ReceivedAllAcks returns true if all disseminated fragments have been ack'd otherwise returns false.
receivedAllAcks(double) - Method in interface ostore.archive.DisseminatableBucket
receivedAllAcks returns true if all Disseminatables have been ack'd otherwise returns false.
receiver - Variable in class ostore.dispatch.Classifier.SlowLink
The name of the receiving stage
RECEIVER - Static variable in class ostore.network.LatTest
 
RECEIVING_UPDATES - Static variable in class ostore.replica.Replica
The value for dtree_status when this node is fully connected to the dissemination tree, receiving all updates from the inner ring.
RECOALESCE_BLK_STAGE - Static variable in class ostore.util.StageId
 
RecoalesceBlkCancel - class ostore.archive.events.RecoalesceBlkCancel.
RecoalesceBlkCancel is an event class indicates that the requests to recoalesce a block from fragments should be cancelled.
RecoalesceBlkCancel() - Constructor for class ostore.archive.events.RecoalesceBlkCancel
Constructor: Initializes instance variables to null.
RecoalesceBlkCancel(CacheableIdentity) - Constructor for class ostore.archive.events.RecoalesceBlkCancel
Constructor.
RecoalesceBlkCancel(InputBuffer) - Constructor for class ostore.archive.events.RecoalesceBlkCancel
Constructs a RecoalesceBlkCancel from its serialized form.
RecoalesceBlkReq - class ostore.archive.events.RecoalesceBlkReq.
RecoalesceBlkReq is an event class that requests a block be recoalesced from its Fragments stored in the cache.
RecoalesceBlkReq() - Constructor for class ostore.archive.events.RecoalesceBlkReq
Constructor: Initializes instance variables to null.
RecoalesceBlkReq(CacheableIdentity, DisseminatableBucket, Object, SinkIF) - Constructor for class ostore.archive.events.RecoalesceBlkReq
Constructor.
RecoalesceBlkReq(InputBuffer) - Constructor for class ostore.archive.events.RecoalesceBlkReq
Constructs a RecoalesceBlkReq from its serialized form.
RecoalesceBlkStage - class ostore.archive.RecoalesceBlkStage.
 
RecoalesceBlkStage() - Constructor for class ostore.archive.RecoalesceBlkStage
 
ReconstructBlkCancel - class ostore.archive.events.ReconstructBlkCancel.
ReconstructBlkCancel is an event class indicates that the requests to pull a block out of the archive should be cancelled.
ReconstructBlkCancel() - Constructor for class ostore.archive.events.ReconstructBlkCancel
Constructor: Initializes instance variables to null.
ReconstructBlkCancel(CacheableIdentity) - Constructor for class ostore.archive.events.ReconstructBlkCancel
Constructor.
ReconstructBlkCancel(InputBuffer) - Constructor for class ostore.archive.events.ReconstructBlkCancel
Constructs a ReconstructBlkCancel from its serialized form.
ReconstructBlkReq - class ostore.archive.events.ReconstructBlkReq.
ReconstructBlkReq is an event class that requests a block be pulled out of the archive and recoalesced.
ReconstructBlkReq() - Constructor for class ostore.archive.events.ReconstructBlkReq
Constructor: Initializes instance variables to null.
ReconstructBlkReq(CacheableIdentity, SecureHash, Object, SinkIF) - Constructor for class ostore.archive.events.ReconstructBlkReq
Constructor.
ReconstructBlkReq(InputBuffer) - Constructor for class ostore.archive.events.ReconstructBlkReq
Constructs a ReconstructBlkReq from its serialized form.
ReconstructBlkResp - class ostore.archive.events.ReconstructBlkResp.
ReconstructBlkResp is an event class that responds to a ReconstructBlkReq once the block has been recoalesced.
ReconstructBlkResp() - Constructor for class ostore.archive.events.ReconstructBlkResp
Constructor: Initializes instance variables to null.
ReconstructBlkResp(CacheableIdentity, CacheablePinned, Object) - Constructor for class ostore.archive.events.ReconstructBlkResp
Constructor.
ReconstructBlkResp(InputBuffer) - Constructor for class ostore.archive.events.ReconstructBlkResp
Constructs a ReconstructBlkResp from its serialized form.
record_bytes(Map, NodeId, int, Object) - Method in class ostore.network.Network
 
record(BtreeNode, Object, int, HandleStore, DataCache) - Method in class ostore.archive.TputGenerateChkptTest.RemoveGuidsHelper
During a DFS, this method is called to record a result produced by the Callback interface.
record(BtreeNode, Object, int, HandleStore, DataCache) - Method in interface ostore.dataobj.Btree.Record
 
record(QuickSerializable) - Method in class ostore.introspect.SemanticDistanceModel
 
record(QuickSerializable) - Method in interface ostore.introspect.ContinuousModel
This method assumes the observation occurred at time now.
record(QuickSerializable) - Method in class ostore.oil.Screen
Records an object from the event stream (does not process).
record(QuickSerializable) - Method in interface ostore.oil.Model
Notes an observation for later processing.
record(QuickSerializable) - Method in class ostore.oil.HMM
 
record(QuickSerializable[]) - Method in class ostore.introspect.SemanticDistanceModel
 
record(QuickSerializable[]) - Method in interface ostore.introspect.ContinuousModel
This method assumes the observations occurred at time now.
record(QuickSerializable[]) - Method in class ostore.oil.Screen
Processes a group of objects from the event stream.
record(QuickSerializable[]) - Method in interface ostore.oil.Model
Notes a group of observations for later processing.
record(QuickSerializable[]) - Method in class ostore.oil.HMM
 
record(QuickSerializable[], Time) - Method in class ostore.introspect.SemanticDistanceModel
 
record(QuickSerializable[], Time) - Method in interface ostore.introspect.ContinuousModel
Record the observations and mark that they occurred at a particular time.
record(QuickSerializable, Time) - Method in class ostore.introspect.SemanticDistanceModel
 
record(QuickSerializable, Time) - Method in interface ostore.introspect.ContinuousModel
Record the observation and mark that it occurred at a particular time.
RecordBytesMsg - class ostore.network.RecordBytesMsg.
Tell the Network stage about a message it would not have otherwise seen (i.e. because it was sent over UDP, etc.)
RecordBytesMsg(NetworkMessage) - Constructor for class ostore.network.RecordBytesMsg
 
RecordBytesMsg(NetworkMessage, long) - Constructor for class ostore.network.RecordBytesMsg
 
RecordEventReq - class ostore.introspect.RecordEventReq.
Request that the local SDMBuilder model record an event.
RecordEventReq.EventId - class ostore.introspect.RecordEventReq.EventId.
Simple class to identify event types.
RecordEventReq.EventId(InputBuffer) - Constructor for class ostore.introspect.RecordEventReq.EventId
 
RecordEventReq.EventId(int) - Constructor for class ostore.introspect.RecordEventReq.EventId
New eventid identified by code
RecordEventReq.EventId(String) - Constructor for class ostore.introspect.RecordEventReq.EventId
New eventid identified by fourcc.
RecordEventReq(InputBuffer) - Constructor for class ostore.introspect.RecordEventReq
 
RecordEventReq(String, QuickSerializable, Time) - Constructor for class ostore.introspect.RecordEventReq
Record that an event identified by id occurred at time t.
RecordEventReq(String, String, Time) - Constructor for class ostore.introspect.RecordEventReq
Record that an event of type fourcc occurred at time t.
recordMapping(CacheablePinned, CacheableIdentity) - Method in class ostore.dataobj.HandleStore
 
recp - Variable in class ostore.apps.qtree.impl.QTreeCloseMsg
 
recreateTree(TreeKey, GuidAddr, boolean, QSVector) - Method in class ostore.apps.qtree.impl.QTree
 
recv(Disseminatable) - Method in class ostore.archive.FragmentBucket
Receive a disseminatable object (presumably from the network) and add it to this bucket.
recv(Disseminatable) - Method in interface ostore.archive.DisseminatableBucket
recv receives a Disseminatable (presumably from the network) and adds it to this bucket.
referenced() - Method in class ostore.cache.CachePolicy.Line
 
REGISTER - Static variable in class ostore.apps.traces.TraceClient.LocateMasterMsg
 
register_type(Class) - Static method in class ostore.util.TypeTable
 
register_type(String) - Static method in class ostore.util.TypeTable
Register a new type, so that TypeTable.new_object(ostore.util.InputBuffer) can be called later.
register(int, String, SinkIF) - Method in class ostore.dispatch.Signal
Subscribes the specified sink to signals of the specified type which have the specified target.
registerAllTypes() - Static method in class ostore.util.Types
 
rehash() - Method in class ostore.util.IntHashtable
Rehashes the contents of the hashtable into a hashtable with a larger capacity.
RejectHint - class ostore.inner.RejectHint.
 
RejectHint(InputBuffer) - Constructor for class ostore.inner.RejectHint
 
RejectHint(SecureHash, QuickSerializable, boolean, boolean, boolean) - Constructor for class ostore.inner.RejectHint
 
rejection - Variable in class ostore.inner.RejectHint
 
REJOIN_DISTANCE_FACTOR - Static variable in class ostore.dtree.DTreeNode
The factor by which a single tree rejoin action can increase this node's total latency from the tree root.
release_all_blocks() - Method in class ostore.replica.Replica
Surrenders all cache state.
release_blocks(int) - Method in class ostore.replica.Replica
Surrenders cache state.
remember(QueueElementIF, long) - Method in class ostore.dispatch.Resender
Waits millis milliseconds, then stores the event in the trash pile.
remember(QueueElementIF, long, Map, Object) - Method in class ostore.dispatch.Resender
Waits millis milliseconds, then stores the event in the trash pile.
remember(QueueElementIF, long, Map, Set) - Method in class ostore.dispatch.Resender
Waits millis milliseconds, then stores the event in the trash pile.
RemoteCacheReplyMessage - class ostore.dtree.RemoteCacheReplyMessage.
The RemoteCacheReplyMessage is a message sent by the cache in repsonse to a RemoteCacheReplyMessage.
RemoteCacheReplyMessage(InputBuffer) - Constructor for class ostore.dtree.RemoteCacheReplyMessage
 
RemoteCacheReplyMessage(VID, Cacheable) - Constructor for class ostore.dtree.RemoteCacheReplyMessage
 
RemoteCacheRequestMessage - class ostore.dtree.RemoteCacheRequestMessage.
The RemoteCacheRequestMessage is a message sent by the cache to request a block known only by its vhash.
RemoteCacheRequestMessage(InputBuffer) - Constructor for class ostore.dtree.RemoteCacheRequestMessage
 
RemoteCacheRequestMessage(SecureHash, VID) - Constructor for class ostore.dtree.RemoteCacheRequestMessage
 
RemoteReplicaCloseAllReq - class ostore.replica.RemoteReplicaCloseAllReq.
HACK: Send a ReplicaCloseAll request to a remote replica
RemoteReplicaCloseAllReq(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaCloseAllReq
 
RemoteReplicaCloseAllReq(SecureHash, int, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaCloseAllReq
 
RemoteReplicaCloseAllResp - class ostore.replica.RemoteReplicaCloseAllResp.
HACK: Response to a RemoteReplicaCloseAllReq.
RemoteReplicaCloseAllResp(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaCloseAllResp
 
RemoteReplicaCloseAllResp(RemoteReplicaCloseAllReq, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaCloseAllResp
 
RemoteReplicaCreateReception - class ostore.replica.RemoteReplicaCreateReception.
Response to a remote replica that issued a request to create an object tentatively at this replica.
RemoteReplicaCreateReception(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaCreateReception
 
RemoteReplicaCreateReception(SecureHash, ReplicaCreateReq, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaCreateReception
 
RemoteReplicaCreateReq - class ostore.replica.RemoteReplicaCreateReq.
Request to a remote ReplicaStage to tentatively create an object.
RemoteReplicaCreateReq(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaCreateReq
 
RemoteReplicaCreateReq(SecureHash, ReplicaCreateReq, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaCreateReq
 
RemoteReplicaCreateResp - class ostore.replica.RemoteReplicaCreateResp.
Response to a RemoteReplicaRequest to the remote client when we have applied the tentative creation.
RemoteReplicaCreateResp(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaCreateResp
 
RemoteReplicaCreateResp(SecureHash, ReplicaCreateResp, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaCreateResp
 
RemoteReplicaOpenReq - class ostore.replica.RemoteReplicaOpenReq.
 
RemoteReplicaOpenReq(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaOpenReq
 
RemoteReplicaOpenReq(SecureHash, boolean, int, SecureHash, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaOpenReq
 
RemoteReplicaOpenReq(SecureHash, SecureHash, boolean, int, SecureHash, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaOpenReq
 
RemoteReplicaOpenResp - class ostore.replica.RemoteReplicaOpenResp.
 
RemoteReplicaOpenResp(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaOpenResp
 
RemoteReplicaOpenResp(RemoteReplicaOpenReq, SecureHash, Heartbeat, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaOpenResp
 
RemoteReplicaOpenResp(RemoteReplicaOpenReq, SecureHash, int, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaOpenResp
 
RemoteReplicaOpenResp(RemoteReplicaProbe, SecureHash, Heartbeat, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaOpenResp
 
RemoteReplicaProbe - class ostore.replica.RemoteReplicaProbe.
 
RemoteReplicaProbe(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaProbe
 
RemoteReplicaProbe(SecureHash, SecureHash, int, boolean, boolean, boolean, byte, byte, VirtualCoordinate) - Constructor for class ostore.replica.RemoteReplicaProbe
 
RemoteReplicaProbe(SecureHash, SecureHash, SecureHash, int, boolean, boolean, boolean, byte, byte, VirtualCoordinate) - Constructor for class ostore.replica.RemoteReplicaProbe
 
RemoteReplicaProbeQuery - class ostore.replica.RemoteReplicaProbeQuery.
 
RemoteReplicaProbeQuery() - Constructor for class ostore.replica.RemoteReplicaProbeQuery
 
RemoteReplicaProbeQuery(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaProbeQuery
 
RemoteReplicaProbeQueryState - class ostore.replica.RemoteReplicaProbeQueryState.
Used if we are explicitly routing the probe to a particular peer.
RemoteReplicaProbeQueryState(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaProbeQueryState
 
RemoteReplicaProbeQueryState(SecureHash, SecureHash) - Constructor for class ostore.replica.RemoteReplicaProbeQueryState
 
RemoteReplicaUpdateReception - class ostore.replica.RemoteReplicaUpdateReception.
Response to a remote replica that issued a request to update an object(s) tentatively at this replica.
RemoteReplicaUpdateReception(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaUpdateReception
 
RemoteReplicaUpdateReception(SecureHash, ReplicaUpdateReq, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaUpdateReception
 
RemoteReplicaUpdateReq - class ostore.replica.RemoteReplicaUpdateReq.
A message sent by the ReplicaStage to a the ReplicaStage of a remote node.
RemoteReplicaUpdateReq(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaUpdateReq
Deserialize from buffer.
RemoteReplicaUpdateReq(SecureHash, ReplicaUpdateReq, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaUpdateReq
 
RemoteReplicaUpdateResp - class ostore.replica.RemoteReplicaUpdateResp.
A response to a RemoteReplicaUpdateReq to a remote client when we have finished applying the tentative update.
RemoteReplicaUpdateResp(InputBuffer) - Constructor for class ostore.replica.RemoteReplicaUpdateResp
 
RemoteReplicaUpdateResp(SecureHash, ReplicaUpdateResp, boolean, boolean, boolean) - Constructor for class ostore.replica.RemoteReplicaUpdateResp
 
REMOVE - Static variable in class ostore.cache.CacheNotify
 
remove_all() - Method in class ostore.oil.Screen
Removes all keys from the screened set.
remove() - Method in class ostore.apps.traces.SurgeIterator
Specified by java.util.Iterator
remove() - Method in class ostore.apps.traces.SetupIterator
 
remove() - Method in class ostore.apps.traces.MobileUserIterator
 
remove() - Method in class ostore.apps.traces.INS_NFS_Iterator
Specified by java.util.Iterator
remove() - Method in class ostore.apps.traces.INS_NFS_ASCII_Iterator
Specified by java.util.Iterator
remove(CachePolicy.Line) - Method in interface ostore.cache.CachePolicy
Manually remove a line.
remove(CachePolicy.Line) - Method in class ostore.cache.ClockAlgorithm
 
remove(int) - Method in class ostore.util.QSVector
Remove the object at the specified index.
remove(int) - Method in class ostore.util.IntHashtable
Removes the key (and its corresponding value) from this hashtable.
remove(Object) - Method in class ostore.util.LruMap
Specified by java.util.Map
remove(Object) - Method in class ostore.util.MultiMap
 
remove(Object) - Method in class ostore.util.PriorityQueue
removes the given object from the priority queue. returns true if the object was found and removed, false otherwise.
remove(QuickSerializable) - Method in class ostore.introspect.SemanticDistanceModel.BoundedPrioQueue
Remove a tuple.
remove(QuickSerializable) - Method in class ostore.oil.Screen
Removes a key from the screened set.
remove(QuickSerializable) - Method in class ostore.oil.Matrix
Removes the row associated with id from this Matrix, and returns the removed row.
remove(QuickSerializable) - Method in class ostore.oil.Array
Removes the value indexed by the specified ID
remove(QuickSerializable) - Method in class ostore.util.QSHashMap
Removes the given key mapping from this map if it is present.
remove(QuickSerializable) - Method in class ostore.util.QSTreeSet
Removes the given element from this set if it is present.
removeAll(Collection) - Method in class ostore.util.QSTreeSet
Removes from this set all of its elements that are contained in the specified collection (optional operation).
removeAll(Object) - Method in class ostore.util.PriorityQueue
removes every instance the given object from the priority queue.
removeAll(QSTreeSet) - Method in class ostore.util.QSTreeSet
 
removeAllElements() - Method in class ostore.util.QSVector
Remove all elements.
removeClassifier(NodeId) - Static method in class ostore.dispatch.Classifier
Deletes the Classifier instance corresponding to a NodeId.
removed - Variable in class ostore.apps.qtree.impl.QTree.ParentEvent
 
removed - Variable in class ostore.apps.qtree.impl.QTree.ChildrenEvent
 
removeFromStore(CacheablePinned) - Method in class ostore.dataobj.HandleStore
 
removeInstance(NodeId) - Static method in class ostore.cache.LRUCache
Deletes the cache instance corresponding to a NodeId.
removeLast() - Method in class ostore.introspect.SemanticDistanceModel.BoundedPrioQueue
Remove the last element in the prio queue
removePendingBlk(SecureHash) - Method in class ostore.archive.ArchiveObjBucket
removePendingBlk removes the block associated with the block GUID from the list of pending blks.
removeRange(int, int) - Method in class ostore.util.QSVector
Remove a range of elements.
removeSignal(NodeId) - Static method in class ostore.dispatch.Signal
Deletes the Signal instance corresponding to a NodeId.
removeType(SecureHash) - Method in class ostore.archive.ArchiveObjBucket
removeType removes the block type associated with the block GUID.
REPLACE - Static variable in class ostore.apps.traces.TraceIterator
 
replace(BtreeKey, BtreeNode, CacheablePinned, HandleStore, DataCache, LinkedList) - Method in class ostore.dataobj.Btree
 
replace(BtreeKey, BtreeNode, HandleStore, DataCache) - Method in class ostore.dataobj.Btree
 
replace(InputBuffer, int, int, DataObjectReplaceException, CacheablePinned, DataCache) - Method in class ostore.dataobj.DataObject
 
ReplaceMicroBenchmark - class ostore.apps.test.ReplaceMicroBenchmark.
The ReplaceMicroBenchmark reports the results of a simple microbenchmark that performs a number of replace operations on a single data object.
ReplaceMicroBenchmark() - Constructor for class ostore.apps.test.ReplaceMicroBenchmark
 
Replica - class ostore.replica.Replica.
Stores the Heartbeats, etc. used by the ReplicaStage to handle client requests for a replica.
REPLICA - Static variable in class ostore.util.DebugFlags
 
REPLICA_MANAGER - Static variable in class ostore.util.DebugFlags
 
REPLICA_STAGE - Static variable in class ostore.util.StageId
 
REPLICA_STAGE - Static variable in class ostore.util.DebugFlags
 
Replica(SecureHash) - Constructor for class ostore.replica.Replica
Constructs a new Replica.
ReplicaBytesReadReq - class ostore.read.ReplicaBytesReadReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to read a portion of a Replica and return the bytes read.
ReplicaBytesReadReq(InputBuffer) - Constructor for class ostore.read.ReplicaBytesReadReq
Constructs a ReplicaBytesReadReq from its serialized form.
ReplicaBytesReadReq(SecureHash, VersionPredicate, Selection, byte) - Constructor for class ostore.read.ReplicaBytesReadReq
Constructs a new ReplicaBytesReadReq.
ReplicaBytesReadResp - class ostore.read.ReplicaBytesReadResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaBytesReadReq events.
ReplicaBytesReadResp(InputBuffer) - Constructor for class ostore.read.ReplicaBytesReadResp
Constructs a ReplicaBytesReadResp from its serialized form.
ReplicaBytesReadResp(ReplicaReadReq, int) - Constructor for class ostore.read.ReplicaBytesReadResp
Constructs a new (failed) ReplicaBytesReadResp.
ReplicaBytesReadResp(ReplicaReadReq, VID, Selection, Selection, byte[][]) - Constructor for class ostore.read.ReplicaBytesReadResp
Constructs a new (successful) ReplicaBytesReadResp.
ReplicaCloseAllReq - class ostore.replica.ReplicaCloseAllReq.
HACK: Request from client to clear all the replicas out of the replica stage.
ReplicaCloseAllReq() - Constructor for class ostore.replica.ReplicaCloseAllReq
Constructs a new ReplicaCloseAllReq.
ReplicaCloseAllReq(InputBuffer) - Constructor for class ostore.replica.ReplicaCloseAllReq
Constructs a ReplicaCloseAllReq from its serialized form.
ReplicaCloseAllResp - class ostore.replica.ReplicaCloseAllResp.
HACK: A response to the client for a ReplicaCloseAllReq.
ReplicaCloseAllResp(InputBuffer) - Constructor for class ostore.replica.ReplicaCloseAllResp
Constructs a ReplicaCloseResp from its serialized form.
ReplicaCloseAllResp(ReplicaCloseAllReq) - Constructor for class ostore.replica.ReplicaCloseAllResp
Constructs a new (successful) ReplicaCloseResp.
ReplicaCloseReq - class ostore.replica.ReplicaCloseReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to remove a local Replica.
ReplicaCloseReq(InputBuffer) - Constructor for class ostore.replica.ReplicaCloseReq
Constructs a ReplicaCloseReq from its serialized form.
ReplicaCloseReq(SecureHash) - Constructor for class ostore.replica.ReplicaCloseReq
Constructs a new ReplicaCloseReq.
ReplicaCloseResp - class ostore.replica.ReplicaCloseResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaCloseReq events.
ReplicaCloseResp(InputBuffer) - Constructor for class ostore.replica.ReplicaCloseResp
Constructs a ReplicaCloseResp from its serialized form.
ReplicaCloseResp(ReplicaCloseReq) - Constructor for class ostore.replica.ReplicaCloseResp
Constructs a new (successful) ReplicaCloseResp.
ReplicaCloseResp(ReplicaCloseReq, int) - Constructor for class ostore.replica.ReplicaCloseResp
Constructs a new (failed) ReplicaCloseResp.
ReplicaCreateReq - class ostore.replica.ReplicaCreateReq.
Events sent from the ClientStage to the ReplicaStage containing a signed request to create a new object.
ReplicaCreateReq(InputBuffer) - Constructor for class ostore.replica.ReplicaCreateReq
Constructs a ReplicaCreateReq from its serialized form.
ReplicaCreateReq(SecureHash, SignedQS, QSArray) - Constructor for class ostore.replica.ReplicaCreateReq
Constructs a new ReplicaCreateReq.
ReplicaCreateResp - class ostore.replica.ReplicaCreateResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaCreateReq events.
ReplicaCreateResp(InputBuffer) - Constructor for class ostore.replica.ReplicaCreateResp
Constructs a ReplicaCreateResp from its serialized form.
ReplicaCreateResp(ReplicaCreateReq, CreateObjectResp) - Constructor for class ostore.replica.ReplicaCreateResp
Constructs a new (successful) ReplicaCreateResp.
ReplicaCreateResp(ReplicaCreateReq, SecureHash) - Constructor for class ostore.replica.ReplicaCreateResp
Constructs a new (successful) ReplicaCreateResp for a tentatively create object.
ReplicaManager - class ostore.replica.ReplicaManager.
A SandStorm stage which manages the set of replicas maintained by this machine.
ReplicaManager() - Constructor for class ostore.replica.ReplicaManager
 
ReplicaMetadataReadReq - class ostore.read.ReplicaMetadataReadReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to return the Metadata object for a Replica.
ReplicaMetadataReadReq(InputBuffer) - Constructor for class ostore.read.ReplicaMetadataReadReq
Constructs a ReplicaMetadataReadReq from its serialized form.
ReplicaMetadataReadReq(SecureHash, VersionPredicate, byte) - Constructor for class ostore.read.ReplicaMetadataReadReq
Constructs a new ReplicaMetadataReadReq.
ReplicaMetadataReadResp - class ostore.read.ReplicaMetadataReadResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaMetadataReadReq events.
ReplicaMetadataReadResp(InputBuffer) - Constructor for class ostore.read.ReplicaMetadataReadResp
Constructs a ReplicaMetadataReadResp from its serialized form.
ReplicaMetadataReadResp(ReplicaReadReq, int) - Constructor for class ostore.read.ReplicaMetadataReadResp
Constructs a new (failed) ReplicaMetadataReadResp.
ReplicaMetadataReadResp(ReplicaReadReq, VID, Metadata) - Constructor for class ostore.read.ReplicaMetadataReadResp
Constructs a new (successful) ReplicaMetadataReadResp.
ReplicaOpenReq - class ostore.replica.ReplicaOpenReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to create a local Replica.
ReplicaOpenReq(InputBuffer) - Constructor for class ostore.replica.ReplicaOpenReq
Constructs a ReplicaOpenReq from its serialized form.
ReplicaOpenReq(SecureHash, boolean) - Constructor for class ostore.replica.ReplicaOpenReq
Constructs a new ReplicaOpenReq.
ReplicaOpenResp - class ostore.replica.ReplicaOpenResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaOpenReq events.
ReplicaOpenResp(InputBuffer) - Constructor for class ostore.replica.ReplicaOpenResp
Constructs a ReplicaOpenResp from its serialized form.
ReplicaOpenResp(ReplicaOpenReq, Heartbeat) - Constructor for class ostore.replica.ReplicaOpenResp
Constructs a new (successful) ReplicaOpenResp.
ReplicaOpenResp(ReplicaOpenReq, int) - Constructor for class ostore.replica.ReplicaOpenResp
Constructs a new (failed) ReplicaOpenResp.
ReplicaQuery - class ostore.replica.ReplicaQuery.
The DD query sent to find object replicas.
ReplicaQuery() - Constructor for class ostore.replica.ReplicaQuery
Creates a new ReplicaQuery.
ReplicaQuery(InputBuffer) - Constructor for class ostore.replica.ReplicaQuery
Constructs a ReplicaQuery from its serialized form.
ReplicaQuery(QSInt, Double) - Constructor for class ostore.replica.ReplicaQuery
Creates a new ReplicaQuery with an upper bound on the depth of replicas in the tree.
ReplicaReadReq - class ostore.read.ReplicaReadReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to read a portion of a Replica.
ReplicaReadReq(InputBuffer) - Constructor for class ostore.read.ReplicaReadReq
Constructs a ReplicaReadReq from its serialized form.
ReplicaReadReq(SecureHash, VersionPredicate, Selection, byte) - Constructor for class ostore.read.ReplicaReadReq
Constructs a new ReplicaReadReq.
ReplicaReadResp - class ostore.read.ReplicaReadResp.
A superclass for events sent from the ReplicaStage to the ClientStage responding to ReplicaReadReq events.
ReplicaReadResp(InputBuffer) - Constructor for class ostore.read.ReplicaReadResp
Constructs a ReplicaReadResp from its serialized form.
ReplicaReadResp(ReplicaReadReq, int) - Constructor for class ostore.read.ReplicaReadResp
Constructs a new (failed) ReplicaReadResp.
ReplicaReadResp(ReplicaReadReq, VID, Selection, Selection) - Constructor for class ostore.read.ReplicaReadResp
Constructs a new (successful) ReplicaReadResp.
ReplicaReq - class ostore.replica.ReplicaReq.
A superclass of all requests sent to the ReplicaStage by the ClientStage, or possibly a remote ReplicaStage.
ReplicaReq(InputBuffer) - Constructor for class ostore.replica.ReplicaReq
Constructs a ReplicaReq from its serialized form.
ReplicaReq(SecureHash) - Constructor for class ostore.replica.ReplicaReq
Constructs a new ReplicaReq.
ReplicaResp - class ostore.replica.ReplicaResp.
A superclass of all responses sent from the ReplicaStage back to the ClientStage or remote ReplicaStage.
ReplicaResp(InputBuffer) - Constructor for class ostore.replica.ReplicaResp
Constructs a ReplicaResp from its serialized form.
ReplicaResp(ReplicaReq, int) - Constructor for class ostore.replica.ReplicaResp
Constructs a ReplicaResp for the specified ReplicaReq.
ReplicaResp(SecureHash, SecureHash, int) - Constructor for class ostore.replica.ReplicaResp
Constructs a new ReplicaResp.
ReplicaSliceReadReq - class ostore.read.ReplicaSliceReadReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to read a portion of a Replica and return the blocks from the entire slice required to verify the read.
ReplicaSliceReadReq(InputBuffer) - Constructor for class ostore.read.ReplicaSliceReadReq
Constructs a ReplicaSliceReadReq from its serialized form.
ReplicaSliceReadReq(SecureHash, VersionPredicate, Selection, byte) - Constructor for class ostore.read.ReplicaSliceReadReq
Constructs a new ReplicaSliceReadReq.
ReplicaSliceReadResp - class ostore.read.ReplicaSliceReadResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaSliceReadReq events.
ReplicaSliceReadResp(InputBuffer) - Constructor for class ostore.read.ReplicaSliceReadResp
Constructs a ReplicaSliceReadResp from its serialized form.
ReplicaSliceReadResp(ReplicaReadReq, int) - Constructor for class ostore.read.ReplicaSliceReadResp
Constructs a new (failed) ReplicaSliceReadResp.
ReplicaSliceReadResp(ReplicaReadReq, VID, Selection, Selection, Map) - Constructor for class ostore.read.ReplicaSliceReadResp
Constructs a new (successful) ReplicaSliceReadResp.
ReplicaStage - class ostore.replica.ReplicaStage.
A template java file, useful for maintaining personal coding conventions for new EventHandlerIF classes.
ReplicaStage.PendingCloseTimer - class ostore.replica.ReplicaStage.PendingCloseTimer.
Dispatched to self when a close_all was received but we are still waiting on pending events.
ReplicaStage.PendingCloseTimer() - Constructor for class ostore.replica.ReplicaStage.PendingCloseTimer
 
ReplicaStage() - Constructor for class ostore.replica.ReplicaStage
Constructs an empty ReplicaStage.
ReplicaTag - class ostore.replica.ReplicaTag.
The Tapestry tag published by object replicas (second-tier and clients).
ReplicaTag(InputBuffer) - Constructor for class ostore.replica.ReplicaTag
Constructs a ReplicaTag from its serialized form.
ReplicaTag(QSInt) - Constructor for class ostore.replica.ReplicaTag
Creates a new ReplicaTag.
ReplicaUpdateReq - class ostore.replica.ReplicaUpdateReq.
Events sent from the ClientStage to the ReplicaStage containing an update request for the inner ring.
ReplicaUpdateReq(InputBuffer) - Constructor for class ostore.replica.ReplicaUpdateReq
Constructs a ReplicaUpdateReq from its serialized form.
ReplicaUpdateReq(SecureHash, SignedQS) - Constructor for class ostore.replica.ReplicaUpdateReq
Constructs a new ReplicaUpdateReq.
ReplicaUpdateResp - class ostore.replica.ReplicaUpdateResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaUpdateReq events.
ReplicaUpdateResp(InputBuffer) - Constructor for class ostore.replica.ReplicaUpdateResp
Constructs a ReplicaUpdateResp from its serialized form.
ReplicaUpdateResp(ReplicaUpdateReq, UpdateResp) - Constructor for class ostore.replica.ReplicaUpdateResp
Constructs a new (successful) ReplicaUpdateResp.
ReplicaVersionQueryReq - class ostore.read.ReplicaVersionQueryReq.
Events sent from the ClientStage to the ReplicaStage requesting the latter to return just a VID for a Replica.
ReplicaVersionQueryReq(InputBuffer) - Constructor for class ostore.read.ReplicaVersionQueryReq
Constructs a ReplicaVersionQueryReq from its serialized form.
ReplicaVersionQueryReq(SecureHash, VersionPredicate, byte) - Constructor for class ostore.read.ReplicaVersionQueryReq
Constructs a new ReplicaVersionQueryReq.
ReplicaVersionQueryResp - class ostore.read.ReplicaVersionQueryResp.
Events sent from the ReplicaStage to the ClientStage responding to ReplicaVersionQueryReq events.
ReplicaVersionQueryResp(InputBuffer) - Constructor for class ostore.read.ReplicaVersionQueryResp
Constructs a ReplicaVersionQueryResp from its serialized form.
ReplicaVersionQueryResp(ReplicaReadReq, int) - Constructor for class ostore.read.ReplicaVersionQueryResp
Constructs a new (failed) ReplicaVersionQueryResp.
ReplicaVersionQueryResp(ReplicaReadReq, VID) - Constructor for class ostore.read.ReplicaVersionQueryResp
Constructs a new (successful) ReplicaVersionQueryResp.
req - Variable in class ostore.agree.ForwardMsg
 
req - Variable in class ostore.agree.AgreementInit
 
req - Variable in class ostore.agree.AgreementForward
 
req - Variable in class ostore.agree.AgreementFailure
 
req - Variable in class ostore.agree.AgreementExecuteReq
 
req - Variable in class ostore.cache.StorageManager.GetBlockCompleted
 
req - Variable in class ostore.cache.StorageManager.PutBlockCompleted
 
req - Variable in class ostore.archive.dissemination.DisseminateFragMsg.Local
The original DisseminateFragMsg.
req_digest - Variable in class ostore.agree.ResultMsg
 
req_digest - Variable in class ostore.agree.PrepareMsg
 
req_digest - Variable in class ostore.agree.CommitMsg
 
req_digest - Variable in class ostore.agree.AgreementSuccess
 
req_digest - Variable in class ostore.agree.AgreementInit
 
req_digest - Variable in class ostore.agree.AgreementForward
 
req_digest - Variable in class ostore.agree.AgreementExecuteResp
 
req_digest - Variable in class ostore.agree.AgreementExecuteReq
 
req_digest - Variable in class ostore.dtree.DTreeResp
A digest of the corresponding DTreeReq.
req_digest - Variable in class ostore.inner.UpdateReject
 
req_digest - Variable in class ostore.inner.LatestHeartbeatReject
 
req_digest - Variable in class ostore.inner.CreateObjectResp
 
req_digest - Variable in class ostore.inner.CreateObjectReject
 
req_digest - Variable in class ostore.read.ReadResp
A digest of the corresponding ReadReq.
req_digest - Variable in class ostore.replica.ReplicaResp
A digest of the corresponding ReplicaReq.
req_digest() - Method in class ostore.replica.RemoteReplicaUpdateReception
 
req_digest() - Method in class ostore.replica.RemoteReplicaCreateReception
 
req_digest(int) - Method in class ostore.agree.AgreementState
 
req_digests - Variable in class ostore.agree.PreprepareMsg
 
req_state - Variable in class ostore.apps.qtree.api.QTreeStateLocal
 
req_state - Variable in class ostore.apps.qtree.api.QTreeStateMsg
 
req() - Method in class ostore.inner.LatestHeartbeatReqMsg
 
req() - Method in class ostore.replica.RemoteReplicaUpdateReq
Get the signed Update.
req() - Method in class ostore.replica.RemoteReplicaCreateReq
Get the ReplicaCreateReq contained in this message.
req() - Method in class ostore.rp.ObjectCreateReqMsg
 
req() - Method in class ostore.rp.CreateObjectReqMsg
 
req(int) - Method in class ostore.agree.AgreementState
 
request - Variable in class ostore.introspect.MessageBundle
 
RequestDisseminationSetMsg - class ostore.archive.dissemination.RequestDisseminationSetMsg.
RequestDisseminationSetMsg is used to request that a SetCreator send a dissemination set.
RequestDisseminationSetMsg(InputBuffer) - Constructor for class ostore.archive.dissemination.RequestDisseminationSetMsg
Constructs a RequestDisseminationSetMsg from its serialized form.
RequestDisseminationSetMsg(SecureHash, SecureHash, DisseminationSetPredicate, boolean, boolean, boolean, byte, byte, VirtualCoordinate) - Constructor for class ostore.archive.dissemination.RequestDisseminationSetMsg
Construct according to the given fields.
RequestDisseminationSetQuery - class ostore.archive.dissemination.RequestDisseminationSetQuery.
RequestDisseminationSetQuery is a DDQuery used in a RequestDisseminationSetMsg DDLocateMsg used to find a SetCreator that will respond with a set of dissemination sets.
RequestDisseminationSetQuery() - Constructor for class ostore.archive.dissemination.RequestDisseminationSetQuery
Creates a new RequestDisseminationSetQuery.
RequestDisseminationSetQuery(InputBuffer) - Constructor for class ostore.archive.dissemination.RequestDisseminationSetQuery
Constructs a RequestDisseminationSetQuery from its serialized form.
RequestDisseminationSetResponseMsg - class ostore.archive.dissemination.RequestDisseminationSetResponseMsg.
RequestDisseminationSetResponseMsg is the SetCreators response a RequestDisseminationSetMsg and containing a set of send a dissemination sets.
RequestDisseminationSetResponseMsg(InputBuffer) - Constructor for class ostore.archive.dissemination.RequestDisseminationSetResponseMsg
Constructs a RequestDisseminationSetResponseMsg from its serialized form.
RequestDisseminationSetResponseMsg(SecureHash, Set, SecureHash, boolean, boolean, boolean) - Constructor for class ostore.archive.dissemination.RequestDisseminationSetResponseMsg
Construct according to the given fields.
requested_state - Variable in class ostore.dtree.DTreeServiceReq
The connection state that the sender wants.
RequestFragMsg - class ostore.archive.RequestFragMsg.
RequestDisseminationSetMsg is used to request that a SetCreator send a dissemination set.
RequestFragMsg(InputBuffer) - Constructor for class ostore.archive.RequestFragMsg
Constructs a RequestFragMsg from its serialized form.
RequestFragMsg(SecureHash, SecureHash, DDQuery, DDQueryState, SecureHash, boolean, boolean, boolean, byte, byte, VirtualCoordinate) - Constructor for class ostore.archive.RequestFragMsg
Construct according to the given fields.
RequestFragQuery - class ostore.archive.RequestFragQuery.
RequestFragQuery is a DDQuery used in a RequestFragMsg DDLocateMsg used to find a Fragments that can be reconstructed into a block.
RequestFragQuery() - Constructor for class ostore.archive.RequestFragQuery
Creates a new RequestFragQuery.
RequestFragQuery(InputBuffer) - Constructor for class ostore.archive.RequestFragQuery
Constructs a RequestFragQuery from its serialized form.
RequestFragQueryState - class ostore.archive.RequestFragQueryState.
RequestFragQueryState is a wrapper class for the state passed along with the RequestFragQuery DDQuery used in a RequestFragMsg DDLocateMsg used to find a Fragments that can be reconstructed into a block.
RequestFragQueryState(InputBuffer) - Constructor for class ostore.archive.RequestFragQueryState
Constructs a RequestFragQueryState from its serialized form.
RequestFragQueryState(int) - Constructor for class ostore.archive.RequestFragQueryState
Creates a new RequestFragQueryState.
RequestFragResponseMsg - class ostore.archive.RequestFragResponseMsg.
RequestFragResponseMsg is the StorageServers response to a RequestFragMsg and containing either a Fragment or the block itself.
RequestFragResponseMsg(InputBuffer) - Constructor for class ostore.archive.RequestFragResponseMsg
Constructs a RequestFragResponseMsg from its serialized form.
RequestFragResponseMsg(SecureHash, SecureHash, QuickSerializable, boolean, boolean, boolean) - Constructor for class ostore.archive.RequestFragResponseMsg
Construct according to the given fields.
requestId - Variable in class ostore.cache.CachePinnedReply.Local
 
requestId - Variable in class ostore.cache.CachePinnedRequest.Local
 
requestId - Variable in class ostore.cache.CacheAssignRequest
The requesting stage, a constant from StageId.
requestId - Variable in class ostore.cache.CacheAssignReply
The requesting stage, a constant from StageId.
requestId - Variable in class ostore.cache.CacheUnpinRequest
The requesting stage, a constant from StageId.
requestId - Variable in class ostore.cache.CacheReserveSpaceMessage
String representing the name of the stage sending a CacheReserveSpaceMessage
requestId - Variable in class ostore.cache.CacheReserveSpaceDone
 
requestId - Variable in class ostore.cache.CachePinnedRequest
 
requestId - Variable in class ostore.cache.CachePinnedReply
id of stage requesting CacheBlockRequest Message
requestId - Variable in class ostore.cache.CacheInsertMessage
 
requestId - Variable in class ostore.cache.CacheInsertDone
 
requestId - Variable in class ostore.cache.CacheDeleteItem
 
requestId - Variable in class ostore.cache.CacheDeleteConfirm
 
requestId - Variable in class ostore.cache.CacheBlockRequestMessage
 
requestId - Variable in class ostore.cache.CacheBlockReplyMessage
id of stage requesting CacheBlockRequest Message
requesting_client - Variable in class ostore.inner.LatestHeartbeatResp
 
requesting_client - Variable in class ostore.inner.LatestHeartbeatReq
 
REQUESTOR_STAGE - Static variable in class ostore.util.StageId
 
RequestorStage - class ostore.archive.RequestorStage.
 
RequestorStage() - Constructor for class ostore.archive.RequestorStage
 
required_type - Variable in class ostore.dispatch.Filter
The most recently required type.
requireType(Class) - Method in class ostore.dispatch.Filter
Add a type restriction.
requireType(String) - Method in class ostore.dispatch.Filter
Add a type restriction.
requireValue(Field, Object) - Method in class ostore.dispatch.Filter
Add a restriction of a field's value.
requireValue(String, Object) - Method in class ostore.dispatch.Filter
Add a restriction of a field's value.
resend(QueueElementIF, int, long) - Method in class ostore.dispatch.Resender
Repeatedly dispatches the specified event, num_retries times, waiting millis milliseconds in between attempts.
resend(QueueElementIF, int, long, Map, Object) - Method in class ostore.dispatch.Resender
Repeatedly dispatches the specified event, num_retries times, waiting millis milliseconds in between attempts.
resend(QueueElementIF, int, long, Map, Set) - Method in class ostore.dispatch.Resender
Repeatedly dispatches the specified event, num_retries times, waiting millis milliseconds in between attempts.
resender - Variable in class ostore.util.StandardStage
a Resender used to remember pending requests
Resender - class ostore.dispatch.Resender.
A utility class that automatically re-dispatches events.
resender_tokens - Variable in class ostore.util.StandardStage
a map storing Resender tokens for pending requests
Resender(NodeId, String) - Constructor for class ostore.dispatch.Resender
Creates a new Resender object that uses the default Classifier for the specified machine.
Resender(NodeId, String, boolean) - Constructor for class ostore.dispatch.Resender
Creates a new Resender object that uses the default Classifier for the specified machine.
reserve(int) - Method in class ostore.cache.BufferCache
 
reserve(int, DataCache) - Method in class ostore.dataobj.HandleStore
 
reserveWithException(int) - Method in interface ostore.cache.DataCache
Reserve n bytes in the cache if there is room; otherwise throw a CacheFullException.
reserveWithException(int) - Method in class ostore.cache.BufferCache
 
reserveWithException(int, int) - Method in interface ostore.cache.DataCache
Reserve b blocks of sz bytes each in the cache if there is room; otherwise throw a CacheFullException.
reserveWithException(int, int) - Method in class ostore.cache.BufferCache
 
reset() - Method in class ostore.archive.ArchiveObjBucket
reset state and incorporate specified parameters.
reset() - Method in class ostore.archive.ArchiveCountBuffer
 
reset() - Method in class ostore.dataobj.RabinFingerprint
Start reading out of a new input stream.
reset() - Method in class ostore.util.StatRecorder
 
reset() - Method in class ostore.util.CountBuffer
 
reset(byte[]) - Method in class ostore.util.ByteArrayOutputBuffer
 
reset(byte[]) - Method in class ostore.util.ByteArrayInputBuffer
Reuse the buffer with a new array of bytes.
reset(byte[], int, int) - Method in class ostore.util.ByteArrayInputBuffer
Reuse the buffer with a new array of bytes.
reset(DisseminateFragAckMsg) - Method in class ostore.archive.dissemination.DisseminateFragAckMsg.Local
resets DisseminateFragAckMsg.Local.
reset(DisseminateFragMsg) - Method in class ostore.archive.dissemination.DisseminateFragMsg.Local
resets DisseminateFragMsg.Local.
reset(NodeId, SecureHash) - Method in class ostore.archive.FragmentBucket
resets internal data structures.
reset(NodeId, SecureHash) - Method in interface ostore.archive.DisseminatableBucket
clear frees internal data structures that can be garbage collected.
reset(SecureHash, DataCache, String, SecureHash, NodeId) - Method in class ostore.archive.TputGenerateChkptTest.RemoveGuidsHelper
reset versionVHash.
reset(SecureHash, int, int, int, NodeId, HandleStore) - Method in class ostore.archive.ArchiveObjBucket
reset state and incorporate specified parameters.
resetParam() - Method in class ostore.archive.cauchy.Parameters
 
resp - Variable in class ostore.agree.AgreementExecuteResp
 
resp - Variable in class ostore.inner.LatestHeartbeatRespMsg
 
resp - Variable in class ostore.inner.CreateObjectRespMsg
 
resp - Variable in class ostore.archive.dissemination.DisseminateFragAckMsg.Local
The original DisseminateFragAckMsg.
resp() - Method in class ostore.replica.RemoteReplicaUpdateResp
Get the ReplicaCreateReq contained in this message.
resp() - Method in class ostore.replica.RemoteReplicaCreateResp
Get the ReplicaCreateReq contained in this message.
RESPOND - Static variable in class ostore.mac.DHMessage
 
response - Variable in class ostore.archive.RequestFragResponseMsg
 
responseGuid - Variable in class ostore.archive.RequestFragResponseMsg
 
restrictions - Variable in class ostore.dispatch.Filter
A HashMap containing all the restrictions for this Filter.
result - Variable in class ostore.agree.ResultMsg
 
result - Variable in class ostore.cache.StorageManager.GetBlockCompleted
Will be null if get failed.
result - Variable in class ostore.introspect.MessageBundle
 
result(int) - Method in class ostore.agree.AgreementState
 
RESULTING_VHASH - Static variable in class ostore.dataobj.Metadata
 
ResultMsg - class ostore.agree.ResultMsg.
 
ResultMsg(InputBuffer) - Constructor for class ostore.agree.ResultMsg
 
ResultMsg(SecureHash, SecureHash, SecureHash, QSDate, long, long, QuickSerializable, SigShare, boolean, boolean, boolean) - Constructor for class ostore.agree.ResultMsg
 
ResultMsg(SecureHash, SecureHash, SecureHash, QSDate, long, long, SignedQS, boolean, boolean, boolean) - Constructor for class ostore.agree.ResultMsg
 
ResurrectTombReq - class ostore.archive.events.ResurrectTombReq.
ResurrectTombReq is an event class that requests a Tombstone be resurrected from the archive.
ResurrectTombReq() - Constructor for class ostore.archive.events.ResurrectTombReq
Constructor: Initializes instance variables to null.
ResurrectTombReq(InputBuffer) - Constructor for class ostore.archive.events.ResurrectTombReq
Constructs a ResurrectTombReq from its serialized form.
ResurrectTombResp - class ostore.archive.events.ResurrectTombResp.
ResurrectTombResp is an event class that responds to a ResurrectTombReq once a Tombstone has been resurrected.
ResurrectTombResp() - Constructor for class ostore.archive.events.ResurrectTombResp
Constructor: Initializes instance variables to null.
ResurrectTombResp(InputBuffer) - Constructor for class ostore.archive.events.ResurrectTombResp
Constructs a ResurrectTombResp from its serialized form.
RETRIES - Static variable in class ostore.dtree.DTreeNode
The number of times to retry any message.
return_address - Variable in class ostore.network.PingStage.PingReq
 
return_address - Variable in class ostore.network.ADns.LookupReq
 
Rfragments() - Method in class ostore.archive.cauchy.Parameters
Rfragments is the number of redundant fragments
ring_id - Variable in class ostore.agree.RingState
The hash of the public key used to verify signatures from this ring.
ring_id - Variable in class ostore.agree.ResultMsg
 
ring_id - Variable in class ostore.agree.PreprepareMsg
 
ring_id - Variable in class ostore.agree.PrepareMsg
 
ring_id - Variable in class ostore.agree.ForwardMsg
 
ring_id - Variable in class ostore.agree.CommitMsg
 
ring_id - Variable in class ostore.agree.AgreementSuccess
 
ring_id - Variable in class ostore.agree.AgreementInit
 
ring_id - Variable in class ostore.agree.AgreementFailure
 
ring_id - Variable in class ostore.agree.AgreementExecuteResp
 
ring_id - Variable in class ostore.agree.AgreementExecuteReq
 
ring_id - Variable in class ostore.inner.VGuidGenerationReq
 
ring_init_success_msg - Variable in class ostore.inner.FakeInner
 
ring_members - Variable in class ostore.archive.events.DisseminateTombstoneReq
ring_members == total number of ring members.
ring_members - Variable in class ostore.archive.events.DisseminateFragsReq
ring_members == total number of ring members.
ring_pkey - Variable in class ostore.agree.RingState
The public key used to verify signatures from this ring.
ring_public_key - Variable in class ostore.agree.RingInitSuccess
 
ring_public_key - Variable in class ostore.agree.RingInitFailure
 
ring_public_key - Variable in class ostore.agree.RingInit
 
ring_public_key - Variable in class ostore.rp.InnerRingCreateRespMsg
 
ring_public_key - Variable in class ostore.rp.InnerRingCreateReqMsg
 
RingInit - class ostore.agree.RingInit.
 
RingInit(long, QSDate, QSPublicKey, QSPublicKey[], KeyShare) - Constructor for class ostore.agree.RingInit
 
RingInitFailure - class ostore.agree.RingInitFailure.
 
RingInitFailure(long, QSDate, QSPublicKey) - Constructor for class ostore.agree.RingInitFailure
 
RingInitSuccess - class ostore.agree.RingInitSuccess.
 
RingInitSuccess(long, QSDate, QSPublicKey) - Constructor for class ostore.agree.RingInitSuccess
 
RingState - class ostore.agree.RingState.
The state associated with a given ring (public key).
RingState(SecureHash, long, long, QSPublicKey, QSPublicKey[], KeyShare, QSPublicKey, int) - Constructor for class ostore.agree.RingState
Construct a new RingState.
root_class - Variable in class ostore.dispatch.Classifier
The Class object for the root of the type hierarchy.
root_guid - Variable in class ostore.apps.qtree.api.QTreeStateLocal
 
root_guid - Variable in class ostore.apps.qtree.api.QTreeStateMsg
 
root_node - Variable in class ostore.apps.qtree.api.QTreeStateLocal
 
root_node - Variable in class ostore.apps.qtree.api.QTreeStateMsg
 
round_up(int, int) - Static method in class ostore.util.ByteUtils
Round a number up to a given multiple.
ROUTER - Static variable in class ostore.network.LatTest
 
rp - Variable in class ostore.archive.events.DisseminateTombstoneReq
rp == Responsible Party's Certificate.
RP - class ostore.rp.RP.
The responsible party.
rp_cert - Variable in class ostore.rp.CreateObjectReq
 
rp_cert() - Method in class ostore.inner.CreateObjectResp
 
RP_GUID - Static variable in class ostore.client.OSSetAppPropertyRequest
 
RP_RP - Static variable in class ostore.util.DebugFlags
 
RP() - Constructor for class ostore.rp.RP
 
RPBuilder - class ostore.apps.traces.RPBuilder.
A configuration builder for RP nodes.
RPBuilder(String[]) - Constructor for class ostore.apps.traces.RPBuilder
Set global parameters.
RPCert - class ostore.dataobj.RPCert.
RPCert
RPCERT - Static variable in class ostore.dataobj.Metadata
 
RPCERT_GUID - Static variable in class ostore.dataobj.Metadata
 
RPCert() - Constructor for class ostore.dataobj.RPCert
 
RPCert(InputBuffer) - Constructor for class ostore.dataobj.RPCert
 
RPCert(QSPublicKey, QSPublicKey, String) - Constructor for class ostore.dataobj.RPCert
 
rsa(BigInteger, BigInteger, BigInteger, BigInteger, BigInteger, BigInteger) - Static method in class ostore.security.NativeRSAAlgorithm
 
rtt_ms - Variable in class ostore.network.NetworkLatencyResp
 
run() - Method in class ostore.dispatch.Test
 
run() - Method in class ostore.util.DestroyStages
Goes through and destroys all stages enumerated in Manager that are associated with the given NodeId.
runTest() - Method in class ostore.apps.test.ReadWriteTestRemote
 

A B C D E F G H I J K L M N O P Q R S T U V W Y Z _