pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/TopologyNodeState.java

   1 /*
   2  * Copyright (c) 2013 Cisco Systems, 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.bgpcep.pcep.topology.provider;
   9
  10 import java.util.Collection;
  11 import java.util.HashMap;
  12 import java.util.Iterator;
  13 import java.util.Map;
  14
  15 import javax.annotation.concurrent.ThreadSafe;
  16
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev131024.lsp.metadata.Metadata;
  18 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
  19
  20 import com.google.common.base.Preconditions;
  21
  22 @ThreadSafe
  23 final class TopologyNodeState {
  24         private final Map<String, Metadata> metadata = new HashMap<>();
  25         private final long holdStateNanos;
  26         private final NodeId nodeId;
  27         private long lastReleased = 0;
  28
  29         public TopologyNodeState(final NodeId nodeId, final long holdStateNanos) {
  30                 Preconditions.checkArgument(holdStateNanos >= 0);
  31                 this.nodeId = Preconditions.checkNotNull(nodeId);
  32                 this.holdStateNanos = holdStateNanos;
  33         }
  34
  35         public NodeId getNodeId() {
  36                 return nodeId;
  37         }
  38
  39         public synchronized Metadata getLspMetadata(final String name) {
  40                 return metadata.get(name);
  41         }
  42
  43         public synchronized void setLspMetadata(final String name, final Metadata value) {
  44                 if (value == null) {
  45                         metadata.remove(name);
  46                 } else {
  47                         metadata.put(name, value);
  48                 }
  49         }
  50
  51         public synchronized void removeLspMetadata(final String name) {
  52                 metadata.remove(name);
  53         }
  54
  55         public synchronized void cleanupExcept(final Collection<String> values) {
  56                 final Iterator<String> it = metadata.keySet().iterator();
  57                 while (it.hasNext()) {
  58                         if (!values.contains(it.next())) {
  59                                 it.remove();
  60                         }
  61                 }
  62         }
  63
  64         public synchronized void released() {
  65                 lastReleased = System.nanoTime();
  66         }
  67
  68         public synchronized void taken() {
  69                 final long now = System.nanoTime();
  70
  71                 if (now - lastReleased > holdStateNanos) {
  72                         metadata.clear();
  73                 }
  74         }
  75 }