Abort directory stream after end JEP-349-branch
authoregahlin
Thu, 29 Aug 2019 19:31:57 +0200
branchJEP-349-branch
changeset 57947 5c8039344562
parent 57946 b77540d274f9
child 57948 59ad17a19e24
Abort directory stream after end
src/jdk.jfr/share/classes/jdk/jfr/consumer/EventDirectoryStream.java
--- a/src/jdk.jfr/share/classes/jdk/jfr/consumer/EventDirectoryStream.java	Thu Aug 29 19:30:32 2019 +0200
+++ b/src/jdk.jfr/share/classes/jdk/jfr/consumer/EventDirectoryStream.java	Thu Aug 29 19:31:57 2019 +0200
@@ -63,7 +63,7 @@
             super(acc, active);
             this.fileAccess = fileAccess;
             this.active = active;
-            repositoryFiles = new RepositoryFiles(fileAccess, p     );
+            repositoryFiles = new RepositoryFiles(fileAccess, p);
         }
 
         @Override
@@ -104,7 +104,7 @@
                         } else {
                             awaitnewEvent = processUnordered(awaitnewEvent);
                         }
-                        if (segmentStart > end) {
+                        if (chunkParser.getStartNanos() + chunkParser.getChunkDuration() > end) {
                             close();
                             return;
                         }