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 <[email protected]> Authored: Fri Mar 17 11:08:16 2017 -0700 Committer: Jing Zhao <[email protected]> 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) {
