Issue #8211 was fixed.

orientechnologies · Apr 24, 2018 · f74b211 · f74b211
1 parent a74e69c
commit f74b211
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/core/src/main/java/com/orientechnologies/orient/core/storage/cache/OCachePointer.java b/core/src/main/java/com/orientechnologies/orient/core/storage/cache/OCachePointer.java
@@ -89,14 +89,12 @@ public void incrementReadersReferrer() {
     int readers = getReaders(readersWriters);
     int writers = getWriters(readersWriters);
     readers++;
-    assert readers == 1;
 
     while (!readersWritersReferrer.compareAndSet(readersWriters, composeReadersWriters(readers, writers))) {
       readersWriters = readersWritersReferrer.get();
       readers = getReaders(readersWriters);
       writers = getWriters(readersWriters);
       readers++;
-      assert readers == 1;
     }
 
     final WritersListener wl = writersListener;
@@ -114,15 +112,13 @@ public void decrementReadersReferrer() {
     int writers = getWriters(readersWriters);
     readers--;
 
-    assert readers == 0;
 
     while (!readersWritersReferrer.compareAndSet(readersWriters, composeReadersWriters(readers, writers))) {
       readersWriters = readersWritersReferrer.get();
       readers = getReaders(readersWriters);
       writers = getWriters(readersWriters);
       readers--;
 
-      assert readers == 0;
     }
 
     final WritersListener wl = writersListener;

diff --git a/core/src/main/java/com/orientechnologies/orient/core/storage/cache/local/twoq/O2QCache.java b/core/src/main/java/com/orientechnologies/orient/core/storage/cache/local/twoq/O2QCache.java
@@ -1190,6 +1190,8 @@ private boolean processFetchedPage(boolean removeColdPages, OCachePointer dataPo
     final long pageIndex = dataPointer.getPageIndex();
 
     if (pinnedPages.containsKey(new PinnedPage(fileId, pageIndex))) {
+      dataPointer.decrementReadersReferrer();
+
       return removeColdPages;
     }