Setup cycleTest in the same txn

flowguru · flowguru · commit 4a28b557cf1f · 2021-07-16T18:29:54.000-07:00
In order to have multiple threads running against same cluster, this has to be done.
diff --git a/bindings/java/src/integration/com/apple/foundationdb/CycleMultiClientIntegrationTest.java b/bindings/java/src/integration/com/apple/foundationdb/CycleMultiClientIntegrationTest.java
@@ -73,16 +73,15 @@ private static synchronized void setupThreads(FDB fdb) {
 
     private static void setup(Collection<Database> dbs) {
         // 0 -> 1 -> 2 -> 3 -> 0
-        for (int k = 0; k < cycleLength; k++) {
-            String key = Integer.toString(k);
-            String value = Integer.toString((k + 1) % cycleLength);
-
-            for (Database db : dbs) {
-                db.run(tr -> {
+        for (Database db : dbs) {
+            db.run(tr -> {
+                for (int k = 0; k < cycleLength; k++) {
+                    String key = Integer.toString(k);
+                    String value = Integer.toString((k + 1) % cycleLength);
                     tr.set(Tuple.from(key).pack(), Tuple.from(value).pack());
-                    return null;
-                });
-            }
+                }
+                return null;
+            });
         }
     }
 
