From c92b77545623cb7dda7285d2cfadd90bd21fdc0f Mon Sep 17 00:00:00 2001 From: Stephane Gamard Date: Mon, 4 Aug 2014 17:39:56 +0200 Subject: [PATCH] Added test case of synchronize above queue intial capacity --- .../activity/ActivityBackendMediumTest.java | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) diff --git a/server/sonar-server/src/test/java/org/sonar/server/activity/ActivityBackendMediumTest.java b/server/sonar-server/src/test/java/org/sonar/server/activity/ActivityBackendMediumTest.java index 18748f2295e..022e21c087f 100644 --- a/server/sonar-server/src/test/java/org/sonar/server/activity/ActivityBackendMediumTest.java +++ b/server/sonar-server/src/test/java/org/sonar/server/activity/ActivityBackendMediumTest.java @@ -29,6 +29,7 @@ import org.sonar.core.activity.ActivityLog; import org.sonar.server.activity.db.ActivityDao; import org.sonar.server.activity.index.ActivityIndex; import org.sonar.server.activity.index.ActivityQuery; +import org.sonar.server.platform.Platform; import org.sonar.server.search.QueryOptions; import org.sonar.server.search.Result; @@ -95,7 +96,7 @@ public class ActivityBackendMediumTest extends SearchMediumTest { // 0 Assert no logs in DB assertThat(dao.findAll(dbSession)).hasSize(0); - int max = 200; + int max = 400; final String testValue = "hello world"; for (int i = 0; i < max; i++) { service.write(dbSession, Activity.Type.QPROFILE, testValue + "_" + i); @@ -117,6 +118,20 @@ public class ActivityBackendMediumTest extends SearchMediumTest { count++; } assertThat(count).isEqualTo(max); + + + // 3 assert synchronize above IndexQueue threshold + tester.clearIndexes(); + tester.get(Platform.class).executeStartupTasks(); + + result = index.search(new ActivityQuery(), new QueryOptions().setScroll(true)); + logs = new Result(index, result).scroll(); + count = 0; + while (logs.hasNext()) { + logs.next(); + count++; + } + assertThat(count).isEqualTo(max); } @Test -- 2.39.5