[ 
https://issues.apache.org/jira/browse/OAK-6882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Vikas Saurabh updated OAK-6882:
-------------------------------
    Comment: was deleted

(was: [~reschke], can you please see if this helps:
{noformat}
diff --git 
a/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/observation/ObservationQueueFullWarnTest.java
 
b/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/observation/ObservationQueueFullWarnTest.java
index 1901795c9f..5dcc725ccf 100644
--- 
a/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/observation/ObservationQueueFullWarnTest.java
+++ 
b/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/observation/ObservationQueueFullWarnTest.java
@@ -263,8 +263,8 @@ public class ObservationQueueFullWarnTest extends 
AbstractRepositoryTest {
             @Override
             public void onEvent(EventIterator events) {
                 try {
-                    semaphore.acquire();
                     if (hasRecievedInit.get()) {
+                        semaphore.acquire();
                         long numEvents = events.getSize();
                         counter.addAndGet(numEvents);
                         System.out.println("GOT: " + numEvents + " - COUNTER: 
" + counter.get());
@@ -282,6 +282,7 @@ public class ObservationQueueFullWarnTest extends 
AbstractRepositoryTest {
                         // as other would be dispatched once we've got init
                         while (events.hasNext()) {
                             Event e = events.nextEvent();
+                            System.out.println(" - " + e);
                             if (PathUtils.getName(e.getPath()).equals("init")) 
{
                                 hasRecievedInit.set(true);
                             }
@@ -313,7 +314,7 @@ public class ObservationQueueFullWarnTest extends 
AbstractRepositoryTest {
         // To avoid this, we would put our own "init" and wait for it to show 
up before continuing the test
         session.getNode("/testNode").setProperty("init", 1);
         session.save();
-        semaphore.release(1);
+
         boolean initNotTimeOut = waitFor(5000, new Condition() {
             @Override
             public boolean evaluate() {
{noformat}

(also, I've added another System.out.println... so, if it doesn't work for you 
then another copy of stdout would be great).)

> ObservationQueueFullWarnTest.testQueueFullThenFlushing failing
> --------------------------------------------------------------
>
>                 Key: OAK-6882
>                 URL: https://issues.apache.org/jira/browse/OAK-6882
>             Project: Jackrabbit Oak
>          Issue Type: Bug
>          Components: jcr
>    Affects Versions: 1.7.10
>            Reporter: Julian Reschke
>            Assignee: Vikas Saurabh
>         Attachments: 
> org.apache.jackrabbit.oak.jcr.observation.ObservationQueueFullWarnTest-output.txt,
>  org.apache.jackrabbit.oak.jcr.observation.ObservationQueueFullWarnTest.txt
>
>
> {noformat}
> [ERROR] 
> testQueueFullThenFlushing[SegmentTar](org.apache.jackrabbit.oak.jcr.observation.ObservationQueueFullWarnTest)
>   Time elapsed: 0.262 s  <<< FAILURE!
> java.lang.AssertionError: Just filled queue must not convert local->external 
> expected:<6> but was:<4>
>         at 
> org.apache.jackrabbit.oak.jcr.observation.ObservationQueueFullWarnTest.testQueueFullThenFlushing(ObservationQueueFullWarnTest.java:347)
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to