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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
