@InterfaceAudience.Private public interface ProcedureMemberRpcs extends java.io.Closeable
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getMemberName()
Each subprocedure is being executed on a member.
|
void |
sendMemberAborted(Subprocedure sub,
ForeignException cause)
Notify the coordinator that we aborted the specified
Subprocedure |
void |
sendMemberAcquired(Subprocedure sub)
Notify the coordinator that the specified
Subprocedure has acquired the locally required
barrier condition. |
void |
sendMemberCompleted(Subprocedure sub,
byte[] data)
Notify the coordinator that the specified
Subprocedure has completed the work that
needed to be done under the global barrier. |
void |
start(java.lang.String memberName,
ProcedureMember member)
Initialize and start any threads or connections the member needs.
|
void start(java.lang.String memberName, ProcedureMember member)
java.lang.String getMemberName()
void sendMemberAborted(Subprocedure sub, ForeignException cause) throws java.io.IOException
Subprocedure
sub
- the Subprocedure
we are abortingcause
- the reason why the member's subprocedure abortedjava.io.IOException
- thrown when the rpcs can't reach the other members of the procedure (and
thus can't recover).void sendMemberAcquired(Subprocedure sub) throws java.io.IOException
Subprocedure
has acquired the locally required
barrier condition.sub
- the specified Subprocedure
java.io.IOException
- if we can't reach the coordinatorvoid sendMemberCompleted(Subprocedure sub, byte[] data) throws java.io.IOException
Subprocedure
has completed the work that
needed to be done under the global barrier.sub
- the specified Subprocedure
data
- the data the member returns to the coordinator along with the notificationjava.io.IOException
- if we can't reach the coordinator