Commit queue stuck when input stream of blob blocks
Surround switch to reading with readMonitor.enter()/leave()
@@ -224,7 +224,14 @@ public class DocumentNodeStoreIT extends AbstractDocumentStoreTest {
private int readOrEnd() {
if (blocking.get()) {
+ if (!reading) {
+ readMonitor.enter();
+ try {
reading = true;
+ } finally {
+ readMonitor.leave();
+ }
+ }
return 0;
} else {
return -1;
