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 2021/03/11 09:45:18 UTC
[ratis] branch master updated: RATIS-1333. Add explicit thread
names for FollowerState and LeaderState threads. (#439)
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 fbe430c RATIS-1333. Add explicit thread names for FollowerState and LeaderState threads. (#439)
fbe430c is described below
commit fbe430cf6b57c16aa21a54f5d68b128bca33adfc
Author: Wei-Chiu Chuang <we...@apache.org>
AuthorDate: Thu Mar 11 01:45:12 2021 -0800
RATIS-1333. Add explicit thread names for FollowerState and LeaderState threads. (#439)
---
.../src/main/java/org/apache/ratis/server/impl/FollowerState.java | 1 +
.../src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java | 5 ++++-
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerState.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerState.java
index d22f86b..9777a85 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerState.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerState.java
@@ -65,6 +65,7 @@ class FollowerState extends Daemon {
FollowerState(RaftServerImpl server, Object reason) {
this.name = server.getMemberId() + "-" + JavaUtils.getClassSimpleName(getClass());
+ this.setName(this.name);
this.server = server;
this.reason = reason;
}
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
index 5e09d0c..601d53e 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
@@ -263,7 +263,7 @@ class LeaderStateImpl implements LeaderState {
this.currentTerm = state.getCurrentTerm();
this.eventQueue = new EventQueue();
- processor = new EventProcessor();
+ processor = new EventProcessor(this.name);
raftServerMetrics = server.getRaftServerMetrics();
logAppenderMetrics = new LogAppenderMetrics(server.getMemberId());
this.pendingRequests = new PendingRequests(server.getMemberId(), properties, raftServerMetrics);
@@ -575,6 +575,9 @@ class LeaderStateImpl implements LeaderState {
* state, such as changing to follower, or updating the committed index.
*/
private class EventProcessor extends Daemon {
+ public EventProcessor(String name) {
+ setName(name);
+ }
@Override
public void run() {
// apply an empty message; check if necessary to replicate (new) conf