equal
deleted
inserted
replaced
20 * |
20 * |
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
22 * or visit www.oracle.com if you need additional information or have any |
22 * or visit www.oracle.com if you need additional information or have any |
23 * questions. |
23 * questions. |
24 */ |
24 */ |
|
25 |
25 package jdk.jfr.internal.consumer; |
26 package jdk.jfr.internal.consumer; |
26 |
27 |
27 import java.io.IOException; |
28 import java.io.IOException; |
28 import java.nio.file.DirectoryStream; |
29 import java.nio.file.DirectoryStream; |
29 import java.nio.file.Path; |
30 import java.nio.file.Path; |
54 |
55 |
55 private final FileAccess fileAccess; |
56 private final FileAccess fileAccess; |
56 private final NavigableMap<Long, Path> pathSet = new TreeMap<>(); |
57 private final NavigableMap<Long, Path> pathSet = new TreeMap<>(); |
57 private final Map<Path, Long> pathLookup = new HashMap<>(); |
58 private final Map<Path, Long> pathLookup = new HashMap<>(); |
58 private final Path repository; |
59 private final Path repository; |
|
60 private final Object waitObject; |
|
61 |
59 private volatile boolean closed; |
62 private volatile boolean closed; |
60 private final Object waitObject; |
|
61 |
63 |
62 RepositoryFiles(FileAccess fileAccess, Path repository) { |
64 RepositoryFiles(FileAccess fileAccess, Path repository) { |
63 this.repository = repository; |
65 this.repository = repository; |
64 this.fileAccess = fileAccess; |
66 this.fileAccess = fileAccess; |
65 this.waitObject = repository == null ? WAIT_OBJECT : new Object(); |
67 this.waitObject = repository == null ? WAIT_OBJECT : new Object(); |