Cleanup ParserFieldsParameter

[netconf.git] / restconf / restconf-nb-rfc8040 / src / main / java / org / opendaylight / restconf / nb / rfc8040 / handlers / TransactionChainHandler.java

diff --git a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java
index c949b15bcf15d1714b19b9ada529b274650d4185..28830dd3417e2ef9afb936ea7a9307b7bbe8b989 100644 (file)
--- a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java
+++ b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java
@@ -5,39 +5,85 @@
  * 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.restconf.nb.rfc8040.handlers;
 
-import com.google.common.base.Preconditions;
-import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain;
-
+import java.util.Objects;
+import java.util.Queue;
+import java.util.concurrent.ConcurrentLinkedQueue;
+import javax.annotation.PreDestroy;
+import javax.inject.Inject;
+import javax.inject.Singleton;
+import org.opendaylight.mdsal.dom.api.DOMDataBroker;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeTransaction;
+import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
+import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener;
+import org.opendaylight.restconf.common.errors.RestconfDocumentedException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * Implementation of {@link TransactionChainHandler}.
- *
  */
-public class TransactionChainHandler implements Handler<DOMTransactionChain> {
+@Singleton
+public class TransactionChainHandler implements Handler<DOMTransactionChain>, AutoCloseable {
+    private static final Logger LOG = LoggerFactory.getLogger(TransactionChainHandler.class);
+
+    private final DOMTransactionChainListener transactionChainListener = new DOMTransactionChainListener() {
+        @Override
+        public void onTransactionChainFailed(final DOMTransactionChain chain, final DOMDataTreeTransaction transaction,
+                final Throwable cause) {
+            LOG.warn("TransactionChain({}) {} FAILED!", chain, transaction.getIdentifier(), cause);
+            transactionChainList.remove(chain);
+            throw new RestconfDocumentedException("TransactionChain(" + chain + ") not committed correctly", cause);
+        }
 
-    private DOMTransactionChain transactionChain;
+        @Override
+        public void onTransactionChainSuccessful(final DOMTransactionChain chain) {
+            LOG.trace("TransactionChain({}) SUCCESSFUL", chain);
+            transactionChainList.remove(chain);
+        }
+    };
+
+    private final DOMDataBroker dataBroker;
+    private final Queue<DOMTransactionChain> transactionChainList;
 
     /**
      * Prepare transaction chain service for Restconf services.
-     *
-     * @param transactionChain Transaction chain
      */
-    public TransactionChainHandler(final DOMTransactionChain transactionChain) {
-        Preconditions.checkNotNull(transactionChain);
-        this.transactionChain = transactionChain;
+    @Inject
+    public TransactionChainHandler(final DOMDataBroker dataBroker) {
+        this.dataBroker = Objects.requireNonNull(dataBroker);
+        this.transactionChainList = new ConcurrentLinkedQueue<>();
     }
 
+    /**
+     * Create and return new instance of object {@link DOMTransactionChain}.
+     * After use, is important to close transactionChain by method {@link DOMTransactionChain#close()}.
+     * @return new instance of object {@link DOMTransactionChain}
+     */
     @Override
-    public void update(final DOMTransactionChain transactionChain) {
-        Preconditions.checkNotNull(transactionChain);
-        this.transactionChain = transactionChain;
+    public DOMTransactionChain get() {
+        final DOMTransactionChain transactionChain = dataBroker.createTransactionChain(transactionChainListener);
+        this.transactionChainList.add(transactionChain);
+        LOG.trace("Started TransactionChain({})", transactionChain);
+        return transactionChain;
     }
 
     @Override
-    public DOMTransactionChain get() {
-        return this.transactionChain;
+    @PreDestroy
+    public synchronized void close() {
+        for (DOMTransactionChain transactionChain: this.transactionChainList) {
+            transactionChain.close();
+            LOG.trace("Closed TransactionChain({})", transactionChain);
+        }
+    }
+
+    /**
+     * Verify if {@link DOMTransactionChain} exist in {@link TransactionChainHandler} queue.
+     * @param transactionChain object to check.
+     * @return true if object still exist in {@link TransactionChainHandler}.
+     */
+    boolean verifyIfExistTransactionChain(DOMTransactionChain transactionChain) {
+        return this.transactionChainList.contains(transactionChain);
     }
 }