test: Added sleep timeout

Julien Ruaux · Julien Ruaux · commit 4ce634784338 · 2023-01-02T22:47:46.000+08:00
diff --git a/src/test/java/com/redis/trino/TestRediSearchConnectorSmokeTest.java b/src/test/java/com/redis/trino/TestRediSearchConnectorSmokeTest.java
@@ -55,7 +55,8 @@ private void deleteBeers() throws InterruptedException {
 		} catch (Exception e) {
 			// ignore
 		}
-		while (redisearch.getTestContext().sync().dbsize() > 0) {
+		long start = System.currentTimeMillis();
+		while (redisearch.getTestContext().sync().dbsize() > 0 && System.currentTimeMillis() < start + 3000) {
 			Thread.sleep(10);
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,8 @@ private void deleteBeers() throws InterruptedException {`
`55`	`55`	`} catch (Exception e) {`
`56`	`56`	`// ignore`
`57`	`57`	`}`
`58`		`- while (redisearch.getTestContext().sync().dbsize() > 0) {`
	`58`	`+ long start = System.currentTimeMillis();`
	`59`	`+ while (redisearch.getTestContext().sync().dbsize() > 0 && System.currentTimeMillis() < start + 3000) {`
`59`	`60`	`Thread.sleep(10);`
`60`	`61`	`}`
`61`	`62`	`}`