@InterfaceAudience.Private public interface ProcedureCoordinatorRpcs extends java.io.Closeable
ProcedureCoordinator
Modifier and Type | Method and Description |
---|---|
void |
resetMembers(Procedure procName)
Notify Members to reset the distributed state for procedure
|
void |
sendAbortToMembers(Procedure procName,
ForeignException cause)
Notify the members that the coordinator has aborted the procedure and that it should release
barrier resources.
|
void |
sendGlobalBarrierAcquire(Procedure procName,
byte[] info,
java.util.List<java.lang.String> members)
Notify the members to acquire barrier for the procedure
|
void |
sendGlobalBarrierReached(Procedure procName,
java.util.List<java.lang.String> members)
Notify members that all members have acquired their parts of the barrier and that they can
now execute under the global barrier.
|
boolean |
start(ProcedureCoordinator listener)
Initialize and start threads necessary to connect an implementation's rpc mechanisms.
|
boolean start(ProcedureCoordinator listener)
listener
- void sendAbortToMembers(Procedure procName, ForeignException cause) throws java.io.IOException
procName
- name of the procedure that was abortedcause
- the reason why the procedure needs to be abortedjava.io.IOException
- if the rpcs can't reach the other members of the procedure (and can't
recover).void sendGlobalBarrierAcquire(Procedure procName, byte[] info, java.util.List<java.lang.String> members) throws java.io.IOException, java.lang.IllegalArgumentException
procName
- name of the procedure to startinfo
- information that should be passed to all membersmembers
- names of the members requested to reach the acquired phasejava.lang.IllegalArgumentException
- if the procedure was already marked as failedjava.io.IOException
- if we can't reach the remote notification mechanismvoid sendGlobalBarrierReached(Procedure procName, java.util.List<java.lang.String> members) throws java.io.IOException
sendGlobalBarrierAcquire(Procedure, byte[], List)
procName
- name of the procedure to startmembers
- members to tell we have reached in-barrier phasejava.io.IOException
- if we can't reach the remote notification mechanismvoid resetMembers(Procedure procName) throws java.io.IOException
procName
- name of the procedure to resetjava.io.IOException
- if the remote notification mechanism cannot be reached