applications/notification-supplier/src/main/java/org/opendaylight/openflowplugin/applications/notification/supplier/impl/item/stat/AbstractNotificationSupplierForItemStat.java

   1 /*
   2  * Copyright (c) 2015 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
   9 package org.opendaylight.openflowplugin.applications.notification.supplier.impl.item.stat;
  10
  11 import com.google.common.base.Preconditions;
  12
  13 import java.util.Collection;
  14 import java.util.Map.Entry;
  15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  16 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
  17 import org.opendaylight.controller.md.sal.binding.api.DataTreeModification;
  18 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
  19 import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
  20 import org.opendaylight.openflowplugin.applications.notification.supplier.NotificationSupplierForItemStat;
  21 import org.opendaylight.openflowplugin.applications.notification.supplier.impl.AbstractNotificationSupplierBase;
  22 import org.opendaylight.yangtools.yang.binding.DataObject;
  23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  24 import org.opendaylight.yangtools.yang.binding.Notification;
  25
  26 /**
  27  * Class is package protected abstract implementation for all Old Statistics
  28  * Notification Suppliers
  29  *
  30  * @param <O> - Statistics {@link DataObject}
  31  * @param <N> - Statistics Notification
  32  */
  33 abstract class AbstractNotificationSupplierForItemStat<O extends DataObject,
  34                                                 N extends Notification>
  35                     extends AbstractNotificationSupplierBase<O>
  36                     implements NotificationSupplierForItemStat<O, N> {
  37
  38     private final NotificationProviderService notifProviderService;
  39
  40     /**
  41      * Default constructor for all Statistic Notification Supplier implementation
  42      *
  43      * @param notifProviderService - notification publisher
  44      * @param db - DataBroker for DataChangeEvent registration
  45      * @param clazz - Statistics Notification Class
  46      */
  47     public AbstractNotificationSupplierForItemStat(final NotificationProviderService notifProviderService,
  48             final DataBroker db, final Class<O> clazz) {
  49         super(db, clazz);
  50         this.notifProviderService = Preconditions.checkNotNull(notifProviderService);
  51     }
  52
  53     @Override
  54     public void onDataTreeChanged(Collection<DataTreeModification<O>> changes) {
  55
  56         Preconditions.checkNotNull(changes, "Changes may not be null!");
  57
  58         for (DataTreeModification<O> change : changes) {
  59             final InstanceIdentifier<O> key = change.getRootPath().getRootIdentifier();
  60             final DataObjectModification<O> mod = change.getRootNode();
  61             switch (mod.getModificationType()) {
  62                 case DELETE:
  63                     remove(key, mod.getDataBefore());
  64                     break;
  65                 case SUBTREE_MODIFIED:
  66                     update(key, mod.getDataBefore(), mod.getDataAfter());
  67                     break;
  68                 case WRITE:
  69                     if (mod.getDataBefore() == null) {
  70                         add(key, mod.getDataAfter());
  71                     } else {
  72                         update(key, mod.getDataBefore(), mod.getDataAfter());
  73                     }
  74                     break;
  75                 default:
  76                     throw new IllegalArgumentException("Unhandled modification type " + mod.getModificationType());
  77             }
  78         }
  79     }
  80
  81
  82     public void add(InstanceIdentifier<O> identifier , O add ){
  83         final N notif = createNotification(add, identifier);
  84         if (notif != null) {
  85             notifProviderService.publish(notif);
  86         }
  87     }
  88
  89
  90     public void remove(InstanceIdentifier<O> identifier , O del){
  91         //EMPTY NO-OP
  92     }
  93
  94
  95     public void update(InstanceIdentifier<O> identifier , O before, O after){
  96         //EMPTY NO-OP
  97     }
  98
  99 }
 100