diff --git a/client/pom.xml b/client/pom.xml index e00e28b6e5e..e62c6a99e20 100644 --- a/client/pom.xml +++ b/client/pom.xml @@ -199,6 +199,7 @@ 60000 + -XX:MaxPermSize=256m -Xmx2g /client ${basedir}/target/${project.artifactId}-${project.version}/WEB-INF/web.xml ${basedir}/target/${project.artifactId}-${project.version} diff --git a/client/tomcatconf/applicationContext.xml.in b/client/tomcatconf/applicationContext.xml.in index 34bb853c52e..60e68e0fd42 100644 --- a/client/tomcatconf/applicationContext.xml.in +++ b/client/tomcatconf/applicationContext.xml.in @@ -19,6 +19,8 @@ + + diff --git a/framework/ipc/test/org/apache/cloudstack/framework/codestyle/AsyncSampleEventDrivenStyleCaller.java b/framework/ipc/test/org/apache/cloudstack/framework/codestyle/AsyncSampleEventDrivenStyleCaller.java index df66f10db23..1176eb22eda 100644 --- a/framework/ipc/test/org/apache/cloudstack/framework/codestyle/AsyncSampleEventDrivenStyleCaller.java +++ b/framework/ipc/test/org/apache/cloudstack/framework/codestyle/AsyncSampleEventDrivenStyleCaller.java @@ -28,14 +28,14 @@ public class AsyncSampleEventDrivenStyleCaller { @SuppressWarnings("unchecked") public void MethodThatWillCallAsyncMethod() { String vol = new String("Hello"); - AsyncCallbackDispatcher caller = AsyncCallbackDispatcher.create(this); + AsyncCallbackDispatcher caller = AsyncCallbackDispatcher.create(this); _ds.createVolume(vol, caller .setCallback(caller.getTarget().HandleVolumeCreateAsyncCallback(null, null)) .setContext(vol) ); } - public Void HandleVolumeCreateAsyncCallback(AsyncCallbackDispatcher callback, String context) { + public Void HandleVolumeCreateAsyncCallback(AsyncCallbackDispatcher callback, String context) { Object resultVol = callback.getResult(); return null; diff --git a/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java b/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java index eb39c0e7c40..4f09954f560 100755 --- a/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java +++ b/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java @@ -116,8 +116,8 @@ public class ClusteredAgentManagerImpl extends AgentManagerImpl implements Clust @Inject protected HostTransferMapDao _hostTransferDao; - @com.cloud.utils.component.Inject(adapter = AgentLoadBalancerPlanner.class) - protected Adapters _lbPlanners; + // @com.cloud.utils.component.Inject(adapter = AgentLoadBalancerPlanner.class) + @Inject protected List _lbPlanners; @Inject protected AgentManager _agentMgr; diff --git a/server/src/com/cloud/baremetal/BareMetalVmManagerImpl.java b/server/src/com/cloud/baremetal/BareMetalVmManagerImpl.java index f7127915796..255d79a2c36 100755 --- a/server/src/com/cloud/baremetal/BareMetalVmManagerImpl.java +++ b/server/src/com/cloud/baremetal/BareMetalVmManagerImpl.java @@ -22,6 +22,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.Executors; +import javax.annotation.PostConstruct; import javax.ejb.Local; import javax.inject.Inject; import javax.naming.ConfigurationException; @@ -112,9 +113,13 @@ public class BareMetalVmManagerImpl extends UserVmManagerImpl implements BareMet @Inject PxeServerManager _pxeMgr; @Inject ResourceManager _resourceMgr; - @com.cloud.utils.component.Inject (adapter=TemplateAdapter.class) - protected Adapters _adapters; + // @com.cloud.utils.component.Inject (adapter=TemplateAdapter.class) + @Inject protected List _adapters; + @PostConstruct + public void init() { + } + @Override public boolean attachISOToVM(long vmId, long isoId, boolean attach) { s_logger.warn("attachISOToVM is not supported by Bare Metal, just fake a true"); diff --git a/server/src/com/cloud/baremetal/PxeServerManagerImpl.java b/server/src/com/cloud/baremetal/PxeServerManagerImpl.java index dde1bb47727..1029790021f 100755 --- a/server/src/com/cloud/baremetal/PxeServerManagerImpl.java +++ b/server/src/com/cloud/baremetal/PxeServerManagerImpl.java @@ -58,8 +58,9 @@ public class PxeServerManagerImpl implements PxeServerManager, ResourceStateAdap @Inject AgentManager _agentMgr; @Inject ExternalDhcpManager exDhcpMgr; @Inject ResourceManager _resourceMgr; - @com.cloud.utils.component.Inject(adapter=PxeServerService.class) - protected Adapters _services; + + // @com.cloud.utils.component.Inject(adapter=PxeServerService.class) + @Inject protected List _services; @Override public boolean configure(String name, Map params) throws ConfigurationException { diff --git a/server/src/com/cloud/configuration/ConfigurationManagerImpl.java b/server/src/com/cloud/configuration/ConfigurationManagerImpl.java index e2e657d336d..0a6aaa8e02f 100755 --- a/server/src/com/cloud/configuration/ConfigurationManagerImpl.java +++ b/server/src/com/cloud/configuration/ConfigurationManagerImpl.java @@ -211,8 +211,10 @@ public class ConfigurationManagerImpl implements ConfigurationManager, Configura ClusterDao _clusterDao; @Inject AlertManager _alertMgr; - @com.cloud.utils.component.Inject(adapter = SecurityChecker.class) - Adapters _secChecker; + // @com.cloud.utils.component.Inject(adapter = SecurityChecker.class) + @Inject + List _secChecker; + @Inject CapacityDao _capacityDao; @Inject diff --git a/server/src/com/cloud/deploy/FirstFitPlanner.java b/server/src/com/cloud/deploy/FirstFitPlanner.java index ec32e63dc8d..9b5646db301 100755 --- a/server/src/com/cloud/deploy/FirstFitPlanner.java +++ b/server/src/com/cloud/deploy/FirstFitPlanner.java @@ -106,10 +106,11 @@ public class FirstFitPlanner extends PlannerBase implements DeploymentPlanner { @Inject protected AccountManager _accountMgr; @Inject protected StorageManager _storageMgr; - @com.cloud.utils.component.Inject(adapter=StoragePoolAllocator.class) - protected Adapters _storagePoolAllocators; - @com.cloud.utils.component.Inject(adapter=HostAllocator.class) - protected Adapters _hostAllocators; + //@com.cloud.utils.component.Inject(adapter=StoragePoolAllocator.class) + @Inject protected List _storagePoolAllocators; + + //@com.cloud.utils.component.Inject(adapter=HostAllocator.class) + @Inject protected List _hostAllocators; protected String _allocationAlgorithm = "random"; @@ -714,17 +715,13 @@ public class FirstFitPlanner extends PlannerBase implements DeploymentPlanner { protected List findSuitableHosts(VirtualMachineProfile vmProfile, DeploymentPlan plan, ExcludeList avoid, int returnUpTo){ List suitableHosts = new ArrayList(); - Enumeration enHost = _hostAllocators.enumeration(); - s_logger.debug("Calling HostAllocators to find suitable hosts"); - - while (enHost.hasMoreElements()) { - final HostAllocator allocator = enHost.nextElement(); + for(HostAllocator allocator : _hostAllocators) { suitableHosts = allocator.allocateTo(vmProfile, plan, Host.Type.Routing, avoid, returnUpTo); if (suitableHosts != null && !suitableHosts.isEmpty()) { break; } } - + if(suitableHosts.isEmpty()){ s_logger.debug("No suitable hosts found"); } @@ -812,12 +809,8 @@ public class FirstFitPlanner extends PlannerBase implements DeploymentPlanner { } diskProfile.setUseLocalStorage(useLocalStorage); - boolean foundPotentialPools = false; - - Enumeration enPool = _storagePoolAllocators.enumeration(); - while (enPool.hasMoreElements()) { - final StoragePoolAllocator allocator = enPool.nextElement(); + for(StoragePoolAllocator allocator : _storagePoolAllocators) { final List suitablePools = allocator.allocateToPool(diskProfile, vmProfile, plan, avoid, returnUpTo); if (suitablePools != null && !suitablePools.isEmpty()) { suitableVolumeStoragePools.put(toBeCreated, suitablePools); @@ -825,7 +818,7 @@ public class FirstFitPlanner extends PlannerBase implements DeploymentPlanner { break; } } - + if(!foundPotentialPools){ s_logger.debug("No suitable pools found for volume: "+toBeCreated +" under cluster: "+plan.getClusterId()); //No suitable storage pools found under this cluster for this volume. - remove any suitable pools found for other volumes. diff --git a/server/src/com/cloud/network/NetworkManagerImpl.java b/server/src/com/cloud/network/NetworkManagerImpl.java index d5b934c09af..085b1c9356d 100755 --- a/server/src/com/cloud/network/NetworkManagerImpl.java +++ b/server/src/com/cloud/network/NetworkManagerImpl.java @@ -272,10 +272,15 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag RemoteAccessVpnService _vpnMgr; @Inject PodVlanMapDao _podVlanMapDao; - @com.cloud.utils.component.Inject(adapter = NetworkGuru.class) - Adapters _networkGurus; - @com.cloud.utils.component.Inject(adapter = NetworkElement.class) - Adapters _networkElements; + + //@com.cloud.utils.component.Inject(adapter = NetworkGuru.class) + @Inject + List _networkGurus; + + // @com.cloud.utils.component.Inject(adapter = NetworkElement.class) + @Inject + List _networkElements; + @Inject NetworkDomainDao _networkDomainDao; @Inject @@ -351,7 +356,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag @Override public NetworkElement getElementImplementingProvider(String providerName) { String elementName = s_providerToNetworkElementMap.get(providerName); - NetworkElement element = _networkElements.get(elementName); + NetworkElement element = Adapters.getAdapterByName(_networkElements, elementName); return element; } @@ -1791,7 +1796,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag NetworkVO ntwkVO = _networksDao.findById(network.getId()); s_logger.debug("Allocating nic for vm " + vm.getVirtualMachine() + " in network " + network + " with requested profile " + requested); - NetworkGuru guru = _networkGurus.get(ntwkVO.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, ntwkVO.getGuruName()); if (requested != null && requested.getMode() == null) { requested.setMode(network.getMode()); @@ -1936,7 +1941,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag } try { - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); Network.State state = network.getState(); if (state == Network.State.Implemented || state == Network.State.Setup || state == Network.State.Implementing) { s_logger.debug("Network id=" + networkId + " is already implemented"); @@ -2124,7 +2129,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag ConcurrentOperationException, InsufficientCapacityException, ResourceUnavailableException { Integer networkRate = getNetworkRate(network.getId(), vmProfile.getId()); - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); NicVO nic = _nicDao.findById(nicId); NicProfile profile = null; @@ -2186,7 +2191,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag NetworkVO network = _networksDao.findById(nic.getNetworkId()); Integer networkRate = getNetworkRate(network.getId(), vm.getId()); - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); NicProfile profile = new NicProfile(nic, network, nic.getBroadcastUri(), nic.getIsolationUri(), networkRate, isSecurityGroupSupportedInNetwork(network), getNetworkTag(vm.getHypervisorType(), network)); guru.updateNicProfile(profile, network); @@ -2216,7 +2221,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag if (nic.getState() == Nic.State.Reserved || nic.getState() == Nic.State.Reserving) { Nic.State originalState = nic.getState(); if (nic.getReservationStrategy() == Nic.ReservationStrategy.Start) { - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); nic.setState(Nic.State.Releasing); _nicDao.update(nic.getId(), nic); NicProfile profile = new NicProfile(nic, network, nic.getBroadcastUri(), nic.getIsolationUri(), null, @@ -2262,7 +2267,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag NetworkVO network = _networksDao.findById(nic.getNetworkId()); Integer networkRate = getNetworkRate(network.getId(), vm.getId()); - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); NicProfile profile = new NicProfile(nic, network, nic.getBroadcastUri(), nic.getIsolationUri(), networkRate, isSecurityGroupSupportedInNetwork(network), getNetworkTag(vm.getHypervisorType(), network)); guru.updateNicProfile(profile, network); @@ -2283,7 +2288,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag NetworkVO network = _networksDao.findById(networkId); Integer networkRate = getNetworkRate(network.getId(), vm.getId()); - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); NicProfile profile = new NicProfile(nic, network, nic.getBroadcastUri(), nic.getIsolationUri(), networkRate, isSecurityGroupSupportedInNetwork(network), getNetworkTag(vm.getHypervisorType(), network)); guru.updateNicProfile(profile, network); @@ -2438,7 +2443,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag NetworkVO network = _networksDao.findById(nic.getNetworkId()); NicProfile profile = new NicProfile(nic, network, null, null, null, isSecurityGroupSupportedInNetwork(network), getNetworkTag(vm.getHypervisorType(), network)); - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); guru.deallocate(network, profile, vm); _nicDao.remove(nic.getId()); s_logger.debug("Removed nic id=" + nic.getId()); @@ -3414,7 +3419,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag if (s_logger.isDebugEnabled()) { s_logger.debug("Network id=" + networkId + " is shutdown successfully, cleaning up corresponding resources now."); } - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); NetworkProfile profile = convertNetworkToNetworkProfile(network.getId()); guru.shutdown(profile, _networkOfferingDao.findById(network.getNetworkOfferingId())); @@ -3574,7 +3579,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag if (s_logger.isDebugEnabled()) { s_logger.debug("Network id=" + networkId + " is destroyed successfully, cleaning up corresponding resources now."); } - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); Account owner = _accountMgr.getAccount(network.getAccountId()); Transaction txn = Transaction.currentTxn(); @@ -4258,7 +4263,7 @@ public class NetworkManagerImpl implements NetworkManager, NetworkService, Manag @Override public NetworkProfile convertNetworkToNetworkProfile(long networkId) { NetworkVO network = _networksDao.findById(networkId); - NetworkGuru guru = _networkGurus.get(network.getGuruName()); + NetworkGuru guru = Adapters.getAdapterByName(_networkGurus, network.getGuruName()); NetworkProfile profile = new NetworkProfile(network); guru.updateNetworkProfile(profile); diff --git a/server/src/com/cloud/resource/ResourceManagerImpl.java b/server/src/com/cloud/resource/ResourceManagerImpl.java index 70549ed293f..b4f6d146ee9 100755 --- a/server/src/com/cloud/resource/ResourceManagerImpl.java +++ b/server/src/com/cloud/resource/ResourceManagerImpl.java @@ -27,6 +27,7 @@ import java.util.List; import java.util.Map; import java.util.Set; +import javax.annotation.PostConstruct; import javax.ejb.Local; import javax.inject.Inject; import javax.naming.ConfigurationException; @@ -204,14 +205,18 @@ public class ResourceManagerImpl implements ResourceManager, ResourceService, Ma protected HighAvailabilityManager _haMgr; @Inject protected StorageService _storageSvr; - @com.cloud.utils.component.Inject(adapter = Discoverer.class) - protected Adapters _discoverers; + //@com.cloud.utils.component.Inject(adapter = Discoverer.class) + @Inject + protected List _discoverers; @Inject protected ClusterManager _clusterMgr; @Inject protected StoragePoolHostDao _storagePoolHostDao; - @com.cloud.utils.component.Inject(adapter = PodAllocator.class) - protected Adapters _podAllocators = null; + + // @com.cloud.utils.component.Inject(adapter = PodAllocator.class) + @Inject + protected List _podAllocators = null; + @Inject protected VMTemplateDao _templateDao; @Inject @@ -226,6 +231,11 @@ public class ResourceManagerImpl implements ResourceManager, ResourceService, Ma protected HashMap> _lifeCycleListeners = new HashMap>(); private HypervisorType _defaultSystemVMHypervisor; + @PostConstruct + public void init() { + // TODO initialize pod allocators here instead + } + private void insertListener(Integer event, ResourceListener listener) { List lst = _lifeCycleListeners.get(event); if (lst == null) { @@ -497,13 +507,10 @@ public class ResourceManagerImpl implements ResourceManager, ResourceService, Ma @Override public Discoverer getMatchingDiscover(Hypervisor.HypervisorType hypervisorType) { - Enumeration en = _discoverers.enumeration(); - while (en.hasMoreElements()) { - Discoverer discoverer = en.nextElement(); - if (discoverer.getHypervisorType() == hypervisorType) { + for(Discoverer discoverer : _discoverers) { + if (discoverer.getHypervisorType() == hypervisorType) return discoverer; - } - } + } return null; } @@ -670,10 +677,8 @@ public class ResourceManagerImpl implements ResourceManager, ResourceService, Ma List hosts = new ArrayList(); s_logger.info("Trying to add a new host at " + url + " in data center " + dcId); - Enumeration en = _discoverers.enumeration(); boolean isHypervisorTypeSupported = false; - while (en.hasMoreElements()) { - Discoverer discoverer = en.nextElement(); + for ( Discoverer discoverer : _discoverers) { if (params != null) { discoverer.putParam(params); } @@ -2161,9 +2166,7 @@ public class ResourceManagerImpl implements ResourceManager, ResourceService, Ma @Override public Pair findPod(VirtualMachineTemplate template, ServiceOfferingVO offering, DataCenterVO dc, long accountId, Set avoids) { - final Enumeration en = _podAllocators.enumeration(); - while (en.hasMoreElements()) { - final PodAllocator allocator = (PodAllocator) en.nextElement(); + for(PodAllocator allocator : _podAllocators) { final Pair pod = allocator.allocateTo(template, offering, dc, accountId, avoids); if (pod != null) { return pod; diff --git a/server/src/com/cloud/secstorage/PremiumSecondaryStorageManagerImpl.java b/server/src/com/cloud/secstorage/PremiumSecondaryStorageManagerImpl.java index 45989f88617..d4f44541c85 100755 --- a/server/src/com/cloud/secstorage/PremiumSecondaryStorageManagerImpl.java +++ b/server/src/com/cloud/secstorage/PremiumSecondaryStorageManagerImpl.java @@ -25,6 +25,7 @@ import javax.inject.Inject; import javax.naming.ConfigurationException; import org.apache.log4j.Logger; +import org.springframework.context.annotation.Primary; import org.springframework.stereotype.Component; import com.cloud.agent.api.Command; @@ -49,6 +50,7 @@ import com.cloud.vm.VirtualMachine.State; import com.cloud.vm.dao.SecondaryStorageVmDao; @Component +@Primary @Local(value = { SecondaryStorageVmManager.class }) public class PremiumSecondaryStorageManagerImpl extends SecondaryStorageManagerImpl { private static final Logger s_logger = Logger.getLogger(PremiumSecondaryStorageManagerImpl.class); diff --git a/server/src/com/cloud/storage/StorageManagerImpl.java b/server/src/com/cloud/storage/StorageManagerImpl.java index f7cfcf81e7c..7cd696202fe 100755 --- a/server/src/com/cloud/storage/StorageManagerImpl.java +++ b/server/src/com/cloud/storage/StorageManagerImpl.java @@ -329,11 +329,11 @@ public class StorageManagerImpl implements StorageManager, Manager, ClusterManag protected DownloadMonitor _downloadMonitor; @Inject protected ResourceTagDao _resourceTagDao; + @Inject + protected List _storagePoolAllocators; - @com.cloud.utils.component.Inject(adapter = StoragePoolAllocator.class) - protected Adapters _storagePoolAllocators; - @com.cloud.utils.component.Inject(adapter = StoragePoolDiscoverer.class) - protected Adapters _discoverers; + @Inject + protected List _discoverers; protected SearchBuilder HostTemplateStatesSearch; @@ -463,9 +463,7 @@ public class StorageManagerImpl implements StorageManager, Manager, ClusterManag protected StoragePoolVO findStoragePool(DiskProfile dskCh, final DataCenterVO dc, HostPodVO pod, Long clusterId, Long hostId, VMInstanceVO vm, final Set avoid) { VirtualMachineProfile profile = new VirtualMachineProfileImpl(vm); - Enumeration en = _storagePoolAllocators.enumeration(); - while (en.hasMoreElements()) { - final StoragePoolAllocator allocator = en.nextElement(); + for (StoragePoolAllocator allocator : _storagePoolAllocators) { final List poolList = allocator.allocateToPool(dskCh, profile, dc.getId(), pod.getId(), clusterId, hostId, avoid, 1); if (poolList != null && !poolList.isEmpty()) { return (StoragePoolVO) poolList.get(0); @@ -1354,11 +1352,10 @@ public class StorageManagerImpl implements StorageManager, Manager, ClusterManag hostPath.replaceFirst("/", ""); pool = new StoragePoolVO(StoragePoolType.IscsiLUN, storageHost, port, hostPath); } else { - Enumeration en = _discoverers.enumeration(); - while (en.hasMoreElements()) { + for (StoragePoolDiscoverer discoverer : _discoverers) { Map> pools; try { - pools = en.nextElement().find(cmd.getZoneId(), podId, uri, details); + pools = discoverer.find(cmd.getZoneId(), podId, uri, details); } catch (DiscoveryException e) { throw new IllegalArgumentException("Not enough information for discovery " + uri, e); } diff --git a/server/src/com/cloud/storage/secondary/SecondaryStorageManagerImpl.java b/server/src/com/cloud/storage/secondary/SecondaryStorageManagerImpl.java index a630d23c64c..31beeafe90d 100755 --- a/server/src/com/cloud/storage/secondary/SecondaryStorageManagerImpl.java +++ b/server/src/com/cloud/storage/secondary/SecondaryStorageManagerImpl.java @@ -173,8 +173,8 @@ public class SecondaryStorageManagerImpl implements SecondaryStorageVmManager, V private int _mgmt_port = 8250; private String _name; - @com.cloud.utils.component.Inject(adapter = SecondaryStorageVmAllocator.class) - private Adapters _ssVmAllocators; + @Inject + private List _ssVmAllocators; @Inject protected SecondaryStorageVmDao _secStorageVmDao; @@ -589,11 +589,9 @@ public class SecondaryStorageManagerImpl implements SecondaryStorageVmManager, V private SecondaryStorageVmAllocator getCurrentAllocator() { // for now, only one adapter is supported - Enumeration it = _ssVmAllocators.enumeration(); - if (it.hasMoreElements()) { - return it.nextElement(); - } - + if(_ssVmAllocators.size() > 0) + return _ssVmAllocators.get(0); + return null; } diff --git a/server/src/com/cloud/template/TemplateManagerImpl.java b/server/src/com/cloud/template/TemplateManagerImpl.java index 8016fd70c6e..289bcf94dd2 100755 --- a/server/src/com/cloud/template/TemplateManagerImpl.java +++ b/server/src/com/cloud/template/TemplateManagerImpl.java @@ -210,16 +210,16 @@ public class TemplateManagerImpl implements TemplateManager, Manager, TemplateSe ScheduledExecutorService _swiftTemplateSyncExecutor; - @com.cloud.utils.component.Inject (adapter=TemplateAdapter.class) - protected Adapters _adapters; + @Inject + protected List _adapters; private TemplateAdapter getAdapter(HypervisorType type) { TemplateAdapter adapter = null; if (type == HypervisorType.BareMetal) { - adapter = _adapters.get(TemplateAdapterType.BareMetal.getName()); + adapter = Adapters.getAdapterByName(_adapters, TemplateAdapterType.BareMetal.getName()); } else { // see HyervisorTemplateAdapter - adapter = _adapters.get(TemplateAdapterType.Hypervisor.getName()); + adapter = Adapters.getAdapterByName(_adapters, TemplateAdapterType.Hypervisor.getName()); } if (adapter == null) { diff --git a/server/src/com/cloud/vm/VirtualMachineManagerImpl.java b/server/src/com/cloud/vm/VirtualMachineManagerImpl.java index 26465deea98..94b2116ac88 100755 --- a/server/src/com/cloud/vm/VirtualMachineManagerImpl.java +++ b/server/src/com/cloud/vm/VirtualMachineManagerImpl.java @@ -230,10 +230,10 @@ public class VirtualMachineManagerImpl implements VirtualMachineManager, Listene @Inject protected NetworkDao _networkDao; - @com.cloud.utils.component.Inject(adapter = DeploymentPlanner.class) - protected Adapters _planners; + @Inject + protected List _planners; - @com.cloud.utils.component.Inject(adapter = HostAllocator.class) + @Inject protected Adapters _hostAllocators; @Inject diff --git a/server/test/com/cloud/vpc/MockNetworkManagerImpl.java b/server/test/com/cloud/vpc/MockNetworkManagerImpl.java index 6ec2ca64b63..95c6ee9df14 100644 --- a/server/test/com/cloud/vpc/MockNetworkManagerImpl.java +++ b/server/test/com/cloud/vpc/MockNetworkManagerImpl.java @@ -95,9 +95,9 @@ public class MockNetworkManagerImpl implements NetworkManager, Manager{ NetworkServiceMapDao _ntwkSrvcDao; @Inject NetworkOfferingServiceMapDao _ntwkOfferingSrvcDao; - - @com.cloud.utils.component.Inject(adapter = NetworkElement.class) - Adapters _networkElements; + + @Inject + List _networkElements; private static HashMap s_providerToNetworkElementMap = new HashMap(); private static final Logger s_logger = Logger.getLogger(MockNetworkManagerImpl.class); diff --git a/utils/src/com/cloud/utils/component/Adapters.java b/utils/src/com/cloud/utils/component/Adapters.java index 00787da1f19..2a2203ff555 100755 --- a/utils/src/com/cloud/utils/component/Adapters.java +++ b/utils/src/com/cloud/utils/component/Adapters.java @@ -82,4 +82,12 @@ public class Adapters implements Iterable { public boolean isSet() { return _map.size() != 0; } + + public static T getAdapterByName(List adapters, String name) { + for(T adapter : adapters) { + if(adapter.getName().equals(name)) + return adapter; + } + return null; + } }