Track FS close

Author: aloubyansky

core/deployment/src/main/java/io/quarkus/deployment/pkg/steps/JarTreeShakeInput.java

@@ -712,7 +712,8 @@ public byte[] get() {
                 return is.readAllBytes();
             } catch (IOException e) {
                 throw new UncheckedIOException("Failed to read bytecode " + path
-                        + " (fileSystem.isOpen=" + path.getFileSystem().isOpen() + ")", e);
+                        + " (fileSystem.isOpen=" + path.getFileSystem().isOpen()
+                        + ", interrupted=" + Thread.currentThread().isInterrupted() + ")", e);
             }
         }
     }

independent-projects/bootstrap/app-model/src/main/java/io/quarkus/paths/ArchivePathTree.java

@@ -282,8 +282,8 @@ protected class OpenArchivePathTree extends OpenContainerPathTree {
 
         protected OpenArchivePathTree(FileSystem fs) {
             super(ArchivePathTree.this.pathFilter, ArchivePathTree.this);
-            this.fs = fs;
-            this.rootPath = fs.getPath("/");
+            this.fs = CloseTrapFileSystem.wrapIfTraced(fs, ArchivePathTree.this.archive);
+            this.rootPath = this.fs.getPath("/");
         }
 
         @Override

independent-projects/bootstrap/app-model/src/main/java/io/quarkus/paths/CloseTrapFileSystem.java

@@ -0,0 +1,106 @@
+package io.quarkus.paths;
+
+import java.io.IOException;
+import java.nio.file.FileStore;
+import java.nio.file.FileSystem;
+import java.nio.file.Path;
+import java.nio.file.PathMatcher;
+import java.nio.file.WatchService;
+import java.nio.file.attribute.UserPrincipalLookupService;
+import java.nio.file.spi.FileSystemProvider;
+import java.util.Set;
+
+import org.jboss.logging.Logger;
+
+/**
+ * Debug wrapper that intercepts {@link FileSystem#close()} to log
+ * the stack trace of the caller. Used to diagnose unexpected
+ * {@code ClosedChannelException} on shared ZipFileSystems.
+ * <p>
+ * Only wraps archives matching a trace filter (currently jboss-threads)
+ * to avoid overhead in production.
+ */
+class CloseTrapFileSystem extends FileSystem {
+
+    private static final Logger log = Logger.getLogger(CloseTrapFileSystem.class);
+
+    private final FileSystem delegate;
+    private final Path archive;
+
+    static FileSystem wrapIfTraced(FileSystem fs, Path archive) {
+        if (archive.toString().contains("jboss-threads")) {
+            return new CloseTrapFileSystem(fs, archive);
+        }
+        return fs;
+    }
+
+    private CloseTrapFileSystem(FileSystem delegate, Path archive) {
+        this.delegate = delegate;
+        this.archive = archive;
+    }
+
+    @Override
+    public void close() throws IOException {
+        log.warnf(new Exception("CloseTrapFileSystem.close() stack trace"),
+                "ZipFS.close() called for %s on thread %s",
+                archive, Thread.currentThread().getName());
+        delegate.close();
+    }
+
+    // --- pure delegation below ---
+
+    @Override
+    public FileSystemProvider provider() {
+        return delegate.provider();
+    }
+
+    @Override
+    public boolean isOpen() {
+        return delegate.isOpen();
+    }
+
+    @Override
+    public boolean isReadOnly() {
+        return delegate.isReadOnly();
+    }
+
+    @Override
+    public String getSeparator() {
+        return delegate.getSeparator();
+    }
+
+    @Override
+    public Iterable<Path> getRootDirectories() {
+        return delegate.getRootDirectories();
+    }
+
+    @Override
+    public Iterable<FileStore> getFileStores() {
+        return delegate.getFileStores();
+    }
+
+    @Override
+    public Set<String> supportedFileAttributeViews() {
+        return delegate.supportedFileAttributeViews();
+    }
+
+    @Override
+    public Path getPath(String first, String... more) {
+        return delegate.getPath(first, more);
+    }
+
+    @Override
+    public PathMatcher getPathMatcher(String syntaxAndPattern) {
+        return delegate.getPathMatcher(syntaxAndPattern);
+    }
+
+    @Override
+    public UserPrincipalLookupService getUserPrincipalLookupService() {
+        return delegate.getUserPrincipalLookupService();
+    }
+
+    @Override
+    public WatchService newWatchService() throws IOException {
+        return delegate.newWatchService();
+    }
+}