opendaylight/networkconfiguration/neutron/implementation/src/main/java/org/opendaylight/controller/networkconfig/neutron/implementation/NeutronLoadBalancerListenerInterface.java

   1 /*
   2  * Copyright (C) 2014 Red Hat, Inc.
   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
   9 package org.opendaylight.controller.networkconfig.neutron.implementation;
  10
  11 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerListenerCRUD;
  12 import org.opendaylight.controller.networkconfig.neutron.NeutronLoadBalancerListener;
  13 import org.slf4j.Logger;
  14 import org.slf4j.LoggerFactory;
  15
  16 import java.lang.reflect.Method;
  17 import java.util.ArrayList;
  18 import java.util.HashSet;
  19 import java.util.List;
  20 import java.util.Map.Entry;
  21 import java.util.Set;
  22 import java.util.concurrent.ConcurrentHashMap;
  23 import java.util.concurrent.ConcurrentMap;
  24
  25 public class NeutronLoadBalancerListenerInterface implements INeutronLoadBalancerListenerCRUD {
  26     private static final Logger logger = LoggerFactory.getLogger(NeutronLoadBalancerListenerInterface.class);
  27     private ConcurrentMap<String, NeutronLoadBalancerListener> loadBalancerListenerDB  = new ConcurrentHashMap<String, NeutronLoadBalancerListener>();
  28
  29
  30
  31     // this method uses reflection to update an object from it's delta.
  32
  33     private boolean overwrite(Object target, Object delta) {
  34         Method[] methods = target.getClass().getMethods();
  35
  36         for (Method toMethod : methods) {
  37             if (toMethod.getDeclaringClass().equals(target.getClass())
  38                     && toMethod.getName().startsWith("set")) {
  39
  40                 String toName = toMethod.getName();
  41                 String fromName = toName.replace("set", "get");
  42
  43                 try {
  44                     Method fromMethod = delta.getClass().getMethod(fromName);
  45                     Object value = fromMethod.invoke(delta, (Object[]) null);
  46                     if (value != null) {
  47                         toMethod.invoke(target, value);
  48                     }
  49                 } catch (Exception e) {
  50                     e.printStackTrace();
  51                     return false;
  52                 }
  53             }
  54         }
  55         return true;
  56     }
  57
  58     @Override
  59     public boolean neutronLoadBalancerListenerExists(String uuid) {
  60         return loadBalancerListenerDB.containsKey(uuid);
  61     }
  62
  63     @Override
  64     public NeutronLoadBalancerListener getNeutronLoadBalancerListener(String uuid) {
  65         if (!neutronLoadBalancerListenerExists(uuid)) {
  66             logger.debug("No LoadBalancerListener Have Been Defined");
  67             return null;
  68         }
  69         return loadBalancerListenerDB.get(uuid);
  70     }
  71
  72     @Override
  73     public List<NeutronLoadBalancerListener> getAllNeutronLoadBalancerListeners() {
  74         Set<NeutronLoadBalancerListener> allLoadBalancerListeners = new HashSet<NeutronLoadBalancerListener>();
  75         for (Entry<String, NeutronLoadBalancerListener> entry : loadBalancerListenerDB.entrySet()) {
  76             NeutronLoadBalancerListener loadBalancerListener = entry.getValue();
  77             allLoadBalancerListeners.add(loadBalancerListener);
  78         }
  79         logger.debug("Exiting getLoadBalancerListeners, Found {} OpenStackLoadBalancerListener", allLoadBalancerListeners.size());
  80         List<NeutronLoadBalancerListener> ans = new ArrayList<NeutronLoadBalancerListener>();
  81         ans.addAll(allLoadBalancerListeners);
  82         return ans;
  83     }
  84
  85     @Override
  86     public boolean addNeutronLoadBalancerListener(NeutronLoadBalancerListener input) {
  87         if (neutronLoadBalancerListenerExists(input.getLoadBalancerListenerID())) {
  88             return false;
  89         }
  90         loadBalancerListenerDB.putIfAbsent(input.getLoadBalancerListenerID(), input);
  91         //TODO: add code to find INeutronLoadBalancerListenerAware services and call newtorkCreated on them
  92         return true;
  93     }
  94
  95     @Override
  96     public boolean removeNeutronLoadBalancerListener(String uuid) {
  97         if (!neutronLoadBalancerListenerExists(uuid)) {
  98             return false;
  99         }
 100         loadBalancerListenerDB.remove(uuid);
 101         //TODO: add code to find INeutronLoadBalancerListenerAware services and call newtorkDeleted on them
 102         return true;
 103     }
 104
 105     @Override
 106     public boolean updateNeutronLoadBalancerListener(String uuid, NeutronLoadBalancerListener delta) {
 107         if (!neutronLoadBalancerListenerExists(uuid)) {
 108             return false;
 109         }
 110         NeutronLoadBalancerListener target = loadBalancerListenerDB.get(uuid);
 111         return overwrite(target, delta);
 112     }
 113
 114     @Override
 115     public boolean neutronLoadBalancerListenerInUse(String loadBalancerListenerUUID) {
 116         return !neutronLoadBalancerListenerExists(loadBalancerListenerUUID);
 117     }
 118 }