elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/cache/ItmExternalTunnelCache.java

   1 /*
   2  * Copyright (c) 2020 Ericsson India Global Services Pvt Ltd. 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
   9 package org.opendaylight.netvirt.elan.cache;
  10
  11 import java.util.Map;
  12 import java.util.Optional;
  13 import java.util.concurrent.ConcurrentHashMap;
  14 import javax.inject.Inject;
  15 import javax.inject.Singleton;
  16 import org.opendaylight.genius.mdsalutil.cache.InstanceIdDataObjectCache;
  17 import org.opendaylight.infrautils.caches.CacheProvider;
  18 import org.opendaylight.mdsal.binding.api.DataBroker;
  19 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnel;
  22 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  23 import org.slf4j.Logger;
  24 import org.slf4j.LoggerFactory;
  25
  26 @Singleton
  27 public class ItmExternalTunnelCache extends InstanceIdDataObjectCache<ExternalTunnel> {
  28
  29     private static final Logger LOG = LoggerFactory.getLogger(ItmExternalTunnelCache.class);
  30     private final Map<String, ExternalTunnel> externalTunnelsByName = new ConcurrentHashMap<>();
  31
  32     @Inject
  33     public ItmExternalTunnelCache(DataBroker dataBroker, CacheProvider cacheProvider) {
  34         super(ExternalTunnel.class, dataBroker, LogicalDatastoreType.CONFIGURATION,
  35             InstanceIdentifier.create(ExternalTunnelList.class).child(ExternalTunnel.class), cacheProvider);
  36     }
  37
  38     /*@PostConstruct
  39     public void init() throws ReadFailedException {
  40         ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction();
  41         try {
  42             Optional<ExternalTunnelList> data = tx.read(LogicalDatastoreType.CONFIGURATION,
  43                 InstanceIdentifier.builder(ExternalTunnelList.class).build()).checkedGet();
  44             if (data.isPresent() && data.get().getExternalTunnel() != null) {
  45                 data.get().getExternalTunnel().stream().forEach(tunnel -> add(null, tunnel));
  46             }
  47         } finally {
  48             tx.close();
  49         }
  50         registerListener(LogicalDatastoreType.CONFIGURATION, dataBroker);
  51     }*/
  52
  53     @Override
  54     protected void removed(InstanceIdentifier<ExternalTunnel> key, ExternalTunnel deleted) {
  55         externalTunnelsByName.remove(deleted.getTunnelInterfaceName());
  56     }
  57
  58     /*@Override
  59     protected void updated(InstanceIdentifier<ExternalTunnel> key, ExternalTunnel old, ExternalTunnel updated) {
  60         externalTunnelsByName.put(updated.getTunnelInterfaceName(), updated);
  61     }*/
  62
  63     @Override
  64     protected synchronized void added(InstanceIdentifier<ExternalTunnel> key, ExternalTunnel added) {
  65         externalTunnelsByName.put(added.getTunnelInterfaceName(), added);
  66     }
  67
  68     public Optional<ExternalTunnel> getExternalTunnel(String key) {
  69         if (externalTunnelsByName.containsKey(key)) {
  70             return Optional.of(externalTunnelsByName.get(key));
  71         }
  72         // TODO get from the DB is missing
  73         return Optional.empty();
  74     }
  75 }