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

Unmuted and fixed test. 

Multiple invocations are expected.

see #48519
This commit is contained in:
Martijn van Groningen 2019-10-28 10:30:24 +01:00
parent 72a601c47f
commit 0476f014bc
No known key found for this signature in database
GPG Key ID: AB236F4FCF2AF12A
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
libs/grok/src/test/java/org/elasticsearch/grok/MatcherWatchdogTests.java
View File

@ -39,7 +39,6 @@ import static org.mockito.Mockito.verifyZeroInteractions;
public class MatcherWatchdogTests extends ESTestCase { public class MatcherWatchdogTests extends ESTestCase {
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/48519")
public void testInterrupt() throws Exception { public void testInterrupt() throws Exception {
AtomicBoolean run = new AtomicBoolean(true); // to avoid a lingering thread when test has completed AtomicBoolean run = new AtomicBoolean(true); // to avoid a lingering thread when test has completed
MatcherWatchdog watchdog = MatcherWatchdog.newInstance(10, 100, System::currentTimeMillis, (delay, command) -> { MatcherWatchdog watchdog = MatcherWatchdog.newInstance(10, 100, System::currentTimeMillis, (delay, command) -> {
@ -63,7 +62,7 @@ public class MatcherWatchdogTests extends ESTestCase {
Thread thread = new Thread(() -> { Thread thread = new Thread(() -> {
Matcher matcher = mock(Matcher.class); Matcher matcher = mock(Matcher.class);
watchdog.register(matcher); watchdog.register(matcher);
verify(matcher, timeout(9999).times(1)).interrupt(); verify(matcher, timeout(9999).atLeastOnce()).interrupt();
interrupted.set(true); interrupted.set(true);
while (run.get()) {} // wait here so that the size of the registry can be asserted while (run.get()) {} // wait here so that the size of the registry can be asserted
watchdog.unregister(matcher); watchdog.unregister(matcher);