2 * Copyright (c) 2016 Cisco Systems, Inc. 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.controller.md.sal.dom.broker.impl.legacy.sharded.adapter;
10 import static java.util.Objects.requireNonNull;
12 import com.google.common.base.Preconditions;
13 import com.google.common.collect.Maps;
15 import java.util.concurrent.atomic.AtomicLong;
16 import org.opendaylight.controller.md.sal.common.api.data.AsyncTransaction;
17 import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener;
18 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadOnlyTransaction;
19 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction;
20 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
21 import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain;
22 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadTransaction;
23 import org.opendaylight.mdsal.dom.api.DOMDataTreeTransaction;
24 import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction;
25 import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener;
26 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
28 class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionChain, DOMTransactionChainListener {
29 private final org.opendaylight.mdsal.dom.api.DOMTransactionChain txChainDelegate;
30 private final SchemaContext schemaContext;
31 private final TransactionChainListener txChainListener;
32 private final Object txChainIdentifier;
33 private final AtomicLong txNum = new AtomicLong();
35 private final Map<Object, AsyncTransaction<?, ?>> transactionMap;
37 ShardedDOMDataBrokerDelegatingTransactionChain(final Object txChainIdentifier,
38 final SchemaContext schemaContext,
39 final org.opendaylight.mdsal.dom.api.DOMDataBroker
41 final TransactionChainListener txChainListener) {
42 requireNonNull(brokerDelegate);
43 this.schemaContext = requireNonNull(schemaContext);
44 this.txChainIdentifier = requireNonNull(txChainIdentifier);
45 this.txChainListener = requireNonNull(txChainListener);
46 this.txChainDelegate = brokerDelegate.createTransactionChain(this);
47 transactionMap = Maps.newHashMap();
51 public DOMDataReadOnlyTransaction newReadOnlyTransaction() {
52 final DOMDataTreeReadTransaction readTxDelegate = txChainDelegate.newReadOnlyTransaction();
53 final DOMDataReadOnlyTransaction readTx = new ShardedDOMDataBrokerDelegatingReadTransaction(
54 newTransactionIdentifier(), readTxDelegate);
55 transactionMap.put(readTxDelegate.getIdentifier(), readTx);
61 public DOMDataReadWriteTransaction newReadWriteTransaction() {
62 final Object readWriteTxId = newTransactionIdentifier();
63 final DOMDataTreeReadTransaction readTxDelegate = txChainDelegate.newReadOnlyTransaction();
64 final DOMDataReadOnlyTransaction readTx = new ShardedDOMDataBrokerDelegatingReadTransaction(readWriteTxId,
67 final DOMDataTreeWriteTransaction writeTxDelegate = txChainDelegate.newWriteOnlyTransaction();
68 final DOMDataWriteTransaction writeTx = new ShardedDOMDataBrokerDelegatingWriteTransaction(readWriteTxId,
71 final DOMDataReadWriteTransaction readWriteTx = new ShardedDOMDataBrokerDelegatingReadWriteTransaction(
72 readWriteTxId, schemaContext, readTx, writeTx);
73 transactionMap.put(readTxDelegate.getIdentifier(), readWriteTx);
74 transactionMap.put(writeTxDelegate.getIdentifier(), readWriteTx);
80 public DOMDataWriteTransaction newWriteOnlyTransaction() {
81 final DOMDataTreeWriteTransaction writeTxDelegate = txChainDelegate.newWriteOnlyTransaction();
82 final DOMDataWriteTransaction writeTx = new ShardedDOMDataBrokerDelegatingWriteTransaction(
83 newTransactionIdentifier(), writeTxDelegate);
84 transactionMap.put(writeTxDelegate.getIdentifier(), writeTx);
91 txChainDelegate.close();
95 public void onTransactionChainFailed(org.opendaylight.mdsal.dom.api.DOMTransactionChain chain,
96 DOMDataTreeTransaction transaction, Throwable cause) {
97 txChainListener.onTransactionChainFailed(this, transactionFromDelegate(transaction.getIdentifier()), cause);
101 public void onTransactionChainSuccessful(org.opendaylight.mdsal.dom.api.DOMTransactionChain chain) {
102 txChainListener.onTransactionChainSuccessful(this);
105 private AsyncTransaction<?, ?> transactionFromDelegate(final Object delegateId) {
106 Preconditions.checkState(transactionMap.containsKey(delegateId),
107 "Delegate transaction {} is not present in transaction chain history", delegateId);
108 return transactionMap.get(delegateId);
111 private Object newTransactionIdentifier() {
112 return "DOM-CHAIN-" + txChainIdentifier + "-" + txNum.getAndIncrement();