|
19 | 19 |
|
20 | 20 | package com.cloud.network.manager; |
21 | 21 |
|
22 | | -import com.google.common.base.MoreObjects; |
23 | | -import com.google.common.base.Strings; |
24 | | -import com.google.common.collect.HashMultimap; |
25 | | -import com.google.common.collect.ImmutableMultimap; |
26 | | -import com.google.common.collect.ImmutableSet; |
27 | | -import com.google.common.collect.Lists; |
28 | | -import com.google.common.collect.Maps; |
29 | | -import com.google.common.collect.Multimap; |
| 22 | +import static com.cloud.agent.api.sync.SyncNuageVspCmsIdCommand.SyncType; |
| 23 | + |
| 24 | +import java.net.URI; |
| 25 | +import java.util.ArrayList; |
| 26 | +import java.util.Arrays; |
| 27 | +import java.util.Comparator; |
| 28 | +import java.util.HashSet; |
| 29 | +import java.util.Iterator; |
| 30 | +import java.util.LinkedList; |
| 31 | +import java.util.List; |
| 32 | +import java.util.Map; |
| 33 | +import java.util.Optional; |
| 34 | +import java.util.Set; |
| 35 | +import java.util.TreeSet; |
| 36 | +import java.util.UUID; |
| 37 | +import java.util.stream.Collectors; |
| 38 | + |
| 39 | +import javax.annotation.Nonnull; |
| 40 | +import javax.inject.Inject; |
| 41 | +import javax.naming.ConfigurationException; |
| 42 | + |
30 | 43 | import net.nuage.vsp.acs.client.api.NuageVspPluginClientLoader; |
31 | 44 | import net.nuage.vsp.acs.client.api.model.VspApiDefaults; |
32 | 45 | import net.nuage.vsp.acs.client.api.model.VspDomain; |
|
37 | 50 | import net.nuage.vsp.acs.client.common.NuageVspConstants; |
38 | 51 | import net.nuage.vsp.acs.client.common.model.Pair; |
39 | 52 | import net.nuage.vsp.acs.client.exception.NuageVspException; |
| 53 | + |
| 54 | +import org.apache.commons.collections.CollectionUtils; |
| 55 | +import org.apache.commons.lang3.StringUtils; |
| 56 | +import org.apache.log4j.Logger; |
| 57 | + |
| 58 | +import com.google.common.base.MoreObjects; |
| 59 | +import com.google.common.base.Strings; |
| 60 | +import com.google.common.collect.HashMultimap; |
| 61 | +import com.google.common.collect.ImmutableMultimap; |
| 62 | +import com.google.common.collect.ImmutableSet; |
| 63 | +import com.google.common.collect.Lists; |
| 64 | +import com.google.common.collect.Maps; |
| 65 | +import com.google.common.collect.Multimap; |
| 66 | + |
40 | 67 | import org.apache.cloudstack.api.ResponseGenerator; |
41 | 68 | import org.apache.cloudstack.context.CallContext; |
42 | 69 | import org.apache.cloudstack.framework.config.ConfigKey; |
|
47 | 74 | import org.apache.cloudstack.network.ExternalNetworkDeviceManager; |
48 | 75 | import org.apache.cloudstack.resourcedetail.VpcDetailVO; |
49 | 76 | import org.apache.cloudstack.resourcedetail.dao.VpcDetailsDao; |
50 | | -import org.apache.commons.collections.CollectionUtils; |
51 | | -import org.apache.commons.lang3.StringUtils; |
52 | | -import org.apache.log4j.Logger; |
53 | | - |
54 | | -import javax.annotation.Nonnull; |
55 | | -import javax.inject.Inject; |
56 | | -import javax.naming.ConfigurationException; |
57 | | -import java.net.URI; |
58 | | -import java.util.ArrayList; |
59 | | -import java.util.Arrays; |
60 | | -import java.util.Comparator; |
61 | | -import java.util.HashMap; |
62 | | -import java.util.HashSet; |
63 | | -import java.util.Iterator; |
64 | | -import java.util.LinkedList; |
65 | | -import java.util.List; |
66 | | -import java.util.Map; |
67 | | -import java.util.Optional; |
68 | | -import java.util.Set; |
69 | | -import java.util.TreeSet; |
70 | | -import java.util.UUID; |
71 | | -import java.util.stream.Collectors; |
72 | 77 |
|
73 | 78 | import com.cloud.agent.AgentManager; |
74 | 79 | import com.cloud.agent.Listener; |
|
142 | 147 | import com.cloud.network.vpc.dao.VpcDao; |
143 | 148 | import com.cloud.network.vpc.dao.VpcOfferingDao; |
144 | 149 | import com.cloud.network.vpc.dao.VpcOfferingServiceMapDao; |
145 | | -import com.cloud.offering.NetworkOffering; |
146 | | -import com.cloud.offerings.NetworkOfferingServiceMapVO; |
147 | | -import com.cloud.offerings.NetworkOfferingVO; |
148 | 150 | import com.cloud.offerings.dao.NetworkOfferingDao; |
149 | 151 | import com.cloud.offerings.dao.NetworkOfferingServiceMapDao; |
150 | 152 | import com.cloud.resource.ResourceManager; |
|
167 | 169 | import com.cloud.vm.dao.NicDao; |
168 | 170 | import com.cloud.vm.dao.VMInstanceDao; |
169 | 171 |
|
170 | | -import static com.cloud.agent.api.sync.SyncNuageVspCmsIdCommand.SyncType; |
171 | | - |
172 | 172 | public class NuageVspManagerImpl extends ManagerBase implements NuageVspManager, Configurable, StateListener<Status, Status.Event, Host> { |
173 | 173 |
|
174 | 174 | private static final Logger s_logger = Logger.getLogger(NuageVspManagerImpl.class); |
@@ -1219,7 +1219,6 @@ public boolean postStateTransitionEvent(StateMachine2.Transition<Status, Status. |
1219 | 1219 | public boolean configure(String name, Map<String, Object> params) throws ConfigurationException { |
1220 | 1220 | initMessageBusListeners(); |
1221 | 1221 | initNuageVspResourceListeners(); |
1222 | | - initNuageNetworkOffering(); |
1223 | 1222 | initNuageVspVpcOffering(); |
1224 | 1223 | Status.getStateMachine().registerListener(this); |
1225 | 1224 | return true; |
@@ -1290,39 +1289,6 @@ private void initNuageVspResourceListeners() { |
1290 | 1289 | _agentMgr.registerForHostEvents(new NuageVspResourceListener(), false, true, false); |
1291 | 1290 | } |
1292 | 1291 |
|
1293 | | - @DB |
1294 | | - private void initNuageNetworkOffering() { |
1295 | | - Transaction.execute(new TransactionCallbackNoReturn() { |
1296 | | - @Override |
1297 | | - public void doInTransactionWithoutResult(TransactionStatus status) { |
1298 | | - NetworkOffering sharedNetworkOfferingWithSG = _networkOfferingDao.findByUniqueName(nuageVspSharedNetworkOfferingWithSGServiceName); |
1299 | | - if (sharedNetworkOfferingWithSG == null) { |
1300 | | - NetworkOfferingVO defaultNuageVspSharedSGNetworkOffering = |
1301 | | - new NetworkOfferingVO(nuageVspSharedNetworkOfferingWithSGServiceName, "Offering for NuageVsp Shared Security group enabled networks", |
1302 | | - Networks.TrafficType.Guest, false, false, null, null, true, NetworkOffering.Availability.Optional, null, Network.GuestType.Shared, true, true, false, false, false, |
1303 | | - false); |
1304 | | - |
1305 | | - defaultNuageVspSharedSGNetworkOffering.setState(NetworkOffering.State.Enabled); |
1306 | | - defaultNuageVspSharedSGNetworkOffering = _networkOfferingDao.persistDefaultNetworkOffering(defaultNuageVspSharedSGNetworkOffering); |
1307 | | - |
1308 | | - Map<Network.Service, Network.Provider> defaultNuageVspSharedSGNetworkOfferingProviders = new HashMap<Network.Service, Network.Provider>(); |
1309 | | - defaultNuageVspSharedSGNetworkOfferingProviders.put(Network.Service.Dhcp, Network.Provider.NuageVsp); |
1310 | | - defaultNuageVspSharedSGNetworkOfferingProviders.put(Network.Service.SecurityGroup, Network.Provider.NuageVsp); |
1311 | | - defaultNuageVspSharedSGNetworkOfferingProviders.put(Network.Service.Connectivity, Network.Provider.NuageVsp); |
1312 | | - |
1313 | | - for (Network.Service service : defaultNuageVspSharedSGNetworkOfferingProviders.keySet()) { |
1314 | | - NetworkOfferingServiceMapVO offService = |
1315 | | - new NetworkOfferingServiceMapVO(defaultNuageVspSharedSGNetworkOffering.getId(), service, defaultNuageVspSharedSGNetworkOfferingProviders.get(service)); |
1316 | | - _networkOfferingServiceMapDao.persist(offService); |
1317 | | - if (s_logger.isTraceEnabled()) { |
1318 | | - s_logger.trace("Added service for the NuageVsp network offering: " + offService); |
1319 | | - } |
1320 | | - } |
1321 | | - } |
1322 | | - } |
1323 | | - }); |
1324 | | - } |
1325 | | - |
1326 | 1292 | private Long getNuageVspHostId(long physicalNetworkId) { |
1327 | 1293 | List<NuageVspDeviceVO> nuageVspDevices = _nuageVspDao.listByPhysicalNetwork(physicalNetworkId); |
1328 | 1294 | if (nuageVspDevices != null && (!nuageVspDevices.isEmpty())) { |
|
0 commit comments