svn commit: r1767246 - /jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/FileStoreUtil.java

[frm]

Author: frm
Date: Mon Oct 31 10:57:38 2016
New Revision: 1767246

URL: http://svn.apache.org/viewvc?rev=1767246&view=rev
Log:
OAK-5034 - Set retry timeout to 20 seconds over 160 iterations

Contribution by Timothee Maret.

Modified:
    
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/FileStoreUtil.java

Modified: 
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/FileStoreUtil.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/FileStoreUtil.java?rev=1767246&r1=1767245&r2=1767246&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/FileStoreUtil.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/FileStoreUtil.java
 Mon Oct 31 10:57:38 2016
@@ -23,21 +23,26 @@ import org.apache.jackrabbit.oak.segment
 import org.apache.jackrabbit.oak.segment.SegmentId;
 import org.apache.jackrabbit.oak.segment.SegmentNotFoundException;
 import org.apache.jackrabbit.oak.segment.file.FileStore;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 class FileStoreUtil {
 
+    private static final Logger log = 
LoggerFactory.getLogger(FileStoreUtil.class);
+
     FileStoreUtil() {
         // Prevent instantiation
     }
 
     static Segment readSegmentWithRetry(FileStore store, SegmentId id) {
-        for (int i = 0; i < 10; i++) {
+        for (int i = 0; i < 160; i++) {
             try {
                 return store.readSegment(id);
             } catch (SegmentNotFoundException e) {
                 // Ignore this exception and wait
             }
             try {
+                log.trace("Unable to read segment, waiting...");
                 TimeUnit.MILLISECONDS.sleep(125);
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();