Skip to content

Commit c10ce8d

Browse files
committed
OAK-11560 rename method, make configuration private
1 parent 15b46e2 commit c10ce8d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

oak-segment-remote/src/main/java/org/apache/jackrabbit/oak/segment/remote/persistentcache/PersistentDiskCache.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public class PersistentDiskCache extends AbstractPersistentCache {
6060
public static final long DEFAULT_TEMP_FILES_CLEANUP_WAIT_TIME_MS = 60000;
6161
private static final String TEMP_FILE_SUFFIX = ".part";
6262

63-
public static boolean DELETE_SEGMENT_ON_REFETCH = Boolean.getBoolean("oak.segment.cache.delete_segment_on_refetch");
63+
private static boolean DELETE_SEGMENT_ON_REFETCH = Boolean.getBoolean("oak.segment.cache.delete_segment_on_refetch");
6464

6565
private final File directory;
6666
private final long maxCacheSizeBytes;
@@ -165,7 +165,7 @@ public void writeSegment(long msb, long lsb, Buffer buffer) {
165165
diskCacheIOMonitor.updateCacheSize(cacheSizeAfter, fileSize);
166166
} catch (FileAlreadyExistsException faee) {
167167
if (DELETE_SEGMENT_ON_REFETCH) {
168-
writeSegmentExceptionHandler(segmentId, segmentFile, tempSegmentFile, faee);
168+
deleteSegmentAndTempSegment(segmentId, segmentFile, tempSegmentFile, faee);
169169
} else {
170170
// just delete the temp file, as the target segment file is already there and valid
171171
try {
@@ -176,7 +176,7 @@ public void writeSegment(long msb, long lsb, Buffer buffer) {
176176
}
177177
}
178178
} catch (Exception e) {
179-
writeSegmentExceptionHandler(segmentId, segmentFile, tempSegmentFile, e);
179+
deleteSegmentAndTempSegment(segmentId, segmentFile, tempSegmentFile, e);
180180
} finally {
181181
writesPending.remove(segmentId);
182182
}
@@ -187,7 +187,7 @@ public void writeSegment(long msb, long lsb, Buffer buffer) {
187187
executor.execute(task);
188188
}
189189

190-
private void writeSegmentExceptionHandler(String segmentId, File segmentFile, File tempSegmentFile, Exception e) {
190+
private void deleteSegmentAndTempSegment(String segmentId, File segmentFile, File tempSegmentFile, Exception e) {
191191
logger.error("Error writing segment {} to cache", segmentId, e);
192192
try {
193193
Files.deleteIfExists(segmentFile.toPath());

0 commit comments

Comments
 (0)