honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: increased time throttle timeout to deal with timing issues 

Original commit: elastic/x-pack-elasticsearch@90fd3c9cd9
This commit is contained in:
Martijn van Groningen 2015-06-17 09:17:13 +02:00
parent f72f4807aa
commit 2f14240915
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/test/java/org/elasticsearch/watcher/actions/throttler/ActionThrottleTests.java
View File

@ -5,7 +5,6 @@
*/ */
package org.elasticsearch.watcher.actions.throttler; package org.elasticsearch.watcher.actions.throttler;
import com.carrotsearch.randomizedtesting.annotations.Repeat;
import org.apache.lucene.util.LuceneTestCase.Slow; import org.apache.lucene.util.LuceneTestCase.Slow;
import org.elasticsearch.ElasticsearchException; import org.elasticsearch.ElasticsearchException;
import org.elasticsearch.common.joda.time.DateTime; import org.elasticsearch.common.joda.time.DateTime;
@ -56,7 +55,7 @@ import static org.hamcrest.Matchers.greaterThan;
*/ */
public class ActionThrottleTests extends AbstractWatcherIntegrationTests { public class ActionThrottleTests extends AbstractWatcherIntegrationTests {
@Test @Slow @Repeat(iterations = 10) @Test @Slow
public void testSingleActionAckThrottle() throws Exception { public void testSingleActionAckThrottle() throws Exception {
boolean useClientForAcking = randomBoolean(); boolean useClientForAcking = randomBoolean();
@ -96,7 +95,7 @@ public class ActionThrottleTests extends AbstractWatcherIntegrationTests {
} }
} }
@Test @Slow @Repeat(iterations = 10) @Test @Slow
public void testRandomMultiActionAckThrottle() throws Exception { public void testRandomMultiActionAckThrottle() throws Exception {
boolean useClientForAcking = randomBoolean(); boolean useClientForAcking = randomBoolean();
@ -256,11 +255,11 @@ public class ActionThrottleTests extends AbstractWatcherIntegrationTests {
}, 6, TimeUnit.SECONDS); }, 6, TimeUnit.SECONDS);
} }
@Test @Slow @Repeat(iterations = 20) @Test @Slow
public void testWatchThrottlePeriod() throws Exception { public void testWatchThrottlePeriod() throws Exception {
WatchSourceBuilder watchSourceBuilder = watchBuilder() WatchSourceBuilder watchSourceBuilder = watchBuilder()
.trigger(schedule(interval("60m"))) .trigger(schedule(interval("60m")))
.defaultThrottlePeriod(new TimeValue(1, TimeUnit.SECONDS)); .defaultThrottlePeriod(new TimeValue(20, TimeUnit.SECONDS));
AvailableAction availableAction = randomFrom(AvailableAction.values()); AvailableAction availableAction = randomFrom(AvailableAction.values());
watchSourceBuilder.addAction("default_global_throttle", availableAction.action()); watchSourceBuilder.addAction("default_global_throttle", availableAction.action());
@ -296,7 +295,7 @@ public class ActionThrottleTests extends AbstractWatcherIntegrationTests {
assertThat(resultStatus.toString(), equalTo("throttled")); assertThat(resultStatus.toString(), equalTo("throttled"));
if (timeWarped()) { if (timeWarped()) {
timeWarp().clock().fastForwardSeconds(1); timeWarp().clock().fastForwardSeconds(20);
} }
assertBusy(new Runnable() { assertBusy(new Runnable() {
@Override @Override
@ -315,7 +314,7 @@ public class ActionThrottleTests extends AbstractWatcherIntegrationTests {
throw new ElasticsearchException("failed to execute", ioe); throw new ElasticsearchException("failed to execute", ioe);
} }
} }
}, 1, TimeUnit.SECONDS); }, 20, TimeUnit.SECONDS);
} }
@Test @Slow @Test @Slow