Issue #2874, cluster with wal tests are fixed.

core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/OPaginatedCluster.java

@@ -588,11 +588,11 @@ public boolean deleteRecord(long clusterPosition) throws IOException {
 
         atomicOperation = storage.getAtomicOperationsManager().getCurrentOperation();
         do {
-          final OCacheEntry cacheEntry = loadPage(atomicOperation, fileId, pageIndex, false, diskCache);
+          OCacheEntry cacheEntry = loadPage(atomicOperation, fileId, pageIndex, false, diskCache);
           cacheEntry.acquireExclusiveLock();
           int initialFreePageIndex;
           try {
-            final OClusterPage localPage = new OClusterPage(cacheEntry, false, getChangesTree(atomicOperation, cacheEntry));
+            OClusterPage localPage = new OClusterPage(cacheEntry, false, getChangesTree(atomicOperation, cacheEntry));
             initialFreePageIndex = calculateFreePageIndex(localPage);
 
             if (localPage.isDeleted(recordPosition)) {
@@ -601,11 +601,18 @@ public boolean deleteRecord(long clusterPosition) throws IOException {
               else
                 throw new OStorageException("Content of record " + new ORecordId(id, clusterPosition) + " was broken.");
             } else if (removedContentSize == 0) {
+              cacheEntry.releaseExclusiveLock();
+              releasePage(atomicOperation, cacheEntry, diskCache);
+
               atomicOperation = startAtomicOperation();
-              localPage.setChangesTree(getChangesTree(atomicOperation, cacheEntry));
+              lockTillAtomicOperationCompletes();
+
+              cacheEntry = loadPage(atomicOperation, fileId, pageIndex, false, diskCache);
+              cacheEntry.acquireExclusiveLock();
+
+              localPage = new OClusterPage(cacheEntry, false, getChangesTree(atomicOperation, cacheEntry));
 
               operationStarted = true;
-              lockTillAtomicOperationCompletes();
             }
 
             byte[] content = localPage.getRecordBinaryValue(recordPosition, 0, localPage.getRecordSize(recordPosition));

core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/atomicoperations/OAtomicOperation.java

@@ -286,6 +286,9 @@ public void commitChanges(ODiskCache diskCache, OWriteAheadLog writeAheadLog) th
         if (cacheEntry == null) {
           assert filePageChanges.isNew;
           do {
+            if (cacheEntry != null)
+              diskCache.release(cacheEntry);
+
             cacheEntry = diskCache.allocateNewPage(fileId);
           } while (cacheEntry.getPageIndex() != pageIndex);
         }

core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/base/ODurablePage.java

@@ -87,10 +87,6 @@ public ODurablePage(OCacheEntry cacheEntry, OWALChangesTree changesTree) {
     this.changesTree = changesTree;
   }
 
-  public void setChangesTree(OWALChangesTree changesTree) {
-    this.changesTree = changesTree;
-  }
-
   public static OLogSequenceNumber getLogSequenceNumberFromPage(ODirectMemoryPointer dataPointer) {
     final long segment = OLongSerializer.INSTANCE.deserializeFromDirectMemory(dataPointer, WAL_SEGMENT_OFFSET + PAGE_PADDING);
     final long position = OLongSerializer.INSTANCE.deserializeFromDirectMemory(dataPointer, WAL_POSITION_OFFSET + PAGE_PADDING);

core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/wal/OUpdatePageRecord.java

@@ -62,14 +62,6 @@ public int toStream(final byte[] content, int offset) {
   public int fromStream(final byte[] content, int offset) {
     offset = super.fromStream(content, offset);
 
-    final long position = OLongSerializer.INSTANCE.deserializeNative(content, offset);
-    offset += OLongSerializer.LONG_SIZE;
-
-    final long segment = OLongSerializer.INSTANCE.deserializeNative(content, offset);
-    offset += OLongSerializer.LONG_SIZE;
-
-    lsn = new OLogSequenceNumber(segment, position);
-
     changesTree = new OWALChangesTree();
     offset = changesTree.fromStream(offset, content);
 

core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/wal/OWALChangesTree.java

@@ -335,6 +335,8 @@ public int fromStream(int offset, byte[] stream) {
   public int toStream(int offset, byte[] stream) {
     OIntegerSerializer.INSTANCE.serializeNative(serializedSize, stream, offset);
     offset += OIntegerSerializer.INT_SIZE;
+    if (root == null)
+      return offset;
 
     offset = toStream(root, offset, stream);
 

core/src/test/java/com/orientechnologies/orient/core/storage/impl/local/paginated/LocalPaginatedClusterTest.java

@@ -172,7 +172,8 @@ public void testAddOneBigRecord() throws IOException {
   public void testAddManySmallRecords() throws IOException {
     final int records = 10000;
 
-    long seed = System.currentTimeMillis();
+    long seed = 1426587095601L;
+    System.currentTimeMillis();
     MersenneTwisterFast mersenneTwisterFast = new MersenneTwisterFast(seed);
     System.out.println("testAddManySmallRecords seed : " + seed);
 

core/src/test/java/com/orientechnologies/orient/core/storage/impl/local/paginated/LocalPaginatedClusterWithWAL.java

@@ -397,6 +397,9 @@ private void restoreClusterFromWAL() throws IOException {
           OCacheEntry cacheEntry = testDiskCache.load(fileId, pageIndex, true);
           if (cacheEntry == null) {
             do {
+              if (cacheEntry != null)
+                diskCache.release(cacheEntry);
+
               cacheEntry = testDiskCache.allocateNewPage(fileId);
             } while (cacheEntry.getPageIndex() != pageIndex);
           }