public static final class DeadlockGrpc.DeadlockStub extends io.grpc.stub.AbstractAsyncStub<DeadlockGrpc.DeadlockStub>
Modifier and Type | Method and Description |
---|---|
protected DeadlockGrpc.DeadlockStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
io.grpc.stub.StreamObserver<DeadlockOuterClass.DeadlockRequest> |
detect(io.grpc.stub.StreamObserver<DeadlockOuterClass.DeadlockResponse> responseObserver)
Detect should only sent to the owner.
|
void |
getWaitForEntries(DeadlockOuterClass.WaitForEntriesRequest request,
io.grpc.stub.StreamObserver<DeadlockOuterClass.WaitForEntriesResponse> responseObserver)
Get local wait for entries, should be handle by every node.
|
protected DeadlockGrpc.DeadlockStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<DeadlockGrpc.DeadlockStub>
public 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.
public 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.
Copyright © 2024 PingCAP. All rights reserved.