deadlock

Interface DeadlockGrpc.AsyncService

All Known Implementing Classes:

DeadlockGrpc.DeadlockImplBase

Enclosing class:

DeadlockGrpc

public static interface DeadlockGrpc.AsyncService

Method Summary

Modifier and Type	Method and Description
default io.grpc.stub.StreamObserver<DeadlockOuterClass.DeadlockRequest>	detect(io.grpc.stub.StreamObserver<DeadlockOuterClass.DeadlockResponse> responseObserver) Detect should only sent to the owner.
default void	getWaitForEntries(DeadlockOuterClass.WaitForEntriesRequest request, io.grpc.stub.StreamObserver<DeadlockOuterClass.WaitForEntriesResponse> responseObserver) Get local wait for entries, should be handle by every node.

Method Detail

getWaitForEntries

default void getWaitForEntries(DeadlockOuterClass.WaitForEntriesRequest request,
                               io.grpc.stub.StreamObserver<DeadlockOuterClass.WaitForEntriesResponse> responseObserver)

 Get local wait for entries, should be handle by every node.
 The owner should sent this request to all members to build the complete wait for graph.
 

detect

default io.grpc.stub.StreamObserver<DeadlockOuterClass.DeadlockRequest> detect(io.grpc.stub.StreamObserver<DeadlockOuterClass.DeadlockResponse> responseObserver)

 Detect should only sent to the owner. only be handled by the owner.
 The DeadlockResponse is sent back only if there is deadlock detected.
 CleanUpWaitFor and CleanUp doesn't return responses.