@InterfaceAudience.Private public interface ProcedureCoordinatorRpcs extends 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,
List<String> members)
Notify the members to acquire barrier for the procedure
|
void |
sendGlobalBarrierReached(Procedure procName,
List<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)
void sendAbortToMembers(Procedure procName, ForeignException cause) throws IOException
procName
- name of the procedure that was abortedcause
- the reason why the procedure needs to be abortedIOException
- if the rpcs can't reach the other members of the procedure (and can't
recover).void sendGlobalBarrierAcquire(Procedure procName, byte[] info, List<String> members) throws IOException, 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 phaseIllegalArgumentException
- if the procedure was already marked as failedIOException
- if we can't reach the remote notification mechanismvoid sendGlobalBarrierReached(Procedure procName, List<String> members) throws IOException
sendGlobalBarrierAcquire(Procedure, byte[], List)
procName
- name of the procedure to startmembers
- members to tell we have reached in-barrier phaseIOException
- if we can't reach the remote notification mechanismvoid resetMembers(Procedure procName) throws IOException
procName
- name of the procedure to resetIOException
- if the remote notification mechanism cannot be reachedCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.