openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/LBaaSPoolMemberHandler.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.INeutronLoadBalancerPoolCRUD;
  15 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerPoolMemberAware;
  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
  30 import java.net.HttpURLConnection;
  31
  32 /**
  33  * Handle requests for OpenStack Neutron v2.0 LBaaS API calls for
  34  * /v2.0/pools/{pool_id}/members
  35  */
  36
  37 public class LBaaSPoolMemberHandler extends AbstractHandler
  38         implements INeutronLoadBalancerPoolMemberAware {
  39
  40     private static final Logger logger = LoggerFactory.getLogger(LBaaSPoolMemberHandler.class);
  41
  42     // The implementation for each of these services is resolved by the OSGi Service Manager
  43     private volatile INeutronLoadBalancerPoolCRUD neutronLBPoolCache;
  44     private volatile INeutronLoadBalancerCRUD neutronLBCache;
  45     private volatile INeutronPortCRUD neutronPortsCache;
  46     private volatile LoadBalancerProvider loadBalancerProvider;
  47     private volatile ISwitchManager switchManager;
  48
  49     @Override
  50     public int canCreateNeutronLoadBalancerPoolMember(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
  51         LoadBalancerConfiguration lbConfig = extractLBConfiguration(neutronLBPoolMember);
  52         if (lbConfig == null)
  53             return HttpURLConnection.HTTP_BAD_REQUEST;
  54         else if (!lbConfig.isValid())
  55             return HttpURLConnection.HTTP_NOT_ACCEPTABLE;
  56         else
  57             return HttpURLConnection.HTTP_OK;
  58     }
  59
  60     @Override
  61     public void neutronLoadBalancerPoolMemberCreated(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
  62         logger.debug("Neutron LB Pool Member Creation : {}", neutronLBPoolMember.toString());
  63         enqueueEvent(new NorthboundEvent(neutronLBPoolMember, Action.ADD));
  64     }
  65
  66     /**
  67      * Assuming that the pool information is fully populated before this call is made,
  68      * we go with creating the LoadBalancerConfiguration object for this call with
  69      * all information that is necessary to insert flow_mods
  70      */
  71     private void doNeutronLoadBalancerPoolMemberCreate(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
  72         Preconditions.checkNotNull(loadBalancerProvider);
  73         LoadBalancerConfiguration lbConfig = extractLBConfiguration(neutronLBPoolMember);
  74         if (lbConfig == null) {
  75             logger.trace("Neutron LB configuration invalid for member {} ", neutronLBPoolMember.getPoolMemberAddress());
  76         } else if (lbConfig.getVip() == null) {
  77             logger.trace("Neutron LB VIP not created yet for member {} ", neutronLBPoolMember.getPoolMemberID());
  78         } else if (!lbConfig.isValid()) {
  79             logger.trace("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
  80         } else if (this.switchManager.getNodes().size() == 0) {
  81             logger.trace("Noop with LB pool member {} creation because no nodes available.", neutronLBPoolMember.getPoolMemberID());
  82         } else {
  83             for (Node node: this.switchManager.getNodes())
  84                 loadBalancerProvider.programLoadBalancerPoolMemberRules(node, lbConfig,
  85                         lbConfig.getMembers().get(neutronLBPoolMember.getPoolMemberID()), Action.ADD);
  86         }
  87     }
  88
  89     @Override
  90     public int canUpdateNeutronLoadBalancerPoolMember(NeutronLoadBalancerPoolMember delta, NeutronLoadBalancerPoolMember original) {
  91         LoadBalancerConfiguration lbConfig = extractLBConfiguration(delta);
  92         if (lbConfig == null)
  93             return HttpURLConnection.HTTP_BAD_REQUEST;
  94         else if (!lbConfig.isValid())
  95             return HttpURLConnection.HTTP_NOT_ACCEPTABLE;
  96         else
  97             return HttpURLConnection.HTTP_OK;
  98     }
  99
 100     @Override
 101     public void neutronLoadBalancerPoolMemberUpdated(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
 102         logger.debug("Neutron LB Pool Member Update : {}", neutronLBPoolMember.toString());
 103         enqueueEvent(new NorthboundEvent(neutronLBPoolMember, Action.UPDATE));
 104     }
 105
 106     @Override
 107     public int canDeleteNeutronLoadBalancerPoolMember(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
 108         LoadBalancerConfiguration lbConfig = extractLBConfiguration(neutronLBPoolMember);
 109         if (lbConfig == null)
 110             return HttpURLConnection.HTTP_BAD_REQUEST;
 111         else if (!lbConfig.isValid())
 112             return HttpURLConnection.HTTP_NOT_ACCEPTABLE;
 113         else
 114             return HttpURLConnection.HTTP_OK;
 115     }
 116
 117     @Override
 118     public void neutronLoadBalancerPoolMemberDeleted(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
 119         logger.debug("Neutron LB Pool Member Deletion : {}", neutronLBPoolMember.toString());
 120         enqueueEvent(new NorthboundEvent(neutronLBPoolMember, Action.DELETE));
 121     }
 122
 123     /**
 124      * Process the event.
 125      *
 126      * @param abstractEvent the {@link org.opendaylight.ovsdb.openstack.netvirt.AbstractEvent} event to be handled.
 127      * @see org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher
 128      */
 129     @Override
 130     public void processEvent(AbstractEvent abstractEvent) {
 131         if (!(abstractEvent instanceof NorthboundEvent)) {
 132             logger.error("Unable to process abstract event " + abstractEvent);
 133             return;
 134         }
 135         NorthboundEvent ev = (NorthboundEvent) abstractEvent;
 136         switch (ev.getAction()) {
 137             case ADD:
 138                 doNeutronLoadBalancerPoolMemberCreate(ev.getLoadBalancerPoolMember());
 139                 break;
 140             case DELETE:
 141                 /* As of now, deleting a member involves recomputing member indices.
 142                  * This is best done through a complete update of the load balancer instance.
 143                  */
 144                 for (NeutronLoadBalancer neutronLB: neutronLBCache.getAllNeutronLoadBalancers()) {
 145                     String loadBalancerSubnetID = neutronLB.getLoadBalancerVipSubnetID();
 146                     if (ev.getLoadBalancerPoolMember()
 147                                          .getPoolMemberSubnetID().equals(loadBalancerSubnetID)) {
 148                         enqueueEvent(new NorthboundEvent(neutronLB, Action.UPDATE));
 149                         break;
 150                     }
 151                 }
 152                 break;
 153             case UPDATE:
 154                 /**
 155                  * Typical upgrade involves changing weights. Since weights are not
 156                  * supported yet, updates are not supported either.
 157                  */
 158                 logger.warn("Load balancer pool member update is not supported");
 159                 break;
 160             default:
 161                 logger.warn("Unable to process event action " + ev.getAction());
 162                 break;
 163         }
 164     }
 165
 166     /**
 167      * Useful utility for extracting the loadbalancer instance
 168      * configuration from the neutron LB cache based on member info
 169      */
 170     public LoadBalancerConfiguration extractLBConfiguration(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
 171         String memberID = neutronLBPoolMember.getPoolMemberID();
 172         String memberIP = neutronLBPoolMember.getPoolMemberAddress();
 173         String memberMAC = NeutronCacheUtils.getMacAddress(neutronPortsCache, memberIP);
 174         if (memberMAC == null) {
 175             logger.trace("Neutron LB pool member {} MAC address unavailable", memberID);
 176             return null;
 177         }
 178         String memberSubnetID = neutronLBPoolMember.getPoolMemberSubnetID();
 179         Integer memberPort = neutronLBPoolMember.getPoolMemberProtoPort();
 180         String memberPoolID = neutronLBPoolMember.getPoolID();
 181         String memberProtocol = null;
 182
 183         if (memberSubnetID == null || memberID == null || memberPoolID == null) {
 184             logger.trace("Neutron LB pool member details incomplete [id={}, pool_id={},subnet_id={}",
 185                     memberID, memberPoolID, memberSubnetID);
 186             return null;
 187         }
 188         NeutronLoadBalancerPool neutronLBPool = neutronLBPoolCache.getNeutronLoadBalancerPool(memberPoolID);
 189         memberProtocol = neutronLBPool.getLoadBalancerPoolProtocol();
 190         if (!(memberProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTP) ||
 191                 memberProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTPS)))
 192             return null;
 193
 194         String loadBalancerSubnetID, loadBalancerVip=null, loadBalancerName=null;
 195         for (NeutronLoadBalancer neutronLB: neutronLBCache.getAllNeutronLoadBalancers()) {
 196             loadBalancerSubnetID = neutronLB.getLoadBalancerVipSubnetID();
 197             if (memberSubnetID.equals(loadBalancerSubnetID)) {
 198                 loadBalancerName = neutronLB.getLoadBalancerName();
 199                 loadBalancerVip = neutronLB.getLoadBalancerVipAddress();
 200                 break;
 201             }
 202         }
 203         /**
 204          * It is possible that the VIP has not been created yet.
 205          * In that case, we create dummy configuration that will not program rules.
 206          */
 207         LoadBalancerConfiguration lbConfig = new LoadBalancerConfiguration(loadBalancerName, loadBalancerVip);
 208         lbConfig.addMember(memberID, memberIP, memberMAC, memberProtocol, memberPort);
 209         return lbConfig;
 210     }
 211 }