binding/mdsal-binding-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/dom/adapter/BindingDOMMountPointListenerAdapter.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 package org.opendaylight.mdsal.binding.dom.adapter;
   9
  10 import static java.util.Objects.requireNonNull;
  11
  12 import com.google.common.annotations.VisibleForTesting;
  13 import org.eclipse.jdt.annotation.NonNull;
  14 import org.opendaylight.mdsal.binding.api.MountPointService.MountPointListener;
  15 import org.opendaylight.mdsal.dom.api.DOMMountPointListener;
  16 import org.opendaylight.mdsal.dom.api.DOMMountPointService;
  17 import org.opendaylight.yangtools.concepts.Registration;
  18 import org.opendaylight.yangtools.yang.binding.DataObject;
  19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  20 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  21 import org.opendaylight.yangtools.yang.data.impl.codec.DeserializationException;
  22 import org.slf4j.Logger;
  23 import org.slf4j.LoggerFactory;
  24
  25 final class BindingDOMMountPointListenerAdapter implements Registration, DOMMountPointListener {
  26     private static final Logger LOG = LoggerFactory.getLogger(BindingDOMMountPointListenerAdapter.class);
  27
  28     @VisibleForTesting
  29     final @NonNull MountPointListener listener;
  30     private final AdapterContext adapterContext;
  31     private final Registration registration;
  32
  33     BindingDOMMountPointListenerAdapter(final MountPointListener listener, final AdapterContext adapterContext,
  34             final DOMMountPointService mountService) {
  35         this.listener = requireNonNull(listener);
  36         this.adapterContext = requireNonNull(adapterContext);
  37         registration = mountService.registerProvisionListener(this);
  38     }
  39
  40     @Override
  41     public void close() {
  42         registration.close();
  43     }
  44
  45     @Override
  46     public void onMountPointCreated(final YangInstanceIdentifier path) {
  47         try {
  48             listener.onMountPointCreated(toBinding(path));
  49         } catch (final DeserializationException e) {
  50             LOG.error("Unable to translate mountPoint path {}. Omitting event.", path, e);
  51         }
  52     }
  53
  54     @Override
  55     public void onMountPointRemoved(final YangInstanceIdentifier path) {
  56         try {
  57             listener.onMountPointRemoved(toBinding(path));
  58         } catch (final DeserializationException e) {
  59             LOG.error("Unable to translate mountPoint path {}. Omitting event.", path, e);
  60         }
  61     }
  62
  63     private InstanceIdentifier<? extends DataObject> toBinding(final YangInstanceIdentifier path)
  64             throws DeserializationException {
  65         final InstanceIdentifier<?> binding;
  66         try {
  67             binding = adapterContext.currentSerializer().fromYangInstanceIdentifier(path);
  68         } catch (IllegalArgumentException e) {
  69             throw new DeserializationException("Deserialization unsuccessful, " + path, e);
  70         }
  71         if (binding == null) {
  72             throw new DeserializationException("Deserialization unsuccessful, " + path);
  73         }
  74         return binding;
  75     }
  76 }