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;
29 class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionChain, DOMTransactionChainListener {
30 private final org.opendaylight.mdsal.dom.api.DOMTransactionChain txChainDelegate;
31 private final SchemaContext schemaContext;
32 private final TransactionChainListener txChainListener;
33 private final Object txChainIdentifier;
34 private final AtomicLong txNum = new AtomicLong();
36 private final Map<Object, AsyncTransaction<?, ?>> transactionMap;
38 ShardedDOMDataBrokerDelegatingTransactionChain(final Object txChainIdentifier,
39 final SchemaContext schemaContext,
40 final org.opendaylight.mdsal.dom.api.DOMDataBroker
42 final TransactionChainListener txChainListener) {
43 requireNonNull(brokerDelegate);
44 this.schemaContext = requireNonNull(schemaContext);
45 this.txChainIdentifier = requireNonNull(txChainIdentifier);
46 this.txChainListener = requireNonNull(txChainListener);
47 this.txChainDelegate = brokerDelegate.createTransactionChain(this);
48 transactionMap = Maps.newHashMap();
52 public DOMDataReadOnlyTransaction newReadOnlyTransaction() {
53 final DOMDataTreeReadTransaction readTxDelegate = txChainDelegate.newReadOnlyTransaction();
54 final DOMDataReadOnlyTransaction readTx = new ShardedDOMDataBrokerDelegatingReadTransaction(
55 newTransactionIdentifier(), readTxDelegate);
56 transactionMap.put(readTxDelegate.getIdentifier(), readTx);
62 public DOMDataReadWriteTransaction newReadWriteTransaction() {
63 final Object readWriteTxId = newTransactionIdentifier();
64 final DOMDataTreeReadTransaction readTxDelegate = txChainDelegate.newReadOnlyTransaction();
65 final DOMDataReadOnlyTransaction readTx = new ShardedDOMDataBrokerDelegatingReadTransaction(readWriteTxId,
68 final DOMDataTreeWriteTransaction writeTxDelegate = txChainDelegate.newWriteOnlyTransaction();
69 final DOMDataWriteTransaction writeTx = new ShardedDOMDataBrokerDelegatingWriteTransaction(readWriteTxId,
72 final DOMDataReadWriteTransaction readWriteTx = new ShardedDOMDataBrokerDelegatingReadWriteTransaction(
73 readWriteTxId, schemaContext, readTx, writeTx);
74 transactionMap.put(readTxDelegate.getIdentifier(), readWriteTx);
75 transactionMap.put(writeTxDelegate.getIdentifier(), readWriteTx);
81 public DOMDataWriteTransaction newWriteOnlyTransaction() {
82 final DOMDataTreeWriteTransaction writeTxDelegate = txChainDelegate.newWriteOnlyTransaction();
83 final DOMDataWriteTransaction writeTx = new ShardedDOMDataBrokerDelegatingWriteTransaction(
84 newTransactionIdentifier(), writeTxDelegate);
85 transactionMap.put(writeTxDelegate.getIdentifier(), writeTx);
92 txChainDelegate.close();
96 public void onTransactionChainFailed(org.opendaylight.mdsal.dom.api.DOMTransactionChain chain,
97 DOMDataTreeTransaction transaction, Throwable cause) {
98 txChainListener.onTransactionChainFailed(this, transactionFromDelegate(transaction.getIdentifier()), cause);
102 public void onTransactionChainSuccessful(org.opendaylight.mdsal.dom.api.DOMTransactionChain chain) {
103 txChainListener.onTransactionChainSuccessful(this);
106 private AsyncTransaction<?, ?> transactionFromDelegate(final Object delegateId) {
107 Preconditions.checkState(transactionMap.containsKey(delegateId),
108 "Delegate transaction {} is not present in transaction chain history", delegateId);
109 return transactionMap.get(delegateId);
112 private Object newTransactionIdentifier() {
113 return "DOM-CHAIN-" + txChainIdentifier + "-" + txNum.getAndIncrement();