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.neutron.spi.INeutronLoadBalancerCRUD;
  14 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
  15 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolMemberAware;
  16 import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
  17 import org.opendaylight.neutron.spi.INeutronPortCRUD;
  18 import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
  19 import org.opendaylight.neutron.spi.NeutronLoadBalancer;
  20 import org.opendaylight.neutron.spi.NeutronLoadBalancerPool;
  21 import org.opendaylight.neutron.spi.NeutronLoadBalancerPoolMember;
  22 import org.opendaylight.controller.sal.core.Node;
  23 import org.opendaylight.controller.switchmanager.ISwitchManager;
  24 import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
  25 import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerConfiguration;
  26 import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerProvider;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 import com.google.common.base.Preconditions;
  31
  32 import java.net.HttpURLConnection;
  33 import java.util.Map;
  34
  35 /**
  36  * Handle requests for OpenStack Neutron v2.0 LBaaS API calls for
  37  * /v2.0/pools/{pool_id}/members
  38  */
  39
  40 public class LBaaSPoolMemberHandler extends AbstractHandler
  41         implements INeutronLoadBalancerPoolMemberAware {
  42
  43     private static final Logger logger = LoggerFactory.getLogger(LBaaSPoolMemberHandler.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 INeutronNetworkCRUD neutronNetworkCache;
  50     private volatile INeutronSubnetCRUD neutronSubnetCache;
  51     private volatile LoadBalancerProvider loadBalancerProvider;
  52     private volatile ISwitchManager switchManager;
  53
  54     @Override
  55     public int canCreateNeutronLoadBalancerPoolMember(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
  56         LoadBalancerConfiguration lbConfig = extractLBConfiguration(neutronLBPoolMember);
  57         if (lbConfig == null)
  58             return HttpURLConnection.HTTP_BAD_REQUEST;
  59         else if (!lbConfig.isValid())
  60             return HttpURLConnection.HTTP_NOT_ACCEPTABLE;
  61         else
  62             return HttpURLConnection.HTTP_OK;
  63     }
  64
  65     @Override
  66     public void neutronLoadBalancerPoolMemberCreated(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
  67         logger.debug("Neutron LB Pool Member Creation : {}", neutronLBPoolMember.toString());
  68         enqueueEvent(new NorthboundEvent(neutronLBPoolMember, Action.ADD));
  69     }
  70
  71     /**
  72      * Assuming that the pool information is fully populated before this call is made,
  73      * we go with creating the LoadBalancerConfiguration object for this call with
  74      * all information that is necessary to insert flow_mods
  75      */
  76     private void doNeutronLoadBalancerPoolMemberCreate(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
  77         Preconditions.checkNotNull(loadBalancerProvider);
  78         LoadBalancerConfiguration lbConfig = extractLBConfiguration(neutronLBPoolMember);
  79         if (lbConfig == null) {
  80             logger.debug("Neutron LB configuration invalid for member {} ", neutronLBPoolMember.getPoolMemberAddress());
  81         } else if (lbConfig.getVip() == null) {
  82             logger.debug("Neutron LB VIP not created yet for member {} ", neutronLBPoolMember.getPoolMemberID());
  83         } else if (!lbConfig.isValid()) {
  84             logger.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
  85         } else if (this.switchManager.getNodes().size() == 0) {
  86             logger.debug("Noop with LB pool member {} creation because no nodes available.", neutronLBPoolMember.getPoolMemberID());
  87         } else {
  88             for (Node node: this.switchManager.getNodes())
  89                 loadBalancerProvider.programLoadBalancerPoolMemberRules(node,
  90                         lbConfig,
  91                         lbConfig.getMembers().get(neutronLBPoolMember.getPoolMemberID()), Action.ADD);
  92         }
  93     }
  94
  95     @Override
  96     public int canUpdateNeutronLoadBalancerPoolMember(NeutronLoadBalancerPoolMember delta, NeutronLoadBalancerPoolMember original) {
  97         return HttpURLConnection.HTTP_NOT_IMPLEMENTED;
  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     private void doNeutronLoadBalancerPoolMemberDelete(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
 124         Preconditions.checkNotNull(loadBalancerProvider);
 125
 126         LoadBalancerConfiguration lbConfig = extractLBConfiguration(neutronLBPoolMember);
 127         if (lbConfig == null) {
 128             logger.debug("Neutron LB configuration invalid for member {} ", neutronLBPoolMember.getPoolMemberAddress());
 129         } else if (lbConfig.getVip() == null) {
 130             logger.debug("Neutron LB VIP not created yet for member {} ", neutronLBPoolMember.getPoolMemberID());
 131         } else if (!lbConfig.isValid()) {
 132             logger.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
 133         } else if (this.switchManager.getNodes().size() == 0) {
 134             logger.debug("Noop with LB pool member {} deletion because no nodes available.", neutronLBPoolMember.getPoolMemberID());
 135         } else {
 136             /* As of now, deleting a member involves recomputing member indices.
 137              * This is best done through a complete update of the load balancer instance.
 138              */
 139             LoadBalancerConfiguration newLBConfig = new LoadBalancerConfiguration(lbConfig);
 140             newLBConfig.removeMember(neutronLBPoolMember.getPoolMemberID());
 141
 142             for (Node node: this.switchManager.getNodes()) {
 143                 loadBalancerProvider.programLoadBalancerRules(node, lbConfig, Action.DELETE);
 144                 loadBalancerProvider.programLoadBalancerRules(node, newLBConfig, Action.ADD);
 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 member 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                 doNeutronLoadBalancerPoolMemberCreate(ev.getLoadBalancerPoolMember());
 166                 break;
 167             case DELETE:
 168                 doNeutronLoadBalancerPoolMemberDelete(ev.getLoadBalancerPoolMember());
 169                 break;
 170             case UPDATE:
 171                 /**
 172                  * Typical upgrade involves changing weights. Since weights are not
 173                  * supported yet, updates are not supported either. TODO
 174                  */
 175                 logger.warn("Load balancer pool member 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
 185      * configuration from the neutron LB cache based on member info
 186      */
 187     public LoadBalancerConfiguration extractLBConfiguration(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
 188         String memberID = neutronLBPoolMember.getPoolMemberID();
 189         String memberIP = neutronLBPoolMember.getPoolMemberAddress();
 190         String memberSubnetID = neutronLBPoolMember.getPoolMemberSubnetID();
 191         Integer memberPort = neutronLBPoolMember.getPoolMemberProtoPort();
 192         String memberPoolID = neutronLBPoolMember.getPoolID();
 193         String memberProtocol = null;
 194
 195         if (memberSubnetID == null || memberID == null || memberPoolID == null) {
 196             logger.debug("Neutron LB pool member details incomplete [id={}, pool_id={},subnet_id={}",
 197                     memberID, memberPoolID, memberSubnetID);
 198             return null;
 199         }
 200         String memberMAC = NeutronCacheUtils.getMacAddress(neutronPortsCache, memberSubnetID, memberIP);
 201         if (memberMAC == null) {
 202             logger.debug("Neutron LB pool member {} MAC address unavailable", memberID);
 203             return null;
 204         }
 205         NeutronLoadBalancerPool neutronLBPool = neutronLBPoolCache.getNeutronLoadBalancerPool(memberPoolID);
 206         memberProtocol = neutronLBPool.getLoadBalancerPoolProtocol();
 207         if (!(memberProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_TCP) ||
 208                 memberProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTP) ||
 209                 memberProtocol.equalsIgnoreCase(LoadBalancerConfiguration.PROTOCOL_HTTPS)))
 210             return null;
 211
 212         String loadBalancerSubnetID=null, loadBalancerVip=null, loadBalancerName=null;
 213         for (NeutronLoadBalancer neutronLB: neutronLBCache.getAllNeutronLoadBalancers()) {
 214             loadBalancerSubnetID = neutronLB.getLoadBalancerVipSubnetID();
 215             if (memberSubnetID.equals(loadBalancerSubnetID)) {
 216                 loadBalancerName = neutronLB.getLoadBalancerName();
 217                 loadBalancerVip = neutronLB.getLoadBalancerVipAddress();
 218                 break;
 219             }
 220         }
 221
 222         /**
 223          * It is possible that the VIP has not been created yet.
 224          * In that case, we create dummy configuration that will not program rules.
 225          */
 226         LoadBalancerConfiguration lbConfig = new LoadBalancerConfiguration(loadBalancerName, loadBalancerVip);
 227         Map.Entry<String,String> providerInfo = NeutronCacheUtils.getProviderInformation(neutronNetworkCache, neutronSubnetCache, memberSubnetID);
 228         if (providerInfo != null) {
 229             lbConfig.setProviderNetworkType(providerInfo.getKey());
 230             lbConfig.setProviderSegmentationId(providerInfo.getValue());
 231         }
 232         lbConfig.setVmac(NeutronCacheUtils.getMacAddress(neutronPortsCache, loadBalancerSubnetID, loadBalancerVip));
 233
 234         /* Extract all other active members and include in LB config
 235          */
 236         String otherMemberID, otherMemberSubnetID, otherMemberIP, otherMemberMAC, otherMemberProtocol;
 237         Boolean otherMemberAdminStateIsUp;
 238         Integer otherMemberPort;
 239
 240         for (NeutronLoadBalancerPoolMember otherMember: neutronLBPool.getLoadBalancerPoolMembers()) {
 241             otherMemberID = otherMember.getPoolMemberID();
 242             if (otherMemberID.equals(memberID))
 243                 continue; //skip
 244
 245             otherMemberIP = otherMember.getPoolMemberAddress();
 246             otherMemberAdminStateIsUp = otherMember.getPoolMemberAdminStateIsUp();
 247             otherMemberSubnetID = otherMember.getPoolMemberSubnetID();
 248             otherMemberPort = otherMember.getPoolMemberProtoPort();
 249             otherMemberProtocol = memberProtocol;
 250
 251             if (otherMemberIP == null || otherMemberSubnetID == null || otherMemberAdminStateIsUp == null)
 252                 continue;
 253             else if (otherMemberAdminStateIsUp.booleanValue()) {
 254                 otherMemberMAC = NeutronCacheUtils.getMacAddress(neutronPortsCache, otherMemberSubnetID, otherMemberIP);
 255                 if (otherMemberMAC == null)
 256                     continue;
 257                 lbConfig.addMember(otherMemberID, otherMemberIP, otherMemberMAC, otherMemberProtocol, otherMemberPort);
 258             }
 259         }
 260
 261         lbConfig.addMember(memberID, memberIP, memberMAC, memberProtocol, memberPort);
 262         return lbConfig;
 263     }
 264 }