You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sh...@apache.org on 2021/11/24 06:47:27 UTC
[ratis] branch master updated: RATIS-1442. Typo: orderedWithTimeout should be unorderedWithTimeout in GrpcClientProtocolClient. (#539)
This is an automated email from the ASF dual-hosted git repository.
shashikant pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git
The following commit(s) were added to refs/heads/master by this push:
new 4fbda52 RATIS-1442. Typo: orderedWithTimeout should be unorderedWithTimeout in GrpcClientProtocolClient. (#539)
4fbda52 is described below
commit 4fbda52079b76e457f878e8d908f0bfedf94e436
Author: Tsz-Wo Nicholas Sze <sz...@apache.org>
AuthorDate: Wed Nov 24 14:46:56 2021 +0800
RATIS-1442. Typo: orderedWithTimeout should be unorderedWithTimeout in GrpcClientProtocolClient. (#539)
---
.../java/org/apache/ratis/grpc/client/GrpcClientProtocolClient.java | 2 +-
.../src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientProtocolClient.java b/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientProtocolClient.java
index 48084c9..3b4aed6 100644
--- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientProtocolClient.java
+++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientProtocolClient.java
@@ -223,7 +223,7 @@ public class GrpcClientProtocolClient implements Closeable {
return asyncStub.ordered(responseHandler);
}
- StreamObserver<RaftClientRequestProto> orderedWithTimeout(StreamObserver<RaftClientReplyProto> responseHandler) {
+ StreamObserver<RaftClientRequestProto> unorderedWithTimeout(StreamObserver<RaftClientReplyProto> responseHandler) {
return asyncStub.withDeadlineAfter(requestTimeoutDuration.getDuration(), requestTimeoutDuration.getUnit())
.unordered(responseHandler);
}
diff --git a/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java b/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java
index 5aeaafb..44c8e78 100644
--- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java
+++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java
@@ -135,7 +135,7 @@ public class GrpcClientRpc extends RaftClientRpcWithProxy<GrpcClientProtocolClie
final CompletableFuture<RaftClientReplyProto> replyFuture = new CompletableFuture<>();
// create a new grpc stream for each non-async call.
final StreamObserver<RaftClientRequestProto> requestObserver =
- proxy.orderedWithTimeout(new StreamObserver<RaftClientReplyProto>() {
+ proxy.unorderedWithTimeout(new StreamObserver<RaftClientReplyProto>() {
@Override
public void onNext(RaftClientReplyProto value) {
replyFuture.complete(value);