You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by ji...@apache.org on 2017/03/17 18:08:21 UTC
incubator-ratis git commit: RATIS-43. Rename
RaftClientProtocolService 'client' field onto 'protocol'. Contributed by Hugo
Louro.
Repository: incubator-ratis
Updated Branches:
refs/heads/master a25143eed -> dc182838b
RATIS-43. Rename RaftClientProtocolService 'client' field onto 'protocol'. Contributed by Hugo Louro.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ratis/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ratis/commit/dc182838
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ratis/tree/dc182838
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ratis/diff/dc182838
Branch: refs/heads/master
Commit: dc182838bfabcb5839aee5e60a2851ffaf5fffaa
Parents: a25143e
Author: Jing Zhao <ji...@apache.org>
Authored: Fri Mar 17 11:08:16 2017 -0700
Committer: Jing Zhao <ji...@apache.org>
Committed: Fri Mar 17 11:08:16 2017 -0700
----------------------------------------------------------------------
.../ratis/grpc/client/RaftClientProtocolService.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ratis/blob/dc182838/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/RaftClientProtocolService.java
----------------------------------------------------------------------
diff --git a/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/RaftClientProtocolService.java b/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/RaftClientProtocolService.java
index 7812cb5..5ebeb66 100644
--- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/RaftClientProtocolService.java
+++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/client/RaftClientProtocolService.java
@@ -66,18 +66,18 @@ public class RaftClientProtocolService extends RaftClientProtocolServiceImplBase
private static final PendingAppend COMPLETED = new PendingAppend(Long.MAX_VALUE);
private final RaftPeerId id;
- private final RaftClientAsynchronousProtocol client;
+ private final RaftClientAsynchronousProtocol protocol;
- public RaftClientProtocolService(RaftPeerId id, RaftClientAsynchronousProtocol client) {
+ public RaftClientProtocolService(RaftPeerId id, RaftClientAsynchronousProtocol protocol) {
this.id = id;
- this.client = client;
+ this.protocol = protocol;
}
@Override
public void setConfiguration(SetConfigurationRequestProto request,
StreamObserver<RaftClientReplyProto> responseObserver) {
try {
- CompletableFuture<RaftClientReply> future = client.setConfigurationAsync(
+ CompletableFuture<RaftClientReply> future = protocol.setConfigurationAsync(
ClientProtoUtils.toSetConfigurationRequest(request));
future.whenCompleteAsync((reply, exception) -> {
if (exception != null) {
@@ -115,7 +115,7 @@ public class RaftClientProtocolService extends RaftClientProtocolServiceImplBase
pendingList.add(p);
}
- CompletableFuture<RaftClientReply> future = client.submitClientRequestAsync(
+ CompletableFuture<RaftClientReply> future = protocol.submitClientRequestAsync(
ClientProtoUtils.toRaftClientRequest(request));
future.whenCompleteAsync((reply, exception) -> {
if (exception != null) {