package jdk.internal.jimage;
import java.io.IOException;
import java.io.InputStream;
import java.io.UncheckedIOException;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.IntBuffer;
import java.nio.file.Files;
import java.nio.file.attribute.BasicFileAttributes;
import java.nio.file.attribute.FileTime;
import java.nio.file.Path;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.function.Consumer;
public final class ImageReader implements AutoCloseable {
private final SharedImageReader reader;
private volatile boolean closed;
private ImageReader(SharedImageReader reader) {
this.reader = reader;
}
public static ImageReader open(Path imagePath, ByteOrder byteOrder) throws IOException {
Objects.requireNonNull(imagePath);
Objects.requireNonNull(byteOrder);
return SharedImageReader.open(imagePath, byteOrder);
}
public static ImageReader open(Path imagePath) throws IOException {
return open(imagePath, ByteOrder.nativeOrder());
}
@Override
public void close() throws IOException {
if (closed) {
throw new IOException("image file already closed");
}
reader.close(this);
closed = true;
}
private void ensureOpen() throws IOException {
if (closed) {
throw new IOException("image file closed");
}
}
private void requireOpen() {
if (closed) {
throw new IllegalStateException("image file closed");
}
}
public Directory getRootDirectory() throws IOException {
ensureOpen();
return reader.getRootDirectory();
}
public Node findNode(String name) throws IOException {
ensureOpen();
return reader.findNode(name);
}
public byte[] getResource(Node node) throws IOException {
ensureOpen();
return reader.getResource(node);
}
public byte[] getResource(Resource rs) throws IOException {
ensureOpen();
return reader.getResource(rs);
}
public ImageHeader () {
requireOpen();
return reader.getHeader();
}
public static void releaseByteBuffer(ByteBuffer buffer) {
BasicImageReader.releaseByteBuffer(buffer);
}
public String getName() {
requireOpen();
return reader.getName();
}
public ByteOrder getByteOrder() {
requireOpen();
return reader.getByteOrder();
}
public Path getImagePath() {
requireOpen();
return reader.getImagePath();
}
public ImageStringsReader getStrings() {
requireOpen();
return reader.getStrings();
}
public ImageLocation findLocation(String mn, String rn) {
requireOpen();
return reader.findLocation(mn, rn);
}
public ImageLocation findLocation(String name) {
requireOpen();
return reader.findLocation(name);
}
public String[] getEntryNames() {
requireOpen();
return reader.getEntryNames();
}
public String[] getModuleNames() {
requireOpen();
int off = "/modules/".length();
return reader.findNode("/modules")
.getChildren()
.stream()
.map(Node::getNameString)
.map(s -> s.substring(off, s.length()))
.toArray(String[]::new);
}
public long[] getAttributes(int offset) {
requireOpen();
return reader.getAttributes(offset);
}
public String getString(int offset) {
requireOpen();
return reader.getString(offset);
}
public byte[] getResource(String name) {
requireOpen();
return reader.getResource(name);
}
public byte[] getResource(ImageLocation loc) {
requireOpen();
return reader.getResource(loc);
}
public ByteBuffer getResourceBuffer(ImageLocation loc) {
requireOpen();
return reader.getResourceBuffer(loc);
}
public InputStream getResourceStream(ImageLocation loc) {
requireOpen();
return reader.getResourceStream(loc);
}
private final static class SharedImageReader extends BasicImageReader {
static final int SIZE_OF_OFFSET = Integer.BYTES;
static final Map<Path, SharedImageReader> OPEN_FILES = new HashMap<>();
final Set<ImageReader> openers;
BasicFileAttributes imageFileAttributes;
final HashMap<String, Node> nodes;
volatile Directory rootDir;
Directory packagesDir;
Directory modulesDir;
private SharedImageReader(Path imagePath, ByteOrder byteOrder) throws IOException {
super(imagePath, byteOrder);
this.openers = new HashSet<>();
this.nodes = new HashMap<>();
}
public static ImageReader open(Path imagePath, ByteOrder byteOrder) throws IOException {
Objects.requireNonNull(imagePath);
Objects.requireNonNull(byteOrder);
synchronized (OPEN_FILES) {
SharedImageReader reader = OPEN_FILES.get(imagePath);
if (reader == null) {
reader = new SharedImageReader(imagePath, byteOrder);
OPEN_FILES.put(imagePath, reader);
} else if (reader.getByteOrder() != byteOrder) {
throw new IOException("\"" + reader.getName() + "\" is not an image file");
}
ImageReader image = new ImageReader(reader);
reader.openers.add(image);
return image;
}
}
public void close(ImageReader image) throws IOException {
Objects.requireNonNull(image);
synchronized (OPEN_FILES) {
if (!openers.remove(image)) {
throw new IOException("image file already closed");
}
if (openers.isEmpty()) {
close();
nodes.clear();
rootDir = null;
if (!OPEN_FILES.remove(this.getImagePath(), this)) {
throw new IOException("image file not found in open list");
}
}
}
}
void addOpener(ImageReader reader) {
synchronized (OPEN_FILES) {
openers.add(reader);
}
}
boolean removeOpener(ImageReader reader) {
synchronized (OPEN_FILES) {
return openers.remove(reader);
}
}
Directory getRootDirectory() {
return buildRootDirectory();
}
synchronized Node buildNode(String name) {
Node n;
boolean isPackages = name.startsWith("/packages");
boolean isModules = !isPackages && name.startsWith("/modules");
if (!(isModules || isPackages)) {
return null;
}
ImageLocation loc = findLocation(name);
if (loc != null) {
if (isPackages) {
n = handlePackages(name, loc);
} else {
n = handleModulesSubTree(name, loc);
}
} else {
if (isModules) {
n = handleResource(name);
} else {
n = handleModuleLink(name);
}
}
return n;
}
synchronized Directory buildRootDirectory() {
Directory root = rootDir;
if (root != null) {
return root;
}
root = newDirectory(null, "/");
root.setIsRootDir();
packagesDir = newDirectory(root, "/packages");
packagesDir.setIsPackagesDir();
modulesDir = newDirectory(root, "/modules");
modulesDir.setIsModulesDir();
root.setCompleted(true);
return rootDir = root;
}
interface LocationVisitor {
void visit(ImageLocation loc);
}
void visitLocation(ImageLocation loc, LocationVisitor visitor) {
byte[] offsets = getResource(loc);
ByteBuffer buffer = ByteBuffer.wrap(offsets);
buffer.order(getByteOrder());
IntBuffer intBuffer = buffer.asIntBuffer();
for (int i = 0; i < offsets.length / SIZE_OF_OFFSET; i++) {
int offset = intBuffer.get(i);
ImageLocation pkgLoc = getLocation(offset);
visitor.visit(pkgLoc);
}
}
void visitPackageLocation(ImageLocation loc) {
String pkgName = getBaseExt(loc);
byte[] stringsOffsets = getResource(loc);
ByteBuffer buffer = ByteBuffer.wrap(stringsOffsets);
buffer.order(getByteOrder());
IntBuffer intBuffer = buffer.asIntBuffer();
for (int i = 0; i < stringsOffsets.length / SIZE_OF_OFFSET; i++) {
intBuffer.get(i);
i++;
int offset = intBuffer.get(i);
String moduleName = getString(offset);
Node targetNode = findNode("/modules/" + moduleName);
if (targetNode != null) {
String pkgDirName = packagesDir.getName() + "/" + pkgName;
Directory pkgDir = (Directory) nodes.get(pkgDirName);
newLinkNode(pkgDir, pkgDir.getName() + "/" + moduleName, targetNode);
}
}
}
Node handlePackages(String name, ImageLocation loc) {
long size = loc.getUncompressedSize();
Node n = null;
if (name.equals("/packages")) {
visitLocation(loc, (childloc) -> {
findNode(childloc.getFullName());
});
packagesDir.setCompleted(true);
n = packagesDir;
} else {
if (size != 0) {
String pkgName = getBaseExt(loc);
Directory pkgDir = newDirectory(packagesDir, packagesDir.getName() + "/" + pkgName);
visitPackageLocation(loc);
pkgDir.setCompleted(true);
n = pkgDir;
} else {
String pkgName = loc.getParent();
String modName = getBaseExt(loc);
Node targetNode = findNode("/modules/" + modName);
if (targetNode != null) {
String pkgDirName = packagesDir.getName() + "/" + pkgName;
Directory pkgDir = (Directory) nodes.get(pkgDirName);
Node linkNode = newLinkNode(pkgDir, pkgDir.getName() + "/" + modName, targetNode);
n = linkNode;
}
}
}
return n;
}
Node handleModuleLink(String name) {
Node ret = null;
String radical = "/packages/";
String path = name;
if (path.startsWith(radical)) {
int start = radical.length();
int pkgEnd = path.indexOf('/', start);
if (pkgEnd != -1) {
String pkg = path.substring(start, pkgEnd);
String pkgPath = radical + pkg;
Node n = findNode(pkgPath);
for (Node child : n.getChildren()) {
if (child.name.equals(name)) {
ret = child;
break;
}
}
}
}
return ret;
}
Node handleModulesSubTree(String name, ImageLocation loc) {
Node n;
assert (name.equals(loc.getFullName()));
Directory dir = makeDirectories(name);
visitLocation(loc, (childloc) -> {
String path = childloc.getFullName();
if (path.startsWith("/modules")) {
makeDirectories(path);
} else {
makeDirectories(childloc.buildName(true, true, false));
newResource(dir, childloc);
}
});
dir.setCompleted(true);
n = dir;
return n;
}
Node handleResource(String name) {
Node n = null;
String locationPath = name.substring("/modules".length());
ImageLocation resourceLoc = findLocation(locationPath);
if (resourceLoc != null) {
Directory dir = makeDirectories(resourceLoc.buildName(true, true, false));
Resource res = newResource(dir, resourceLoc);
n = res;
}
return n;
}
String getBaseExt(ImageLocation loc) {
String base = loc.getBase();
String ext = loc.getExtension();
if (ext != null && !ext.isEmpty()) {
base = base + "." + ext;
}
return base;
}
synchronized Node findNode(String name) {
buildRootDirectory();
Node n = nodes.get(name);
if (n == null || !n.isCompleted()) {
n = buildNode(name);
}
return n;
}
BasicFileAttributes imageFileAttributes() {
BasicFileAttributes attrs = imageFileAttributes;
if (attrs == null) {
try {
Path file = getImagePath();
attrs = Files.readAttributes(file, BasicFileAttributes.class);
} catch (IOException ioe) {
throw new UncheckedIOException(ioe);
}
imageFileAttributes = attrs;
}
return attrs;
}
Directory newDirectory(Directory parent, String name) {
Directory dir = Directory.create(parent, name, imageFileAttributes());
nodes.put(dir.getName(), dir);
return dir;
}
Resource newResource(Directory parent, ImageLocation loc) {
Resource res = Resource.create(parent, loc, imageFileAttributes());
nodes.put(res.getName(), res);
return res;
}
LinkNode newLinkNode(Directory dir, String name, Node link) {
LinkNode linkNode = LinkNode.create(dir, name, link);
nodes.put(linkNode.getName(), linkNode);
return linkNode;
}
Directory makeDirectories(String parent) {
Directory last = rootDir;
for (int offset = parent.indexOf('/', 1);
offset != -1;
offset = parent.indexOf('/', offset + 1)) {
String dir = parent.substring(0, offset);
last = makeDirectory(dir, last);
}
return makeDirectory(parent, last);
}
Directory makeDirectory(String dir, Directory last) {
Directory nextDir = (Directory) nodes.get(dir);
if (nextDir == null) {
nextDir = newDirectory(last, dir);
}
return nextDir;
}
byte[] getResource(Node node) throws IOException {
if (node.isResource()) {
return super.getResource(node.getLocation());
}
throw new IOException("Not a resource: " + node);
}
byte[] getResource(Resource rs) throws IOException {
return super.getResource(rs.getLocation());
}
}
public abstract static class Node {
private static final int ROOT_DIR = 0b0000_0000_0000_0001;
private static final int PACKAGES_DIR = 0b0000_0000_0000_0010;
private static final int MODULES_DIR = 0b0000_0000_0000_0100;
private int flags;
private final String name;
private final BasicFileAttributes fileAttrs;
private boolean completed;
protected Node(String name, BasicFileAttributes fileAttrs) {
this.name = Objects.requireNonNull(name);
this.fileAttrs = Objects.requireNonNull(fileAttrs);
}
public boolean isCompleted() {
return completed;
}
public void setCompleted(boolean completed) {
this.completed = completed;
}
public final void setIsRootDir() {
flags |= ROOT_DIR;
}
public final boolean isRootDir() {
return (flags & ROOT_DIR) != 0;
}
public final void setIsPackagesDir() {
flags |= PACKAGES_DIR;
}
public final boolean isPackagesDir() {
return (flags & PACKAGES_DIR) != 0;
}
public final void setIsModulesDir() {
flags |= MODULES_DIR;
}
public final boolean isModulesDir() {
return (flags & MODULES_DIR) != 0;
}
public final String getName() {
return name;
}
public final BasicFileAttributes getFileAttributes() {
return fileAttrs;
}
public final Node resolveLink() {
return resolveLink(false);
}
public Node resolveLink(boolean recursive) {
return this;
}
public boolean isLink() {
return false;
}
public boolean isDirectory() {
return false;
}
public List<Node> getChildren() {
throw new IllegalArgumentException("not a directory: " + getNameString());
}
public boolean isResource() {
return false;
}
public ImageLocation getLocation() {
throw new IllegalArgumentException("not a resource: " + getNameString());
}
public long size() {
return 0L;
}
public long compressedSize() {
return 0L;
}
public String extension() {
return null;
}
public long contentOffset() {
return 0L;
}
public final FileTime creationTime() {
return fileAttrs.creationTime();
}
public final FileTime lastAccessTime() {
return fileAttrs.lastAccessTime();
}
public final FileTime lastModifiedTime() {
return fileAttrs.lastModifiedTime();
}
public final String getNameString() {
return name;
}
@Override
public final String toString() {
return getNameString();
}
@Override
public final int hashCode() {
return name.hashCode();
}
@Override
public final boolean equals(Object other) {
if (this == other) {
return true;
}
if (other instanceof Node) {
return name.equals(((Node) other).name);
}
return false;
}
}
static final class Directory extends Node {
private final List<Node> children;
private Directory(String name, BasicFileAttributes fileAttrs) {
super(name, fileAttrs);
children = new ArrayList<>();
}
static Directory create(Directory parent, String name, BasicFileAttributes fileAttrs) {
Directory d = new Directory(name, fileAttrs);
if (parent != null) {
parent.addChild(d);
}
return d;
}
@Override
public boolean isDirectory() {
return true;
}
@Override
public List<Node> getChildren() {
return Collections.unmodifiableList(children);
}
void addChild(Node node) {
children.add(node);
}
public void walk(Consumer<? super Node> consumer) {
consumer.accept(this);
for ( Node child : children ) {
if (child.isDirectory()) {
((Directory)child).walk(consumer);
} else {
consumer.accept(child);
}
}
}
}
static class Resource extends Node {
private final ImageLocation loc;
private Resource(ImageLocation loc, BasicFileAttributes fileAttrs) {
super(loc.getFullName(true), fileAttrs);
this.loc = loc;
}
static Resource create(Directory parent, ImageLocation loc, BasicFileAttributes fileAttrs) {
Resource rs = new Resource(loc, fileAttrs);
parent.addChild(rs);
return rs;
}
@Override
public boolean isCompleted() {
return true;
}
@Override
public boolean isResource() {
return true;
}
@Override
public ImageLocation getLocation() {
return loc;
}
@Override
public long size() {
return loc.getUncompressedSize();
}
@Override
public long compressedSize() {
return loc.getCompressedSize();
}
@Override
public String extension() {
return loc.getExtension();
}
@Override
public long contentOffset() {
return loc.getContentOffset();
}
}
static class LinkNode extends Node {
private final Node link;
private LinkNode(String name, Node link) {
super(name, link.getFileAttributes());
this.link = link;
}
static LinkNode create(Directory parent, String name, Node link) {
LinkNode ln = new LinkNode(name, link);
parent.addChild(ln);
return ln;
}
@Override
public boolean isCompleted() {
return true;
}
@Override
public Node resolveLink(boolean recursive) {
return (recursive && link instanceof LinkNode) ? ((LinkNode)link).resolveLink(true) : link;
}
@Override
public boolean isLink() {
return true;
}
}
}