You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2022/02/24 17:02:43 UTC
[ratis] branch master updated: RATIS-1533. Fix typo in RaftClientImpl and RaftServerImpl. (#609)
This is an automated email from the ASF dual-hosted git repository.
szetszwo 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 507121c RATIS-1533. Fix typo in RaftClientImpl and RaftServerImpl. (#609)
507121c is described below
commit 507121c0bbb2702074cb6099d2a625990443ca95
Author: Potato <ta...@apache.org>
AuthorDate: Thu Feb 24 11:02:35 2022 -0600
RATIS-1533. Fix typo in RaftClientImpl and RaftServerImpl. (#609)
---
.../main/java/org/apache/ratis/client/impl/RaftClientImpl.java | 8 ++++----
.../main/java/org/apache/ratis/server/impl/RaftServerImpl.java | 4 ++--
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/ratis-client/src/main/java/org/apache/ratis/client/impl/RaftClientImpl.java b/ratis-client/src/main/java/org/apache/ratis/client/impl/RaftClientImpl.java
index f937880..22254be 100644
--- a/ratis-client/src/main/java/org/apache/ratis/client/impl/RaftClientImpl.java
+++ b/ratis-client/src/main/java/org/apache/ratis/client/impl/RaftClientImpl.java
@@ -141,8 +141,8 @@ public final class RaftClientImpl implements RaftClient {
private final MemoizedSupplier<DataStreamApi> dataStreamApi;
private final Supplier<AdminImpl> adminApi;
- private final ConcurrentMap<RaftPeerId, GroupManagementImpl> groupManagmenets = new ConcurrentHashMap<>();
- private final ConcurrentMap<RaftPeerId, SnapshotManagementApi> snapshotManagemenet = new ConcurrentHashMap<>();
+ private final ConcurrentMap<RaftPeerId, GroupManagementImpl> groupManagement = new ConcurrentHashMap<>();
+ private final ConcurrentMap<RaftPeerId, SnapshotManagementApi> snapshotManagement = new ConcurrentHashMap<>();
private final ConcurrentMap<RaftPeerId, LeaderElectionManagementApi>
leaderElectionManagement = new ConcurrentHashMap<>();
@@ -245,7 +245,7 @@ public final class RaftClientImpl implements RaftClient {
@Override
public GroupManagementImpl getGroupManagementApi(RaftPeerId server) {
- return groupManagmenets.computeIfAbsent(server, id -> new GroupManagementImpl(id, this));
+ return groupManagement.computeIfAbsent(server, id -> new GroupManagementImpl(id, this));
}
@Override
@@ -255,7 +255,7 @@ public final class RaftClientImpl implements RaftClient {
@Override
public SnapshotManagementApi getSnapshotManagementApi(RaftPeerId server) {
- return snapshotManagemenet.computeIfAbsent(server, id -> new SnapshotManagementImpl(id, this));
+ return snapshotManagement.computeIfAbsent(server, id -> new SnapshotManagementImpl(id, this));
}
@Override
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
index ed7ae0b..51447be 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
@@ -326,8 +326,8 @@ class RaftServerImpl implements RaftServer.Division,
}
static boolean registerMBean(
- RaftPeerId id, RaftGroupId groupdId, RaftServerMXBean mBean, JmxRegister jmx) {
- final String prefix = "Ratis:service=RaftServer,group=" + groupdId + ",id=";
+ RaftPeerId id, RaftGroupId groupId, RaftServerMXBean mBean, JmxRegister jmx) {
+ final String prefix = "Ratis:service=RaftServer,group=" + groupId + ",id=";
final String registered = jmx.register(mBean, Arrays.asList(
() -> prefix + id,
() -> prefix + ObjectName.quote(id.toString())));