|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.body.ft.protocols.FTManager
org.objectweb.proactive.core.body.ft.protocols.cic.managers.HalfFTManagerCIC
This class implements a Communication Induced Checkpointing protocol for ProActive. This FTManager is linked non active object communicating with fault-tolerant active objects.
Field Summary | |
protected static org.apache.log4j.Logger |
logger
|
Fields inherited from class org.objectweb.proactive.core.body.ft.protocols.FTManager |
additionalCodebase, DEFAULT_TTC_VALUE, HALF_BODY_EXCEPTION_MESSAGE, IMMEDIATE_SERVICE, location, NON_FT, ORPHAN_REPLY, owner, ownerID, recovery, storage, TIME_TO_RESEND, ttc |
Constructor Summary | |
HalfFTManagerCIC()
|
Method Summary | |
int |
beforeRestartAfterRecovery(CheckpointInfo ci,
int inc)
This method is called before restarting an object which has been recovered from a checkpoint. |
int |
getIncarnation()
|
java.lang.Object |
handleFTMessage(FTMessage fte)
This method is called when a non fonctionnal fault-tolerance message is received |
int |
init(AbstractBody owner)
Initialize the FTManager. |
int |
onDeliverReply(Reply reply)
This method is called after the future is updated by the reply. |
int |
onDeliverRequest(Request request)
This method is called when a request is stored in the requestqueue |
int |
onReceiveReply(Reply reply)
This method is called when a reply is received. |
int |
onReceiveRequest(Request request)
This method is called when a request is received. |
int |
onSendReplyAfter(Reply reply,
int rdvValue,
UniversalBody destination)
This method is called after the sending of a reply |
int |
onSendReplyBefore(Reply reply)
This method is called before the sending of a reply |
int |
onSendRequestAfter(Request request,
int rdvValue,
UniversalBody destination)
This method is called after the sending of a request |
int |
onSendRequestBefore(Request request)
This method is called before the sending of a request |
int |
onServeRequestAfter(Request request)
This method is called after the service of a request |
int |
onServeRequestBefore(Request request)
This method is called before the service of a request |
Methods inherited from class org.objectweb.proactive.core.body.ft.protocols.FTManager |
communicationFailed, getProtoSelector, handleHBEvent, isACheckpoint, sendReply, sendRequest, setCheckpointTag, termination |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static org.apache.log4j.Logger logger
Constructor Detail |
public HalfFTManagerCIC()
Method Detail |
public int init(AbstractBody owner) throws ProActiveException
FTManager
init
in class FTManager
owner
- The object linked to this FTManager
ProActiveException
- A problem occurs during the connection with the serversFTManager.init(org.objectweb.proactive.core.body.AbstractBody)
public int onReceiveReply(Reply reply)
FTManager
onReceiveReply
in class FTManager
reply
- the received replypublic int onDeliverReply(Reply reply)
FTManager
onDeliverReply
in class FTManager
reply
- the reply that updates a futurepublic int onSendRequestBefore(Request request)
FTManager
onSendRequestBefore
in class FTManager
request
- the request that will be sent
public int onSendReplyBefore(Reply reply)
FTManager
onSendReplyBefore
in class FTManager
reply
- the reply that will be sentpublic int onSendRequestAfter(Request request, int rdvValue, UniversalBody destination) throws RenegotiateSessionException
FTManager
onSendRequestAfter
in class FTManager
request
- the sent requestrdvValue
- the value returned by the sendingdestination
- the destination body of request
RenegotiateSessionException
public int onSendReplyAfter(Reply reply, int rdvValue, UniversalBody destination)
FTManager
onSendReplyAfter
in class FTManager
reply
- the sent replyrdvValue
- the value returned by the sendingdestination
- the destination body of reply
public int onReceiveRequest(Request request)
FTManager
onReceiveRequest
in class FTManager
request
- the received requestpublic int onDeliverRequest(Request request)
FTManager
onDeliverRequest
in class FTManager
request
- the stored requestpublic int onServeRequestBefore(Request request)
FTManager
onServeRequestBefore
in class FTManager
request
- the request that is served
public int onServeRequestAfter(Request request)
FTManager
onServeRequestAfter
in class FTManager
request
- the request that has been served
public int beforeRestartAfterRecovery(CheckpointInfo ci, int inc)
FTManager
beforeRestartAfterRecovery
in class FTManager
ci
- infos of the checkpoint used for recoveryinc
- incarantion number of this recovery
public int getIncarnation()
public java.lang.Object handleFTMessage(FTMessage fte)
FTManager
handleFTMessage
in class FTManager
fte
- the received message
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |