Repository: ambari Updated Branches: refs/heads/branch-feature-AMBARI-12556 522039ebd -> 1427d818b
http://git-wip-us.apache.org/repos/asf/ambari/blob/fb20c7c5/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/GSInstallerServiceProviderTest.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/GSInstallerServiceProviderTest.java b/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/GSInstallerServiceProviderTest.java deleted file mode 100644 index 5ea00a8..0000000 --- a/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/GSInstallerServiceProviderTest.java +++ /dev/null @@ -1,166 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ambari.server.controller.gsinstaller; - -import java.util.HashMap; -import java.util.Set; - -import org.apache.ambari.server.controller.internal.RequestImpl; -import org.apache.ambari.server.controller.spi.Predicate; -import org.apache.ambari.server.controller.spi.Resource; -import org.apache.ambari.server.controller.utilities.PredicateBuilder; -import org.apache.ambari.server.controller.utilities.PropertyHelper; -import org.junit.Test; - -import junit.framework.Assert; - -/** - * - */ -public class GSInstallerServiceProviderTest { - - @Test - public void testGetResources() throws Exception { - ClusterDefinition clusterDefinition = new ClusterDefinition(new TestGSInstallerStateProvider()); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider(clusterDefinition); - Set<Resource> resources = provider.getResources(PropertyHelper.getReadRequest(), null); - Assert.assertEquals(11, resources.size()); - } - - @Test - public void testGetResourcesWithPredicate() throws Exception { - ClusterDefinition clusterDefinition = new ClusterDefinition( - new TestGSInstallerStateProvider()); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider( - clusterDefinition); - Predicate predicate = new PredicateBuilder().property( - GSInstallerServiceProvider.SERVICE_SERVICE_NAME_PROPERTY_ID).equals( - "MAPREDUCE").toPredicate(); - Set<Resource> resources = provider.getResources( - PropertyHelper.getReadRequest(), predicate); - Assert.assertEquals(1, resources.size()); - - predicate = new PredicateBuilder().property( - GSInstallerServiceProvider.SERVICE_SERVICE_NAME_PROPERTY_ID).equals( - "HDFS").or().property( - GSInstallerServiceProvider.SERVICE_SERVICE_NAME_PROPERTY_ID).equals( - "GANGLIA").toPredicate(); - - resources = provider.getResources(PropertyHelper.getReadRequest(), - predicate); - - Assert.assertEquals(2, resources.size()); - - predicate = new PredicateBuilder().property( - GSInstallerServiceProvider.SERVICE_SERVICE_NAME_PROPERTY_ID).equals( - "NO SERVICE").toPredicate(); - resources = provider.getResources(PropertyHelper.getReadRequest(), - predicate); - Assert.assertTrue(resources.isEmpty()); - } - - @Test - public void testGetResourcesCheckState() throws Exception { - TestGSInstallerStateProvider stateProvider = new TestGSInstallerStateProvider(); - ClusterDefinition clusterDefinition = new ClusterDefinition(stateProvider, 500); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider(clusterDefinition); - Predicate predicate = new PredicateBuilder().property(GSInstallerServiceProvider.SERVICE_SERVICE_NAME_PROPERTY_ID).equals("MAPREDUCE").toPredicate(); - Set<Resource> resources = provider.getResources(PropertyHelper.getReadRequest(), predicate); - Assert.assertEquals(1, resources.size()); - - Resource resource = resources.iterator().next(); - - Assert.assertEquals("STARTED", resource.getPropertyValue(GSInstallerServiceProvider.SERVICE_SERVICE_STATE_PROPERTY_ID)); - - stateProvider.setHealthy(false); - - // need to wait for old state value to expire - Thread.sleep(501); - - resources = provider.getResources(PropertyHelper.getReadRequest(), predicate); - Assert.assertEquals(1, resources.size()); - - resource = resources.iterator().next(); - Assert.assertEquals("INIT", resource.getPropertyValue(GSInstallerServiceProvider.SERVICE_SERVICE_STATE_PROPERTY_ID)); - } - - @Test - public void testGetResourcesCheckStateFromCategory() throws Exception { - TestGSInstallerStateProvider stateProvider = new TestGSInstallerStateProvider(); - ClusterDefinition clusterDefinition = new ClusterDefinition(stateProvider, 500); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider(clusterDefinition); - Predicate predicate = new PredicateBuilder().property(GSInstallerServiceProvider.SERVICE_SERVICE_NAME_PROPERTY_ID).equals("MAPREDUCE").toPredicate(); - Set<Resource> resources = provider.getResources(PropertyHelper.getReadRequest("ServiceInfo"), predicate); - Assert.assertEquals(1, resources.size()); - - Resource resource = resources.iterator().next(); - - Assert.assertEquals("STARTED", resource.getPropertyValue(GSInstallerServiceProvider.SERVICE_SERVICE_STATE_PROPERTY_ID)); - - stateProvider.setHealthy(false); - - // need to wait for old state value to expire - Thread.sleep(501); - - resources = provider.getResources(PropertyHelper.getReadRequest(), predicate); - Assert.assertEquals(1, resources.size()); - - resource = resources.iterator().next(); - Assert.assertEquals("INIT", resource.getPropertyValue(GSInstallerServiceProvider.SERVICE_SERVICE_STATE_PROPERTY_ID)); - } - - @Test - public void testCreateResources() throws Exception { - ClusterDefinition clusterDefinition = new ClusterDefinition(new TestGSInstallerStateProvider()); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider(clusterDefinition); - - try { - provider.createResources(PropertyHelper.getReadRequest()); - Assert.fail("Expected UnsupportedOperationException."); - } catch (UnsupportedOperationException e) { - //expected - } - } - - @Test - public void testUpdateResources() throws Exception { - ClusterDefinition clusterDefinition = new ClusterDefinition(new TestGSInstallerStateProvider()); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider(clusterDefinition); - - try { - provider.updateResources(PropertyHelper.getUpdateRequest(new HashMap<String, Object>(), null), null); - Assert.fail("Expected UnsupportedOperationException."); - } catch (UnsupportedOperationException e) { - //expected - } - } - - @Test - public void testDeleteResources() throws Exception { - ClusterDefinition clusterDefinition = new ClusterDefinition(new TestGSInstallerStateProvider()); - GSInstallerResourceProvider provider = new GSInstallerServiceProvider(clusterDefinition); - - try { - provider.deleteResources(new RequestImpl(null, null, null, null), null); - Assert.fail("Expected UnsupportedOperationException."); - } catch (UnsupportedOperationException e) { - //expected - } - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/fb20c7c5/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/TestGSInstallerStateProvider.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/TestGSInstallerStateProvider.java b/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/TestGSInstallerStateProvider.java deleted file mode 100644 index a8e7a6d..0000000 --- a/ambari-server/src/test/java/org/apache/ambari/server/controller/gsinstaller/TestGSInstallerStateProvider.java +++ /dev/null @@ -1,36 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ambari.server.controller.gsinstaller; - -/** - * Test gsInstaller state provider. - */ -public class TestGSInstallerStateProvider implements GSInstallerStateProvider { - - private boolean healthy = true; - - public void setHealthy(boolean healthy) { - this.healthy = healthy; - } - - @Override - public boolean isHealthy(String hostName, String componentName) { - return healthy; - } -}
