Integrate MRI projects for Neon

[controller.git] / opendaylight / md-sal / sal-dom-broker / src / main / java / org / opendaylight / controller / md / sal / dom / broker / impl / legacy / sharded / adapter / ShardedDOMDataBrokerDelegatingTransactionChain.java

diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/legacy/sharded/adapter/ShardedDOMDataBrokerDelegatingTransactionChain.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/legacy/sharded/adapter/ShardedDOMDataBrokerDelegatingTransactionChain.java
index 1bbf8f53e528cb4150019edcb2855d7659673bf7..ef77bf1da80d842aded2728da63422d61219fa9a 100644 (file)
--- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/legacy/sharded/adapter/ShardedDOMDataBrokerDelegatingTransactionChain.java
+++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/legacy/sharded/adapter/ShardedDOMDataBrokerDelegatingTransactionChain.java
@@ -5,10 +5,9 @@
  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
  * and is available at http://www.eclipse.org/legal/epl-v10.html
  */
-
 package org.opendaylight.controller.md.sal.dom.broker.impl.legacy.sharded.adapter;
 
-import static com.google.common.base.Preconditions.checkNotNull;
+import static java.util.Objects.requireNonNull;
 
 import com.google.common.base.Preconditions;
 import com.google.common.collect.Maps;
@@ -20,14 +19,13 @@ import org.opendaylight.controller.md.sal.dom.api.DOMDataReadOnlyTransaction;
 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction;
 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
 import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain;
-import org.opendaylight.mdsal.common.api.TransactionChain;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadTransaction;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeTransaction;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction;
+import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener;
 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
 
-
-class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionChain,
-        org.opendaylight.mdsal.common.api.TransactionChainListener {
+class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionChain, DOMTransactionChainListener {
     private final org.opendaylight.mdsal.dom.api.DOMTransactionChain txChainDelegate;
     private final SchemaContext schemaContext;
     private final TransactionChainListener txChainListener;
@@ -36,13 +34,15 @@ class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionCh
 
     private final Map<Object, AsyncTransaction<?, ?>> transactionMap;
 
-    public ShardedDOMDataBrokerDelegatingTransactionChain(final Object txChainIdentifier, final SchemaContext schemaContext,
-                                                          final org.opendaylight.mdsal.dom.api.DOMDataBroker brokerDelegate,
+    ShardedDOMDataBrokerDelegatingTransactionChain(final Object txChainIdentifier,
+                                                          final SchemaContext schemaContext,
+                                                          final org.opendaylight.mdsal.dom.api.DOMDataBroker
+                                                                  brokerDelegate,
                                                           final TransactionChainListener txChainListener) {
-        checkNotNull(brokerDelegate);
-        this.schemaContext = checkNotNull(schemaContext);
-        this.txChainIdentifier = checkNotNull(txChainIdentifier);
-        this.txChainListener = checkNotNull(txChainListener);
+        requireNonNull(brokerDelegate);
+        this.schemaContext = requireNonNull(schemaContext);
+        this.txChainIdentifier = requireNonNull(txChainIdentifier);
+        this.txChainListener = requireNonNull(txChainListener);
         this.txChainDelegate = brokerDelegate.createTransactionChain(this);
         transactionMap = Maps.newHashMap();
     }
@@ -50,8 +50,8 @@ class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionCh
     @Override
     public DOMDataReadOnlyTransaction newReadOnlyTransaction() {
         final DOMDataTreeReadTransaction readTxDelegate = txChainDelegate.newReadOnlyTransaction();
-        final DOMDataReadOnlyTransaction readTx =
-                new ShardedDOMDataBrokerDelegatingReadTransaction(newTransactionIdentifier(), readTxDelegate);
+        final DOMDataReadOnlyTransaction readTx = new ShardedDOMDataBrokerDelegatingReadTransaction(
+                newTransactionIdentifier(), readTxDelegate);
         transactionMap.put(readTxDelegate.getIdentifier(), readTx);
 
         return readTx;
@@ -61,16 +61,15 @@ class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionCh
     public DOMDataReadWriteTransaction newReadWriteTransaction() {
         final Object readWriteTxId = newTransactionIdentifier();
         final DOMDataTreeReadTransaction readTxDelegate = txChainDelegate.newReadOnlyTransaction();
-        final DOMDataReadOnlyTransaction readTx =
-                new ShardedDOMDataBrokerDelegatingReadTransaction(readWriteTxId, readTxDelegate);
+        final DOMDataReadOnlyTransaction readTx = new ShardedDOMDataBrokerDelegatingReadTransaction(readWriteTxId,
+                                                                                                    readTxDelegate);
 
         final DOMDataTreeWriteTransaction writeTxDelegate = txChainDelegate.newWriteOnlyTransaction();
-        final DOMDataWriteTransaction writeTx =
-                new ShardedDOMDataBrokerDelegatingWriteTransaction(readWriteTxId, writeTxDelegate);
+        final DOMDataWriteTransaction writeTx = new ShardedDOMDataBrokerDelegatingWriteTransaction(readWriteTxId,
+                                                                                                   writeTxDelegate);
 
-        final DOMDataReadWriteTransaction readWriteTx =
-                new ShardedDOMDataBrokerDelegatingReadWriteTransaction(readWriteTxId, schemaContext,
-                        readTx, writeTx);
+        final DOMDataReadWriteTransaction readWriteTx = new ShardedDOMDataBrokerDelegatingReadWriteTransaction(
+                readWriteTxId, schemaContext, readTx, writeTx);
         transactionMap.put(readTxDelegate.getIdentifier(), readWriteTx);
         transactionMap.put(writeTxDelegate.getIdentifier(), readWriteTx);
 
@@ -80,8 +79,8 @@ class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionCh
     @Override
     public DOMDataWriteTransaction newWriteOnlyTransaction() {
         final DOMDataTreeWriteTransaction writeTxDelegate = txChainDelegate.newWriteOnlyTransaction();
-        final DOMDataWriteTransaction writeTx =
-                new ShardedDOMDataBrokerDelegatingWriteTransaction(newTransactionIdentifier(), writeTxDelegate);
+        final DOMDataWriteTransaction writeTx = new ShardedDOMDataBrokerDelegatingWriteTransaction(
+                newTransactionIdentifier(), writeTxDelegate);
         transactionMap.put(writeTxDelegate.getIdentifier(), writeTx);
 
         return writeTx;
@@ -93,21 +92,19 @@ class ShardedDOMDataBrokerDelegatingTransactionChain implements DOMTransactionCh
     }
 
     @Override
-    public void onTransactionChainFailed(final TransactionChain<?, ?> transactionChain,
-                                         final org.opendaylight.mdsal.common.api.AsyncTransaction<?, ?> asyncTransaction,
-                                         final Throwable throwable) {
-        txChainListener.onTransactionChainFailed(
-                this, transactionFromDelegate(asyncTransaction.getIdentifier()), throwable);
+    public void onTransactionChainFailed(org.opendaylight.mdsal.dom.api.DOMTransactionChain chain,
+            DOMDataTreeTransaction transaction, Throwable cause) {
+        txChainListener.onTransactionChainFailed(this, transactionFromDelegate(transaction.getIdentifier()), cause);
     }
 
     @Override
-    public void onTransactionChainSuccessful(final TransactionChain<?, ?> transactionChain) {
+    public void onTransactionChainSuccessful(org.opendaylight.mdsal.dom.api.DOMTransactionChain chain) {
         txChainListener.onTransactionChainSuccessful(this);
     }
 
     private AsyncTransaction<?, ?> transactionFromDelegate(final Object delegateId) {
         Preconditions.checkState(transactionMap.containsKey(delegateId),
-                "Delegate transaction {} is not present in transaction chain history", delegateId);
+                                 "Delegate transaction {} is not present in transaction chain history", delegateId);
         return transactionMap.get(delegateId);
     }