southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/ovsdb/transact/DataChangesTerminationPointEvent.java

   1 /*
   2  * Copyright (c) 2015 Brocade Communications 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.ovsdb.southbound.ovsdb.transact;
   9
  10 import java.util.HashMap;
  11 import java.util.HashSet;
  12 import java.util.Map;
  13 import java.util.Set;
  14 import java.util.Map.Entry;
  15
  16 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
  18 import org.opendaylight.yangtools.yang.binding.DataObject;
  19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  20
  21 public class DataChangesTerminationPointEvent implements AsyncDataChangeEvent<InstanceIdentifier<?>,
  22         OvsdbTerminationPointAugmentation> {
  23
  24     private AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> event;
  25     private InstanceIdentifier<?> iid;
  26
  27     // local caches of computed data
  28     private Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> createdData = null;
  29     private Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> updatedData = null;
  30     private Set<InstanceIdentifier<?>> removedPaths = null;
  31     private Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> originalData;
  32
  33     public DataChangesTerminationPointEvent(InstanceIdentifier<?> iid,
  34                                             AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> event) {
  35         this.iid = iid;
  36         this.event = event;
  37     }
  38
  39     private Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> filter(Map<InstanceIdentifier<?>,
  40             DataObject> data) {
  41         Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> result
  42             = new HashMap<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation>();
  43         for (Entry<InstanceIdentifier<?>, DataObject> created: data.entrySet()) {
  44             if (created.getValue() != null
  45                     && created.getValue() instanceof OvsdbTerminationPointAugmentation
  46                     && ((OvsdbTerminationPointAugmentation)created.getValue()).getAttachedTo() != null
  47                     && ((OvsdbTerminationPointAugmentation)created.getValue()).getAttachedTo().getValue() != null) {
  48                 result.put(created.getKey(),((OvsdbTerminationPointAugmentation)created.getValue()));
  49             }
  50         }
  51         return result;
  52     }
  53
  54     @Override
  55     public Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> getCreatedData() {
  56         if (this.createdData == null) {
  57             this.createdData = filter(event.getCreatedData());
  58         }
  59         return this.createdData;
  60     }
  61
  62     @Override
  63     public Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> getUpdatedData() {
  64         if (this.updatedData == null) {
  65             this.updatedData = filter(event.getUpdatedData());
  66         }
  67         return this.updatedData;
  68     }
  69
  70     @Override
  71     public Set<InstanceIdentifier<?>> getRemovedPaths() {
  72         if (this.removedPaths != null) {
  73             this.removedPaths = new HashSet<InstanceIdentifier<?>>();
  74             for (InstanceIdentifier<?> path: event.getRemovedPaths()) {
  75                 DataObject original = this.event.getOriginalData().get(path);
  76                 if (original != null
  77                         && original instanceof OvsdbTerminationPointAugmentation) {
  78                     this.removedPaths.add(path);
  79                 }
  80             }
  81         }
  82         return this.removedPaths;
  83     }
  84
  85     @Override
  86     public Map<InstanceIdentifier<?>, OvsdbTerminationPointAugmentation> getOriginalData() {
  87         if (this.originalData == null) {
  88             this.originalData = filter(event.getOriginalData());
  89         }
  90         return this.originalData;
  91     }
  92
  93     @Override
  94     public OvsdbTerminationPointAugmentation getOriginalSubtree() {
  95         if (this.event.getOriginalSubtree() instanceof OvsdbTerminationPointAugmentation) {
  96             return (OvsdbTerminationPointAugmentation)this.event.getOriginalSubtree();
  97         } else {
  98             return null;
  99         }
 100     }
 101
 102     @Override
 103     public OvsdbTerminationPointAugmentation getUpdatedSubtree() {
 104         if (this.event.getUpdatedSubtree() instanceof OvsdbTerminationPointAugmentation) {
 105             return (OvsdbTerminationPointAugmentation)this.event.getUpdatedSubtree();
 106         } else {
 107             return null;
 108         }
 109     }
 110
 111 }