X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=dom%2Fmdsal-dom-broker%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fdom%2Fbroker%2FShardedDOMDataTreeTest.java;h=6e5a41e7d17f442c6085790657a1a9d38610da7a;hb=dca009bba2d4ceb2e13537f3ac6f9a5f1b05302f;hp=058769544c0c0ed951192f904973af188ddbf4ed;hpb=395348596fcc6296e1a9ed0d9899b5aa16f08625;p=mdsal.git 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 058769544c..6e5a41e7d1 100644 --- 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> futures = new ArrayList<>(); - final Collection 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 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();