You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by ad...@apache.org on 2022/08/16 17:46:04 UTC
[ozone] branch master updated: HDDS-7074. DN EndpointStateMachineMBean to add getType() (#3650)
This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 5f84fd1c9f HDDS-7074. DN EndpointStateMachineMBean to add getType() (#3650)
5f84fd1c9f is described below
commit 5f84fd1c9f35d82f2558b9c05dbe9c4d0b252900
Author: Chung En Lee <wf...@gmail.com>
AuthorDate: Wed Aug 17 01:45:59 2022 +0800
HDDS-7074. DN EndpointStateMachineMBean to add getType() (#3650)
---
.../common/statemachine/EndpointStateMachine.java | 16 +++++++++++++++-
.../common/statemachine/EndpointStateMachineMBean.java | 2 ++
2 files changed, 17 insertions(+), 1 deletion(-)
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachine.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachine.java
index 10c9b7461d..8b3e5dd657 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachine.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachine.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.ozone.container.common.statemachine;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.apache.hadoop.hdds.conf.ConfigurationSource;
import org.apache.hadoop.ozone.protocol.VersionResponse;
+import org.apache.hadoop.ozone.protocolPB.ReconDatanodeProtocolPB;
import org.apache.hadoop.ozone.protocolPB
.StorageContainerDatanodeProtocolClientSideTranslatorPB;
import org.slf4j.Logger;
@@ -56,6 +57,10 @@ public class EndpointStateMachine
private boolean isPassive;
private final ExecutorService executorService;
+ private static final String RECON_TYPE = "Recon";
+
+ private static final String SCM_TYPE = "SCM";
+
/**
* Constructs RPC Endpoints.
*
@@ -341,4 +346,13 @@ public class EndpointStateMachine
ZonedDateTime lastSuccessfulHeartbeat) {
this.lastSuccessfulHeartbeat = lastSuccessfulHeartbeat;
}
-}
+
+ @Override
+ public String getType() {
+ if (endPoint.getUnderlyingProxyObject()
+ instanceof ReconDatanodeProtocolPB) {
+ return RECON_TYPE;
+ }
+ return SCM_TYPE;
+ }
+}
\ No newline at end of file
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachineMBean.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachineMBean.java
index 4f64bde0b3..47b53936a1 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachineMBean.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/EndpointStateMachineMBean.java
@@ -31,4 +31,6 @@ public interface EndpointStateMachineMBean {
int getVersionNumber();
long getLastSuccessfulHeartbeat();
+
+ String getType();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org