entityownership/mdsal-eos-binding-adapter/src/main/java/org/opendaylight/mdsal/eos/binding/dom/adapter/DOMEntityOwnershipListenerAdapter.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.mdsal.eos.binding.dom.adapter;
   9
  10 import static com.google.common.base.Verify.verifyNotNull;
  11 import static java.util.Objects.requireNonNull;
  12
  13 import org.opendaylight.mdsal.binding.dom.adapter.AdapterContext;
  14 import org.opendaylight.mdsal.eos.binding.api.Entity;
  15 import org.opendaylight.mdsal.eos.binding.api.EntityOwnershipListener;
  16 import org.opendaylight.mdsal.eos.common.api.EntityOwnershipStateChange;
  17 import org.opendaylight.mdsal.eos.dom.api.DOMEntity;
  18 import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipListener;
  19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  20 import org.slf4j.Logger;
  21 import org.slf4j.LoggerFactory;
  22
  23 /**
  24  * Adapter that bridges between the binding and DOM EntityOwnershipListener interfaces.
  25  *
  26  * @author Thomas Pantelis
  27  */
  28 final class DOMEntityOwnershipListenerAdapter implements DOMEntityOwnershipListener {
  29     private static final Logger LOG = LoggerFactory.getLogger(DOMEntityOwnershipListenerAdapter.class);
  30
  31     private final EntityOwnershipListener bindingListener;
  32     private final AdapterContext adapterContext;
  33
  34     DOMEntityOwnershipListenerAdapter(final EntityOwnershipListener bindingListener,
  35             final AdapterContext adapterContext) {
  36         this.bindingListener = requireNonNull(bindingListener);
  37         this.adapterContext = requireNonNull(adapterContext);
  38     }
  39
  40     @Override
  41     @SuppressWarnings("checkstyle:IllegalCatch")
  42     public void ownershipChanged(final DOMEntity entity, final EntityOwnershipStateChange change,
  43             final boolean inJeopardy) {
  44         final var domId = entity.getIdentifier();
  45         final InstanceIdentifier<?> bindingId;
  46         try {
  47             bindingId = verifyNotNull(adapterContext.currentSerializer().fromYangInstanceIdentifier(domId));
  48         } catch (RuntimeException e) {
  49             LOG.error("Error converting DOM entity ID {} to binding InstanceIdentifier", domId, e);
  50             return;
  51         }
  52
  53         final var bindingEntity = new Entity(entity.getType(), bindingId);
  54         try {
  55             bindingListener.ownershipChanged(bindingEntity, change, inJeopardy);
  56         } catch (Exception e) {
  57             LOG.error("Listener {} failed on during {} {}change {}", bindingListener, bindingEntity,
  58                 inJeopardy ? "jeopardy " : "", change, e);
  59         }
  60     }
  61 }