Skip to content

Commit d332e0a

Browse files
Update disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/Storage.java
Co-authored-by: Jay DeLuca <jaydeluca4@gmail.com>
1 parent 052794f commit d332e0a

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

  • disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/Storage.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,7 @@ public final class Storage<T> implements Closeable {
2929
private static final int MAX_ATTEMPTS = 3;
3030
private final Logger logger = Logger.getLogger(Storage.class.getName());
3131
private final FolderManager folderManager;
32-
private final AtomicReference<Predicate<FolderManager.CacheFile>> fileExclusion =
33-
new AtomicReference<>(file -> false);
32+
private volatile Predicate<FolderManager.CacheFile> fileExclusion = file -> false;
3433
private final AtomicBoolean isClosed = new AtomicBoolean(false);
3534
private final AtomicBoolean activeReadResultAvailable = new AtomicBoolean(false);
3635
private final AtomicReference<WritableFile> writableFileRef = new AtomicReference<>();

0 commit comments

Comments
 (0)