diff --git a/server/test/com/cloud/agent/manager/ResourceManagerTest.java b/server/test/com/cloud/agent/manager/ResourceManagerTest.java deleted file mode 100755 index b763da8327a..00000000000 --- a/server/test/com/cloud/agent/manager/ResourceManagerTest.java +++ /dev/null @@ -1,364 +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 com.cloud.agent.manager; - -import java.io.Serializable; -import java.lang.reflect.Field; - -import junit.framework.TestCase; - -import org.apache.log4j.Logger; -import org.junit.After; -import org.junit.Before; - -import com.cloud.alert.AlertManagerImpl; -import com.cloud.alert.dao.AlertDaoImpl; -import com.cloud.api.BaseCmd; -import com.cloud.api.commands.CreatePodCmd; -import com.cloud.api.commands.CreateZoneCmd; -import com.cloud.async.AsyncJobExecutorContextImpl; -import com.cloud.async.AsyncJobManagerImpl; -import com.cloud.async.SyncQueueManagerImpl; -import com.cloud.async.dao.AsyncJobDaoImpl; -import com.cloud.async.dao.SyncQueueDaoImpl; -import com.cloud.async.dao.SyncQueueItemDaoImpl; -import com.cloud.capacity.CapacityManagerImpl; -import com.cloud.capacity.dao.CapacityDaoImpl; -import com.cloud.certificate.dao.CertificateDaoImpl; -import com.cloud.cluster.CheckPointManagerImpl; -import com.cloud.cluster.ClusterFenceManagerImpl; -import com.cloud.cluster.ClusterManagerImpl; -import com.cloud.cluster.agentlb.dao.HostTransferMapDaoImpl; -import com.cloud.cluster.dao.ManagementServerHostDaoImpl; -import com.cloud.cluster.dao.StackMaidDaoImpl; -import com.cloud.configuration.ConfigurationManagerImpl; -import com.cloud.configuration.ConfigurationService; -import com.cloud.configuration.dao.ConfigurationDaoImpl; -import com.cloud.configuration.dao.ResourceCountDaoImpl; -import com.cloud.configuration.dao.ResourceLimitDaoImpl; -import com.cloud.consoleproxy.ConsoleProxyManagerImpl; -import com.cloud.dao.EntityManagerImpl; -import com.cloud.dc.ClusterDetailsDaoImpl; -import com.cloud.dc.dao.AccountVlanMapDaoImpl; -import com.cloud.dc.dao.ClusterDaoImpl; -import com.cloud.dc.dao.DataCenterDaoImpl; -import com.cloud.dc.dao.DataCenterIpAddressDaoImpl; -import com.cloud.dc.dao.DcDetailsDaoImpl; -import com.cloud.dc.dao.HostPodDaoImpl; -import com.cloud.dc.dao.PodVlanMapDaoImpl; -import com.cloud.dc.dao.VlanDaoImpl; -import com.cloud.domain.dao.DomainDaoImpl; -import com.cloud.event.dao.EventDaoImpl; -import com.cloud.event.dao.UsageEventDaoImpl; -import com.cloud.ha.HighAvailabilityManagerImpl; -import com.cloud.ha.dao.HighAvailabilityDaoImpl; -import com.cloud.host.dao.HostDaoImpl; -import com.cloud.host.dao.HostDetailsDaoImpl; -import com.cloud.host.dao.HostTagsDaoImpl; -import com.cloud.hypervisor.HypervisorGuruManagerImpl; -import com.cloud.hypervisor.dao.HypervisorCapabilitiesDaoImpl; -import com.cloud.keystore.KeystoreDaoImpl; -import com.cloud.keystore.KeystoreManagerImpl; -import com.cloud.maint.UpgradeManagerImpl; -import com.cloud.maint.dao.AgentUpgradeDaoImpl; -import com.cloud.network.NetworkManagerImpl; -import com.cloud.network.dao.FirewallRulesCidrsDaoImpl; -import com.cloud.network.dao.FirewallRulesDaoImpl; -import com.cloud.network.dao.IPAddressDaoImpl; -import com.cloud.network.dao.InlineLoadBalancerNicMapDaoImpl; -import com.cloud.network.dao.LoadBalancerDaoImpl; -import com.cloud.network.dao.LoadBalancerVMMapDaoImpl; -import com.cloud.network.dao.NetworkDaoImpl; -import com.cloud.network.dao.NetworkDomainDaoImpl; -import com.cloud.network.dao.NetworkRuleConfigDaoImpl; -import com.cloud.network.dao.RemoteAccessVpnDaoImpl; -import com.cloud.network.dao.VpnUserDaoImpl; -import com.cloud.network.firewall.FirewallManagerImpl; -import com.cloud.network.lb.ElasticLoadBalancerManagerImpl; -import com.cloud.network.lb.LoadBalancingRulesManagerImpl; -import com.cloud.network.lb.dao.ElasticLbVmMapDaoImpl; -import com.cloud.network.ovs.OvsTunnelManagerImpl; -import com.cloud.network.router.VirtualNetworkApplianceManagerImpl; -import com.cloud.network.rules.RulesManagerImpl; -import com.cloud.network.rules.dao.PortForwardingRulesDaoImpl; -import com.cloud.network.security.SecurityGroupManagerImpl2; -import com.cloud.network.security.dao.SecurityGroupDaoImpl; -import com.cloud.network.security.dao.SecurityGroupRulesDaoImpl; -import com.cloud.network.security.dao.SecurityGroupVMMapDaoImpl; -import com.cloud.network.security.dao.SecurityGroupWorkDaoImpl; -import com.cloud.network.security.dao.VmRulesetLogDaoImpl; -import com.cloud.network.vpn.RemoteAccessVpnManagerImpl; -import com.cloud.offerings.dao.NetworkOfferingDaoImpl; -import com.cloud.projects.ProjectManagerImpl; -import com.cloud.projects.dao.ProjectAccountDaoImpl; -import com.cloud.projects.dao.ProjectDaoImpl; -import com.cloud.resource.ResourceManagerImpl; -import com.cloud.resourcelimit.ResourceLimitManagerImpl; -import com.cloud.service.dao.ServiceOfferingDaoImpl; -import com.cloud.storage.OCFS2ManagerImpl; -import com.cloud.storage.StorageManagerImpl; -import com.cloud.storage.dao.DiskOfferingDaoImpl; -import com.cloud.storage.dao.GuestOSCategoryDaoImpl; -import com.cloud.storage.dao.GuestOSDaoImpl; -import com.cloud.storage.dao.LaunchPermissionDaoImpl; -import com.cloud.storage.dao.SnapshotDaoImpl; -import com.cloud.storage.dao.SnapshotPolicyDaoImpl; -import com.cloud.storage.dao.SnapshotScheduleDaoImpl; -import com.cloud.storage.dao.StoragePoolDaoImpl; -import com.cloud.storage.dao.StoragePoolHostDaoImpl; -import com.cloud.storage.dao.StoragePoolWorkDaoImpl; -import com.cloud.storage.dao.SwiftDaoImpl; -import com.cloud.storage.dao.UploadDaoImpl; -import com.cloud.storage.dao.VMTemplateDaoImpl; -import com.cloud.storage.dao.VMTemplateHostDaoImpl; -import com.cloud.storage.dao.VMTemplatePoolDaoImpl; -import com.cloud.storage.dao.VMTemplateZoneDaoImpl; -import com.cloud.storage.dao.VolumeDaoImpl; -import com.cloud.storage.download.DownloadMonitorImpl; -import com.cloud.storage.secondary.SecondaryStorageManagerImpl; -import com.cloud.storage.snapshot.SnapshotManagerImpl; -import com.cloud.storage.snapshot.SnapshotSchedulerImpl; -import com.cloud.storage.upload.UploadMonitorImpl; -import com.cloud.template.TemplateManagerImpl; -import com.cloud.user.AccountManagerImpl; -import com.cloud.user.DomainManagerImpl; -import com.cloud.user.dao.AccountDaoImpl; -import com.cloud.user.dao.SSHKeyPairDaoImpl; -import com.cloud.user.dao.UserAccountDaoImpl; -import com.cloud.user.dao.UserDaoImpl; -import com.cloud.user.dao.UserStatisticsDaoImpl; -import com.cloud.utils.component.ComponentLocator; -import com.cloud.utils.component.ComponentLocator.ComponentInfo; -import com.cloud.utils.component.Manager; -import com.cloud.utils.component.MockComponentLocator; -import com.cloud.utils.db.GenericDao; -import com.cloud.vm.ClusteredVirtualMachineManagerImpl; -import com.cloud.vm.ItWorkDaoImpl; -import com.cloud.vm.UserVmManagerImpl; -import com.cloud.vm.dao.ConsoleProxyDaoImpl; -import com.cloud.vm.dao.DomainRouterDaoImpl; -import com.cloud.vm.dao.InstanceGroupDaoImpl; -import com.cloud.vm.dao.InstanceGroupVMMapDaoImpl; -import com.cloud.vm.dao.NicDaoImpl; -import com.cloud.vm.dao.SecondaryStorageVmDaoImpl; -import com.cloud.vm.dao.UserVmDaoImpl; -import com.cloud.vm.dao.UserVmDetailsDaoImpl; -import com.cloud.vm.dao.VMInstanceDaoImpl; - -public class ResourceManagerTest extends TestCase { - MockComponentLocator _locator; - private static final Logger s_logger = Logger.getLogger(ResourceManagerTest.class); - ConfigurationService _configService; - - @Override - @Before - public void setUp() throws Exception { - _locator = new MockComponentLocator("management-server"); - _locator.addDao("StackMaidDao", StackMaidDaoImpl.class); - _locator.addDao("VMTemplateZoneDao", VMTemplateZoneDaoImpl.class); - _locator.addDao("DomainRouterDao", DomainRouterDaoImpl.class); - _locator.addDao("HostDao", HostDaoImpl.class); - _locator.addDao("VMInstanceDao", VMInstanceDaoImpl.class); - _locator.addDao("UserVmDao", UserVmDaoImpl.class); - ComponentInfo> info = _locator.addDao("ServiceOfferingDao", ServiceOfferingDaoImpl.class); - info.addParameter("cache.size", "50"); - info.addParameter("cache.time.to.live", "600"); - info = _locator.addDao("DiskOfferingDao", DiskOfferingDaoImpl.class); - info.addParameter("cache.size", "50"); - info.addParameter("cache.time.to.live", "600"); - info = _locator.addDao("DataCenterDao", DataCenterDaoImpl.class); - info.addParameter("cache.size", "50"); - info.addParameter("cache.time.to.live", "600"); - info = _locator.addDao("HostPodDao", HostPodDaoImpl.class); - info.addParameter("cache.size", "50"); - info.addParameter("cache.time.to.live", "600"); - _locator.addDao("IPAddressDao", IPAddressDaoImpl.class); - info = _locator.addDao("VlanDao", VlanDaoImpl.class); - info.addParameter("cache.size", "30"); - info.addParameter("cache.time.to.live", "3600"); - _locator.addDao("PodVlanMapDao", PodVlanMapDaoImpl.class); - _locator.addDao("AccountVlanMapDao", AccountVlanMapDaoImpl.class); - _locator.addDao("VolumeDao", VolumeDaoImpl.class); - _locator.addDao("EventDao", EventDaoImpl.class); - info = _locator.addDao("UserDao", UserDaoImpl.class); - info.addParameter("cache.size", "5000"); - info.addParameter("cache.time.to.live", "300"); - _locator.addDao("UserStatisticsDao", UserStatisticsDaoImpl.class); - _locator.addDao("FirewallRulesDao", FirewallRulesDaoImpl.class); - _locator.addDao("LoadBalancerDao", LoadBalancerDaoImpl.class); - _locator.addDao("NetworkRuleConfigDao", NetworkRuleConfigDaoImpl.class); - _locator.addDao("LoadBalancerVMMapDao", LoadBalancerVMMapDaoImpl.class); - _locator.addDao("DataCenterIpAddressDao", DataCenterIpAddressDaoImpl.class); - _locator.addDao("SecurityGroupDao", SecurityGroupDaoImpl.class); - //_locator.addDao("IngressRuleDao", IngressRuleDaoImpl.class); - _locator.addDao("SecurityGroupVMMapDao", SecurityGroupVMMapDaoImpl.class); - _locator.addDao("SecurityGroupRulesDao", SecurityGroupRulesDaoImpl.class); - _locator.addDao("SecurityGroupWorkDao", SecurityGroupWorkDaoImpl.class); - _locator.addDao("VmRulesetLogDao", VmRulesetLogDaoImpl.class); - _locator.addDao("AlertDao", AlertDaoImpl.class); - _locator.addDao("CapacityDao", CapacityDaoImpl.class); - _locator.addDao("DomainDao", DomainDaoImpl.class); - _locator.addDao("AccountDao", AccountDaoImpl.class); - _locator.addDao("ResourceLimitDao", ResourceLimitDaoImpl.class); - _locator.addDao("ResourceCountDao", ResourceCountDaoImpl.class); - _locator.addDao("UserAccountDao", UserAccountDaoImpl.class); - _locator.addDao("VMTemplateHostDao", VMTemplateHostDaoImpl.class); - _locator.addDao("UploadDao", UploadDaoImpl.class); - _locator.addDao("VMTemplatePoolDao", VMTemplatePoolDaoImpl.class); - _locator.addDao("LaunchPermissionDao", LaunchPermissionDaoImpl.class); - _locator.addDao("ConfigurationDao", ConfigurationDaoImpl.class); - info = _locator.addDao("VMTemplateDao", VMTemplateDaoImpl.class); - info.addParameter("cache.size", "100"); - info.addParameter("cache.time.to.live", "600"); - info.addParameter("routing.uniquename", "routing"); - _locator.addDao("HighAvailabilityDao", HighAvailabilityDaoImpl.class); - _locator.addDao("ConsoleProxyDao", ConsoleProxyDaoImpl.class); - _locator.addDao("SecondaryStorageVmDao", SecondaryStorageVmDaoImpl.class); - _locator.addDao("ManagementServerHostDao", ManagementServerHostDaoImpl.class); - _locator.addDao("AgentUpgradeDao", AgentUpgradeDaoImpl.class); - _locator.addDao("SnapshotDao", SnapshotDaoImpl.class); - _locator.addDao("AsyncJobDao", AsyncJobDaoImpl.class); - _locator.addDao("SyncQueueDao", SyncQueueDaoImpl.class); - _locator.addDao("SyncQueueItemDao", SyncQueueItemDaoImpl.class); - _locator.addDao("GuestOSDao", GuestOSDaoImpl.class); - _locator.addDao("GuestOSCategoryDao", GuestOSCategoryDaoImpl.class); - _locator.addDao("StoragePoolDao", StoragePoolDaoImpl.class); - _locator.addDao("StoragePoolHostDao", StoragePoolHostDaoImpl.class); - _locator.addDao("DetailsDao", HostDetailsDaoImpl.class); - _locator.addDao("SnapshotPolicyDao", SnapshotPolicyDaoImpl.class); - _locator.addDao("SnapshotScheduleDao", SnapshotScheduleDaoImpl.class); - _locator.addDao("ClusterDao", ClusterDaoImpl.class); - _locator.addDao("CertificateDao", CertificateDaoImpl.class); - _locator.addDao("NetworkConfigurationDao", NetworkDaoImpl.class); - _locator.addDao("NetworkOfferingDao", NetworkOfferingDaoImpl.class); - _locator.addDao("NicDao", NicDaoImpl.class); - _locator.addDao("InstanceGroupDao", InstanceGroupDaoImpl.class); - _locator.addDao("InstanceGroupVMMapDao", InstanceGroupVMMapDaoImpl.class); - _locator.addDao("RemoteAccessVpnDao", RemoteAccessVpnDaoImpl.class); - _locator.addDao("VpnUserDao", VpnUserDaoImpl.class); - _locator.addDao("ItWorkDao", ItWorkDaoImpl.class); - _locator.addDao("FirewallRulesDao", FirewallRulesDaoImpl.class); - _locator.addDao("PortForwardingRulesDao", PortForwardingRulesDaoImpl.class); - _locator.addDao("FirewallRulesCidrsDao", FirewallRulesCidrsDaoImpl.class); - _locator.addDao("SSHKeyPairDao", SSHKeyPairDaoImpl.class); - _locator.addDao("UsageEventDao", UsageEventDaoImpl.class); - _locator.addDao("ClusterDetailsDao", ClusterDetailsDaoImpl.class); - _locator.addDao("UserVmDetailsDao", UserVmDetailsDaoImpl.class); - _locator.addDao("StoragePoolWorkDao", StoragePoolWorkDaoImpl.class); - _locator.addDao("HostTagsDao", HostTagsDaoImpl.class); - _locator.addDao("NetworkDomainDao", NetworkDomainDaoImpl.class); - _locator.addDao("KeystoreDao", KeystoreDaoImpl.class); - _locator.addDao("DcDetailsDao", DcDetailsDaoImpl.class); - _locator.addDao("SwiftDao", SwiftDaoImpl.class); - _locator.addDao("AgentTransferMapDao", HostTransferMapDaoImpl.class); - _locator.addDao("ProjectDao", ProjectDaoImpl.class); - _locator.addDao("InlineLoadBalancerNicMapDao", InlineLoadBalancerNicMapDaoImpl.class); - _locator.addDao("ElasticLbVmMap", ElasticLbVmMapDaoImpl.class); - _locator.addDao("ProjectsAccountDao", ProjectAccountDaoImpl.class); - info = _locator.addDao("HypervisorCapabilitiesDao", HypervisorCapabilitiesDaoImpl.class); - info.addParameter("cache.size", "100"); - info.addParameter("cache.time.to.live", "600"); - - _locator.addManager("StackMaidManager", CheckPointManagerImpl.class); - _locator.addManager("account manager", AccountManagerImpl.class); - _locator.addManager("domain manager", DomainManagerImpl.class); - _locator.addManager("resource limit manager", ResourceLimitManagerImpl.class); - _locator.addManager("configuration manager", ConfigurationManagerImpl.class); - _locator.addManager("network manager", NetworkManagerImpl.class); - _locator.addManager("download manager", DownloadMonitorImpl.class); - _locator.addManager("upload manager", UploadMonitorImpl.class); - _locator.addManager("keystore manager", KeystoreManagerImpl.class); - _locator.addManager("secondary storage vm manager", SecondaryStorageManagerImpl.class); - _locator.addManager("vm manager", UserVmManagerImpl.class); - _locator.addManager("upgrade manager", UpgradeManagerImpl.class); - _locator.addManager("StorageManager", StorageManagerImpl.class); - _locator.addManager("SyncQueueManager", SyncQueueManagerImpl.class); - _locator.addManager("AsyncJobManager", AsyncJobManagerImpl.class); - _locator.addManager("AsyncJobExecutorContext", AsyncJobExecutorContextImpl.class); - _locator.addManager("HA Manager", HighAvailabilityManagerImpl.class); - _locator.addManager("Alert Manager", AlertManagerImpl.class); - _locator.addManager("Template Manager", TemplateManagerImpl.class); - _locator.addManager("Snapshot Manager", SnapshotManagerImpl.class); - _locator.addManager("SnapshotScheduler", SnapshotSchedulerImpl.class); - _locator.addManager("SecurityGroupManager", SecurityGroupManagerImpl2.class); - _locator.addManager("DomainRouterManager", VirtualNetworkApplianceManagerImpl.class); - _locator.addManager("EntityManager", EntityManagerImpl.class); - _locator.addManager("LoadBalancingRulesManager", LoadBalancingRulesManagerImpl.class); - _locator.addManager("RulesManager", RulesManagerImpl.class); - _locator.addManager("RemoteAccessVpnManager", RemoteAccessVpnManagerImpl.class); - _locator.addManager("OvsTunnelManager", OvsTunnelManagerImpl.class); - _locator.addManager("Capacity Manager", CapacityManagerImpl.class); - _locator.addManager("Cluster Manager", ClusterManagerImpl.class); - _locator.addManager("VirtualMachineManager", ClusteredVirtualMachineManagerImpl.class); - _locator.addManager("HypervisorGuruManager", HypervisorGuruManagerImpl.class); - _locator.addManager("ClusterFenceManager", ClusterFenceManagerImpl.class); - _locator.addManager("ResourceManager", ResourceManagerImpl.class); - - _locator.addManager("OCFS2Manager", OCFS2ManagerImpl.class); - _locator.addManager("FirewallManager", FirewallManagerImpl.class); - ComponentInfo info1 = _locator.addManager("ConsoleProxyManager", ConsoleProxyManagerImpl.class); - info1.addParameter("consoleproxy.sslEnabled", "true"); - _locator.addManager("ClusteredAgentManager", ClusteredAgentManagerImpl.class); - _locator.addManager("ProjectManager", ProjectManagerImpl.class); - _locator.addManager("ElasticLoadBalancerManager", ElasticLoadBalancerManagerImpl.class); - - _locator.makeActive(null); - _configService = ComponentLocator.inject(ConfigurationManagerImpl.class); - } - - private void evaluateCmd(T cmd, String name, Object value) { - try { - Field f = cmd.getClass().getDeclaredField(name); - f.set(cmd, value); - } catch (Exception e) { - s_logger.debug("Unable to evaluate " + cmd.getClass().getName() + "." + name, e); - TestCase.fail(); - } - } - - private void createZone(String zoneName) { - CreateZoneCmd cZone = new CreateZoneCmd(); - evaluateCmd(cZone, "dns1", "10.223.110.254"); - evaluateCmd(cZone, "internalDns1", "10.223.110.254"); - evaluateCmd(cZone, "zoneName", zoneName); - evaluateCmd(cZone, "networkType", "Basic"); - evaluateCmd(cZone, "securitygroupenabled", false); - s_logger.info("Create zone:" + cZone.getZoneName()); - - _configService.createZone(cZone); - } - - private void createPod(String name) { - CreatePodCmd cPod = new CreatePodCmd(); - evaluateCmd(cPod, "netmask", "255.255.255.0"); - - } - - private void deploy100Hosts() { - createZone("test1"); - } - - public void testDeploy100Hosts() { - deploy100Hosts(); - } - - @Override - @After - public void tearDown() throws Exception { - } - -}