You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by so...@apache.org on 2023/01/06 09:33:42 UTC
[ozone] branch master updated: HDDS-7727. EC: SCM unregistered event handler for DatanodeCommandCountUpdated (#4147)
This is an automated email from the ASF dual-hosted git repository.
sodonnell 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 7d6ee034d7 HDDS-7727. EC: SCM unregistered event handler for DatanodeCommandCountUpdated (#4147)
7d6ee034d7 is described below
commit 7d6ee034d715294f7c229c9b4bd2b0e1defa8b55
Author: Doroszlai, Attila <64...@users.noreply.github.com>
AuthorDate: Fri Jan 6 10:33:36 2023 +0100
HDDS-7727. EC: SCM unregistered event handler for DatanodeCommandCountUpdated (#4147)
---
.../org/apache/hadoop/hdds/scm/server/StorageContainerManager.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
index e8ff409fa9..1452c7f6b3 100644
--- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
+++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
@@ -43,6 +43,7 @@ import org.apache.hadoop.hdds.scm.container.ContainerManagerImpl;
import org.apache.hadoop.hdds.scm.PlacementPolicyValidateProxy;
import org.apache.hadoop.hdds.scm.container.ContainerReplica;
import org.apache.hadoop.hdds.scm.container.replication.ContainerReplicaPendingOps;
+import org.apache.hadoop.hdds.scm.container.replication.DatanodeCommandCountUpdatedHandler;
import org.apache.hadoop.hdds.scm.container.replication.LegacyReplicationManager;
import org.apache.hadoop.hdds.scm.crl.CRLStatusReportHandler;
import org.apache.hadoop.hdds.scm.ha.BackgroundSCMService;
@@ -455,6 +456,8 @@ public final class StorageContainerManager extends ServiceRuntimeInfoImpl
eventQueue.addHandler(SCMEvents.NODE_REPORT, nodeReportHandler);
eventQueue.addHandler(SCMEvents.COMMAND_QUEUE_REPORT,
commandQueueReportHandler);
+ eventQueue.addHandler(SCMEvents.DATANODE_COMMAND_COUNT_UPDATED,
+ new DatanodeCommandCountUpdatedHandler(replicationManager));
// Use the same executor for both ICR and FCR.
// The Executor maps the event to a thread for DN.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org