From common-commits-return-88964-archive-asf-public=cust-asf.ponee.io@hadoop.apache.org Sat Oct 6 00:06:37 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id A306D1807A3 for ; Sat, 6 Oct 2018 00:06:36 +0200 (CEST) Received: (qmail 4905 invoked by uid 500); 5 Oct 2018 22:06:32 -0000 Mailing-List: contact common-commits-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list common-commits@hadoop.apache.org Received: (qmail 3386 invoked by uid 99); 5 Oct 2018 22:06:31 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Oct 2018 22:06:31 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C5A55E11B0; Fri, 5 Oct 2018 22:06:30 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: shv@apache.org To: common-commits@hadoop.apache.org Date: Fri, 05 Oct 2018 22:06:46 -0000 Message-Id: <2227c3d8defe44bc95c21e552bc8dfaa@git.apache.org> In-Reply-To: <51fadf003695466096a2218649b67138@git.apache.org> References: <51fadf003695466096a2218649b67138@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [17/50] [abbrv] hadoop git commit: HDDS-567. Rename Mapping to ContainerManager in SCM. Contributed by Nanda kumar. http://git-wip-us.apache.org/repos/asf/hadoop/blob/095c2696/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java ---------------------------------------------------------------------- diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java index d644190..019cc52 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java @@ -580,7 +580,7 @@ public class TestOzoneRpcClient { // Second, sum the data size from chunks in Container via containerID // and localID, make sure the size equals to the size from keyDetails. Pipeline pipeline = cluster.getStorageContainerManager() - .getScmContainerManager().getContainerWithPipeline(containerID) + .getContainerManager().getContainerWithPipeline(containerID) .getPipeline(); List datanodes = pipeline.getMachines(); Assert.assertEquals(datanodes.size(), 1); http://git-wip-us.apache.org/repos/asf/hadoop/blob/095c2696/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestBlockDeletion.java ---------------------------------------------------------------------- diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestBlockDeletion.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestBlockDeletion.java index 5b9bcbd..fc361b8 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestBlockDeletion.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestBlockDeletion.java @@ -72,7 +72,6 @@ import static org.apache.hadoop.hdds .HddsConfigKeys.HDDS_CONTAINER_REPORT_INTERVAL; import static org.apache.hadoop.hdds.scm.ScmConfigKeys.HDDS_SCM_WATCHER_TIMEOUT; import static org.apache.hadoop.hdds.scm.ScmConfigKeys.OZONE_SCM_STALENODE_INTERVAL; -import static org.apache.hadoop.hdds.scm.ScmConfigKeys.OZONE_SCM_STALENODE_INTERVAL_DEFAULT; import static org.apache.hadoop.ozone .OzoneConfigKeys.OZONE_BLOCK_DELETING_SERVICE_INTERVAL; @@ -242,7 +241,7 @@ public class TestBlockDeletion { ContainerReportsProto dummyReport = dummyReportsBuilder.build(); logCapturer.clearOutput(); - scm.getScmContainerManager().processContainerReports( + scm.getContainerManager().processContainerReports( cluster.getHddsDatanodes().get(0).getDatanodeDetails(), dummyReport, false); // wait for event to be handled by event handler http://git-wip-us.apache.org/repos/asf/hadoop/blob/095c2696/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerByPipeline.java ---------------------------------------------------------------------- diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerByPipeline.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerByPipeline.java index 8c52847..9602207 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerByPipeline.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerByPipeline.java @@ -102,7 +102,7 @@ public class TestCloseContainerByPipeline { long containerID = omKeyLocationInfo.getContainerID(); Pipeline pipeline = cluster.getStorageContainerManager() - .getScmContainerManager().getContainerWithPipeline(containerID) + .getContainerManager().getContainerWithPipeline(containerID) .getPipeline(); List datanodes = pipeline.getMachines(); Assert.assertEquals(datanodes.size(), 1); @@ -157,7 +157,7 @@ public class TestCloseContainerByPipeline { long containerID = omKeyLocationInfo.getContainerID(); Pipeline pipeline = cluster.getStorageContainerManager() - .getScmContainerManager().getContainerWithPipeline(containerID) + .getContainerManager().getContainerWithPipeline(containerID) .getPipeline(); List datanodes = pipeline.getMachines(); Assert.assertEquals(datanodes.size(), 1); @@ -214,7 +214,7 @@ public class TestCloseContainerByPipeline { long containerID = omKeyLocationInfo.getContainerID(); Pipeline pipeline = cluster.getStorageContainerManager() - .getScmContainerManager().getContainerWithPipeline(containerID) + .getContainerManager().getContainerWithPipeline(containerID) .getPipeline(); List datanodes = pipeline.getMachines(); Assert.assertEquals(3, datanodes.size()); http://git-wip-us.apache.org/repos/asf/hadoop/blob/095c2696/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerHandler.java ---------------------------------------------------------------------- diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerHandler.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerHandler.java index 84b7b76..0137a40 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerHandler.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerHandler.java @@ -81,7 +81,7 @@ public class TestCloseContainerHandler { long containerID = omKeyLocationInfo.getContainerID(); Pipeline pipeline = cluster.getStorageContainerManager() - .getScmContainerManager().getContainerWithPipeline(containerID) + .getContainerManager().getContainerWithPipeline(containerID) .getPipeline(); Assert.assertFalse(isContainerClosed(cluster, containerID)); http://git-wip-us.apache.org/repos/asf/hadoop/blob/095c2696/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestScmChillMode.java ---------------------------------------------------------------------- diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestScmChillMode.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestScmChillMode.java index 2a6921a..ef84b0e 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestScmChillMode.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestScmChillMode.java @@ -29,7 +29,7 @@ import org.apache.hadoop.hdds.protocol.proto.HddsProtos; import org.apache.hadoop.hdds.protocol.proto.HddsProtos.LifeCycleEvent; import org.apache.hadoop.hdds.protocol.proto.HddsProtos.ReplicationFactor; import org.apache.hadoop.hdds.protocol.proto.HddsProtos.ReplicationType; -import org.apache.hadoop.hdds.scm.container.ContainerMapping; +import org.apache.hadoop.hdds.scm.container.SCMContainerManager; import org.apache.hadoop.hdds.scm.container.common.helpers.ContainerInfo; import org.apache.hadoop.hdds.scm.events.SCMEvents; import org.apache.hadoop.hdds.scm.exceptions.SCMException; @@ -128,7 +128,7 @@ public class TestScmChillMode { Map keyLocations = helper.createKeys(100, 4096); final List containers = cluster .getStorageContainerManager() - .getScmContainerManager().getStateManager().getAllContainers(); + .getContainerManager().getStateManager().getAllContainers(); GenericTestUtils.waitFor(() -> { return containers.size() > 10; }, 100, 1000); @@ -251,7 +251,7 @@ public class TestScmChillMode { new TestStorageContainerManagerHelper(miniCluster, conf); Map keyLocations = helper.createKeys(100 * 2, 4096); final List containers = miniCluster - .getStorageContainerManager().getScmContainerManager() + .getStorageContainerManager().getContainerManager() .getStateManager().getAllContainers(); GenericTestUtils.waitFor(() -> { return containers.size() > 10; @@ -264,8 +264,8 @@ public class TestScmChillMode { containers.remove(3); // Close remaining containers - ContainerMapping mapping = (ContainerMapping) miniCluster - .getStorageContainerManager().getScmContainerManager(); + SCMContainerManager mapping = (SCMContainerManager) miniCluster + .getStorageContainerManager().getContainerManager(); containers.forEach(c -> { try { mapping.updateContainerState(c.getContainerID(), @@ -347,7 +347,7 @@ public class TestScmChillMode { SCMClientProtocolServer clientProtocolServer = cluster .getStorageContainerManager().getClientProtocolServer(); assertFalse((scm.getClientProtocolServer()).getChillModeStatus()); - final List containers = scm.getScmContainerManager() + final List containers = scm.getContainerManager() .getStateManager().getAllContainers(); scm.getEventQueue().fireEvent(SCMEvents.CHILL_MODE_STATUS, true); GenericTestUtils.waitFor(() -> { http://git-wip-us.apache.org/repos/asf/hadoop/blob/095c2696/hadoop-ozone/tools/src/test/java/org/apache/hadoop/ozone/scm/TestContainerSQLCli.java ---------------------------------------------------------------------- diff --git a/hadoop-ozone/tools/src/test/java/org/apache/hadoop/ozone/scm/TestContainerSQLCli.java b/hadoop-ozone/tools/src/test/java/org/apache/hadoop/ozone/scm/TestContainerSQLCli.java index 4026348..a476583 100644 --- a/hadoop-ozone/tools/src/test/java/org/apache/hadoop/ozone/scm/TestContainerSQLCli.java +++ b/hadoop-ozone/tools/src/test/java/org/apache/hadoop/ozone/scm/TestContainerSQLCli.java @@ -17,6 +17,8 @@ */ package org.apache.hadoop.ozone.scm; +import org.apache.hadoop.hdds.scm.container.ContainerManager; +import org.apache.hadoop.hdds.scm.container.SCMContainerManager; import org.apache.hadoop.hdds.scm.events.SCMEvents; import org.apache.hadoop.hdds.scm.node.NodeManager; import org.apache.hadoop.hdds.server.events.EventQueue; @@ -25,7 +27,6 @@ import org.apache.hadoop.ozone.OzoneConfigKeys; import org.apache.hadoop.hdds.conf.OzoneConfiguration; import org.apache.hadoop.hdds.protocol.proto.HddsProtos; import org.apache.hadoop.hdds.scm.block.BlockManagerImpl; -import org.apache.hadoop.hdds.scm.container.ContainerMapping; import org.apache.hadoop.hdds.scm.container.placement.algorithms.ContainerPlacementPolicy; import org.apache.hadoop.hdds.scm.container.placement.algorithms.SCMContainerPlacementCapacity; import org.apache.hadoop.hdds.scm.ScmConfigKeys; @@ -83,7 +84,7 @@ public class TestContainerSQLCli { private OzoneConfiguration conf; private String datanodeIpAddress; - private ContainerMapping mapping; + private ContainerManager containerManager; private NodeManager nodeManager; private BlockManagerImpl blockManager; @@ -119,9 +120,10 @@ public class TestContainerSQLCli { cluster.getStorageContainerManager().stop(); eventQueue = new EventQueue(); nodeManager = cluster.getStorageContainerManager().getScmNodeManager(); - mapping = new ContainerMapping(conf, nodeManager, 128, + containerManager = new SCMContainerManager(conf, nodeManager, 128, eventQueue); - blockManager = new BlockManagerImpl(conf, nodeManager, mapping, eventQueue); + blockManager = new BlockManagerImpl( + conf, nodeManager, containerManager, eventQueue); eventQueue.addHandler(SCMEvents.CHILL_MODE_STATUS, blockManager); eventQueue.fireEvent(SCMEvents.CHILL_MODE_STATUS, false); GenericTestUtils.waitFor(() -> { @@ -165,7 +167,7 @@ public class TestContainerSQLCli { } blockManager.close(); - mapping.close(); + containerManager.close(); nodeManager.close(); conf.set(OzoneConfigKeys.OZONE_METADATA_STORE_IMPL, metaStoreType); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org For additional commands, e-mail: common-commits-help@hadoop.apache.org