|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.dream.AbstractComponent
org.objectweb.dream.protocol.utobcast.LeaderFaultForwarderImpl
Implementation of the LeaderFaultForwarder component. This component is notified by the ProcessMembership component that the leader has crashed. Its role is to unblock push calls that are waiting in the PushWithReturn component by sending a "AllKey" message.
Field Summary | |
protected MessageManager |
messageManagerItf
The interface to manage message lifecycle. |
protected Push |
outPushItf
The interface to send "AllKey" messages. |
Fields inherited from class org.objectweb.dream.AbstractComponent |
bindingLogger, componentDesc, fcState, firstStart, lifeCycleLogger, logger, weaveableC |
Fields inherited from interface org.objectweb.dream.protocol.utobcast.ProcessMembershipUpdateNotification |
ITF_NAME |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
STARTED, STOPPED |
Constructor Summary | |
LeaderFaultForwarderImpl()
Constructor. |
Method Summary | |
void |
bindFc(String clientItfName,
Object serverItf)
|
String[] |
listFc()
|
void |
newBackup(Process backup)
Notifies the component that a new backup has been elected. |
void |
newLeader(Process leader)
Notifies the component that a new leader has been elected. |
void |
newProcesses(Process[] processes)
Notifies the component that new processes have joined. |
Methods inherited from class org.objectweb.dream.AbstractComponent |
beforeFirstStart, getFcState, initComponent, lookupFc, setLogger, startFc, stopFc, unbindFc |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected Push outPushItf
protected MessageManager messageManagerItf
Constructor Detail |
public LeaderFaultForwarderImpl()
Method Detail |
public void newBackup(Process backup)
ProcessMembershipUpdateNotification
newBackup
in interface ProcessMembershipUpdateNotification
backup
- the new backup.ProcessMembershipUpdateNotification.newBackup(org.objectweb.dream.protocol.Process)
public void newLeader(Process leader)
ProcessMembershipUpdateNotification
newLeader
in interface ProcessMembershipUpdateNotification
leader
- the new leader.ProcessMembershipUpdateNotification.newLeader(org.objectweb.dream.protocol.Process)
public void newProcesses(Process[] processes)
ProcessMembershipUpdateNotification
newProcesses
in interface ProcessMembershipUpdateNotification
processes
- the new processes.ProcessMembershipUpdateNotification.newProcesses(org.objectweb.dream.protocol.Process[])
public void bindFc(String clientItfName, Object serverItf) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
bindFc
in interface BindingController
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.bindFc(java.lang.String,
java.lang.Object)
public String[] listFc()
listFc
in interface BindingController
BindingController.listFc()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |