openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/LBaaSPoolHandler.java

   1 /*
   2  * Copyright (C) 2014 SDN Hub, LLC.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  *
   8  * Authors : Srini Seetharaman
   9  */
  10
  11 package org.opendaylight.ovsdb.openstack.netvirt;
  12
  13 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerCRUD;
  14 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerPoolAware;
  15 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerPoolCRUD;
  16 import org.opendaylight.controller.networkconfig.neutron.INeutronPortCRUD;
  17 import org.opendaylight.controller.networkconfig.neutron.NeutronLoadBalancer;
  18 import org.opendaylight.controller.networkconfig.neutron.NeutronLoadBalancerPool;
  19 import org.opendaylight.controller.networkconfig.neutron.NeutronLoadBalancerPoolMember;
  20 import org.opendaylight.controller.sal.core.Node;
  21 import org.opendaylight.controller.switchmanager.ISwitchManager;
  22 import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
  23 import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerConfiguration;
  24 import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerProvider;
  25 import org.slf4j.Logger;
  26 import org.slf4j.LoggerFactory;
  27
  28 import com.google.common.base.Preconditions;
  29 import com.google.common.collect.Lists;
  30
  31 import java.net.HttpURLConnection;
  32 import java.util.List;
  33
  34 /**
  35  * Handle requests for OpenStack Neutron v2.0 LBaaS API calls for
  36  * /v2.0/pools . It is possible that each pool spans multiple subnets.
  37  * In that case, the user should be creating a separate VIP for each subnet.
  38  */
  39
  40 public class LBaaSPoolHandler extends AbstractHandler
  41         implements INeutronLoadBalancerPoolAware {
  42
  43     private static final Logger logger = LoggerFactory.getLogger(LBaaSPoolHandler.class);
  44
  45     // The implementation for each of these services is resolved by the OSGi Service Manager
  46     private volatile INeutronLoadBalancerPoolCRUD neutronLBPoolCache;
  47     private volatile INeutronLoadBalancerCRUD neutronLBCache;
  48     private volatile INeutronPortCRUD neutronPortsCache;
  49     private volatile LoadBalancerProvider loadBalancerProvider;
  50     private volatile ISwitchManager switchManager;
  51
  52     @Override
  53     public int canCreateNeutronLoadBalancerPool(NeutronLoadBalancerPool neutronLBPool) {
  54         String poolProtocol = neutronLBPool.getLoadBalancerPoolProtocol();
  55         if (poolProtocol == null)
  56             return HttpURLConnection.HTTP_BAD_REQUEST;
  57         else if (!(poolProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTP) ||
  58                 poolProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTPS)))
  59             return HttpURLConnection.HTTP_NOT_ACCEPTABLE;
  60         else
  61             return HttpURLConnection.HTTP_OK;
  62     }
  63
  64     @Override
  65     public void neutronLoadBalancerPoolCreated(NeutronLoadBalancerPool neutronLBPool) {
  66         logger.debug("Neutron LB Pool Creation : {}", neutronLBPool.toString());
  67         enqueueEvent(new NorthboundEvent(neutronLBPool, Action.ADD));
  68     }
  69
  70     /**
  71      * Assuming that the pool information is fully populated before this call is made,
  72      * we go with creating the LoadBalancerConfiguration object for this call with
  73      * all information that is necessary to insert flow_mods
  74      */
  75     private void doNeutronLoadBalancerPoolCreate(NeutronLoadBalancerPool neutronLBPool) {
  76         Preconditions.checkNotNull(loadBalancerProvider);
  77         List<LoadBalancerConfiguration> lbConfigList = extractLBConfiguration(neutronLBPool);
  78         if (lbConfigList == null) {
  79             logger.debug("Neutron LB configuration invalid for pool {} ", neutronLBPool.getLoadBalancerPoolID());
  80         } else if (lbConfigList.size() == 0) {
  81             logger.debug("No Neutron LB VIP not created yet for pool {} ", neutronLBPool.getLoadBalancerPoolID());
  82         } else if (this.switchManager.getNodes().size() == 0) {
  83             logger.debug("Noop with LB pool {} creation because no nodes available.", neutronLBPool.getLoadBalancerPoolID());
  84         } else {
  85             for (LoadBalancerConfiguration lbConfig: lbConfigList) {
  86                 if (!lbConfig.isValid()) {
  87                     logger.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
  88                     continue;
  89                 } else {
  90                     for (Node node: this.switchManager.getNodes())
  91                         loadBalancerProvider.programLoadBalancerRules(node, lbConfig, Action.ADD);
  92                 }
  93             }
  94         }
  95     }
  96
  97     @Override
  98     public int canUpdateNeutronLoadBalancerPool(NeutronLoadBalancerPool delta, NeutronLoadBalancerPool original) {
  99         return HttpURLConnection.HTTP_NOT_IMPLEMENTED;
 100     }
 101
 102     @Override
 103     public void neutronLoadBalancerPoolUpdated(NeutronLoadBalancerPool neutronLBPool) {
 104         logger.debug("Neutron LB Pool Update : {}", neutronLBPool.toString());
 105         enqueueEvent(new NorthboundEvent(neutronLBPool, Action.UPDATE));
 106     }
 107
 108     @Override
 109     public int canDeleteNeutronLoadBalancerPool(NeutronLoadBalancerPool neutronLBPool) {
 110         String poolProtocol = neutronLBPool.getLoadBalancerPoolProtocol();
 111         if (poolProtocol == null)
 112             return HttpURLConnection.HTTP_BAD_REQUEST;
 113         else if (!(poolProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTP) ||
 114                 poolProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTPS)))
 115             return HttpURLConnection.HTTP_NOT_ACCEPTABLE;
 116         else
 117             return HttpURLConnection.HTTP_OK;
 118     }
 119
 120     @Override
 121     public void neutronLoadBalancerPoolDeleted(NeutronLoadBalancerPool neutronLBPool) {
 122         logger.debug("Neutron LB Pool Deletion : {}", neutronLBPool.toString());
 123         enqueueEvent(new NorthboundEvent(neutronLBPool, Action.DELETE));
 124     }
 125
 126     private void doNeutronLoadBalancerPoolDelete(NeutronLoadBalancerPool neutronLBPool) {
 127         Preconditions.checkNotNull(loadBalancerProvider);
 128
 129         List<LoadBalancerConfiguration> lbConfigList = extractLBConfiguration(neutronLBPool);
 130         if (lbConfigList == null) {
 131             logger.debug("Neutron LB configuration invalid for pool {} ", neutronLBPool.getLoadBalancerPoolID());
 132         } else if (lbConfigList.size() == 0) {
 133             logger.debug("No Neutron LB VIP not created yet for pool {} ", neutronLBPool.getLoadBalancerPoolID());
 134         } else if (this.switchManager.getNodes().size() == 0) {
 135             logger.debug("Noop with LB pool {} deletion because no nodes available.", neutronLBPool.getLoadBalancerPoolID());
 136         } else {
 137             for (LoadBalancerConfiguration lbConfig: lbConfigList) {
 138                 if (!lbConfig.isValid()) {
 139                     logger.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
 140                     continue;
 141                 } else {
 142                     for (Node node: this.switchManager.getNodes())
 143                         loadBalancerProvider.programLoadBalancerRules(node, lbConfig, Action.DELETE);
 144                 }
 145             }
 146         }
 147     }
 148
 149     /**
 150      * Process the event.
 151      *
 152      * @param abstractEvent the {@link org.opendaylight.ovsdb.openstack.netvirt.AbstractEvent} event to be handled.
 153      * @see org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher
 154      */
 155     @Override
 156     public void processEvent(AbstractEvent abstractEvent) {
 157         logger.debug("Processing Loadbalancer Pool event " + abstractEvent);
 158         if (!(abstractEvent instanceof NorthboundEvent)) {
 159             logger.error("Unable to process abstract event " + abstractEvent);
 160             return;
 161         }
 162         NorthboundEvent ev = (NorthboundEvent) abstractEvent;
 163         switch (ev.getAction()) {
 164             case ADD:
 165                 doNeutronLoadBalancerPoolCreate(ev.getLoadBalancerPool());
 166                 break;
 167             case DELETE:
 168                 doNeutronLoadBalancerPoolDelete(ev.getLoadBalancerPool());
 169                 break;
 170             case UPDATE:
 171                 /**
 172                  * Typical upgrade involves changing algorithm. Right now
 173                  * we do not support this flexibility. TODO
 174                  */
 175                 logger.warn("Load balancer pool update is not supported");
 176                 break;
 177             default:
 178                 logger.warn("Unable to process event action " + ev.getAction());
 179                 break;
 180         }
 181     }
 182
 183     /**
 184      * Useful utility for extracting the loadbalancer instance. With
 185      * each LB pool, we allow multiple VIP and LB to be instantiated.
 186      */
 187     public List<LoadBalancerConfiguration> extractLBConfiguration(NeutronLoadBalancerPool neutronLBPool) {
 188         String poolProtocol = neutronLBPool.getLoadBalancerPoolProtocol();
 189         if (poolProtocol == null)
 190             return null;
 191         if (!(poolProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTP) ||
 192                 poolProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTPS)))
 193             return null;
 194
 195         List<NeutronLoadBalancerPoolMember> poolMembers = neutronLBPool.getLoadBalancerPoolMembers();
 196         if (poolMembers.size() == 0) {
 197             logger.debug("Neutron LB pool is empty: {}", neutronLBPool);
 198             return null;
 199         }
 200
 201         List<LoadBalancerConfiguration> lbConfigList = Lists.newLinkedList();
 202
 203         /* Iterate over all the Loadbalancers created so far and identify VIP
 204          */
 205         String loadBalancerSubnetID, loadBalancerVip=null, loadBalancerName=null;
 206         for (NeutronLoadBalancer neutronLB: neutronLBCache.getAllNeutronLoadBalancers()) {
 207             loadBalancerSubnetID = neutronLB.getLoadBalancerVipSubnetID();
 208             loadBalancerName = neutronLB.getLoadBalancerName();
 209             loadBalancerVip = neutronLB.getLoadBalancerVipAddress();
 210             LoadBalancerConfiguration lbConfig = new LoadBalancerConfiguration(loadBalancerName, loadBalancerVip);
 211
 212             /* Iterate over all the members in this pool and find those in same
 213              * subnet as the VIP. Those will be included in the lbConfigList
 214              */
 215             String memberSubnetID, memberIP, memberID, memberMAC;
 216             Integer memberPort;
 217             Boolean memberAdminStateIsUp;
 218             for (NeutronLoadBalancerPoolMember neutronLBPoolMember: neutronLBPool.getLoadBalancerPoolMembers()) {
 219                 memberAdminStateIsUp = neutronLBPoolMember.getPoolMemberAdminStateIsUp();
 220                 memberSubnetID = neutronLBPoolMember.getPoolMemberSubnetID();
 221                 if (memberSubnetID == null || memberAdminStateIsUp == null)
 222                     continue;
 223                 else if (memberSubnetID.equals(loadBalancerSubnetID) && memberAdminStateIsUp.booleanValue()) {
 224                     memberID = neutronLBPoolMember.getPoolMemberID();
 225                     memberIP = neutronLBPoolMember.getPoolMemberAddress();
 226                     memberPort = neutronLBPoolMember.getPoolMemberProtoPort();
 227                     if (memberSubnetID == null || memberID == null || memberIP == null || memberPort == null) {
 228                         logger.debug("Neutron LB pool member details incomplete: {}", neutronLBPoolMember);
 229                         continue;
 230                     }
 231                     memberMAC = NeutronCacheUtils.getMacAddress(neutronPortsCache, memberIP);
 232                     if (memberMAC == null)
 233                         continue;
 234                     lbConfig.addMember(memberID, memberIP, memberMAC, poolProtocol, memberPort);
 235                 }
 236             }
 237
 238             if (lbConfig.getMembers().size() > 0)
 239                 lbConfigList.add(lbConfig);
 240         }
 241
 242         return lbConfigList;
 243     }
 244 }