sodonnel commented on code in PR #3743:
URL: https://github.com/apache/ozone/pull/3743#discussion_r970512587
##########
hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java:
##########
@@ -187,15 +188,22 @@ public ReplicationManager(final ConfigurationSource conf,
TimeUnit.MILLISECONDS);
this.containerReplicaPendingOps = replicaPendingOps;
this.legacyReplicationManager = legacyReplicationManager;
- this.ecContainerHealthCheck = new ECContainerHealthCheck();
+ this.ecReplicationCheckHandler = new ECReplicationCheckHandler();
this.nodeManager = nodeManager;
this.underRepQueue = createUnderReplicatedQueue();
this.overRepQueue = new LinkedList<>();
this.maintenanceRedundancy = rmConf.maintenanceRemainingRedundancy;
ecUnderReplicationHandler = new ECUnderReplicationHandler(
- containerPlacement, conf, nodeManager);
+ ecReplicationCheckHandler, containerPlacement, conf, nodeManager);
ecOverReplicationHandler =
- new ECOverReplicationHandler(containerPlacement, nodeManager);
+ new ECOverReplicationHandler(ecReplicationCheckHandler,
+ containerPlacement, nodeManager);
+
+ // Chain together the series of checks that are needed to validate the
+ // containers when they are checked by RM.
+ containerCheckChain = new OpenContainerHandler(this);
+ containerCheckChain.addNext(new ClosedWithMismatchedReplicasHandler(this));
+ containerCheckChain.addNext(ecReplicationCheckHandler);
Review Comment:
Yea you are correct, the calls should be chained like:
```
containerCheckChain = new OpenContainerHandler(this);
containerCheckChain.addNext(new ClosedWithMismatchedReplicasHandler(this))
.addNext(ecReplicationCheckHandler);
```
I have fixed this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
