|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.body.ft.servers.recovery.RecoveryProcessImpl
Field Summary | |
protected java.util.Hashtable |
bodies
|
protected static org.apache.log4j.Logger |
logger
|
static int |
MAX_ACTIVE_QUEUES
Maximum number of active queues |
protected FTServer |
server
|
Fields inherited from interface org.objectweb.proactive.core.body.ft.servers.recovery.RecoveryProcess |
FAILED, RECOVERING, RUNNING |
Constructor Summary | |
RecoveryProcessImpl(FTServer server)
|
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. |
protected abstract void |
recover(UniqueID failed)
This method define the recovery behavior. |
void |
register(UniqueID id)
Register the calling AO. |
void |
submitJob(ActiveQueueJob job)
Submit an ActiveQueueJob to the active queue of the recovery process. |
JobBarrier |
submitJobWithBarrier(ActiveQueueJob job)
Submit an ActiveQueueJob to the active queue of the recovery process. |
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. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final int MAX_ACTIVE_QUEUES
protected static org.apache.log4j.Logger logger
protected FTServer server
protected java.util.Hashtable bodies
Constructor Detail |
public RecoveryProcessImpl(FTServer server)
Method Detail |
protected abstract void recover(UniqueID failed)
failed
- public void register(UniqueID id) throws java.rmi.RemoteException
RecoveryProcess
register
in interface RecoveryProcess
id
- the registered body id
java.rmi.RemoteException
RecoveryProcess.register(org.objectweb.proactive.core.UniqueID)
public void unregister(UniqueID id) throws java.rmi.RemoteException
RecoveryProcess
unregister
in interface RecoveryProcess
id
- the unregistered body id
java.rmi.RemoteException
RecoveryProcess.unregister(org.objectweb.proactive.core.UniqueID)
public void failureDetected(UniqueID id) throws java.rmi.RemoteException
RecoveryProcess
failureDetected
in interface RecoveryProcess
id
- the id of the suspected AO
java.rmi.RemoteException
RecoveryProcess.failureDetected(org.objectweb.proactive.core.UniqueID)
public void updateState(UniqueID id, int state) throws java.rmi.RemoteException
RecoveryProcess
updateState
in interface RecoveryProcess
id
- id of the AO to updatestate
- state of the active object
java.rmi.RemoteException
RecoveryProcess.updateState(org.objectweb.proactive.core.UniqueID, int)
public void submitJob(ActiveQueueJob job)
submitJob
in interface RecoveryProcess
job
- the job to submit.public JobBarrier submitJobWithBarrier(ActiveQueueJob job)
submitJobWithBarrier
in interface RecoveryProcess
job
- the job to submit.
public int getSystemSize() throws java.rmi.RemoteException
RecoveryProcess
getSystemSize
in interface RecoveryProcess
java.rmi.RemoteException
RecoveryProcess.getSystemSize()
public void initialize() throws java.rmi.RemoteException
RecoveryProcess
initialize
in interface RecoveryProcess
java.rmi.RemoteException
RecoveryProcess.initialize()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |