svn commit: r1878500 - /jackrabbit/oak/trunk/oak-segment-remote/src/test/java/org/apache/jackrabbit/oak/segment/remote/queue/SegmentWriteQueueTest.java

[adulceanu]

Author: adulceanu
Date: Fri Jun  5 10:20:03 2020
New Revision: 1878500

URL: http://svn.apache.org/viewvc?rev=1878500&view=rev
Log:
OAK-9086 - Flaky test 
SegmentWriteQueueTest#testThreadInterruptedWhileAddigToQueue
Contribution by Miroslav Smiljanic

Modified:
    
jackrabbit/oak/trunk/oak-segment-remote/src/test/java/org/apache/jackrabbit/oak/segment/remote/queue/SegmentWriteQueueTest.java

Modified: 
jackrabbit/oak/trunk/oak-segment-remote/src/test/java/org/apache/jackrabbit/oak/segment/remote/queue/SegmentWriteQueueTest.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-remote/src/test/java/org/apache/jackrabbit/oak/segment/remote/queue/SegmentWriteQueueTest.java?rev=1878500&r1=1878499&r2=1878500&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-segment-remote/src/test/java/org/apache/jackrabbit/oak/segment/remote/queue/SegmentWriteQueueTest.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-segment-remote/src/test/java/org/apache/jackrabbit/oak/segment/remote/queue/SegmentWriteQueueTest.java
 Fri Jun  5 10:20:03 2020
@@ -64,7 +64,6 @@ public class SegmentWriteQueueTest {
     }
 
     @Test
-    @Ignore("OAK-9086")
     public void testThreadInterruptedWhileAddigToQueue() throws 
InterruptedException, NoSuchFieldException {
 
         Set<UUID> added = Collections.synchronizedSet(new HashSet<>());
@@ -81,8 +80,8 @@ public class SegmentWriteQueueTest {
             added.add(new UUID(tarEntry.getMsb(), tarEntry.getLsb()));
         });
 
-        FieldSetter.setField(queueBlocked, 
queueBlocked.getClass().getDeclaredField("queue"), queue);
         Mockito.when(queue.offer(any(SegmentWriteAction.class), anyLong(), 
any(TimeUnit.class))).thenThrow(new InterruptedException());
+        FieldSetter.setField(queueBlocked, 
queueBlocked.getClass().getDeclaredField("queue"), queue);
 
         try {
             queueBlocked.addToQueue(tarEntry(0), EMPTY_DATA, 0, 0);