mirror of https://github.com/apache/cloudstack.git
237 lines
10 KiB
Java
237 lines
10 KiB
Java
/**
|
|
* Copyright (C) 2010 Cloud.com, Inc. All rights reserved.
|
|
*
|
|
* This software is licensed under the GNU General Public License v3 or later.
|
|
*
|
|
* It is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or any later version.
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
package com.cloud.network.element;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
import javax.ejb.Local;
|
|
|
|
import org.apache.log4j.Logger;
|
|
|
|
import com.cloud.configuration.ConfigurationManager;
|
|
import com.cloud.dc.DataCenter;
|
|
import com.cloud.dc.DataCenter.NetworkType;
|
|
import com.cloud.dc.dao.HostPodDao;
|
|
import com.cloud.deploy.DeployDestination;
|
|
import com.cloud.exception.ConcurrentOperationException;
|
|
import com.cloud.exception.InsufficientCapacityException;
|
|
import com.cloud.exception.ResourceUnavailableException;
|
|
import com.cloud.network.Network;
|
|
import com.cloud.network.Network.Capability;
|
|
import com.cloud.network.Network.GuestIpType;
|
|
import com.cloud.network.Network.Provider;
|
|
import com.cloud.network.Network.Service;
|
|
import com.cloud.network.NetworkManager;
|
|
import com.cloud.network.Networks.TrafficType;
|
|
import com.cloud.network.PublicIpAddress;
|
|
import com.cloud.network.dao.NetworkDao;
|
|
import com.cloud.network.router.VirtualNetworkApplianceManager;
|
|
import com.cloud.network.router.VirtualRouter;
|
|
import com.cloud.network.rules.FirewallRule;
|
|
import com.cloud.network.vpn.PasswordResetElement;
|
|
import com.cloud.offering.NetworkOffering;
|
|
import com.cloud.user.AccountManager;
|
|
import com.cloud.uservm.UserVm;
|
|
import com.cloud.utils.component.AdapterBase;
|
|
import com.cloud.utils.component.Inject;
|
|
import com.cloud.vm.DomainRouterVO;
|
|
import com.cloud.vm.NicProfile;
|
|
import com.cloud.vm.ReservationContext;
|
|
import com.cloud.vm.UserVmManager;
|
|
import com.cloud.vm.VirtualMachine;
|
|
import com.cloud.vm.VirtualMachine.State;
|
|
import com.cloud.vm.VirtualMachineProfile;
|
|
import com.cloud.vm.dao.DomainRouterDao;
|
|
import com.cloud.vm.dao.UserVmDao;
|
|
|
|
|
|
@Local(value=NetworkElement.class)
|
|
public class DhcpElement extends AdapterBase implements NetworkElement, PasswordResetElement{
|
|
private static final Logger s_logger = Logger.getLogger(DhcpElement.class);
|
|
|
|
private static final Map<Service, Map<Capability, String>> capabilities = setCapabilities();
|
|
|
|
@Inject NetworkDao _networkConfigDao;
|
|
@Inject NetworkManager _networkMgr;
|
|
@Inject VirtualNetworkApplianceManager _routerMgr;
|
|
@Inject UserVmManager _userVmMgr;
|
|
@Inject UserVmDao _userVmDao;
|
|
@Inject DomainRouterDao _routerDao;
|
|
@Inject ConfigurationManager _configMgr;
|
|
@Inject HostPodDao _podDao;
|
|
@Inject AccountManager _accountMgr;
|
|
|
|
private boolean canHandle(GuestIpType ipType, DeployDestination dest, TrafficType trafficType) {
|
|
DataCenter dc = dest.getDataCenter();
|
|
String provider = dc.getGatewayProvider();
|
|
|
|
if (provider != null && provider.equalsIgnoreCase(Provider.JuniperSRX.getName()) && ipType == GuestIpType.Virtual) {
|
|
return true;
|
|
} else if (dest.getPod() != null && dest.getPod().getExternalDhcp()){
|
|
//This pod is using external DHCP server
|
|
return false;
|
|
} else {
|
|
if (dc.getNetworkType() == NetworkType.Basic) {
|
|
return (ipType == GuestIpType.Direct && trafficType == TrafficType.Guest);
|
|
} else {
|
|
return (ipType == GuestIpType.Direct);
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public boolean implement(Network network, NetworkOffering offering, DeployDestination dest, ReservationContext context) throws ResourceUnavailableException, ConcurrentOperationException, InsufficientCapacityException {
|
|
if (!canHandle(network.getGuestType(), dest, offering.getTrafficType())) {
|
|
return false;
|
|
}
|
|
|
|
Map<VirtualMachineProfile.Param, Object> params = new HashMap<VirtualMachineProfile.Param, Object>(1);
|
|
params.put(VirtualMachineProfile.Param.RestartNetwork, true);
|
|
_routerMgr.deployDhcp(network, dest, _accountMgr.getAccount(network.getAccountId()), params);
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean prepare(Network network, NicProfile nic, VirtualMachineProfile<? extends VirtualMachine> vm, DeployDestination dest, ReservationContext context) throws ConcurrentOperationException, InsufficientCapacityException, ResourceUnavailableException {
|
|
if (canHandle(network.getGuestType(), dest, network.getTrafficType())) {
|
|
|
|
if (vm.getType() != VirtualMachine.Type.User) {
|
|
return false;
|
|
}
|
|
|
|
@SuppressWarnings("unchecked")
|
|
VirtualMachineProfile<UserVm> uservm = (VirtualMachineProfile<UserVm>)vm;
|
|
Map<VirtualMachineProfile.Param, Object> params = new HashMap<VirtualMachineProfile.Param, Object>(1);
|
|
params.put(VirtualMachineProfile.Param.RestartNetwork, true);
|
|
|
|
List<DomainRouterVO> routers = _routerMgr.deployDhcp(network, dest, _accountMgr.getAccount(network.getAccountId()), uservm.getParameters());
|
|
List<VirtualRouter> rets = _routerMgr.addVirtualMachineIntoNetwork(network, nic, uservm, dest, context, routers);
|
|
return (rets != null) && (!rets.isEmpty());
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public boolean release(Network network, NicProfile nic, VirtualMachineProfile<? extends VirtualMachine> vm, ReservationContext context) {
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean shutdown(Network network, ReservationContext context) throws ConcurrentOperationException, ResourceUnavailableException {
|
|
List<DomainRouterVO> routers = _routerDao.findByNetwork(network.getId());
|
|
if (routers == null || routers.isEmpty()) {
|
|
return true;
|
|
}
|
|
boolean result = true;
|
|
for (DomainRouterVO router : routers) {
|
|
result = result && _routerMgr.stop(router, false, context.getCaller(), context.getAccount()) != null;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
@Override
|
|
public boolean destroy(Network config) throws ConcurrentOperationException, ResourceUnavailableException{
|
|
List<DomainRouterVO> routers = _routerDao.findByNetwork(config.getId());
|
|
if (routers == null || routers.isEmpty()) {
|
|
return true;
|
|
}
|
|
boolean result = true;
|
|
for (DomainRouterVO router : routers) {
|
|
result = result && _routerMgr.destroyRouter(router.getId());
|
|
}
|
|
return result;
|
|
}
|
|
|
|
@Override
|
|
public boolean applyRules(Network network, List<? extends FirewallRule> rules) throws ResourceUnavailableException {
|
|
return false;
|
|
}
|
|
|
|
@Override
|
|
public boolean applyIps(Network network, List<? extends PublicIpAddress> ipAddress) throws ResourceUnavailableException {
|
|
return false;
|
|
}
|
|
|
|
|
|
@Override
|
|
public Provider getProvider() {
|
|
return Provider.DhcpServer;
|
|
}
|
|
|
|
@Override
|
|
public Map<Service, Map<Capability, String>> getCapabilities() {
|
|
return capabilities;
|
|
}
|
|
|
|
private static Map<Service, Map<Capability, String>> setCapabilities() {
|
|
Map<Service, Map<Capability, String>> capabilities = new HashMap<Service, Map<Capability, String>>();
|
|
|
|
Map<Capability, String> dnsCapabilities = new HashMap<Capability, String>();
|
|
dnsCapabilities.put(Capability.AllowDnsSuffixModification, "true");
|
|
capabilities.put(Service.Dns, dnsCapabilities);
|
|
|
|
capabilities.put(Service.UserData, null);
|
|
capabilities.put(Service.Dhcp, null);
|
|
|
|
return capabilities;
|
|
}
|
|
|
|
@Override
|
|
public boolean restart(Network network, ReservationContext context) throws ConcurrentOperationException, ResourceUnavailableException, InsufficientCapacityException{
|
|
DataCenter dc = _configMgr.getZone(network.getDataCenterId());
|
|
NetworkOffering offering = _configMgr.getNetworkOffering(network.getNetworkOfferingId());
|
|
DeployDestination dest = new DeployDestination(dc, null, null, null);
|
|
List<DomainRouterVO> routers = _routerDao.findByNetwork(network.getId());
|
|
if (routers == null || routers.isEmpty()) {
|
|
s_logger.trace("Can't find dhcp element in network " + network.getId());
|
|
return true;
|
|
}
|
|
|
|
VirtualRouter result = null;
|
|
boolean ret = true;
|
|
for (DomainRouterVO router : routers) {
|
|
if (canHandle(network.getGuestType(), dest, offering.getTrafficType())) {
|
|
if (router.getState() == State.Stopped) {
|
|
result = _routerMgr.startRouter(router.getId(), false);
|
|
} else {
|
|
result = _routerMgr.rebootRouter(router.getId(), false);
|
|
}
|
|
if (result == null) {
|
|
s_logger.warn("Failed to restart dhcp element " + router + " as a part of netowrk " + network + " restart");
|
|
ret = false;
|
|
}
|
|
} else {
|
|
s_logger.trace("Dhcp element doesn't handle network restart for the network " + network);
|
|
}
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
@Override
|
|
public boolean savePassword(Network network, NicProfile nic, VirtualMachineProfile<? extends VirtualMachine> vm) throws ResourceUnavailableException{
|
|
|
|
@SuppressWarnings("unchecked")
|
|
VirtualMachineProfile<UserVm> uservm = (VirtualMachineProfile<UserVm>)vm;
|
|
|
|
return _routerMgr.savePasswordToRouter(network, nic, uservm);
|
|
}
|
|
}
|