You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by mr...@apache.org on 2016/09/13 10:18:58 UTC

svn commit: r1760521 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java

Author: mreutegg
Date: Tue Sep 13 10:18:57 2016
New Revision: 1760521

URL: http://svn.apache.org/viewvc?rev=1760521&view=rev
Log:
OAK-4800: Log info message when background operation is successful again

Modified:
    jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java

Modified: jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java?rev=1760521&r1=1760520&r2=1760521&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java Tue Sep 13 10:18:57 2016
@@ -2583,6 +2583,7 @@ public final class DocumentNodeStore
         final WeakReference<DocumentNodeStore> ref;
         private final AtomicBoolean isDisposed;
         private final Supplier<Integer> delaySupplier;
+        private boolean failing;
 
         NodeStoreTask(final DocumentNodeStore nodeStore,
                       final AtomicBoolean isDisposed,
@@ -2623,7 +2624,13 @@ public final class DocumentNodeStore
                 if (nodeStore != null) {
                     try {
                         execute(nodeStore);
+                        if (failing) {
+                            LOG.info("Background operation {} successful again",
+                                    getClass().getSimpleName());
+                            failing = false;
+                        }
                     } catch (Throwable t) {
+                        failing = true;
                         LOG.warn("Background operation failed: " + t.toString(), t);
                     }
                     delay = delaySupplier.get();