|
|||||||||||
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.FTManagerCIC
This class implements a Communication Induced Checkpointing protocol for ProActive. This FTManager is linked to each fault-tolerant active object.
Field Summary | |
protected static short |
CKPT_INDEX
|
protected static short |
FROM_HALF_BODY
|
protected static short |
HISTO_INDEX
|
protected static short |
INCARNATION
|
protected static short |
INFOS_SIZE
|
protected static short |
IS_ACTIVE
|
protected static short |
IS_HALF
|
protected static short |
IS_ORPHAN_FOR
|
protected static short |
LAST_REC
|
protected static org.apache.log4j.Logger |
logger
|
static int |
RECOVER
Value returned by an object if the sender of the received message must recover asap |
static int |
RESEND_MESSAGE
Value returned by an object if the recieved message must be send again |
static long |
TIME_TO_RESEND
Time to wait between a send and a resend in ms |
Fields inherited from class org.objectweb.proactive.core.body.ft.protocols.FTManager |
additionalCodebase, DEFAULT_TTC_VALUE, IMMEDIATE_SERVICE, location, NON_FT, ORPHAN_REPLY, owner, recovery, storage, ttc |
Constructor Summary | |
FTManagerCIC()
|
Method Summary | |
int |
beforeRestartAfterRecovery(CheckpointInfo ci,
int inc)
This method is called before restarting an object which has been recovered from a checkpoint. |
UniversalBody |
communicationFailed(UniqueID suspect,
UniversalBody suspectLocation,
java.lang.Exception e)
|
int |
handleFTMessage(FTMessage fte)
This method is called when a non fonctionnal fault-tolerance message is received |
int |
HandleHBEvent(Heartbeat fte)
Heartbeat message. |
int |
HandlingGSCEEvent(GlobalStateCompletion fte)
Closing history. |
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 |
int |
sendReply(Reply r,
UniversalBody destination)
Fault-tolerant sending: this send notices fault tolerance servers if the destination is unreachable and resent the message until destination is reachable. |
int |
sendRequest(Request r,
UniversalBody destination)
Fault-tolerant sending: this send notices fault tolerance servers if the destination is unreachable and resent the message until destination is reachable. |
java.lang.String |
toString()
|
Methods inherited from class org.objectweb.proactive.core.body.ft.protocols.FTManager |
isACheckpoint, setCheckpointTag |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public static final long TIME_TO_RESEND
public static final int RESEND_MESSAGE
public static final int RECOVER
protected static org.apache.log4j.Logger logger
protected static final short INFOS_SIZE
protected static final short CKPT_INDEX
protected static final short HISTO_INDEX
protected static final short INCARNATION
protected static final short LAST_REC
protected static final short IS_ORPHAN_FOR
protected static final short FROM_HALF_BODY
protected static final short IS_HALF
protected static final short IS_ACTIVE
Constructor Detail |
public FTManagerCIC()
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 serverspublic 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 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 onSendReplyBefore(Reply reply)
FTManager
onSendReplyBefore
in class FTManager
reply
- the reply that will be sentpublic 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 onSendRequestBefore(Request request)
FTManager
onSendRequestBefore
in class FTManager
request
- the request that will be sent
public 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 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 sendReply(Reply r, UniversalBody destination)
FTManager
sendReply
in class FTManager
r
- the reply to senddestination
- the destination of the reply
public int sendRequest(Request r, UniversalBody destination) throws RenegotiateSessionException
FTManager
sendRequest
in class FTManager
r
- the request to senddestination
- the destination of the request
RenegotiateSessionException
public java.lang.String toString()
public UniversalBody communicationFailed(UniqueID suspect, UniversalBody suspectLocation, java.lang.Exception e)
public int handleFTMessage(FTMessage fte)
FTManager
handleFTMessage
in class FTManager
fte
- the received message
public int HandlingGSCEEvent(GlobalStateCompletion fte)
fte
- Message that contains the last complete global state
public int HandleHBEvent(Heartbeat fte)
fte
- heartbeat message.
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |