org.objectweb.proactive.core.body.ft.protocols.pmlrb.servers
Class CheckpointServerPMLRB

java.lang.Object
  extended byorg.objectweb.proactive.core.body.ft.servers.storage.CheckpointServerImpl
      extended byorg.objectweb.proactive.core.body.ft.protocols.pmlrb.servers.CheckpointServerPMLRB
All Implemented Interfaces:
CheckpointServer, java.rmi.Remote

public class CheckpointServerPMLRB
extends CheckpointServerImpl

This class defines a checkpoint server for PMLRB protcol.

Since:
3.0
Author:
cdelbe

Field Summary
protected static org.apache.log4j.Logger logger
           
 
Fields inherited from class org.objectweb.proactive.core.body.ft.servers.storage.CheckpointServerImpl
checkpointStorage, classServerHelper, codebase, server
 
Constructor Summary
CheckpointServerPMLRB(FTServer server)
          Constructor.
 
Method Summary
 void addInfoToCheckpoint(CheckpointInfo ci, UniqueID id, int sequenceNumber, int incarnation)
          Not implemented for this protocol.
 void commitHistory(HistoryUpdater rh)
          Add an history to a checkpoint.
 Checkpoint getCheckpoint(UniqueID id, int sequenceNumber)
          Not implemented for this procotol.
 CheckpointInfo getInfoFromCheckpoint(UniqueID id, int sequenceNumber)
          Not implemented for this protocol.
 Checkpoint getLastCheckpoint(UniqueID id)
          Return the latest checkpoint of the object identified by id
 void outputCommit(MessageInfo mi)
          The state of the system must be commited before the sent of the message linked to the messageInfo mi.
 int storeCheckpoint(Checkpoint c, int incarnation)
          Store a checkpoint in the checkpoint server.
 void storeReply(UniqueID receiverID, Reply reply)
          The reply passed in paramter must be synchronously logged on the server.
 void storeRequest(UniqueID receiverId, Request request)
          The request passed in paramter must be synchronously logged on the server.
 
Methods inherited from class org.objectweb.proactive.core.body.ft.servers.storage.CheckpointServerImpl
getServerCodebase, getSize, getUsedMem, initialize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

protected static org.apache.log4j.Logger logger
Constructor Detail

CheckpointServerPMLRB

public CheckpointServerPMLRB(FTServer server)
Constructor.

Parameters:
server - the corresponding global server.
Method Detail

storeCheckpoint

public int storeCheckpoint(Checkpoint c,
                           int incarnation)
                    throws java.rmi.RemoteException
Description copied from interface: CheckpointServer
Store a checkpoint in the checkpoint server.

Parameters:
c - the checkpoint to stored
incarnation - incarnation number of the caller
Returns:
the last global state of the system, i.e. the index of the latest completed image of the system.
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.storeCheckpoint(org.objectweb.proactive.core.body.ft.checkpointing.Checkpoint, int)

getCheckpoint

public Checkpoint getCheckpoint(UniqueID id,
                                int sequenceNumber)
                         throws java.rmi.RemoteException
Not implemented for this procotol.

Parameters:
id - the owner of the returned checkpoint
sequenceNumber - the index of the requiered checkpoint
Returns:
a checkpoint of the object identified by id
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.getCheckpoint(org.objectweb.proactive.core.UniqueID, int)

getLastCheckpoint

public Checkpoint getLastCheckpoint(UniqueID id)
                             throws java.rmi.RemoteException
Description copied from interface: CheckpointServer
Return the latest checkpoint of the object identified by id

Parameters:
id - the owner of the returned checkpoint
Returns:
the latest checkpoint of the object identified by id
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.getLastCheckpoint(org.objectweb.proactive.core.UniqueID)

addInfoToCheckpoint

public void addInfoToCheckpoint(CheckpointInfo ci,
                                UniqueID id,
                                int sequenceNumber,
                                int incarnation)
                         throws java.rmi.RemoteException
Not implemented for this protocol.

Parameters:
ci - informations that have to be added
id - owner of the considered checkpoint
sequenceNumber - index of the considered checkpoint
incarnation - incarnation number of the caller
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.addInfoToCheckpoint(org.objectweb.proactive.core.body.ft.checkpointing.CheckpointInfo, org.objectweb.proactive.core.UniqueID, int, int)

getInfoFromCheckpoint

public CheckpointInfo getInfoFromCheckpoint(UniqueID id,
                                            int sequenceNumber)
                                     throws java.rmi.RemoteException
Not implemented for this protocol.

Parameters:
id - owner of the considered checkpoint
sequenceNumber - index of the considered checkpoint
Returns:
informations on the given checkpoint
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.getInfoFromCheckpoint(org.objectweb.proactive.core.UniqueID, int)

storeRequest

public void storeRequest(UniqueID receiverId,
                         Request request)
                  throws java.rmi.RemoteException
Description copied from interface: CheckpointServer
The request passed in paramter must be synchronously logged on the server. It must be associated with the ID passed in parameter.

Parameters:
receiverId - the ID associated to the request.
request - the request to log.
Throws:
java.rmi.RemoteException - If communication with server fails.
See Also:
CheckpointServer.storeRequest(org.objectweb.proactive.core.UniqueID, org.objectweb.proactive.core.body.request.Request)

storeReply

public void storeReply(UniqueID receiverID,
                       Reply reply)
                throws java.rmi.RemoteException
Description copied from interface: CheckpointServer
The reply passed in paramter must be synchronously logged on the server. It must be associated with the ID passed in parameter.

Parameters:
receiverID - the ID associated to the reply.
reply - the reply to log.
Throws:
java.rmi.RemoteException - If communication with server fails.
See Also:
CheckpointServer.storeReply(org.objectweb.proactive.core.UniqueID, org.objectweb.proactive.core.body.reply.Reply)

outputCommit

public void outputCommit(MessageInfo mi)
                  throws java.rmi.RemoteException
Description copied from interface: CheckpointServer
The state of the system must be commited before the sent of the message linked to the messageInfo mi.

Parameters:
mi - the message information linked to the message that is sent to the outside world
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.outputCommit(org.objectweb.proactive.core.body.ft.message.MessageInfo)

commitHistory

public void commitHistory(HistoryUpdater rh)
                   throws java.rmi.RemoteException
Description copied from interface: CheckpointServer
Add an history to a checkpoint. Informations about the corresponding checkpoint are stored in the HistoryUpdater object.

Parameters:
rh - the history updater.
Throws:
java.rmi.RemoteException
See Also:
CheckpointServer.commitHistory(org.objectweb.proactive.core.body.ft.message.HistoryUpdater)


Copyright 2001-2005 INRIA All Rights Reserved.