org.objectweb.proactive.core.body.ft.servers.recovery
Interface RecoveryProcess

All Superinterfaces:
java.rmi.Remote
All Known Implementing Classes:
FTServer, RecoveryProcessImpl

public interface RecoveryProcess
extends java.rmi.Remote

An object implementing this interface provides recovery methods. This server is an RMI object.

Since:
ProActive 2.2
Author:
cdelbe

Field Summary
static int FAILED
          Active objects possible states.
static int RECOVERING
           
static int RUNNING
           
 
Method Summary
 void failureDetected(UniqueID id)
          Notify the recovery process that the body passed in paramater is suspected to be failed.
 int getSystemSize()
          Return the size of the system, i.e. the number of registred bodies.
 void initialize()
          Reinit the state of the recovery process.
 void register(UniqueID id)
          Register the calling AO.
 void submitJob(ActiveQueueJob job)
          to submit a job to recovery process
 JobBarrier submitJobWithBarrier(ActiveQueueJob job)
          to submit a job to recovery process, with a barrier for waiting its completion
 void unregister(UniqueID id)
          Unregister the AO identified by id.
 void updateState(UniqueID id, int state)
          Update the current state of the active object id.
 

Field Detail

FAILED

public static final int FAILED
Active objects possible states.

See Also:
Constant Field Values

RECOVERING

public static final int RECOVERING
See Also:
Constant Field Values

RUNNING

public static final int RUNNING
See Also:
Constant Field Values
Method Detail

register

public void register(UniqueID id)
              throws java.rmi.RemoteException
Register the calling AO. Each AO is registred on creation by newActive. Default state is RUNNING.

Parameters:
id - the registered body id
Throws:
java.rmi.RemoteException

unregister

public void unregister(UniqueID id)
                throws java.rmi.RemoteException
Unregister the AO identified by id.

Parameters:
id - the unregistered body id
Throws:
java.rmi.RemoteException

failureDetected

public void failureDetected(UniqueID id)
                     throws java.rmi.RemoteException
Notify the recovery process that the body passed in paramater is suspected to be failed.

Parameters:
id - the id of the suspected AO
Throws:
java.rmi.RemoteException

updateState

public void updateState(UniqueID id,
                        int state)
                 throws java.rmi.RemoteException
Update the current state of the active object id. Its state can be failed, recovering or running.

Parameters:
id - id of the AO to update
state - state of the active object
Throws:
java.rmi.RemoteException

submitJob

public void submitJob(ActiveQueueJob job)
               throws java.rmi.RemoteException
to submit a job to recovery process

Parameters:
job - the job to submit
Throws:
java.rmi.RemoteException

submitJobWithBarrier

public JobBarrier submitJobWithBarrier(ActiveQueueJob job)
                                throws java.rmi.RemoteException
to submit a job to recovery process, with a barrier for waiting its completion

Parameters:
job - the job to submit
Returns:
the barrier on which waiting for the completion of the job
Throws:
java.rmi.RemoteException

getSystemSize

public int getSystemSize()
                  throws java.rmi.RemoteException
Return the size of the system, i.e. the number of registred bodies.

Returns:
the number of registred bodies
Throws:
java.rmi.RemoteException

initialize

public void initialize()
                throws java.rmi.RemoteException
Reinit the state of the recovery process.

Throws:
java.rmi.RemoteException


Copyright 2001-2005 INRIA All Rights Reserved.