svn commit: r1729821 - in /jackrabbit/oak/trunk: oak-segment/src/main/java/org/apache/jackrabbit/oak/plugins/segment/file/FileStore.java oak-tarmk-standby/src/main/java/org/apache/jackrabbit/oak/plugins/segment/standby/store/StandbyStore.java

[frm]

Author: frm
Date: Thu Feb 11 13:19:27 2016
New Revision: 1729821

URL: http://svn.apache.org/viewvc?rev=1729821&view=rev
Log:
OAK-4004 - The cold standby segment store should delete the files marked for 
deletion

Modified:
    
jackrabbit/oak/trunk/oak-segment/src/main/java/org/apache/jackrabbit/oak/plugins/segment/file/FileStore.java
    
jackrabbit/oak/trunk/oak-tarmk-standby/src/main/java/org/apache/jackrabbit/oak/plugins/segment/standby/store/StandbyStore.java

Modified: 
jackrabbit/oak/trunk/oak-segment/src/main/java/org/apache/jackrabbit/oak/plugins/segment/file/FileStore.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment/src/main/java/org/apache/jackrabbit/oak/plugins/segment/file/FileStore.java?rev=1729821&r1=1729820&r2=1729821&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-segment/src/main/java/org/apache/jackrabbit/oak/plugins/segment/file/FileStore.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-segment/src/main/java/org/apache/jackrabbit/oak/plugins/segment/file/FileStore.java
 Thu Feb 11 13:19:27 2016
@@ -794,10 +794,13 @@ public class FileStore implements Segmen
     }
 
     public void flush() throws IOException {
+        flush(cleanupNeeded.getAndSet(false));
+    }
+
+    public void flush(boolean cleanup) throws IOException {
         synchronized (persistedHead) {
             RecordId before = persistedHead.get();
             RecordId after = head.get();
-            boolean cleanup = cleanupNeeded.getAndSet(false);
 
             if (cleanup || !after.equals(before)) {
                 // needs to happen outside the synchronization block below to

Modified: 
jackrabbit/oak/trunk/oak-tarmk-standby/src/main/java/org/apache/jackrabbit/oak/plugins/segment/standby/store/StandbyStore.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-tarmk-standby/src/main/java/org/apache/jackrabbit/oak/plugins/segment/standby/store/StandbyStore.java?rev=1729821&r1=1729820&r2=1729821&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-tarmk-standby/src/main/java/org/apache/jackrabbit/oak/plugins/segment/standby/store/StandbyStore.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-tarmk-standby/src/main/java/org/apache/jackrabbit/oak/plugins/segment/standby/store/StandbyStore.java
 Thu Feb 11 13:19:27 2016
@@ -246,7 +246,7 @@ public class StandbyStore implements Seg
         if (delegate instanceof FileStore) {
             try {
                 delegate.getTracker().getWriter().dropCache();
-                ((FileStore) delegate).cleanup();
+                ((FileStore) delegate).flush(true);
             } catch (IOException e) {
                 log.error("Error running cleanup", e);
             }