svn commit: r1845333 - /jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStoreIT.java

[mreutegg]

Author: mreutegg
Date: Wed Oct 31 14:23:59 2018
New Revision: 1845333

URL: http://svn.apache.org/viewvc?rev=1845333&view=rev
Log:
OAK-7869: Commit queue stuck when input stream of blob blocks

Surround switch to reading with readMonitor.enter()/leave()

Modified:
    
jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStoreIT.java

Modified: 
jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStoreIT.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStoreIT.java?rev=1845333&r1=1845332&r2=1845333&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStoreIT.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStoreIT.java
 Wed Oct 31 14:23:59 2018
@@ -224,7 +224,14 @@ public class DocumentNodeStoreIT extends
 
                 private int readOrEnd() {
                     if (blocking.get()) {
-                        reading = true;
+                        if (!reading) {
+                            readMonitor.enter();
+                            try {
+                                reading = true;
+                            } finally {
+                                readMonitor.leave();
+                            }
+                        }
                         return 0;
                     } else {
                         return -1;