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

A

a_minus_b_a_inters_b_b_minus_a(Hashtable, Hashtable) - Static method in class universal.utils.Utils
 
a_minus_b_b_minus_a(long[], long[]) - Static method in class universal.utils.Utils
 
ACK_READ_MSG - Static variable in class universal.Message
 
ACK_WRITE_MSG - Static variable in class universal.Message
 
AckBuffer - Variable in class universal.communication.Receiver
Contain the AckRead,NackRead,AckWrite and NackWrite messages that have been received but not yet analize in AckListenner.
acklistener - Variable in class universal.consensus.register.Register
The thread who is going to wait for Acknowledgement Message from the replicated servers
AckListener - class universal.consensus.register.AckListener.
Thread that wait for AckReadMessage, NackReadMessage, AckWriteMessage, NackwriteMessage to arrive.
acklistener() - Method in class universal.consensus.register.Registry
 
ackListener() - Method in class universal.consensus.register.AckListener
The thread that is going to wait for Acknowledgement message to arrive.
AckListener(Register) - Constructor for class universal.consensus.register.AckListener
 
ackreadcount - Variable in class universal.consensus.register.AckListener
Number of Ackread messages we have received
AckReadMessage - class universal.AckReadMessage.
Used for creating AckReadMessage.
AckReadMessage(int, int, int, Outcome) - Constructor for class universal.AckReadMessage
The constructor
ackwritecount - Variable in class universal.consensus.register.AckListener
Number of AckWrite messages we have received
AckWriteMessage - class universal.AckWriteMessage.
Used for creating an AckWriteMessage.
AckWriteMessage(int, int, boolean) - Constructor for class universal.AckWriteMessage
To create an AckWriteMessage
add - Variable in class universal.Universal
 
add - Variable in class universal.UniversalClient
 
add1 - Variable in class universal.Universal
 
add1 - Variable in class universal.UniversalClient
 
address - Variable in class universal.communication.ProcessDetails
The IP address of the replicated server that is described by this object
AM_ALIVE_MSG - Static variable in class universal.Message
 
AmAliveMessage - class universal.AmAliveMessage.
Used in leader election.
AmAliveMessage(int[]) - Constructor for class universal.AmAliveMessage
 
Announce() - Method in class universal.messagein.ClientAnnounce
Sends the Corba messages to the replicated servers.
Announce() - Method in class universal.messagein.ReplicasAnnounce
Each replicated server sends the Corba messages to all the replicated servers.

B

BACKUP_SYNCH - Static variable in class universal.utils.Utils
 
batchno - Variable in class universal.ReadMessage
batchno the place in the total order for which the consensus is actually made
batchno - Variable in class universal.consensus.register.AckListener
The position in the total order for which we are actually doing the consensus
BEG_SYNCH_FAILOVER - Static variable in class universal.utils.Utils
 
bind_context(NamingContext, NameComponent[]) - Static method in class universal.utils.Utils
 
bool - Variable in class universal.StoreResult
True if the consensus is successful
bool - Variable in class universal.consensus.register.ReadResult
True if the leader hasn't received any NackReadMessage
bool - Variable in class universal.consensus.register.WriteResult
True if the leader hasn't received any NackWriteMessage

C

CALL_INVOKE - Static variable in class universal.utils.Utils
 
client_id - Variable in class universal.Request
Each client has its own client id
client_id - Variable in class universal.RequestServiceContext
Struct member client_id.
clientAnnounce - Variable in class universal.UniversalClient
Sends Corba message to the replicated servers to inform them on which port the client is listenning
ClientAnnounce - class universal.messagein.ClientAnnounce.
The client uses this class to send a CORBA message to all the replicated servers to inform them in which port and which address they can send the message AmAlive needed for the leader election.
ClientAnnounce(UniversalClient) - Constructor for class universal.messagein.ClientAnnounce
 
ClientInterceptor - class universal.ClientInterceptor.
Intercepts the CORBA request in order to add it a service context to identify it uniquely.
ClientInterceptor(ORBInitInfo, int) - Constructor for class universal.ClientInterceptor
 
clientSocket - Variable in class universal.communication.ReceiverClient
 
clientSocket - Variable in class universal.communication.SocketReceiver
 
codec - Variable in class universal.NRServerInterceptor
 
codec - Variable in class universal.ServerInterceptor
 
COMM - Static variable in class universal.Debug
True if we want to print also some message for debugging but which are more related to the communication beetween the different host.
cons - Variable in class universal.Universal
Object for the consensus purposes
Consensus - class universal.consensus.Consensus.
For each position in the total order the serverInterceptor instantiates a new Consensus.
Consensus() - Constructor for class universal.consensus.Consensus
 
Consensus(Universal, int) - Constructor for class universal.consensus.Consensus
Initialize the value L and uni.
Constants - class universal.Constants.
Define some constants
Constants() - Constructor for class universal.Constants
 

D

Debug - class universal.Debug.
Permit to choose if we want to print some debugging message in the screen or not.
DEBUG - Static variable in class universal.Debug
True if we want to print all the message for debugging
Debug() - Constructor for class universal.Debug
 
decode(byte[]) - Static method in class universal.Message
When you want to decode a message whatever is its type you have to call the Decode function of this class which is going to first decode the common variable of all the messages and then to call the Decode function of his real type.
decode(DataInputStream) - Static method in class universal.AckReadMessage
If you want to decode an AckReadMessage, you should call the method Decode of the superclass Message, not this one.
decode(DataInputStream) - Static method in class universal.AckWriteMessage
If you want to decode an AckWriteMessage, you should call the method Decode of the superclass Message, not this one.
decode(DataInputStream) - Static method in class universal.AmAliveMessage
If you want to decode an AmAliveMessage, you should call the method Decode of the superclass Message, not this one.
decode(DataInputStream) - Static method in class universal.NackReadMessage
When you want to decode a NackReadMessage you have to call the decode function of the superclass Message.
decode(DataInputStream) - Static method in class universal.NackWriteMessage
When you want to decode a NackWriteMessage you have to call the decode function of the superclass Message.
decode(DataInputStream) - Static method in class universal.ReadMessage
When you want to decode a ReadMessage you have to call the decode function of the superclass Message.
decode(DataInputStream) - Static method in class universal.communication.ProcessDetails
 
delta - Variable in class universal.leader.LeaderCrashStopClient.trustListElement
If we don't have received any AmAlive message from the replicated server k during a period delta, this server is considered as not to be alive.
delta - Variable in class universal.leader.LeaderCrashStopServer.trustListElement
If we don't have received any AmAlive message from the replicated server k during a period delta, this server is considered as not to be alive.
destroy() - Method in class universal.ClientInterceptor
 
destroy() - Method in class universal.NRClientInterceptor
 
destroy() - Method in class universal.NRServerInterceptor
 
destroy() - Method in class universal.ServerInterceptor
 

E

encode() - Method in class universal.AckReadMessage
If you want to encode a ReadMessage, you should call this method not the one from the superclass.
encode() - Method in class universal.AckWriteMessage
If you want to encode a WriteMessage, you should call this method not the one from the superclass.
encode() - Method in class universal.AmAliveMessage
If you want to encode an AmAliveMessage, you should call this method not the one from the superclass.
encode() - Method in class universal.Message
When you want to encode a message, you should call the encode function of the real type of the message and not this one.
encode() - Method in class universal.NackReadMessage
When you want to encode a NackReadMessage you should call this function.
encode() - Method in class universal.NackWriteMessage
When you want to encode a NackWriteMessage you should call this function.
encode() - Method in class universal.ReadMessage
When you want to encode a ReadMessage you should call this function.
encode() - Method in class universal.communication.ProcessDetails
 
END_CALL_BY_CLIENT - Static variable in class universal.utils.Utils
 
END_SYNCH_FAILOVER - Static variable in class universal.utils.Utils
 
END_SYNCH_SEND_CALLS - Static variable in class universal.utils.Utils
 
ENTER_RECEIVE_REPLY - Static variable in class universal.utils.Utils
 
ENTER_RECEIVE_REQUEST - Static variable in class universal.utils.Utils
 
ENTER_RECEIVE_REQUEST_G - Static variable in class universal.utils.Utils
 
ENTER_SEND_REPLY - Static variable in class universal.utils.Utils
 
ENTER_SEND_REQUEST - Static variable in class universal.utils.Utils
 
epoch - Variable in class universal.leader.LeaderCrashStopClient.trustListElement
Useful only for the crash recovery model
epoch - Variable in class universal.leader.LeaderCrashStopServer.trustListElement
Useful only for the crash recovery model
epochArray - Variable in class universal.AmAliveMessage
the variable epochArray is not useful in the crashStop model but could be in the crash recovery model
equals(Object) - Method in class universal.AckReadMessage
Compares two objects for equality.
equals(Object) - Method in class universal.AckWriteMessage
Compares two objects for equality.
equals(Object) - Method in class universal.NackReadMessage
Compares two objects for equality.
equals(Object) - Method in class universal.NackWriteMessage
Compares two objects for equality.
equals(Object) - Method in class universal.ReadMessage
Compares two objects for equality.
errorcode - Variable in class universal.exception.NotUserException
 
EXIT_RECEIVE_REPLY - Static variable in class universal.utils.Utils
 
EXIT_RECEIVE_REQUEST - Static variable in class universal.utils.Utils
 
EXIT_REPLY_ALREADY_THERE - Static variable in class universal.utils.Utils
 
EXIT_SEND_REPLY - Static variable in class universal.utils.Utils
 
EXIT_SEND_REPLY_GW - Static variable in class universal.utils.Utils
 
EXIT_SEND_REQUEST - Static variable in class universal.utils.Utils
 
expiration_time - Variable in class universal.Request
Useful to know when we can remove a request form the OutcomeStore
EXPIRATION_TIME - Static variable in class universal.Constants
Expiration time after which the request can be remove from the outcomeStore.
extract_obj_from_any(Any) - Static method in class universal.utils.Utils
 
extract(Any) - Static method in class universal.RequestServiceContextHelper
Extract RequestServiceContext from an any
extract(Any) - Static method in class universal.exception.NotUserExceptionHelper
Extract NotUserException from an any

F

factory - Variable in class universal.NRServerInterceptor
 
factory - Variable in class universal.ServerInterceptor
 
falsepermissioncount - Variable in class universal.consensus.register.AckListener
Could be useful if we want to implement the crash recovery model as it was done in Paxos
filename - Variable in class universal.consensus.register.AckListener
Could be useful if we want to implement the crash recovery model as it was done in Paxos
filename - Variable in class universal.consensus.register.Registry
Could be useful if we want to instantiate the crashRecovery model as in paxos
ft_dom_name_fn - Static variable in class universal.utils.Utils
 
ft_slot - Variable in class universal.ClientInterceptor
 
ft_slot - Variable in class universal.NRClientInterceptor
 
ft_slot - Variable in class universal.NRServerInterceptor
 
ft_slot - Variable in class universal.ServerInterceptor
 

G

GET_ANSWER_GW - Static variable in class universal.utils.Utils
 
get_class_helper_s(String) - Static method in class universal.utils.Utils
 
get_class_helper(String) - Static method in class universal.utils.Utils
 
get_class_name(String) - Static method in class universal.utils.Utils
 
get_class(String) - Static method in class universal.utils.Utils
 
get_ior(Object) - Static method in class universal.utils.Utils
 
get_ior(Object[]) - Static method in class universal.utils.Utils
 
getAcklistener() - Method in class universal.consensus.register.Register
 
getLocalInetAddress() - Static method in class universal.Universal
 
getLocalInetAddress() - Static method in class universal.UniversalClient
 
getReadlistener() - Method in class universal.consensus.register.Register
 
getWritelistener() - Method in class universal.consensus.register.Register
 
give_any_arg(ORB, Object) - Static method in class universal.utils.Utils
 
give_any(ORB, Object, boolean) - Static method in class universal.utils.Utils
 
give_object_holder(Any, boolean) - Static method in class universal.utils.Utils
 
give_object(Any) - Static method in class universal.utils.Utils
 
GW_SEND_REQUESTS - Static variable in class universal.utils.Utils
 
GW_SEND_TRANSIENT - Static variable in class universal.utils.Utils
 

H

HAS_OPENORB - Static variable in class universal.RequestServiceContextHelper
 
HAS_OPENORB - Static variable in class universal.exception.NotUserExceptionHelper
 
holder_with_value(Any, boolean) - Static method in class universal.utils.Utils
 

I

i - Variable in class universal.OutcomeStore
 
id() - Static method in class universal.RequestServiceContextHelper
Return the RequestServiceContext IDL ID
id() - Static method in class universal.exception.NotUserExceptionHelper
Return the NotUserException IDL ID
in - Variable in class universal.communication.SocketReceiver
The InputStream that arrive via the socket.
info - Variable in class universal.ClientInterceptor
 
info - Variable in class universal.NRClientInterceptor
 
info - Variable in class universal.NRServerInterceptor
 
info - Variable in class universal.ServerInterceptor
 
INITIAL_MAX_DELTA - Static variable in class universal.Constants
Initial maximum time interval to receive am alive message before suspecting a process to be crash.
initialize(boolean) - Method in class universal.leader.LeaderCrashStopClient
Create one object trustlist per replicated server.
initialize(boolean) - Method in class universal.leader.LeaderCrashStopServer
Create one object trustlist per replicated server.
initialize(int, int) - Method in class universal.consensus.register.AckListener
Initialize all the global variable
Initializer - class universal.Initializer.
Adds the ClientInterceptor and the ServerInterceptor neccessary for our infrastructure.
Initializer() - Constructor for class universal.Initializer
 
initializeTasks() - Method in class universal.Universal
 
initializeTasks() - Method in class universal.UniversalClient
 
initializeTasks() - Method in class universal.UniversalClientCrashStop
Instantiate the LeaderCrashStopClient (useful for the leader election).
initializeTasks() - Method in class universal.UniversalCrashStop
Instantiate the object LeaderCrashStopserver (useful for the leader election) Instantiate the object Register (useful for the consensus)
initializeUniversal() - Method in class universal.Universal
Look for a port free to listen.
initializeUniversal() - Method in class universal.UniversalClient
Look for a port free to listen.
insert_obj_read_seq(Any, InputStream, TypeCode) - Static method in class universal.utils.Utils
 
insert_obj_read(Any, InputStream) - Static method in class universal.utils.Utils
 
insert(Any, NotUserException) - Static method in class universal.exception.NotUserExceptionHelper
Insert NotUserException into an any
insert(Any, RequestServiceContext) - Static method in class universal.RequestServiceContextHelper
Insert RequestServiceContext into an any
INV_EXITS_SEND_REQUEST - Static variable in class universal.utils.Utils
 
is_leader() - Method in class universal.leader.Leader
Returns first alive replicated server in the list.
is_leader() - Method in class universal.leader.LeaderCrashStopClient
Returns first correct replicated server alive in the list.
is_leader() - Method in class universal.leader.LeaderCrashStopServer
Returns first correct replicated server alive in the list.
isCommitted(Request) - Method in class universal.OutcomeStore
Check whether a Request has already been processed.

J

JustMeasureTimeUnivInitializer - class universal.JustMeasureTimeUnivInitializer.
Add a serverInterceptor for the non replicated case
JustMeasureTimeUnivInitializer() - Constructor for class universal.JustMeasureTimeUnivInitializer
 

L

L - Variable in class universal.consensus.Consensus
The position in the total order for which this object consensus has been created
lastread - Variable in class universal.consensus.register.Registry
The last time it has received a ReadMessage from the leader for the position in the total order that this regitry has been instantiated.
lastReceivingTime - Variable in class universal.leader.LeaderCrashStopClient.trustListElement
The last time we have received a message AmAlive for the replicated server k
lastReceivingTime - Variable in class universal.leader.LeaderCrashStopServer.trustListElement
The last time we have received a message AmAlive for the replicated server k
lastwrite - Variable in class universal.AckReadMessage
The last round number it has written for the place in the total order for which it has received the read message
lastwrite - Variable in class universal.consensus.register.Registry
The last time it has received a WriteMessage from the leader for the position in the total order that this regitry has been instantiated.
lead - Variable in class universal.Universal
Object which treats the leader election
lead - Variable in class universal.UniversalClient
Object which treats the leader election in the client side
Leader - class universal.leader.Leader.
 
leader() - Method in class universal.communication.Receiver
 
leader() - Method in class universal.communication.ReceiverClient
 
Leader(Universal) - Constructor for class universal.leader.Leader
 
LeaderCrashStopClient - class universal.leader.LeaderCrashStopClient.
This is the implementation of the leader part of the algorithm in the client side.
LeaderCrashStopClient.trustListElement - class universal.leader.LeaderCrashStopClient.trustListElement.
 
LeaderCrashStopClient.trustListElement() - Constructor for class universal.leader.LeaderCrashStopClient.trustListElement
Initialisation of all the variables.
LeaderCrashStopClient(UniversalClientCrashStop) - Constructor for class universal.leader.LeaderCrashStopClient
 
LeaderCrashStopServer - class universal.leader.LeaderCrashStopServer.
This is the implementation of the leader part of the algorithm in the server side.
LeaderCrashStopServer.trustListElement - class universal.leader.LeaderCrashStopServer.trustListElement.
 
LeaderCrashStopServer.trustListElement() - Constructor for class universal.leader.LeaderCrashStopServer.trustListElement
Initialisation of all the variables.
LeaderCrashStopServer(Universal) - Constructor for class universal.leader.LeaderCrashStopServer
 
Li - Variable in class universal.consensus.Consensus
The same than L
location - Variable in class universal.ClientInterceptor
 
location - Variable in class universal.NRClientInterceptor
 
location - Variable in class universal.NRServerInterceptor
 
location - Variable in class universal.ServerInterceptor
 

M

makeByteInt(byte[]) - Static method in class universal.utils.Utils
 
makeIntByte(int) - Static method in class universal.utils.Utils
 
MAX_OBJECT_LENGTH - Static variable in class universal.Constants
Max length of packet receive
MAX_PROCESSES - Static variable in class universal.Constants
The number maximal of replicated server
MAX_STORE - Static variable in class universal.Constants
 
merge_unique_iors(String, IOR[]) - Static method in class universal.utils.Utils
 
Message - class universal.Message.
This class is the superclass for all the kind of messages exchanges for the consensus and leader election purposes.
Message() - Constructor for class universal.Message
 
methods - Variable in class universal.MethTable
Array of the size of the number of method our application implement.
methSgn - Variable in class universal.ServerInterceptor
 
MethSignStr - class universal.MethSignStr.
This class is used to store information about each method implemented by the application server
MethSignStr() - Constructor for class universal.MethSignStr
 
MethTable - class universal.MethTable.
This class should be complete by the application writer to store the information about each method of the server.
MethTable(ORB) - Constructor for class universal.MethTable
Contains the definition of each method
mid - Variable in class universal.Message
 
minus(Hashtable, Hashtable) - Static method in class universal.utils.Utils
 
minus(long[], long[]) - Static method in class universal.utils.Utils
 
msgId() - Method in class universal.Message
 
msgType - Variable in class universal.Message
Define the type of the message.
msgType() - Method in class universal.Message
 

N

NACK_READ_MSG - Static variable in class universal.Message
 
NACK_WRITE_MSG - Static variable in class universal.Message
 
nackreadcount - Variable in class universal.consensus.register.AckListener
Number of NackRead messages we have received
NackReadMessage - class universal.NackReadMessage.
Used for creating NackReadMessage.
NackReadMessage(int, int) - Constructor for class universal.NackReadMessage
The constructor
nackwritecount - Variable in class universal.consensus.register.AckListener
Number of NackWrite messages we have received
NackWriteMessage - class universal.NackWriteMessage.
Used for creating NackWriteMessage.
NackWriteMessage(int, int) - Constructor for class universal.NackWriteMessage
The constructor
name - Variable in class universal.MethSignStr
name of the method
name() - Method in class universal.ClientInterceptor
 
name() - Method in class universal.NRClientInterceptor
 
name() - Method in class universal.NRServerInterceptor
 
name() - Method in class universal.ServerInterceptor
 
NonReplUnivClInitializer - class universal.NonReplUnivClInitializer.
Add a clientInterceptor for the non replicated case
NonReplUnivClInitializer() - Constructor for class universal.NonReplUnivClInitializer
 
NotUserException - exception universal.exception.NotUserException.
This exception is thrown when the replicated server that receives a request finally doesn't trust itself as the leader.
NotUserException() - Constructor for class universal.exception.NotUserException
 
NotUserException(int, String) - Constructor for class universal.exception.NotUserException
 
NotUserException(String, int, String) - Constructor for class universal.exception.NotUserException
 
NotUserExceptionHelper - class universal.exception.NotUserExceptionHelper.
We need it to use the function write to marshal the exception.
NotUserExceptionHelper() - Constructor for class universal.exception.NotUserExceptionHelper
 
NotUserExceptionHolder - class universal.exception.NotUserExceptionHolder.
Holder class for : NotUserException
NotUserExceptionHolder() - Constructor for class universal.exception.NotUserExceptionHolder
Default constructor
NotUserExceptionHolder(NotUserException) - Constructor for class universal.exception.NotUserExceptionHolder
Constructor with value initialisation
NRClientInterceptor - class universal.NRClientInterceptor.
The client interceptor for the case we don't replicate the server.
NRClientInterceptor(ORBInitInfo, int) - Constructor for class universal.NRClientInterceptor
 
NRServerInterceptor - class universal.NRServerInterceptor.
The server interceptor for the case when we don't replicate the server.
NRServerInterceptor(ORBInitInfo, int) - Constructor for class universal.NRServerInterceptor
 
num - Variable in class universal.NRServerInterceptor
 
num - Variable in class universal.ServerInterceptor
Num is the idea for this server of the next position in the total order, the next request should be.
NUM_Service_Context - Static variable in class universal.Constants
The service context id can be choose randomly but shouldn't be equal to one
number_notify - Variable in class universal.ServerInterceptor
 
NUMBER_REQUEST - Static variable in class universal.Constants
Number of request store in the outcomeStore after which check if some have expire.
number_waiting - Variable in class universal.ServerInterceptor
Number of request that wait to be processed

O

OMEGA_DELTA - Static variable in class universal.Constants
Time interval to update the trust list and send amAlive messages
omega() - Method in class universal.leader.Leader
Send periodically AmAliveMessage to the client and to all the replicated servers
omega() - Method in class universal.leader.LeaderCrashStopClient
Check if some replicated server shouldn't be trusted anymore because we don't have receive any AmAlive message from it since a period of length delta.
omega() - Method in class universal.leader.LeaderCrashStopServer
Sends periodically AmAliveMessage to all the others replicated server and also to the client.
one_by_one - Variable in class universal.ServerInterceptor
Permit to synchronized on this object in order to treat each request one after another
orb - Variable in class universal.ClientInterceptor
 
orb - Variable in class universal.NRClientInterceptor
 
orb - Variable in class universal.NRServerInterceptor
 
orb - Variable in class universal.ServerInterceptor
 
orb1 - Variable in class universal.NRServerInterceptor
 
orb1 - Variable in class universal.ServerInterceptor
 
out - Variable in class universal.StoreResult
Contains the (Request, Reply,Update) that is for the position in the total order that the consensus was done for.
out - Variable in class universal.consensus.register.ReadResult
If a request has already been processed for this position in the total order, out contains the out that has been written for the higher round number.
out - Variable in class universal.consensus.register.Registry
The Outcome that was in the WriteMessage from the leader
Outcome - class universal.Outcome.
Object that represents a request and its associated reply and update
Outcome() - Constructor for class universal.Outcome
 
Outcome(Request, Reply, Update) - Constructor for class universal.Outcome
 
outcomes - Variable in class universal.OutcomeStore
The vector uses to store the decisions
OutcomeStore - class universal.OutcomeStore.
Used to store the decision return by the consensus when it is sucessful.
OutcomeStore() - Constructor for class universal.OutcomeStore
 

P

param_modes - Variable in class universal.MethSignStr
Array which contains the modes of each parameters of the method (in,out,inout)
param_types - Variable in class universal.MethSignStr
Array which contains the type of each parameters of the method(float,..).
permission - Variable in class universal.AckWriteMessage
the variable permission is not useful in a case of the crashStop model but could be used in the crashRecovery.
permission - Variable in class universal.consensus.register.WriteResult
Could be useful if we want to implement the crash recovery model in the way that it has been done in paxos.
pid - Variable in class universal.Universal
The pid of this server
pid - Variable in class universal.communication.ProcessDetails
The pid of the replicated server that is decribed by this object
pid - Variable in class universal.communication.Sender
The pid of the process that is going to send messages
port - Variable in class universal.Universal
 
port - Variable in class universal.UniversalClient
 
port - Variable in class universal.communication.ProcessDetails
The port where this replicated server is listenning
post_init(ORBInitInfo) - Method in class universal.Initializer
 
post_init(ORBInitInfo) - Method in class universal.JustMeasureTimeUnivInitializer
 
post_init(ORBInitInfo) - Method in class universal.NonReplUnivClInitializer
 
pre_init(ORBInitInfo) - Method in class universal.Initializer
Add the interceptors
pre_init(ORBInitInfo) - Method in class universal.JustMeasureTimeUnivInitializer
 
pre_init(ORBInitInfo) - Method in class universal.NonReplUnivClInitializer
 
print_IOR(ORB, IOR) - Static method in class universal.utils.Utils
 
printCommunication(String) - Static method in class universal.Debug
Print the message for communication
println(String) - Static method in class universal.Debug
Print the message for debugging
printRegister() - Method in class universal.consensus.register.Register
 
ProcessDetails - class universal.communication.ProcessDetails.
Each replicated server and the client keeps a description of all the replicated servers : the port where it is listenning, its IP address, its pid.
ProcessDetails(int, InetAddress, int) - Constructor for class universal.communication.ProcessDetails
 
processes - Variable in class universal.communication.ReceiverClient
List of the replicated servers
processes - Variable in class universal.communication.Sender
List of the replicated server plus the client .
processesReplicas - Variable in class universal.communication.Sender
List of the replicated servers that messages for the consensus should be send
profile_body(ORB, TaggedProfile) - Static method in class universal.utils.Utils
 
propose(int, Outcome) - Method in class universal.consensus.Consensus
The leader propose the request, reply an update that it thinks should be for this position in the total order.

R

READ - Static variable in class universal.utils.Utils
 
read_args(ORB, MethSignStr, CDRInputStream) - Static method in class universal.utils.Utils
 
read_input_stream(InputStream, Any, boolean) - Static method in class universal.utils.Utils
 
READ_MSG - Static variable in class universal.Message
 
read_param(InputStream, String) - Static method in class universal.utils.Utils
 
read(InputStream) - Static method in class universal.RequestServiceContextHelper
Read RequestServiceContext from a marshalled stream
read(InputStream) - Static method in class universal.exception.NotUserExceptionHelper
Read NotUserException from a marshalled stream
read(int, int) - Method in class universal.consensus.register.Registry
Read for the round number k and the position in the total order K.
ReadBuffer - Variable in class universal.communication.Receiver
Contains the Read messages that have been received but not yet analize in ReadListenner
readcount - Variable in class universal.consensus.register.AckListener
Number of AckRead+NackRead messages we have received
readlistener - Variable in class universal.consensus.register.Register
The thread who is going to wait for ReadMessage from the leader
ReadListener - class universal.consensus.register.ReadListener.
Thread that waits for ReadMessage from the leader.
readListener() - Method in class universal.consensus.register.ReadListener
When a server receives a ReadMessage it sends an AckReadMessage or a NackReadMessage depending if it has already read or written for an higer round number or not.
ReadListener(Register) - Constructor for class universal.consensus.register.ReadListener
 
ReadMessage - class universal.ReadMessage.
Used for creating ReadMessage.
ReadMessage(int, int) - Constructor for class universal.ReadMessage
 
readMethod - Variable in class universal.MethSignStr
true if the method just read and doesn't change the state of the object
readObject(DataInputStream) - Method in class universal.Outcome
 
readObject(DataInputStream) - Method in class universal.Reply
 
readObject(DataInputStream) - Method in class universal.Request
 
readrecvd - Variable in class universal.consensus.register.AckListener
True if we have received a majority + 1 AckRead or NackRead messages for this round number
ReadResult - class universal.consensus.register.ReadResult.
The object return by the read method of the registry.
ReadResult() - Constructor for class universal.consensus.register.ReadResult
 
reason - Variable in class universal.exception.NotUserException
 
rec - Variable in class universal.communication.SocketReceiver
 
REC_GET_STATE_REPLY - Static variable in class universal.utils.Utils
 
REC_GET_STATE_REQ - Static variable in class universal.utils.Utils
 
REC_GET_UPDATE_REPLY - Static variable in class universal.utils.Utils
 
REC_GET_UPDATE_REQ - Static variable in class universal.utils.Utils
 
RECEIVE_EXCEPTION - Static variable in class universal.utils.Utils
 
receive_exception(ClientRequestInfo) - Method in class universal.ClientInterceptor
 
receive_exception(ClientRequestInfo) - Method in class universal.NRClientInterceptor
 
RECEIVE_FIRST_REPLY - Static variable in class universal.utils.Utils
 
RECEIVE_OTHER - Static variable in class universal.utils.Utils
 
receive_other(ClientRequestInfo) - Method in class universal.ClientInterceptor
 
receive_other(ClientRequestInfo) - Method in class universal.NRClientInterceptor
 
receive_reply(ClientRequestInfo) - Method in class universal.ClientInterceptor
 
receive_reply(ClientRequestInfo) - Method in class universal.NRClientInterceptor
 
receive_request_service_contexts(ServerRequestInfo) - Method in class universal.NRServerInterceptor
get the transaction propagation context from the service context list and save it to the PICurrent
receive_request_service_contexts(ServerRequestInfo) - Method in class universal.ServerInterceptor
This is precisely from that method that everything is going to be done.
receive_request(ServerRequestInfo) - Method in class universal.NRServerInterceptor
 
receive_request(ServerRequestInfo) - Method in class universal.ServerInterceptor
 
receive() - Method in class universal.communication.ReceiverClient
Waits for new packet to arrive and then return as an Object the message that has been decoded.
receive() - Method in class universal.communication.SocketReceiver
 
receivedAmAlive(AmAliveMessage) - Method in class universal.leader.Leader
Update if a replicated server is alive each time it recieves an AmaliveMessage from it
receivedAmAlive(AmAliveMessage) - Method in class universal.leader.LeaderCrashStopClient
Call when it receives an AmAliveMessage from one of the replicated servers.
receivedAmAlive(AmAliveMessage) - Method in class universal.leader.LeaderCrashStopServer
Call when it receives an AmAliveMessage from one of the replicated servers.
receiver - Variable in class universal.Universal
Object which waits for message comming to the socket
Receiver - class universal.communication.Receiver.
This subclass implements the crash stop model receiver.
receiver() - Method in class universal.consensus.register.AckListener
 
receiver() - Method in class universal.consensus.register.ReadListener
 
receiver() - Method in class universal.consensus.register.WriteListener
 
Receiver(Universal) - Constructor for class universal.communication.Receiver
It starts the thread that is going to listen for connection.
receiverClient - Variable in class universal.UniversalClient
Object which waits for message comming to the socket
ReceiverClient - class universal.communication.ReceiverClient.
This subclass implements the crash stop model receiver in the side of the client.
receiverClient() - Method in class universal.leader.LeaderCrashStopClient
 
ReceiverClient(UniversalClient) - Constructor for class universal.communication.ReceiverClient
Start the thread to listen for new messages to arrive
reg - Variable in class universal.Universal
Object for the consensus purposes
reg - Variable in class universal.consensus.register.AckListener
 
reg - Variable in class universal.consensus.register.ReadListener
 
reg - Variable in class universal.consensus.register.WriteListener
 
reg() - Method in class universal.communication.Receiver
 
Register - class universal.consensus.register.Register.
 
Register(Universal) - Constructor for class universal.consensus.register.Register
Instantiate the object ReadListener, WriteListenner and AckListener
registry - Variable in class universal.consensus.Consensus
The object in which we are going to register the Outcome value (Request,Reply,Update) that has been decided for this position in the total order and also the last time it has read and write for this position.
registry - Variable in class universal.consensus.register.Register
The HahsTable of registry which contains the request decided for each position in the total order
Registry - class universal.consensus.register.Registry.
Each time a new consensus is started for a new position in the total order, a registry is added to the hashtable of the register.
Registry(Universal) - Constructor for class universal.consensus.register.Registry
 
remember_highest_k_out - Variable in class universal.consensus.register.AckListener
If a request has already been processed for this position in the total order,the AckRead messages contain the value decided and for for which round number it has been written.
remember_highest_k_value - Variable in class universal.consensus.register.AckListener
If a request has already been processed for this position in the total order,the AckRead messages contains the value decided and for for which round number it has been written.
REPL_MAN_BEG_GET_STATE - Static variable in class universal.utils.Utils
 
REPL_MAN_BEG_SET_STATE - Static variable in class universal.utils.Utils
 
REPL_MAN_BEGIN_CR_OBJ - Static variable in class universal.utils.Utils
 
REPL_MAN_BEGIN_REC - Static variable in class universal.utils.Utils
 
REPL_MAN_END_CR_OBJ - Static variable in class universal.utils.Utils
 
REPL_MAN_END_GET_STATE - Static variable in class universal.utils.Utils
 
REPL_MAN_END_REC - Static variable in class universal.utils.Utils
 
REPL_MAN_END_SET_STATE - Static variable in class universal.utils.Utils
 
REPL_MAN_REC_F_NOT - Static variable in class universal.utils.Utils
 
replicasAnnounce - Variable in class universal.Universal
Sends Corba message to the other replicated servers to tell them in which port the TCP socket listen
ReplicasAnnounce - class universal.messagein.ReplicasAnnounce.
Each replicated server uses this class to send a CORBA message to all the replicated servers to inform them in which port and which address they can send the messages needed for the leader election and for the consensus .
ReplicasAnnounce(Universal) - Constructor for class universal.messagein.ReplicasAnnounce
 
replicasNameFile - Variable in class universal.Universal
The name of the file which contains the name of the others replicated server and their pid
Reply - class universal.Reply.
Reply is the return of the method of the application server and the out and inout parameters.
Reply() - Constructor for class universal.Reply
 
Reply(Object, Object[]) - Constructor for class universal.Reply
Create to store the reply that should be send to the client as answer to its requests.
req - Variable in class universal.Outcome
The request sends by the client.
Request - class universal.Request.
Object Request contains the retention id of the request, the client id and its expirarion time.
request_start_time - Variable in class universal.RequestServiceContext
Struct member request_start_time.
Request() - Constructor for class universal.Request
 
Request(int, String, long) - Constructor for class universal.Request
 
RequestServiceContext - class universal.RequestServiceContext.
Struct definition : RequestServiceContext Add a service context to the request when it goes through the clientInterceptor in the method send_request.
RequestServiceContext() - Constructor for class universal.RequestServiceContext
 
RequestServiceContext(long, int, String) - Constructor for class universal.RequestServiceContext
 
RequestServiceContextHelper - class universal.RequestServiceContextHelper.
Helper class for : RequestServiceContext
RequestServiceContextHelper() - Constructor for class universal.RequestServiceContextHelper
 
RequestServiceContextHolder - class universal.RequestServiceContextHolder.
Holder class for : RequestServiceContext
RequestServiceContextHolder() - Constructor for class universal.RequestServiceContextHolder
Default constructor
RequestServiceContextHolder(RequestServiceContext) - Constructor for class universal.RequestServiceContextHolder
Constructor with value initialisation
res - Variable in class universal.Outcome
The reply associates to the request.
res - Variable in class universal.Reply
return of the method of the application server
res_args - Variable in class universal.Reply
inout and out parameters
resolve_n(NamingContext, NameComponent[]) - Static method in class universal.utils.Utils
 
retention_id - Variable in class universal.Request
Each different request from a certain client has a different id
retention_id - Variable in class universal.RequestServiceContext
Struct member retention_id.
RETRANSMIT_DELTA - Static variable in class universal.Constants
 
roundno - Variable in class universal.ReadMessage
roundno the round number for this consensus.
roundno - Variable in class universal.consensus.register.AckListener
The round number for which we are actually doing the consensus
run() - Method in class universal.communication.Receiver
Waits for connection to the socket.
run() - Method in class universal.communication.ReceiverClient
Waits for AmAlive messages and then informs the leader part of our algorithm that an AmAlive message has arrived.
run() - Method in class universal.communication.SocketReceiver
Depending on the type of the message, it adds it to the vector AckBuffer, ReadBuffer or WriteBuffer if it is respectively an acknowledgement, read or write messages.
run() - Method in class universal.consensus.register.AckListener
 
run() - Method in class universal.consensus.register.ReadListener
 
run() - Method in class universal.consensus.register.WriteListener
 
run() - Method in class universal.leader.Leader
 
run() - Method in class universal.leader.LeaderCrashStopClient
 

S

s_send(Message, InetAddress, int) - Method in class universal.communication.Sender
Send message through Universal's socket to the specified address and port
s_send(Message, Vector) - Method in class universal.communication.Sender
Sends the message m through Universal's socket to the proccesses specified in the list processesSend.
semaphor - Static variable in class universal.utils.Utils
 
SEND_EXCEPTION - Static variable in class universal.utils.Utils
 
SEND_EXCEPTION_RM - Static variable in class universal.utils.Utils
 
send_exception(ServerRequestInfo) - Method in class universal.NRServerInterceptor
 
send_exception(ServerRequestInfo) - Method in class universal.ServerInterceptor
 
SEND_FORWARD_EXC - Static variable in class universal.utils.Utils
 
SEND_GET_STATE_REPLY - Static variable in class universal.utils.Utils
 
SEND_GET_STATE_REQ - Static variable in class universal.utils.Utils
 
SEND_GET_UPDATE_REPLY - Static variable in class universal.utils.Utils
 
SEND_GET_UPDATE_REQ - Static variable in class universal.utils.Utils
 
SEND_OTHER - Static variable in class universal.utils.Utils
 
SEND_OTHER_RM - Static variable in class universal.utils.Utils
 
send_other(ServerRequestInfo) - Method in class universal.NRServerInterceptor
 
send_other(ServerRequestInfo) - Method in class universal.ServerInterceptor
 
send_poll(ClientRequestInfo) - Method in class universal.ClientInterceptor
 
send_poll(ClientRequestInfo) - Method in class universal.NRClientInterceptor
 
send_reply(ServerRequestInfo) - Method in class universal.NRServerInterceptor
 
send_reply(ServerRequestInfo) - Method in class universal.ServerInterceptor
 
SEND_REQ_EXP_EXC - Static variable in class universal.utils.Utils
 
SEND_REQ_EXP_EXC_GW - Static variable in class universal.utils.Utils
 
send_request(ClientRequestInfo) - Method in class universal.ClientInterceptor
Add the service context to the request : retention_id,client_id ,request_start_time.
send_request(ClientRequestInfo) - Method in class universal.NRClientInterceptor
 
SEND_WR_PRIM_EXC - Static variable in class universal.utils.Utils
 
send(Message, InetAddress, int) - Method in class universal.communication.Sender
Send message through Universal's socket to the specified address and port
send(Message, Vector) - Method in class universal.communication.Sender
Sends the message m through Universal's socket to the proccesses specified in the list processesSend.
sender - Variable in class universal.Universal
Object which send message through the socket
Sender - class universal.communication.Sender.
To send messages via the TCP socket (in order to simulate a reliable channel).
sender() - Method in class universal.consensus.register.AckListener
 
sender() - Method in class universal.consensus.register.ReadListener
 
sender() - Method in class universal.consensus.register.WriteListener
 
sender() - Method in class universal.consensus.register.Registry
 
sender() - Method in class universal.leader.Leader
 
Sender(Universal) - Constructor for class universal.communication.Sender
 
senderid - Variable in class universal.Message
the pid of the replicated server that send this message
ServerInterceptor - class universal.ServerInterceptor.
This is from this class that everything is going to be done (execution of the request, consensus, sending back of the reply).
ServerInterceptor(ORBInitInfo, int) - Constructor for class universal.ServerInterceptor
 
serverNameFile - Variable in class universal.UniversalClient
The name of the file which contains the list of the name of the host on which are the others replicated servers and their associated pid.
serverSocket - Variable in class universal.Universal
 
serverSocket - Variable in class universal.UniversalClient
 
SET_STATE - Static variable in class universal.utils.Utils
 
SET_UPDATE - Static variable in class universal.utils.Utils
 
setCommitted(Outcome) - Method in class universal.OutcomeStore
Stores the Outcome (Request, Reply, Update) return by the consensus when it is successful.
SocketReceiver - class universal.communication.SocketReceiver.
Wait for packet to arrive to the socket.
SocketReceiver(Socket, Receiver) - Constructor for class universal.communication.SocketReceiver
 
START_CALL_BY_CLIENT - Static variable in class universal.utils.Utils
 
START_CONSENSUS - Static variable in class universal.utils.Utils
 
START_GET_S_WAIT - Static variable in class universal.utils.Utils
 
START_GET_STATE - Static variable in class universal.utils.Utils
 
START_GET_STATE_A - Static variable in class universal.utils.Utils
 
START_GET_STATE_B - Static variable in class universal.utils.Utils
 
START_GET_STATE_CALL - Static variable in class universal.utils.Utils
 
START_GET_U_WAIT - Static variable in class universal.utils.Utils
 
START_GET_UPDATE - Static variable in class universal.utils.Utils
 
START_GET_UPDATE_CALL - Static variable in class universal.utils.Utils
 
START_INVOKE - Static variable in class universal.utils.Utils
 
START_LOOKUP - Static variable in class universal.utils.Utils
 
START_PROC - Static variable in class universal.utils.Utils
 
START_REC_BR_METHOD_CALL - Static variable in class universal.utils.Utils
 
START_REC_BR_REPLY - Static variable in class universal.utils.Utils
 
START_REC_METHOD_CALL - Static variable in class universal.utils.Utils
 
START_REC_REPLY - Static variable in class universal.utils.Utils
 
START_RESTORE_ST - Static variable in class universal.utils.Utils
 
START_SET_STATE - Static variable in class universal.utils.Utils
 
START_STATE_REC - Static variable in class universal.utils.Utils
 
START_TENT_EXEC - Static variable in class universal.utils.Utils
 
START_UPDATE_REC - Static variable in class universal.utils.Utils
 
START_WAIT_ANSWER_GW - Static variable in class universal.utils.Utils
 
START_WAIT_GET_STATE - Static variable in class universal.utils.Utils
 
START_WAIT_UPD_OPER - Static variable in class universal.utils.Utils
 
startTasks() - Method in class universal.Universal
Starts the thread ReadListenner, WriteListenner, AckListenner
startTasks() - Method in class universal.UniversalClient
 
startTime - Variable in class universal.Universal
 
startTime - Variable in class universal.UniversalClient
 
STOP_CONSENSUS - Static variable in class universal.utils.Utils
 
STOP_GET_S_WAIT - Static variable in class universal.utils.Utils
 
STOP_GET_STATE - Static variable in class universal.utils.Utils
 
STOP_GET_STATE_CALL - Static variable in class universal.utils.Utils
 
STOP_GET_U_WAIT - Static variable in class universal.utils.Utils
 
STOP_GET_UPDATE - Static variable in class universal.utils.Utils
 
STOP_GET_UPDATE_CALL - Static variable in class universal.utils.Utils
 
STOP_LOOKUP - Static variable in class universal.utils.Utils
 
STOP_PROC_EXC - Static variable in class universal.utils.Utils
 
STOP_PROC_NORMAL - Static variable in class universal.utils.Utils
 
STOP_PROC_REPLY_THERE - Static variable in class universal.utils.Utils
 
STOP_REC_BR_METHOD_CALL - Static variable in class universal.utils.Utils
 
STOP_REC_BR_REPLY - Static variable in class universal.utils.Utils
 
STOP_REC_METHOD_CALL - Static variable in class universal.utils.Utils
 
STOP_REC_REPLY - Static variable in class universal.utils.Utils
 
STOP_RESTORE_ST - Static variable in class universal.utils.Utils
 
STOP_SET_STATE - Static variable in class universal.utils.Utils
 
STOP_SET_UPDATE - Static variable in class universal.utils.Utils
 
STOP_STATE_REC - Static variable in class universal.utils.Utils
 
STOP_TENT_EXEC - Static variable in class universal.utils.Utils
 
STOP_UPDATE_REC - Static variable in class universal.utils.Utils
 
STOP_WAIT_GET_STATE - Static variable in class universal.utils.Utils
 
STOP_WAIT_UPD_OPER - Static variable in class universal.utils.Utils
 
store - Variable in class universal.ServerInterceptor
The variable store contains the outcome (Request, Reply, Update) for requests that have already been processed and that have not yet expired.
StoreResult - class universal.StoreResult.
This object contains the return value by the method propose() of the class Consensus.
StoreResult(boolean, Outcome) - Constructor for class universal.StoreResult
 

T

t - Variable in class universal.Universal
 
t - Variable in class universal.UniversalClient
 
t_slot - Variable in class universal.Initializer
 
t_slot - Variable in class universal.JustMeasureTimeUnivInitializer
 
t_slot - Variable in class universal.NonReplUnivClInitializer
 
table - Variable in class universal.ServerInterceptor
Contains the description of all the methods of the application server.
THROW_REPLY_HERE - Static variable in class universal.utils.Utils
 
toString() - Method in class universal.AckReadMessage
 
toString() - Method in class universal.AckWriteMessage
 
toString() - Method in class universal.AmAliveMessage
 
toString() - Method in class universal.NackReadMessage
 
toString() - Method in class universal.NackWriteMessage
 
toString() - Method in class universal.ReadMessage
 
toString() - Method in class universal.Universal
 
toString() - Method in class universal.communication.ProcessDetails
 
totalDel - Variable in class universal.Universal
 
totalDel - Variable in class universal.UniversalClient
 
totalno() - Method in class universal.communication.ReceiverClient
 
totalno() - Method in class universal.communication.Sender
Returns the number of replicated server in the list processesReplicas.
trace_file - Variable in class universal.ClientInterceptor
 
trace_file - Variable in class universal.NRClientInterceptor
 
trace_file - Variable in class universal.NRServerInterceptor
 
trace_file - Variable in class universal.ServerInterceptor
The file which contains the traces.
trace(int, int, String, long, String, RandomAccessFile) - Static method in class universal.utils.Utils
 
trusted - Variable in class universal.leader.LeaderCrashStopClient.trustListElement
True if the replicated server k is consider to be alive
trusted - Variable in class universal.leader.LeaderCrashStopServer.trustListElement
True if the replicated server k is consider to be alive
trustList - Variable in class universal.leader.LeaderCrashStopClient
trustList[k] contains information about the replicated server of pid k
trustList - Variable in class universal.leader.LeaderCrashStopServer
trustList[k] contains information about the replicated server of pid k
type() - Static method in class universal.RequestServiceContextHelper
Return the RequestServiceContext TypeCode
type() - Static method in class universal.exception.NotUserExceptionHelper
Return the NotUserException TypeCode

U

uni - Variable in class universal.communication.Receiver
The Universal object this receiver is linked to.
uni - Variable in class universal.communication.Sender
The Universal Object that this sender is linked to.
uni - Variable in class universal.consensus.register.AckListener
The object Universal this AckListenner is linked to
uni - Variable in class universal.consensus.register.Register
The object universal the register is linked to
uni - Variable in class universal.consensus.register.Registry
The object Universal that this Registry is linked to
uni - Variable in class universal.leader.Leader
 
uni - Variable in class universal.messagein.ReplicasAnnounce
 
uni - Variable in class universal.ServerInterceptor
This object permit to access the implementation of the algorithm (Leader election, consensus)
uniClient - Variable in class universal.communication.ReceiverClient
The Universal object this receiver is linked to
uniClient - Variable in class universal.leader.LeaderCrashStopClient
The object UniversalClientCrashStop this LeaderCrashStopClient is linked to
uniClient - Variable in class universal.messagein.ClientAnnounce
The UniversalClient this ClientAnnounce is linked to
univ - Variable in class universal.consensus.Consensus
The object Universal the consensus is linked to
universal - package universal
 
Universal - class universal.Universal.
This class is the superclass of the object UniversalCrashStop which is instantiate by the server.
universal.communication - package universal.communication
 
universal.consensus - package universal.consensus
 
universal.consensus.register - package universal.consensus.register
 
universal.exception - package universal.exception
 
universal.leader - package universal.leader
 
universal.messagein - package universal.messagein
 
universal.utils - package universal.utils
 
Universal(int, String) - Constructor for class universal.Universal
Each replicated servers has one object universal.
UniversalClient - class universal.UniversalClient.
This class is the superclass of the class UniversalClientCrashStop which is instantiated by the client application.
UniversalClient(String) - Constructor for class universal.UniversalClient
 
UniversalClientCrashStop - class universal.UniversalClientCrashStop.
This subclass implements the crash stop model in the client side.
UniversalClientCrashStop(String) - Constructor for class universal.UniversalClientCrashStop
The client instantiates one object universalClientCrashStop by group of replicated servers that it wants to acces because for example it needs to know who is the leader for each group.
UniversalCrashStop - class universal.UniversalCrashStop.
This subclass of Universal implements the crash stop model in the server side It is instantiated by the aplication server.
UniversalCrashStop(int, String) - Constructor for class universal.UniversalCrashStop
Each replicated servers instantiate one object UniversalCrashStop.
upd - Variable in class universal.Outcome
The update of the state associates with this request.
UPDATE_NON_VOID - Static variable in class universal.utils.Utils
 
UPDATE_ONEWAY - Static variable in class universal.utils.Utils
 
UPDATE_VOID - Static variable in class universal.utils.Utils
 
Utils - class universal.utils.Utils.
 
Utils() - Constructor for class universal.utils.Utils
 

V

v2a(Vector) - Static method in class universal.Debug
for compatibility with java 1.1.8 toArray() method did not exist in Vector
value - Variable in class universal.AckReadMessage
The last value read for the place in the total order for which it has received the read message
value - Variable in class universal.RequestServiceContextHolder
Internal RequestServiceContext value
value - Variable in class universal.exception.NotUserExceptionHolder
Internal NotUserException value

W

waiting - Variable in class universal.Universal
 
waiting - Variable in class universal.UniversalClient
 
WRITE_MSG - Static variable in class universal.Message
 
write_obj_extract_seq(Any, OutputStream, TypeCode) - Static method in class universal.utils.Utils
 
write_obj_extract(Any, OutputStream) - Static method in class universal.utils.Utils
 
write_obj_helper_extract(Any, OutputStream) - Static method in class universal.utils.Utils
 
write_output_stream(Any, OutputStream) - Static method in class universal.utils.Utils
 
write(int, Outcome, int) - Method in class universal.consensus.register.Registry
Try to write the value out for the round number k and the position in the total order K.
write(OutputStream, NotUserException) - Static method in class universal.exception.NotUserExceptionHelper
Write NotUserException into a marshalled stream
write(OutputStream, RequestServiceContext) - Static method in class universal.RequestServiceContextHelper
Write RequestServiceContext into a marshalled stream
WriteBuffer - Variable in class universal.communication.Receiver
Contains the Write messages that have been recived but not yet analize in WriteListenner
writecount - Variable in class universal.consensus.register.AckListener
Number of AckWrite+NackWrite messages we have received
writelistener - Variable in class universal.consensus.register.Register
The thread who is going to wait for WriteMessage from the leader
WriteListener - class universal.consensus.register.WriteListener.
Thread that waits for WriteMessage from the leader.
writeListener() - Method in class universal.consensus.register.WriteListener
When a server recceives a WriteMessage, it sends an AckWriteMessage or a NackWriteMessage depending if it has already read or write for a higher round number or not.
WriteListener(Register) - Constructor for class universal.consensus.register.WriteListener
 
writeObject(DataOutputStream) - Method in class universal.Outcome
 
writeObject(DataOutputStream) - Method in class universal.Reply
 
writeObject(DataOutputStream) - Method in class universal.Request
 
writerecvd - Variable in class universal.consensus.register.AckListener
True if we have received a majority + 1 AckWrite or NackWrite for this round number
WriteResult - class universal.consensus.register.WriteResult.
The object return by the write method of the registry
WriteResult(boolean, boolean) - Constructor for class universal.consensus.register.WriteResult
 

Y

YES_REQUEST_RIGHT_PLACE - Static variable in class universal.utils.Utils
 

_

_id - Static variable in class universal.RequestServiceContextHelper
 
_id - Static variable in class universal.exception.NotUserExceptionHelper
 
_read(InputStream) - Method in class universal.RequestServiceContextHolder
Read RequestServiceContext from a marshalled stream
_read(InputStream) - Method in class universal.exception.NotUserExceptionHolder
Read NotUserException from a marshalled stream
_tc - Static variable in class universal.RequestServiceContextHelper
Internal TypeCode value
_tc - Static variable in class universal.exception.NotUserExceptionHelper
Internal TypeCode value
_type() - Method in class universal.RequestServiceContextHolder
Return the RequestServiceContext TypeCode
_type() - Method in class universal.exception.NotUserExceptionHolder
Return the NotUserException TypeCode
_working - Static variable in class universal.RequestServiceContextHelper
 
_working - Static variable in class universal.exception.NotUserExceptionHelper
 
_write(OutputStream) - Method in class universal.RequestServiceContextHolder
Write RequestServiceContext into a marshalled stream
_write(OutputStream) - Method in class universal.exception.NotUserExceptionHolder
Write NotUserException into a marshalled stream

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