2 * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
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
8 package org.opendaylight.netconf.topology.singleton.impl;
10 import akka.actor.ActorRef;
11 import akka.pattern.Patterns;
12 import akka.util.Timeout;
13 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadTransaction;
14 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadWriteTransaction;
15 import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction;
16 import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
17 import org.opendaylight.mdsal.dom.spi.PingPongMergingDOMDataBroker;
18 import org.opendaylight.netconf.client.mdsal.api.RemoteDeviceId;
19 import org.opendaylight.netconf.topology.singleton.impl.tx.ProxyReadTransaction;
20 import org.opendaylight.netconf.topology.singleton.impl.tx.ProxyReadWriteTransaction;
21 import org.opendaylight.netconf.topology.singleton.messages.transactions.NewReadTransactionRequest;
22 import org.opendaylight.netconf.topology.singleton.messages.transactions.NewReadWriteTransactionRequest;
23 import org.opendaylight.netconf.topology.singleton.messages.transactions.NewWriteTransactionRequest;
24 import scala.concurrent.ExecutionContext;
25 import scala.concurrent.Future;
27 public class ProxyDOMDataBroker implements PingPongMergingDOMDataBroker {
29 private final Timeout askTimeout;
30 private final RemoteDeviceId id;
31 private final ActorRef masterNode;
32 private final ExecutionContext executionContext;
35 * Constructor for {@code ProxyDOMDataBroker}.
38 * @param masterNode {@link org.opendaylight.netconf.topology.singleton.impl.actors.NetconfNodeActor} ref
39 * @param executionContext ExecutionContext
40 * @param askTimeout ask timeout
42 public ProxyDOMDataBroker(final RemoteDeviceId id, final ActorRef masterNode,
43 final ExecutionContext executionContext, final Timeout askTimeout) {
45 this.masterNode = masterNode;
46 this.executionContext = executionContext;
47 this.askTimeout = askTimeout;
50 @SuppressWarnings("checkstyle:IllegalCatch")
52 public DOMDataTreeReadTransaction newReadOnlyTransaction() {
53 final Future<Object> txActorFuture = Patterns.ask(masterNode, new NewReadTransactionRequest(), askTimeout);
54 return new ProxyReadTransaction(id, txActorFuture, executionContext, askTimeout);
57 @SuppressWarnings("checkstyle:IllegalCatch")
59 public DOMDataTreeReadWriteTransaction newReadWriteTransaction() {
60 final Future<Object> txActorFuture = Patterns.ask(masterNode, new NewReadWriteTransactionRequest(), askTimeout);
61 return new ProxyReadWriteTransaction(id, txActorFuture, executionContext, askTimeout);
64 @SuppressWarnings("checkstyle:IllegalCatch")
66 public DOMDataTreeWriteTransaction newWriteOnlyTransaction() {
67 final Future<Object> txActorFuture = Patterns.ask(masterNode, new NewWriteTransactionRequest(), askTimeout);
68 return new ProxyReadWriteTransaction(id, txActorFuture, executionContext, askTimeout);
72 public DOMTransactionChain createTransactionChain() {
73 throw new UnsupportedOperationException(id + ": Transaction chains not supported for netconf mount point");