natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/SnatServiceManagerImpl.java

   1 /*
   2  * Copyright (c) 2017 Red Hat, Inc. and others. All rights reserved.
   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 package org.opendaylight.netvirt.natservice.internal;
   9
  10 import java.math.BigInteger;
  11 import java.util.List;
  12 import java.util.concurrent.CopyOnWriteArrayList;
  13 import java.util.concurrent.ExecutionException;
  14 import javax.inject.Inject;
  15 import javax.inject.Singleton;
  16 import org.opendaylight.genius.infra.Datastore;
  17 import org.opendaylight.genius.infra.TypedReadWriteTransaction;
  18 import org.opendaylight.netvirt.natservice.api.SnatServiceListener;
  19 import org.opendaylight.netvirt.natservice.api.SnatServiceManager;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.ext.routers.Routers;
  21 import org.slf4j.Logger;
  22 import org.slf4j.LoggerFactory;
  23
  24 @Singleton
  25 public class SnatServiceManagerImpl implements SnatServiceManager {
  26
  27     private static final Logger LOG = LoggerFactory.getLogger(SnatServiceManagerImpl.class);
  28
  29     private final List<SnatServiceListener> snatServiceListeners = new CopyOnWriteArrayList<>();
  30
  31     @Inject
  32     public SnatServiceManagerImpl(final SnatServiceImplFactory factory) {
  33         AbstractSnatService flatVlaSnatServiceImpl = factory.createFlatVlanSnatServiceImpl();
  34         if (flatVlaSnatServiceImpl != null) {
  35             addNatServiceListener(flatVlaSnatServiceImpl);
  36         }
  37         addNatServiceListener(factory.createFlatVlanIpv6ServiceImpl());
  38         AbstractSnatService vxlanGreSnatServiceImpl = factory.createVxlanGreSnatServiceImpl();
  39         if (vxlanGreSnatServiceImpl != null) {
  40             addNatServiceListener(vxlanGreSnatServiceImpl);
  41         }
  42     }
  43
  44     private void addNatServiceListener(SnatServiceListener natServiceListner) {
  45         snatServiceListeners.add(natServiceListner);
  46     }
  47
  48     @Override
  49     public void notify(TypedReadWriteTransaction<Datastore.Configuration> confTx,
  50             Routers router,  Routers oldRouter, BigInteger primarySwitchId, BigInteger dpnId, Action action)
  51             throws ExecutionException, InterruptedException {
  52         for (SnatServiceListener snatServiceListener : snatServiceListeners) {
  53             boolean result = false;
  54             switch (action) {
  55                 //Enables or disables SNAT specific flows in the NAPT and NON-NAPT switches
  56                 case SNAT_ALL_SWITCH_ENBL:
  57                     result = snatServiceListener.addSnatAllSwitch(confTx, router, primarySwitchId);
  58                     break;
  59
  60                 case SNAT_ALL_SWITCH_DISBL:
  61                     result = snatServiceListener.removeSnatAllSwitch(confTx, router, primarySwitchId);
  62                     break;
  63
  64                 case SNAT_ROUTER_ENBL:
  65                     result = snatServiceListener.addSnat(confTx, router, primarySwitchId, dpnId);
  66                     break;
  67
  68                 case SNAT_ROUTER_DISBL:
  69                     result = snatServiceListener.removeSnat(confTx, router, primarySwitchId, dpnId);
  70                     break;
  71
  72                 case SNAT_ROUTER_UPDATE:
  73                     result = snatServiceListener.handleRouterUpdate(confTx, oldRouter, router);
  74                     break;
  75
  76                 //Enables or disables flows to send the traffic to the NAT tables in NAPT switch and
  77                 //the flows to send the traffic to the NAPT switch from a NON-NAPT switch.
  78                 case CNT_ROUTER_ALL_SWITCH_ENBL:
  79                     result = snatServiceListener.addCentralizedRouterAllSwitch(confTx, router, primarySwitchId);
  80                     break;
  81
  82                 case CNT_ROUTER_ALL_SWITCH_DISBL:
  83                     result = snatServiceListener.removeCentralizedRouterAllSwitch(confTx, router, primarySwitchId);
  84                     break;
  85
  86                 case CNT_ROUTER_ENBL:
  87                     result = snatServiceListener.addCentralizedRouter(confTx, router, primarySwitchId, dpnId);
  88                     break;
  89
  90                 case CNT_ROUTER_DISBL:
  91                     result = snatServiceListener.removeCentralizedRouter(confTx, router, primarySwitchId, dpnId);
  92                     break;
  93
  94
  95                 default:
  96                     break;
  97             }
  98
  99             if (result) {
 100                 LOG.debug("notify : Nat action {} invoking listener {} succeeded", action,
 101                     snatServiceListener.getClass().getName());
 102             } else {
 103                 LOG.warn("notify : Nat action {} invoking listener {} failed",
 104                         action, snatServiceListener.getClass().getName());
 105             }
 106         }
 107     }
 108
 109 }