| /** |
| * 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.router.VirtualRouter.Role; |
| import com.cloud.network.rules.FirewallRule; |
| import com.cloud.network.rules.StaticNat; |
| 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()); |
| |
| //for Basic zone, add all Running routers - we have to send Dhcp/vmData/password info to them when network.dns.basiczone.updates is set to "all" |
| Long podId = dest.getPod().getId(); |
| DataCenter dc = dest.getDataCenter(); |
| boolean isPodBased = (dc.getNetworkType() == NetworkType.Basic || network.isSecurityGroupEnabled()) && network.getTrafficType() == TrafficType.Guest; |
| if (isPodBased && _routerMgr.getDnsBasicZoneUpdate().equalsIgnoreCase("all")) { |
| List<DomainRouterVO> allRunningRoutersOutsideThePod = _routerDao.findByNetworkOutsideThePod(network.getId(), podId, State.Running, Role.DHCP_USERDATA); |
| routers.addAll(allRunningRoutersOutsideThePod); |
| } |
| |
| 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.listByNetworkAndRole(network.getId(), Role.DHCP_USERDATA); |
| 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.listByNetworkAndRole(config.getId(), Role.DHCP_USERDATA); |
| if (routers == null || routers.isEmpty()) { |
| return true; |
| } |
| boolean result = true; |
| for (DomainRouterVO router : routers) { |
| result = result && (_routerMgr.destroyRouter(router.getId()) != null); |
| } |
| 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, boolean cleanup) throws ConcurrentOperationException, ResourceUnavailableException, InsufficientCapacityException{ |
| DataCenter dc = _configMgr.getZone(network.getDataCenterId()); |
| DeployDestination dest = new DeployDestination(dc, null, null, null); |
| NetworkOffering offering = _configMgr.getNetworkOffering(network.getNetworkOfferingId()); |
| |
| if (!canHandle(network.getGuestType(), dest, offering.getTrafficType())) { |
| s_logger.trace("Dhcp element doesn't handle network restart for the network " + network); |
| return false; |
| } |
| |
| List<DomainRouterVO> routers = _routerDao.listByNetworkAndRole(network.getId(), Role.DHCP_USERDATA); |
| 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 (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; |
| } |
| |
| } |
| return ret; |
| } |
| |
| @Override |
| public boolean savePassword(Network network, NicProfile nic, VirtualMachineProfile<? extends VirtualMachine> vm) throws ResourceUnavailableException{ |
| |
| List<DomainRouterVO> routers = _routerDao.listByNetworkAndRole(network.getId(), Role.DHCP_USERDATA); |
| if (routers == null || routers.isEmpty()) { |
| s_logger.trace("Can't find dhcp element in network " + network.getId()); |
| return true; |
| } |
| |
| @SuppressWarnings("unchecked") |
| VirtualMachineProfile<UserVm> uservm = (VirtualMachineProfile<UserVm>)vm; |
| |
| return _routerMgr.savePasswordToRouter(network, nic, uservm, routers); |
| } |
| |
| @Override |
| public boolean applyStaticNats(Network config, List<? extends StaticNat> rules) throws ResourceUnavailableException { |
| return false; |
| } |
| } |
