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

A

ACK - Static variable in interface org.objectweb.dream.protocol.utobcast.message.UTOBcastChunk
The byte value for ACK message type.
ACKImpl - class org.objectweb.dream.protocol.utobcast.ACKImpl.
Implementation of the ACK component.
ACKImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.ACKImpl
Constructor.
ALL_INTEGER_KEY - Static variable in class org.objectweb.dream.pushwithreturn.KeyGeneratorIntegerImpl
The "All" Integer key.
ALREADY_DELIVERED - Static variable in interface org.objectweb.dream.protocol.causality.MatrixClock
the value returned by MatrixClock.testRecvMatrix(Object, short, short)if the message has already been delivred.
AbstractAcceptSocketImpl - class org.objectweb.dream.channel.AbstractAcceptSocketImpl.
Abstract Accept socket component.
AbstractAcceptSocketImpl() - Constructor for class org.objectweb.dream.channel.AbstractAcceptSocketImpl
 
AbstractAcceptSocketImpl.AcceptTask - class org.objectweb.dream.channel.AbstractAcceptSocketImpl.AcceptTask.
 
AbstractAcceptSocketImpl.AcceptTask() - Constructor for class org.objectweb.dream.channel.AbstractAcceptSocketImpl.AcceptTask
Constructor
AbstractBufferImpl - class org.objectweb.dream.queue.AbstractBufferImpl.
Abstract implementation of a buffer.
AbstractBufferImpl() - Constructor for class org.objectweb.dream.queue.AbstractBufferImpl
 
AbstractPullOutgoingHandlerImpl - class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl.
Abstract implementation of a Pull outgoing handler.
AbstractPullOutgoingHandlerImpl() - Constructor for class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
 
AbstractPushIncomingHandlerOverflowImpl - class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl.
Abstract implementation of a Push incoming handler.
AbstractPushIncomingHandlerOverflowImpl() - Constructor for class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
AbstractRouterImpl - class org.objectweb.dream.router.AbstractRouterImpl.
Abstract implementation of a basic Push/Push router.
AbstractRouterImpl() - Constructor for class org.objectweb.dream.router.AbstractRouterImpl
Default contructor
AbstractRouterKeyBasedImpl - class org.objectweb.dream.router.AbstractRouterKeyBasedImpl.
Abstract implementation of a key-based Push/Push router.
AbstractRouterKeyBasedImpl() - Constructor for class org.objectweb.dream.router.AbstractRouterKeyBasedImpl
Constructor.
AddIPChannelAttributeController - interface org.objectweb.dream.channel.AddIPChannelAttributeController.
Attribute controller interface for AddIPChannel components.
AddIPChannelDestinationChunkImpl - class org.objectweb.dream.channel.AddIPChannelDestinationChunkImpl.
This message transformer adds a IPChannelDestinationChunkcontaining the inet address and the listenning port of a channel.
AddIPChannelDestinationChunkImpl() - Constructor for class org.objectweb.dream.channel.AddIPChannelDestinationChunkImpl
 
AddIPChannelSourceChunkImpl - class org.objectweb.dream.channel.AddIPChannelSourceChunkImpl.
This message transformer adds a IPChannelSourceChunkcontaining the inet address and the listenning port of a channel.
AddIPChannelSourceChunkImpl() - Constructor for class org.objectweb.dream.channel.AddIPChannelSourceChunkImpl
 
ArrowChunk - interface org.objectweb.dream.protocol.ArrowChunk.
A general purpose chunk that can be use to identify the sender and receiver processes of a message.
ArrowChunkImpl - class org.objectweb.dream.protocol.ArrowChunkImpl.
A basic Chunk interface that defines an arrow from a source process to a destination process.
ArrowChunkImpl() - Constructor for class org.objectweb.dream.protocol.ArrowChunkImpl
 
AtomicReactorImpl - class org.objectweb.dream.protocol.atomicity.AtomicReactorImpl.
Transient impelmentation of the Reactor component.
AtomicReactorImpl() - Constructor for class org.objectweb.dream.protocol.atomicity.AtomicReactorImpl
 
AtomicRouterImpl - class org.objectweb.dream.protocol.atomicity.AtomicRouterImpl.
A Router that choose a route depending on the pushing thread.
AtomicRouterImpl() - Constructor for class org.objectweb.dream.protocol.atomicity.AtomicRouterImpl
 
Attachment - class org.objectweb.dream.multiplexer.Attachment.
This class defines an Attachement.
Attachment(int, String[], Pull[], Map[], String[], Push[], Map[]) - Constructor for class org.objectweb.dream.multiplexer.Attachment
Creates a new Attachment object
acceptSocket() - Method in class org.objectweb.dream.channel.AbstractAcceptSocketImpl
Abstract method that return a newly accepted socket.
acceptSocket() - Method in class org.objectweb.dream.channel.TCPAcceptSocketImpl
 
acceptTask - Variable in class org.objectweb.dream.channel.AbstractAcceptSocketImpl
 
add(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
This method should not be overriden.
add(Message) - Method in interface org.objectweb.dream.queue.Buffer
Adds the specified message to the buffer.
add(Object) - Method in interface org.objectweb.dream.queue.List
Adds the specified element to the list.
add(Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastFastImpl
 
add(Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastImpl
 
addFirst(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
addFirst(Message) - Method in interface org.objectweb.dream.queue.BufferAddFirstLast
Inserts the given message at the beginning of this buffer.
addFirst(Object) - Method in interface org.objectweb.dream.queue.ListAddFirstLast
Inserts the given element at the beginning of this list.
addFirst(Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastFastImpl
 
addFirst(Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastImpl
 
addLast(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
addLast(Message) - Method in interface org.objectweb.dream.queue.BufferAddFirstLast
Inserts the given message at the end of this buffer.
addLast(Object) - Method in interface org.objectweb.dream.queue.ListAddFirstLast
Appends the given element to the end of this list.
addLast(Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastFastImpl
 
addLast(Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastImpl
 
addProcess(Process) - Method in interface org.objectweb.dream.protocol.utobcast.ProcessMembership
Adds a process to the group of processes.
addProcess(Process) - Method in class org.objectweb.dream.protocol.utobcast.ProcessMembershipImpl
 
attach(String[], Map[], String[], Map[], Map) - Method in interface org.objectweb.dream.multiplexer.PullPushMultiplexer
Attaches a set of inputs to a set of outputs.
attach(String[], Map[], String[], Map[], Map) - Method in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
Attaches a set of inputs to a set of outputs.
attachmentId - Variable in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
An integer used to generate attachment ids.
attachments - Variable in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
The registered attachments.
availableMessagesIndicator - Variable in class org.objectweb.dream.queue.AbstractBufferImpl
An indicator on available messages into the buffer.
availableMessagesIndicator() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
availableMessagesIndicator() - Method in interface org.objectweb.dream.queue.Buffer
Returns an indicator on available messages.
availableSocketList - Variable in class org.objectweb.dream.channel.OpenedSocketManagerMultiPersistentImpl
 
availableSpaceIndicator() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
availableSpaceIndicator() - Method in interface org.objectweb.dream.queue.Buffer
Returns an indicator on available space.

B

BAK - Static variable in interface org.objectweb.dream.protocol.utobcast.message.UTOBcastChunk
The byte value for BAK message type.
BAKImpl - class org.objectweb.dream.protocol.utobcast.BAKImpl.
Implementation of the BAK component.
BAKImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.BAKImpl
Constructor.
BLOCK_OVERFLOW_POLICY - Static variable in interface org.objectweb.dream.queue.PushQueueAttributeController
An overflow policy that block incoming messages until a message is delivered on the output.
BLOCK_OVERFLOW_POLICY_ID - Static variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
BackupElection - interface org.objectweb.dream.protocol.utobcast.BackupElection.
This interface defines methods to elect a new backup.
BackupElectionImpl - class org.objectweb.dream.protocol.utobcast.BackupElectionImpl.
Implementation of the BackupElection component.
BackupElectionImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.BackupElectionImpl
Constructor.
BroadcastImpl - class org.objectweb.dream.protocol.utobcast.BroadcastImpl.
Implementation of the UTOBroadcast component.
BroadcastImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.BroadcastImpl
Constructor.
Buffer - interface org.objectweb.dream.queue.Buffer.
This interface defines methods that must be implemented by a buffer.
BufferAddFirstLast - interface org.objectweb.dream.queue.BufferAddFirstLast.
This interface defines methods that must be implemented by a buffer for adding messages to its begining or to its end.
BufferAscendingSequenceNumberImpl - class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl.
Implementation of the Buffer interface using a sorted list.
BufferAscendingSequenceNumberImpl() - Constructor for class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
 
BufferAscendingSequenceNumberImpl.Element - class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl.Element.
This class represents elements of a linked list.
BufferAscendingSequenceNumberImpl.Element() - Constructor for class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl.Element
 
BufferImpl - class org.objectweb.dream.queue.BufferImpl.
Basic implementation of the Buffer interface using a LinkedList.
BufferImpl() - Constructor for class org.objectweb.dream.queue.BufferImpl
 
BufferOverflowException - exception org.objectweb.dream.queue.BufferOverflowException.
Exception thrown by queues when the maximum capacity of the queue is raised and the overflow policy is exception
BufferOverflowException() - Constructor for class org.objectweb.dream.queue.BufferOverflowException
 
BufferOverflowException(String) - Constructor for class org.objectweb.dream.queue.BufferOverflowException
 
BufferOverflowException(String, Throwable) - Constructor for class org.objectweb.dream.queue.BufferOverflowException
 
BufferOverflowException(Throwable) - Constructor for class org.objectweb.dream.queue.BufferOverflowException
 
BufferRemoveFirstLast - interface org.objectweb.dream.queue.BufferRemoveFirstLast.
This interface defines methods that must be implemented by a buffer for removing messages from its begining or from its end.
backupElectionItf - Variable in class org.objectweb.dream.protocol.utobcast.DATImpl
The interface to elect a new backup.
backupElectionItf - Variable in class org.objectweb.dream.protocol.utobcast.REPImpl
The interface to elect a new backup.
beforeFirstStart(Component) - Method in class org.objectweb.dream.channel.AbstractAcceptSocketImpl
 
beforeFirstStart(Component) - Method in class org.objectweb.dream.channel.OpenedSocketManagerMultiPersistentImpl
 
beforeFirstStart(Component) - Method in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
 
beforeFirstStart(Component) - Method in class org.objectweb.dream.pump.PumpSynchronizedImpl
 
beforeFirstStart(Component) - Method in class org.objectweb.dream.queue.PushOutgoingHandlerActiveImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.aggregator.PullPullAggregatorCollectionInputImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.aggregator.PullPullAggregatorContextualImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.aggregator.PullPullAggregatorFixedNumberImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.aggregator.PullPullAggregatorWhileNotNullImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.aggregator.PushPullAggregatorImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.aggregator.PushPushDeAggregatorImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.cache.CacheImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.AbstractAcceptSocketImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.AddIPChannelDestinationChunkImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.AddIPChannelSourceChunkImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.GenericPushChannelInImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.GenericPushChannelOutImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.IPSocketManagerCachingImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.IPSocketManagerTCPImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.OpenedSocketManagerMonoNotPersistentImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.OpenedSocketManagerMonoPersistentImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.OpenedSocketManagerMultiPersistentImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.SocketManagerIPChunkBasedImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.exception.CatchPushExceptionImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.exception.RetryPushImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.atomicity.AtomicReactorImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.atomicity.AtomicRouterImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.causality.InMessageSorterImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.causality.OutMessageStamperImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.ACKImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.BAKImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.BackupElectionImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.BroadcastImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.DATImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.DeliveredMessageRouterImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.IncomingMessageRouterImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.LeaderFaultForwarderImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.PendingMessagesDataStructureImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.ProcessMembershipImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.REPImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.UPDImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.protocol.utobcast.UTOImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.pump.PumpSynchronizedImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.pushwithreturn.KeyGeneratorIntegerImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.pushwithreturn.SynchronizerImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.BufferImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastFastImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.PushIncomingHandlerImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.PushOutgoingHandlerActiveImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.queue.PushPullQueueNotSynchronizedImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.router.AbstractRouterImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.router.RouterChunkNameImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.synchro.LockPullUnlockImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.synchro.LockPushUnlockImpl
 
bindFc(String, Object) - Method in class org.objectweb.dream.xml.SaxXercesParser
 
blocking - Variable in class org.objectweb.dream.channel.IPSocketManagerCachingImpl
 
blockingPull - Variable in class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
 
bufferAddFirstLastItf - Variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
bufferItf - Variable in class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
 
bufferItf - Variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
bufferItf - Variable in class org.objectweb.dream.queue.PushIncomingHandlerImpl
 
bufferItf - Variable in class org.objectweb.dream.queue.PushOutgoingHandlerActiveImpl
 
bufferRemoveFirstLastItf - Variable in class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
 
bufferRemoveFirstLastItf - Variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
bufferRemoveFirstLastItf - Variable in class org.objectweb.dream.queue.PushOutgoingHandlerActiveImpl
 

C

CNX_RETRY_DEFAULT - Static variable in interface org.objectweb.dream.channel.IPSocketManagerTCPAttributeController
Default value of cnxRetry attribute.
CONTENT_HANDLER_ITF_NAME - Static variable in class org.objectweb.dream.xml.SaxXercesParser
The name of the ContentHandlerclient interface.
CacheAttributeController - interface org.objectweb.dream.cache.CacheAttributeController.
This class defines a controller for managing the cache attributes.
CacheImpl - class org.objectweb.dream.cache.CacheImpl.
This class defines a basic cache.
CacheImpl() - Constructor for class org.objectweb.dream.cache.CacheImpl
 
CatchPushExceptionImpl - class org.objectweb.dream.exception.CatchPushExceptionImpl.
Try to push incomming messages on the output ("out-push" client interface).
CatchPushExceptionImpl() - Constructor for class org.objectweb.dream.exception.CatchPushExceptionImpl
 
CausalityChunk - interface org.objectweb.dream.protocol.causality.CausalityChunk.
Chunk interface for causality sorted messages.
CausalityChunkImpl - class org.objectweb.dream.protocol.causality.CausalityChunkImpl.
Basic implementation of CausalityChunk
CausalityChunkImpl() - Constructor for class org.objectweb.dream.protocol.causality.CausalityChunkImpl
 
CausalityProtocolAttributeController - interface org.objectweb.dream.protocol.causality.CausalityProtocolAttributeController.
Causality protocol attribute controller interface.
CausalityTransformerAttributeController - interface org.objectweb.dream.protocol.causality.CausalityTransformerAttributeController.
Causality message transformer attribute controller interface.
ChannelOutAttributeController - interface org.objectweb.dream.channel.ChannelOutAttributeController.
ChannelOut attribute controller.
CrashedLeaderChunk - interface org.objectweb.dream.protocol.utobcast.message.CrashedLeaderChunk.
Chunk interface that indicates that the leader has crashed.
CrashedLeaderChunkImpl - class org.objectweb.dream.protocol.utobcast.message.CrashedLeaderChunkImpl.
Basic implementation of the CrashedLeaderChunkinterface.
CrashedLeaderChunkImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.message.CrashedLeaderChunkImpl
 
cache - Variable in class org.objectweb.dream.channel.IPSocketManagerCachingImpl
 
cacheRemove() - Method in class org.objectweb.dream.channel.IPSocketManagerCachingImpl.CacheEntry
 
cachedMessage - Variable in class org.objectweb.dream.cache.CacheImpl
The last cached message.
canAdd(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Checks whether the given message can be added into the buffer.
canAdd(Message) - Method in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
Checks whether the given message can be added into the buffer.
canAdd(Message) - Method in class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
 
canAdd(Message) - Method in class org.objectweb.dream.queue.BufferImpl
 
canAdd(Message) - Method in class org.objectweb.dream.queue.PushIncomingHandlerOverflowImpl
 
canPass() - Method in class org.objectweb.dream.pushwithreturn.SynchronizerImpl.WaitingKey
Returns the value of canPass.
chunkName - Variable in class org.objectweb.dream.channel.AddIPChannelDestinationChunkImpl
the name of the IPChannelDestinationChunk added by this transformer.
chunkName - Variable in class org.objectweb.dream.channel.AddIPChannelSourceChunkImpl
the name of the IPChannelDestinationChunk added by this transformer.
chunkName - Variable in class org.objectweb.dream.router.RouterChunkNameImpl
the chunk name to test
clone() - Method in class org.objectweb.dream.multiplexer.Attachment
Returns a clone of this attachment.
clone() - Method in class org.objectweb.dream.multiplexer.PeriodicAttachment
Returns a clone of this attachment.
clone() - Method in interface org.objectweb.dream.protocol.Process
Clones the process.
clone() - Method in class org.objectweb.dream.protocol.ProcessImpl
 
close() - Method in interface org.objectweb.dream.channel.SocketState
Closes the connection.
close() - Method in class org.objectweb.dream.channel.SocketStateImpl
 
cnxRetry - Variable in class org.objectweb.dream.channel.IPSocketManagerTCPImpl
 
compareTo(Object) - Method in class org.objectweb.dream.protocol.ProcessImpl
 
createServerSocket() - Method in class org.objectweb.dream.channel.TCPAcceptSocketImpl
 
currentSocket - Variable in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 

D

DAT - Static variable in interface org.objectweb.dream.protocol.utobcast.message.UTOBcastChunk
The byte value for DAT message type.
DATImpl - class org.objectweb.dream.protocol.utobcast.DATImpl.
Implementation of the DAT component.
DATImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.DATImpl
Constructor.
DEFAULT_NAME - Static variable in interface org.objectweb.dream.channel.IPChannelDestinationChunk
The default name of chunks of this type.
DEFAULT_NAME - Static variable in interface org.objectweb.dream.channel.IPChannelSourceChunk
The default name of chunks of this type.
DEFAULT_NAME - Static variable in interface org.objectweb.dream.protocol.ArrowChunk
The default name for chunks of this type
DEFAULT_NAME - Static variable in interface org.objectweb.dream.protocol.causality.CausalityChunk
The default name for chunks of this type
DEFAULT_NAME - Static variable in interface org.objectweb.dream.protocol.utobcast.message.CrashedLeaderChunk
The default name for chunks of this type.
DEFAULT_NAME - Static variable in interface org.objectweb.dream.protocol.utobcast.message.UPDChunk
The default name for chunks of this type.
DEFAULT_NAME - Static variable in interface org.objectweb.dream.protocol.utobcast.message.UTOBcastChunk
The default name for chunks of this type.
DEFAULT_NAME - Static variable in interface org.objectweb.dream.pushwithreturn.KeyChunk
The default name for chunks of this type
DEFAULT_NAME - Static variable in interface org.objectweb.dream.queue.SequenceNumberChunk
The default name for chunks of this type.
DEFAULT_OUT_PUSH_ITF_NAME - Static variable in class org.objectweb.dream.router.AbstractRouterImpl
The name of the default Pushclient interface.
DELEGATE_IP_SOCKET_MANAGER - Static variable in class org.objectweb.dream.channel.IPSocketManagerCachingImpl
The name of the client interface used to retreive a socket when it can't be found in the cache.
DELIVER - Static variable in interface org.objectweb.dream.protocol.causality.MatrixClock
the value returned by MatrixClock.testRecvMatrix(Object, short, short)if the message can be delivred
DELIVERY_ITF_NAME - Static variable in class org.objectweb.dream.protocol.utobcast.UTOImpl
The commonly used name to refer to the deliveryItf interface.
DROP_FIRST_OVERFLOW_POLICY - Static variable in interface org.objectweb.dream.queue.PushQueueAttributeController
An overflow policy that drops the first message of the queue when it is full.
DROP_FIRST_OVERFLOW_POLICY_ID - Static variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
DROP_LAST_OVERFLOW_POLICY - Static variable in interface org.objectweb.dream.queue.PushQueueAttributeController
An overflow policy that drops the last message of the queue when it is full.
DROP_LAST_OVERFLOW_POLICY_ID - Static variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
DROP_PROCESSED_MESSAGE_OVERFLOW_POLICY - Static variable in interface org.objectweb.dream.queue.PushQueueAttributeController
An overflow policy that drops the current message when the queue is full: this means that the message will not be inserted into the queue.
DROP_PROCESSED_MESSAGE_OVERFLOW_POLICY_ID - Static variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
DROP_QUEUE_MESSAGE_OVERFLOW_POLICY - Static variable in interface org.objectweb.dream.queue.PushQueueAttributeController
An overflow policy that drops a message message from the queue when it is full.
DROP_QUEUE_MESSAGE_OVERFLOW_POLICY_ID - Static variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
DeliveredMessageRouterImpl - class org.objectweb.dream.protocol.utobcast.DeliveredMessageRouterImpl.
Implementation of the DeliveredMessageRouter component.
DeliveredMessageRouterImpl() - Constructor for class org.objectweb.dream.protocol.utobcast.DeliveredMessageRouterImpl
Constructor.
decrementNbWaitings() - Method in class org.objectweb.dream.pushwithreturn.SynchronizerImpl.WaitingKey
Decrements the number of waiting calls.
defaultOutPushItf - Variable in class org.objectweb.dream.router.AbstractRouterImpl
Default Push interface to be used if no Push interface can be found in outPushTable.
delegateOpenedSocketItf - Variable in class org.objectweb.dream.channel.OpenedSocketManagerMonoNotPersistentImpl
 
delegateOpenedSocketItf - Variable in class org.objectweb.dream.channel.OpenedSocketManagerMonoPersistentImpl
 
delegateOpenedSocketItf - Variable in class org.objectweb.dream.channel.OpenedSocketManagerMultiPersistentImpl
 
delegateSocketManagerItf - Variable in class org.objectweb.dream.channel.IPSocketManagerCachingImpl
 
delegateSocketManagerItf - Variable in class org.objectweb.dream.channel.SocketManagerIPChunkBasedImpl
 
delegateSocketManagerItf - Variable in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
deleteChunk - Variable in class org.objectweb.dream.channel.SocketManagerIPChunkBasedImpl
 
deliveryItf - Variable in class org.objectweb.dream.protocol.utobcast.UTOImpl
The interface to deliver messages.
destinationAddress - Variable in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
destinationChanged - Variable in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
destinationChunkName - Variable in class org.objectweb.dream.channel.SocketManagerIPChunkBasedImpl
 
destinationPort - Variable in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
detach(Attachment) - Method in interface org.objectweb.dream.multiplexer.PullPushMultiplexer
Detaches a set of inputs from a set of outputs.
detach(Attachment) - Method in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
 
doAdd(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Adds a message to the buffer.
doAdd(Message) - Method in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
Adds a message to the buffer.
doAdd(Message) - Method in class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
 
doAdd(Message) - Method in class org.objectweb.dream.queue.BufferImpl
 
doAdd(Message) - Method in class org.objectweb.dream.queue.PushIncomingHandlerOverflowImpl
 
doAddFirst(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Adds a message to the beginning of the buffer.
doAddFirst(Message) - Method in class org.objectweb.dream.queue.BufferImpl
 
doAddLast(Message) - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Adds a message to end of the buffer.
doAddLast(Message) - Method in class org.objectweb.dream.queue.BufferImpl
 
doGet() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Gets a message from the buffer.
doGet() - Method in class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
 
doGet() - Method in class org.objectweb.dream.queue.BufferImpl
 
doGetFirst() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Gets the first message from the buffer.
doGetFirst() - Method in class org.objectweb.dream.queue.BufferImpl
 
doGetLast() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Gets the last message from the buffer.
doGetLast() - Method in class org.objectweb.dream.queue.BufferImpl
 
doPull() - Method in class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
Pulls a message from the buffer (i.e. get or remove).
doPull() - Method in class org.objectweb.dream.queue.PullOutgoingHandlerImpl
 
doRemove() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Removes a message from the buffer.
doRemove() - Method in class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
 
doRemove() - Method in class org.objectweb.dream.queue.BufferImpl
 
doRemoveFirst() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Removes the first message from the buffer.
doRemoveFirst() - Method in class org.objectweb.dream.queue.BufferImpl
 
doRemoveLast() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
Removes the last message from the buffer.
doRemoveLast() - Method in class org.objectweb.dream.queue.BufferImpl
 

E

END_DATE - Static variable in class org.objectweb.dream.multiplexer.PeriodicAttachment
The name of the key that must be used to specify the end date of this attachment in the parameters passed to the PullPushMultiplexer.attach(String[], Map[], String[], Map[], Map)
EXCEPTION_MESSAGE_NOT_FOUND_POLICY - Static variable in interface org.objectweb.dream.queue.PushPullKeyQueueAttributeController
"Message not found" policy that throw a KeyNotFoundException exception.
EXCEPTION_OVERFLOW_POLICY - Static variable in interface org.objectweb.dream.queue.PushQueueAttributeController
An overflow policy that causes the Push server interface to throw a BufferOverflowException
EXCEPTION_OVERFLOW_POLICY_ID - Static variable in class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
 
EXCEPTION_PUSH_ITF_NAME - Static variable in class org.objectweb.dream.exception.CatchPushExceptionImpl
The default name of the out push interface used if a PushException has been catched while a message was pushed on the normal out push.
elect() - Method in interface org.objectweb.dream.protocol.utobcast.BackupElection
Elects a new backup and propagate information to all the processes.
elect() - Method in class org.objectweb.dream.protocol.utobcast.BackupElectionImpl
 
electBackup() - Method in interface org.objectweb.dream.protocol.utobcast.ProcessMembership
Elects a new backup process.
electBackup() - Method in class org.objectweb.dream.protocol.utobcast.ProcessMembershipImpl
 
electBackupAsLeader(Process) - Method in interface org.objectweb.dream.protocol.utobcast.ProcessMembership
Elects the backup as new leader provided the curerntly registered leader is the one given in parameter.
electBackupAsLeader(Process) - Method in class org.objectweb.dream.protocol.utobcast.ProcessMembershipImpl
 
elements() - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastFastImpl
Returns a java.util.Enumeration enumeration over the elements of the linked list.
endDate - Variable in class org.objectweb.dream.multiplexer.PeriodicAttachment
 
equals(Object) - Method in class org.objectweb.dream.channel.IPSocketManagerCachingImpl.CacheEntry
 
equals(Object) - Method in class org.objectweb.dream.multiplexer.Attachment
Returns true iff the specified object is an Attachment with the same id.
equals(Object) - Method in class org.objectweb.dream.protocol.ProcessImpl
 
equals(Object) - Method in class org.objectweb.dream.pushwithreturn.KeyInteger
 
exceptionPushItf - Variable in class org.objectweb.dream.exception.CatchPushExceptionImpl
 
execute(Object) - Method in class org.objectweb.dream.channel.AbstractAcceptSocketImpl.AcceptTask
 
execute(Object) - Method in class org.objectweb.dream.channel.OpenedSocketManagerMultiPersistentImpl.InTask
 

F

first - Variable in class org.objectweb.dream.queue.BufferAscendingSequenceNumberImpl
The first element stored in this buffer.

G

GenericPushChannelInImpl - class org.objectweb.dream.channel.GenericPushChannelInImpl.
Generic push ChannelIn implementation.
GenericPushChannelInImpl() - Constructor for class org.objectweb.dream.channel.GenericPushChannelInImpl
 
GenericPushChannelOutImpl - class org.objectweb.dream.channel.GenericPushChannelOutImpl.
Generic Push ChannelOut.
GenericPushChannelOutImpl() - Constructor for class org.objectweb.dream.channel.GenericPushChannelOutImpl
 
GetTimeStamp - interface org.objectweb.dream.time.GetTimeStamp.
This interface defines a method to get a time stamp.
generateKey(Message) - Method in interface org.objectweb.dream.pushwithreturn.KeyGenerator
Generates a key for the given message.
generateKey(Message) - Method in class org.objectweb.dream.pushwithreturn.KeyGeneratorIntegerImpl
 
get() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
This method should not be overriden.
get() - Method in interface org.objectweb.dream.queue.Buffer
Gets a message from the buffer.
getArrowChunkName() - Method in interface org.objectweb.dream.protocol.causality.CausalityTransformerAttributeController
Returns the name of the ArrowChunk used to know the source or the destination process of messages.
getArrowChunkName() - Method in class org.objectweb.dream.protocol.causality.InMessageSorterImpl
 
getArrowChunkName() - Method in class org.objectweb.dream.protocol.causality.OutMessageStamperImpl
 
getAttachments() - Method in interface org.objectweb.dream.multiplexer.PullPushMultiplexer
Returns the attachments that have been registered.
getAttachments() - Method in class org.objectweb.dream.multiplexer.PullPushMultiplexerImpl
 
getBackup() - Method in interface org.objectweb.dream.protocol.utobcast.ProcessMembership
Returns the backup process.
getBackup() - Method in class org.objectweb.dream.protocol.utobcast.ProcessMembershipImpl
 
getBlocking() - Method in interface org.objectweb.dream.channel.IPSocketManagerCachingAttributeController
Returns the blocking parameter value.
getBlocking() - Method in class org.objectweb.dream.channel.IPSocketManagerCachingImpl
 
getBlocking() - Method in interface org.objectweb.dream.protocol.utobcast.ProcessMembershipAttributeController
Returns true if the ProcessMembership component is in blocking mode.
getBlocking() - Method in class org.objectweb.dream.protocol.utobcast.ProcessMembershipImpl
 
getBlockingPull() - Method in class org.objectweb.dream.queue.AbstractPullOutgoingHandlerImpl
 
getBlockingPull() - Method in interface org.objectweb.dream.queue.PullQueueAttributeController
Returns the blocking pull policy.
getCausalityChunkName() - Method in interface org.objectweb.dream.protocol.causality.CausalityTransformerAttributeController
Returns the name of the CausalityChunkwhere the matrix clock, or the updates are stored.
getCausalityChunkName() - Method in class org.objectweb.dream.protocol.causality.InMessageSorterImpl
 
getCausalityChunkName() - Method in class org.objectweb.dream.protocol.causality.OutMessageStamperImpl
 
getCausalityStamp() - Method in interface org.objectweb.dream.protocol.causality.CausalityChunk
Returns the causality stamp of this chunk
getCausalityStamp() - Method in class org.objectweb.dream.protocol.causality.CausalityChunkImpl
 
getChannelDestinationAddr() - Method in interface org.objectweb.dream.channel.IPChannelDestinationChunk
Returns the inet address of the ChannelIn.
getChannelDestinationAddr() - Method in class org.objectweb.dream.channel.IPChannelDestinationChunkImpl
 
getChannelDestinationPort() - Method in interface org.objectweb.dream.channel.IPChannelDestinationChunk
Returns the listening port of the ChannelIn.
getChannelDestinationPort() - Method in class org.objectweb.dream.channel.IPChannelDestinationChunkImpl
 
getChannelSourceAddr() - Method in interface org.objectweb.dream.channel.IPChannelSourceChunk
Returns the inet address of the ChannelOut.
getChannelSourceAddr() - Method in class org.objectweb.dream.channel.IPChannelSourceChunkImpl
 
getChannelSourcePort() - Method in interface org.objectweb.dream.channel.IPChannelSourceChunk
Returns the listening port of the ChannelOut.
getChannelSourcePort() - Method in class org.objectweb.dream.channel.IPChannelSourceChunkImpl
 
getChunkName() - Method in interface org.objectweb.dream.channel.AddIPChannelAttributeController
Returns the name of added chunks.
getChunkName() - Method in class org.objectweb.dream.channel.AddIPChannelDestinationChunkImpl
 
getChunkName() - Method in class org.objectweb.dream.channel.AddIPChannelSourceChunkImpl
 
getChunkName() - Method in interface org.objectweb.dream.router.RouterChunkNameAttributeController
Returns the chunk name used by chunk name routeur.
getChunkName() - Method in class org.objectweb.dream.router.RouterChunkNameImpl
 
getCnxRetry() - Method in interface org.objectweb.dream.channel.IPSocketManagerTCPAttributeController
Returns the number of connection retry before abording.
getCnxRetry() - Method in class org.objectweb.dream.channel.IPSocketManagerTCPImpl
 
getColumn() - Method in class org.objectweb.dream.protocol.causality.Update
 
getConnectionRetry() - Method in interface org.objectweb.dream.channel.ChannelOutAttributeController
Returns the number of attempt to connect to ChannelIn before abording.
getCurrentSize() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
getCurrentSize() - Method in class org.objectweb.dream.queue.PushPullQueueNotSynchronizedImpl
 
getCurrentSize() - Method in interface org.objectweb.dream.queue.QueueAttributeController
Returns the current size of the queue.
getDeleteChunk() - Method in interface org.objectweb.dream.channel.SocketManagerIPChunkBasedAttributeController
Returns true if the destination chunk should be deleted from the message.
getDeleteChunk() - Method in class org.objectweb.dream.channel.SocketManagerIPChunkBasedImpl
 
getDestinationChunkName() - Method in interface org.objectweb.dream.channel.SocketManagerIPChunkBasedAttributeController
Returns the name of the chunks that contains the destination identification of the message.
getDestinationChunkName() - Method in class org.objectweb.dream.channel.SocketManagerIPChunkBasedImpl
 
getDestinationHostname() - Method in interface org.objectweb.dream.channel.SocketManagerIPStaticAttributeController
Returns the destination hostname.
getDestinationHostname() - Method in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
getDestinationPort() - Method in interface org.objectweb.dream.channel.SocketManagerIPStaticAttributeController
Returns the destination port.
getDestinationPort() - Method in class org.objectweb.dream.channel.SocketManagerIPStaticImpl
 
getEndDate() - Method in class org.objectweb.dream.multiplexer.PeriodicAttachment
Returns the endDate value.
getFirst() - Method in class org.objectweb.dream.queue.AbstractBufferImpl
 
getFirst() - Method in interface org.objectweb.dream.queue.BufferRemoveFirstLast
Returns the first message in this buffer.
getFirst() - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastFastImpl
 
getFirst() - Method in class org.objectweb.dream.queue.ListAddRemoveFirstLastImpl
 
getFirst() - Method in interface org.objectweb.dream.queue.ListRemoveFirstLast
Returns the first element in this list.
getId() - Method in class org.objectweb.dream.multiplexer.