// 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.network.security; import java.util.ArrayList; import java.util.List; import javax.naming.ConfigurationException; import junit.framework.TestCase; import org.junit.After; import org.junit.Before; import org.junit.Ignore; import com.cloud.agent.MockAgentManagerImpl; import com.cloud.configuration.DefaultInterceptorLibrary; import com.cloud.configuration.dao.ConfigurationDaoImpl; import com.cloud.domain.dao.DomainDaoImpl; import com.cloud.event.dao.UsageEventDaoImpl; import com.cloud.network.MockNetworkManagerImpl; import com.cloud.network.security.dao.SecurityGroupDaoImpl; import com.cloud.network.security.dao.SecurityGroupRuleDaoImpl; 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.projects.MockProjectManagerImpl; import com.cloud.tags.dao.ResourceTagsDaoImpl; import com.cloud.user.MockAccountManagerImpl; import com.cloud.user.MockDomainManagerImpl; import com.cloud.user.dao.AccountDaoImpl; import com.cloud.utils.Profiler; import com.cloud.utils.component.ComponentLocator; import com.cloud.utils.component.MockComponentLocator; import com.cloud.vm.MockUserVmManagerImpl; import com.cloud.vm.MockVirtualMachineManagerImpl; import com.cloud.vm.dao.UserVmDaoImpl; import com.cloud.vm.dao.VMInstanceDaoImpl; public class SecurityGroupManagerImpl2Test extends TestCase { //private final static Logger s_logger = Logger.getLogger(SecurityGroupManagerImpl2Test.class); SecurityGroupManagerImpl2 _sgMgr = null; UserVmDaoImpl _vmDao = null; @Before @Override public void setUp() { MockComponentLocator locator = new MockComponentLocator("management-server"); locator.addDao("ConfigurationDao", ConfigurationDaoImpl.class); locator.addDao("SecurityGroupDao", SecurityGroupDaoImpl.class); locator.addDao("SecurityGroupRuleDao", SecurityGroupRuleDaoImpl.class); locator.addDao("SecurityGroupVMMapDao", SecurityGroupVMMapDaoImpl.class); locator.addDao("SecurityGroupRulesDao", SecurityGroupRulesDaoImpl.class); locator.addDao("UserVmDao", UserVmDaoImpl.class); locator.addDao("AccountDao", AccountDaoImpl.class); locator.addDao("ConfigurationDao", ConfigurationDaoImpl.class); locator.addDao("SecurityGroupWorkDao", SecurityGroupWorkDaoImpl.class); locator.addDao("VmRulesetLogDao", VmRulesetLogDaoImpl.class); locator.addDao("VMInstanceDao", VMInstanceDaoImpl.class); locator.addDao("DomainDao", DomainDaoImpl.class); locator.addDao("UsageEventDao", UsageEventDaoImpl.class); locator.addDao("ResourceTagDao", ResourceTagsDaoImpl.class); locator.addManager("AgentManager", MockAgentManagerImpl.class); locator.addManager("VirtualMachineManager", MockVirtualMachineManagerImpl.class); locator.addManager("UserVmManager", MockUserVmManagerImpl.class); locator.addManager("NetworkManager", MockNetworkManagerImpl.class); locator.addManager("AccountManager", MockAccountManagerImpl.class); locator.addManager("DomainManager", MockDomainManagerImpl.class); locator.addManager("ProjectManager", MockProjectManagerImpl.class); locator.makeActive(new DefaultInterceptorLibrary()); _sgMgr = ComponentLocator.inject(SecurityGroupManagerImpl2.class); _sgMgr._mBean = new SecurityManagerMBeanImpl(_sgMgr); } @Override @After public void tearDown() throws Exception { } protected void _schedule(final int numVms) { System.out.println("Starting"); List work = new ArrayList(); for (long i=100; i <= 100+numVms; i++) { work.add(i); } Profiler profiler = new Profiler(); profiler.start(); _sgMgr.scheduleRulesetUpdateToHosts(work, false, null); profiler.stop(); System.out.println("Done " + numVms + " in " + profiler.getDuration() + " ms"); } @Ignore public void testSchedule() throws ConfigurationException { _schedule(1000); } public void testWork() throws ConfigurationException { _schedule(1000); _sgMgr.work(); } }