Fix InMemory shard transaction chaining.

[mdsal.git] / dom / mdsal-dom-broker / src / test / java / org / opendaylight / mdsal / dom / broker / ShardedDOMDataTreeTest.java

diff --git a/dom/mdsal-dom-broker/src/test/java/org/opendaylight/mdsal/dom/broker/ShardedDOMDataTreeTest.java b/dom/mdsal-dom-broker/src/test/java/org/opendaylight/mdsal/dom/broker/ShardedDOMDataTreeTest.java
index 058769544c0c0ed951192f904973af188ddbf4ed..6e5a41e7d17f442c6085790657a1a9d38610da7a 100644 (file)
--- a/dom/mdsal-dom-broker/src/test/java/org/opendaylight/mdsal/dom/broker/ShardedDOMDataTreeTest.java
+++ b/dom/mdsal-dom-broker/src/test/java/org/opendaylight/mdsal/dom/broker/ShardedDOMDataTreeTest.java
@@ -229,15 +229,17 @@ public class ShardedDOMDataTreeTest {
         tx.submit().checkedGet();
 
         final ArrayList<CheckedFuture<Void, TransactionCommitFailedException>> futures = new ArrayList<>();
-        final Collection<MapEntryNode> innerListMapEntries = createInnerListMapEntries(1000, "run-1");
-        for (final MapEntryNode innerListMapEntry : innerListMapEntries) {
-            final DOMDataTreeCursorAwareTransaction tx1 = shardProducer.createTransaction(false);
-            final DOMDataTreeWriteCursor cursor1 = tx1.createCursor(
-                    new DOMDataTreeIdentifier(LogicalDatastoreType.CONFIGURATION,
-                            oid1.node(new NodeIdentifier(TestModel.INNER_LIST_QNAME))));
-            cursor1.write(innerListMapEntry.getIdentifier(), innerListMapEntry);
-            cursor1.close();
-            futures.add(tx1.submit());
+        for (int i = 0; i < 1000; i++) {
+            final Collection<MapEntryNode> innerListMapEntries = createInnerListMapEntries(1000, "run-" + i);
+            for (final MapEntryNode innerListMapEntry : innerListMapEntries) {
+                final DOMDataTreeCursorAwareTransaction tx1 = shardProducer.createTransaction(false);
+                final DOMDataTreeWriteCursor cursor1 = tx1.createCursor(
+                        new DOMDataTreeIdentifier(LogicalDatastoreType.CONFIGURATION,
+                                oid1.node(new NodeIdentifier(TestModel.INNER_LIST_QNAME))));
+                cursor1.write(innerListMapEntry.getIdentifier(), innerListMapEntry);
+                cursor1.close();
+                futures.add(tx1.submit());
+            }
         }
 
         futures.get(futures.size() - 1).checkedGet();