apps/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/ProxyDOMDataBroker.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.netconf.topology.singleton.impl;
   9
  10 import akka.actor.ActorRef;
  11 import akka.pattern.Patterns;
  12 import akka.util.Timeout;
  13 import com.google.common.collect.ClassToInstanceMap;
  14 import com.google.common.collect.ImmutableClassToInstanceMap;
  15 import org.opendaylight.mdsal.dom.api.DOMDataBrokerExtension;
  16 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadTransaction;
  17 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadWriteTransaction;
  18 import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction;
  19 import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
  20 import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener;
  21 import org.opendaylight.mdsal.dom.spi.PingPongMergingDOMDataBroker;
  22 import org.opendaylight.netconf.sal.connect.api.RemoteDeviceId;
  23 import org.opendaylight.netconf.topology.singleton.impl.tx.ProxyReadTransaction;
  24 import org.opendaylight.netconf.topology.singleton.impl.tx.ProxyReadWriteTransaction;
  25 import org.opendaylight.netconf.topology.singleton.messages.transactions.NewReadTransactionRequest;
  26 import org.opendaylight.netconf.topology.singleton.messages.transactions.NewReadWriteTransactionRequest;
  27 import org.opendaylight.netconf.topology.singleton.messages.transactions.NewWriteTransactionRequest;
  28 import scala.concurrent.ExecutionContext;
  29 import scala.concurrent.Future;
  30
  31 public class ProxyDOMDataBroker implements PingPongMergingDOMDataBroker {
  32
  33     private final Timeout askTimeout;
  34     private final RemoteDeviceId id;
  35     private final ActorRef masterNode;
  36     private final ExecutionContext executionContext;
  37
  38     /**
  39      * Constructor for {@code ProxyDOMDataBroker}.
  40      *
  41      * @param id          id
  42      * @param masterNode  {@link org.opendaylight.netconf.topology.singleton.impl.actors.NetconfNodeActor} ref
  43      * @param executionContext ExecutionContext
  44      * @param askTimeout  ask timeout
  45      */
  46     public ProxyDOMDataBroker(final RemoteDeviceId id, final ActorRef masterNode,
  47             final ExecutionContext executionContext, final Timeout askTimeout) {
  48         this.id = id;
  49         this.masterNode = masterNode;
  50         this.executionContext = executionContext;
  51         this.askTimeout = askTimeout;
  52     }
  53
  54     @SuppressWarnings("checkstyle:IllegalCatch")
  55     @Override
  56     public DOMDataTreeReadTransaction newReadOnlyTransaction() {
  57         final Future<Object> txActorFuture = Patterns.ask(masterNode, new NewReadTransactionRequest(), askTimeout);
  58         return new ProxyReadTransaction(id, txActorFuture, executionContext, askTimeout);
  59     }
  60
  61     @SuppressWarnings("checkstyle:IllegalCatch")
  62     @Override
  63     public DOMDataTreeReadWriteTransaction newReadWriteTransaction() {
  64         final Future<Object> txActorFuture = Patterns.ask(masterNode, new NewReadWriteTransactionRequest(), askTimeout);
  65         return new ProxyReadWriteTransaction(id, txActorFuture, executionContext, askTimeout);
  66     }
  67
  68     @SuppressWarnings("checkstyle:IllegalCatch")
  69     @Override
  70     public DOMDataTreeWriteTransaction newWriteOnlyTransaction() {
  71         final Future<Object> txActorFuture = Patterns.ask(masterNode, new NewWriteTransactionRequest(), askTimeout);
  72         return new ProxyReadWriteTransaction(id, txActorFuture, executionContext, askTimeout);
  73     }
  74
  75     @Override
  76     public DOMTransactionChain createTransactionChain(final DOMTransactionChainListener listener) {
  77         throw new UnsupportedOperationException(id + ": Transaction chains not supported for netconf mount point");
  78     }
  79
  80     @Override
  81     public ClassToInstanceMap<DOMDataBrokerExtension> getExtensions() {
  82         return ImmutableClassToInstanceMap.of();
  83     }
  84 }