Wait nodes to sync each other

Junha Yang · mergify[bot] · commit ec7923318d2d · 2020-12-15T07:37:22.000Z
diff --git a/integration-test/tests/multi.rs b/integration-test/tests/multi.rs
@@ -85,7 +85,15 @@ async fn track_blocks() {
         delay_for(Duration::from_secs(1)).await;
     }
 
-    for i in 0..4 {
-        assert!(get_latest_block(GRAPHQL_PORT_BASE + i).await >= start_block + 8)
+    for _ in 0..60 {
+        delay_for(Duration::from_secs(1)).await;
+        let mut success = true;
+        for i in 0..4 {
+            success = success && get_latest_block(GRAPHQL_PORT_BASE + i).await >= start_block + 8;
+        }
+        if success {
+            return
+        }
     }
+    panic!("Failed to sync 4 nodes")
 }

Original file line number	Diff line number	Diff line change
`@@ -85,7 +85,15 @@ async fn track_blocks() {`
`85`	`85`	`delay_for(Duration::from_secs(1)).await;`
`86`	`86`	`}`
`87`	`87`
`88`		`- for i in 0..4 {`
`89`		`- assert!(get_latest_block(GRAPHQL_PORT_BASE + i).await >= start_block + 8)`
	`88`	`+ for _ in 0..60 {`
	`89`	`+ delay_for(Duration::from_secs(1)).await;`
	`90`	`+ let mut success = true;`
	`91`	`+ for i in 0..4 {`
	`92`	`+ success = success && get_latest_block(GRAPHQL_PORT_BASE + i).await >= start_block + 8;`
	`93`	`+ }`
	`94`	`+ if success {`
	`95`	`+ return`
	`96`	`+ }`
`90`	`97`	`}`
	`98`	`+ panic!("Failed to sync 4 nodes")`
`91`	`99`	`}`