From 855096b62f197edee1f32f971730343f64dd16ab Mon Sep 17 00:00:00 2001 From: =?utf8?q?S=C3=A9bastien=20Lesaint?= Date: Thu, 15 Oct 2015 18:22:28 +0200 Subject: [PATCH] reduce polling time of Compute Engine scheduler from 10s to 2 --- .../computation/taskprocessor/CeProcessingSchedulerImpl.java | 2 +- .../taskprocessor/CeProcessingSchedulerImplTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/sonar-server/src/main/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImpl.java b/server/sonar-server/src/main/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImpl.java index d9e346a7028..4737c4010dd 100644 --- a/server/sonar-server/src/main/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImpl.java +++ b/server/sonar-server/src/main/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImpl.java @@ -33,7 +33,7 @@ public class CeProcessingSchedulerImpl implements CeProcessingScheduler { this.executorService = processingExecutorService; this.workerRunnable = workerRunnable; - this.delayBetweenTasks = 10; + this.delayBetweenTasks = 2; this.delayForFirstStart = 0; this.timeUnit = TimeUnit.SECONDS; } diff --git a/server/sonar-server/src/test/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImplTest.java b/server/sonar-server/src/test/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImplTest.java index 9dfa6da2453..c94bbd4312d 100644 --- a/server/sonar-server/src/test/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImplTest.java +++ b/server/sonar-server/src/test/java/org/sonar/server/computation/taskprocessor/CeProcessingSchedulerImplTest.java @@ -37,7 +37,7 @@ public class CeProcessingSchedulerImplTest { public void startScheduling_schedules_CeWorkerRunnable_at_fixed_rate_run_head_of_queue() { underTest.startScheduling(); - verify(processingExecutorService).scheduleAtFixedRate(same(workerRunnable), eq(0L), eq(10L), eq(TimeUnit.SECONDS)); + verify(processingExecutorService).scheduleAtFixedRate(same(workerRunnable), eq(0L), eq(2L), eq(TimeUnit.SECONDS)); verifyNoMoreInteractions(processingExecutorService); } -- 2.39.5