提交 e871a245 编写于 作者: J jjg

6988106: javac report 'java.lang.IllegalMonitorStateException'

Reviewed-by: ksrini
上级 9d919669
/* /*
* Copyright (c) 2005, 2008, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2005, 2011, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
...@@ -28,11 +28,11 @@ package com.sun.tools.javac.file; ...@@ -28,11 +28,11 @@ package com.sun.tools.javac.file;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.util.List; import java.util.List;
import com.sun.tools.javac.util.Context;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import com.sun.tools.javac.util.Context;
/** /**
* Caching implementation of FSInfo. * Caching implementation of FSInfo.
* *
......
...@@ -76,8 +76,6 @@ import static com.sun.tools.javac.main.OptionName.*; ...@@ -76,8 +76,6 @@ import static com.sun.tools.javac.main.OptionName.*;
*/ */
public class JavacFileManager extends BaseFileManager implements StandardJavaFileManager { public class JavacFileManager extends BaseFileManager implements StandardJavaFileManager {
boolean useZipFileIndex;
public static char[] toArray(CharBuffer buffer) { public static char[] toArray(CharBuffer buffer) {
if (buffer.hasArray()) if (buffer.hasArray())
return ((CharBuffer)buffer.compact().flip()).array(); return ((CharBuffer)buffer.compact().flip()).array();
...@@ -91,6 +89,9 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil ...@@ -91,6 +89,9 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil
private FSInfo fsInfo; private FSInfo fsInfo;
private boolean useZipFileIndex;
private ZipFileIndexCache zipFileIndexCache;
private final File uninited = new File("U N I N I T E D"); private final File uninited = new File("U N I N I T E D");
private final Set<JavaFileObject.Kind> sourceOrClass = private final Set<JavaFileObject.Kind> sourceOrClass =
...@@ -163,7 +164,11 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil ...@@ -163,7 +164,11 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil
fsInfo = FSInfo.instance(context); fsInfo = FSInfo.instance(context);
useZipFileIndex = System.getProperty("useJavaUtilZip") == null;// TODO: options.get("useJavaUtilZip") == null; // retain check for system property for compatibility
useZipFileIndex = options.isUnset("useJavaUtilZip")
&& System.getProperty("useJavaUtilZip") == null;
if (useZipFileIndex)
zipFileIndexCache = ZipFileIndexCache.getSharedInstance();
mmappedIO = options.isSet("mmappedIO"); mmappedIO = options.isSet("mmappedIO");
ignoreSymbolFile = options.isSet("ignore.symbol.file"); ignoreSymbolFile = options.isSet("ignore.symbol.file");
...@@ -526,7 +531,7 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil ...@@ -526,7 +531,7 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil
archive = new ZipArchive(this, zdir); archive = new ZipArchive(this, zdir);
} else { } else {
archive = new ZipFileIndexArchive(this, archive = new ZipFileIndexArchive(this,
ZipFileIndex.getZipFileIndex(zipFileName, zipFileIndexCache.getZipFileIndex(zipFileName,
null, null,
usePreindexedCache, usePreindexedCache,
preindexCacheLocation, preindexCacheLocation,
...@@ -538,7 +543,7 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil ...@@ -538,7 +543,7 @@ public class JavacFileManager extends BaseFileManager implements StandardJavaFil
} }
else { else {
archive = new ZipFileIndexArchive(this, archive = new ZipFileIndexArchive(this,
ZipFileIndex.getZipFileIndex(zipFileName, zipFileIndexCache.getZipFileIndex(zipFileName,
symbolFilePrefix, symbolFilePrefix,
usePreindexedCache, usePreindexedCache,
preindexCacheLocation, preindexCacheLocation,
......
/* /*
* Copyright (c) 2007, 2008, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2007, 2011, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
...@@ -38,11 +38,9 @@ import java.util.Calendar; ...@@ -38,11 +38,9 @@ import java.util.Calendar;
import java.util.Collections; import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.concurrent.locks.ReentrantLock;
import java.util.zip.DataFormatException; import java.util.zip.DataFormatException;
import java.util.zip.Inflater; import java.util.zip.Inflater;
import java.util.zip.ZipException; import java.util.zip.ZipException;
...@@ -50,24 +48,28 @@ import java.util.zip.ZipException; ...@@ -50,24 +48,28 @@ import java.util.zip.ZipException;
import com.sun.tools.javac.file.RelativePath.RelativeDirectory; import com.sun.tools.javac.file.RelativePath.RelativeDirectory;
import com.sun.tools.javac.file.RelativePath.RelativeFile; import com.sun.tools.javac.file.RelativePath.RelativeFile;
/** This class implements building of index of a zip archive and access to it's context. /**
* It also uses prebuild index if available. It supports invocations where it will * This class implements the building of index of a zip archive and access to
* serialize an optimized zip index file to disk. * its context. It also uses a prebuilt index if available.
* It supports invocations where it will serialize an optimized zip index file
* to disk.
* *
* In oreder to use secondary index file make sure the option "usezipindex" is in the Options object, * In order to use a secondary index file, set "usezipindex" in the Options
* when JavacFileManager is invoked. (You can pass "-XDusezipindex" on the command line. * object when JavacFileManager is invoked. (You can pass "-XDusezipindex" on
* the command line.)
* *
* Location where to look for/generate optimized zip index files can be provided using * Location where to look for/generate optimized zip index files can be
* "-XDcachezipindexdir=<directory>". If this flag is not provided, the dfault location is * provided using "-XDcachezipindexdir=<directory>". If this flag is not
* the value of the "java.io.tmpdir" system property. * provided, the default location is the value of the "java.io.tmpdir" system
* property.
* *
* If key "-XDwritezipindexfiles" is specified, there will be new optimized index file * If "-XDwritezipindexfiles" is specified, there will be new optimized index
* created for each archive, used by the compiler for compilation, at location, * file created for each archive, used by the compiler for compilation, at the
* specified by "cachezipindexdir" option. * location specified by the "cachezipindexdir" option.
* *
* If nonBatchMode option is specified (-XDnonBatchMode) the compiler will use timestamp * If system property nonBatchMode option is specified the compiler will use
* checking to reindex the zip files if it is needed. In batch mode the timestamps are not checked * timestamp checking to reindex the zip files if it is needed. In batch mode
* and the compiler uses the cached indexes. * the timestamps are not checked and the compiler uses the cached indexes.
* *
* <p><b>This is NOT part of any supported API. * <p><b>This is NOT part of any supported API.
* If you write code that depends on this, you do so at your own risk. * If you write code that depends on this, you do so at your own risk.
...@@ -80,18 +82,18 @@ public class ZipFileIndex { ...@@ -80,18 +82,18 @@ public class ZipFileIndex {
public final static long NOT_MODIFIED = Long.MIN_VALUE; public final static long NOT_MODIFIED = Long.MIN_VALUE;
private static Map<File, ZipFileIndex> zipFileIndexCache = new HashMap<File, ZipFileIndex>();
private static ReentrantLock lock = new ReentrantLock();
private static boolean NON_BATCH_MODE = System.getProperty("nonBatchMode") != null;// TODO: Use -XD compiler switch for this. private static boolean NON_BATCH_MODE = System.getProperty("nonBatchMode") != null;// TODO: Use -XD compiler switch for this.
private Map<RelativeDirectory, DirectoryEntry> directories = Collections.<RelativeDirectory, DirectoryEntry>emptyMap(); private Map<RelativeDirectory, DirectoryEntry> directories =
private Set<RelativeDirectory> allDirs = Collections.<RelativeDirectory>emptySet(); Collections.<RelativeDirectory, DirectoryEntry>emptyMap();
private Set<RelativeDirectory> allDirs =
Collections.<RelativeDirectory>emptySet();
// ZipFileIndex data entries // ZipFileIndex data entries
private File zipFile; final File zipFile;
private Reference<File> absFileRef; private Reference<File> absFileRef;
private long zipFileLastModified = NOT_MODIFIED; long zipFileLastModified = NOT_MODIFIED;
private RandomAccessFile zipRandomFile; private RandomAccessFile zipRandomFile;
private Entry[] entries; private Entry[] entries;
...@@ -99,156 +101,24 @@ public class ZipFileIndex { ...@@ -99,156 +101,24 @@ public class ZipFileIndex {
private File zipIndexFile = null; private File zipIndexFile = null;
private boolean triedToReadIndex = false; private boolean triedToReadIndex = false;
final RelativeDirectory symbolFilePrefix; final RelativeDirectory symbolFilePrefix;
private int symbolFilePrefixLength = 0; private final int symbolFilePrefixLength;
private boolean hasPopulatedData = false; private boolean hasPopulatedData = false;
private long lastReferenceTimeStamp = NOT_MODIFIED; long lastReferenceTimeStamp = NOT_MODIFIED;
private boolean usePreindexedCache = false; private final boolean usePreindexedCache;
private String preindexedCacheLocation = null; private final String preindexedCacheLocation;
private boolean writeIndex = false; private boolean writeIndex = false;
private Map <String, SoftReference<RelativeDirectory>> relativeDirectoryCache = private Map<String, SoftReference<RelativeDirectory>> relativeDirectoryCache =
new HashMap<String, SoftReference<RelativeDirectory>>(); new HashMap<String, SoftReference<RelativeDirectory>>();
/**
* Returns a list of all ZipFileIndex entries
*
* @return A list of ZipFileIndex entries, or an empty list
*/
public static List<ZipFileIndex> getZipFileIndexes() {
return getZipFileIndexes(false);
}
/**
* Returns a list of all ZipFileIndex entries
*
* @param openedOnly If true it returns a list of only opened ZipFileIndex entries, otherwise
* all ZipFileEntry(s) are included into the list.
* @return A list of ZipFileIndex entries, or an empty list
*/
public static List<ZipFileIndex> getZipFileIndexes(boolean openedOnly) {
List<ZipFileIndex> zipFileIndexes = new ArrayList<ZipFileIndex>();
lock.lock();
try {
zipFileIndexes.addAll(zipFileIndexCache.values());
if (openedOnly) {
for(ZipFileIndex elem : zipFileIndexes) {
if (!elem.isOpen()) {
zipFileIndexes.remove(elem);
}
}
}
}
finally {
lock.unlock();
}
return zipFileIndexes;
}
public boolean isOpen() {
lock.lock();
try {
return zipRandomFile != null;
}
finally {
lock.unlock();
}
}
public static ZipFileIndex getZipFileIndex(File zipFile,
RelativeDirectory symbolFilePrefix,
boolean useCache, String cacheLocation,
boolean writeIndex) throws IOException {
ZipFileIndex zi = null;
lock.lock();
try {
zi = getExistingZipIndex(zipFile);
if (zi == null || (zi != null && zipFile.lastModified() != zi.zipFileLastModified)) {
zi = new ZipFileIndex(zipFile, symbolFilePrefix, writeIndex,
useCache, cacheLocation);
zipFileIndexCache.put(zipFile, zi);
}
}
finally {
lock.unlock();
}
return zi;
}
public static ZipFileIndex getExistingZipIndex(File zipFile) { public synchronized boolean isOpen() {
lock.lock(); return (zipRandomFile != null);
try {
return zipFileIndexCache.get(zipFile);
}
finally {
lock.unlock();
}
} }
public static void clearCache() { ZipFileIndex(File zipFile, RelativeDirectory symbolFilePrefix, boolean writeIndex,
lock.lock();
try {
zipFileIndexCache.clear();
}
finally {
lock.unlock();
}
}
public static void clearCache(long timeNotUsed) {
lock.lock();
try {
Iterator<File> cachedFileIterator = zipFileIndexCache.keySet().iterator();
while (cachedFileIterator.hasNext()) {
File cachedFile = cachedFileIterator.next();
ZipFileIndex cachedZipIndex = zipFileIndexCache.get(cachedFile);
if (cachedZipIndex != null) {
long timeToTest = cachedZipIndex.lastReferenceTimeStamp + timeNotUsed;
if (timeToTest < cachedZipIndex.lastReferenceTimeStamp || // Overflow...
System.currentTimeMillis() > timeToTest) {
zipFileIndexCache.remove(cachedFile);
}
}
}
}
finally {
lock.unlock();
}
}
public static void removeFromCache(File file) {
lock.lock();
try {
zipFileIndexCache.remove(file);
}
finally {
lock.unlock();
}
}
/** Sets already opened list of ZipFileIndexes from an outside client
* of the compiler. This functionality should be used in a non-batch clients of the compiler.
*/
public static void setOpenedIndexes(List<ZipFileIndex>indexes) throws IllegalStateException {
lock.lock();
try {
if (zipFileIndexCache.isEmpty()) {
throw new IllegalStateException("Setting opened indexes should be called only when the ZipFileCache is empty. Call JavacFileManager.flush() before calling this method.");
}
for (ZipFileIndex zfi : indexes) {
zipFileIndexCache.put(zfi.zipFile, zfi);
}
}
finally {
lock.unlock();
}
}
private ZipFileIndex(File zipFile, RelativeDirectory symbolFilePrefix, boolean writeIndex,
boolean useCache, String cacheLocation) throws IOException { boolean useCache, String cacheLocation) throws IOException {
this.zipFile = zipFile; this.zipFile = zipFile;
this.symbolFilePrefix = symbolFilePrefix; this.symbolFilePrefix = symbolFilePrefix;
...@@ -266,19 +136,22 @@ public class ZipFileIndex { ...@@ -266,19 +136,22 @@ public class ZipFileIndex {
checkIndex(); checkIndex();
} }
@Override
public String toString() { public String toString() {
return "ZipFileIndex[" + zipFile + "]"; return "ZipFileIndex[" + zipFile + "]";
} }
// Just in case... // Just in case...
protected void finalize() { @Override
protected void finalize() throws Throwable {
closeFile(); closeFile();
super.finalize();
} }
private boolean isUpToDate() { private boolean isUpToDate() {
if (zipFile != null && if (zipFile != null
((!NON_BATCH_MODE) || zipFileLastModified == zipFile.lastModified()) && && ((!NON_BATCH_MODE) || zipFileLastModified == zipFile.lastModified())
hasPopulatedData) { && hasPopulatedData) {
return true; return true;
} }
...@@ -339,16 +212,10 @@ public class ZipFileIndex { ...@@ -339,16 +212,10 @@ public class ZipFileIndex {
allDirs = Collections.<RelativeDirectory>emptySet(); allDirs = Collections.<RelativeDirectory>emptySet();
} }
public void close() { public synchronized void close() {
lock.lock();
try {
writeIndex(); writeIndex();
closeFile(); closeFile();
} }
finally {
lock.unlock();
}
}
private void closeFile() { private void closeFile() {
if (zipRandomFile != null) { if (zipRandomFile != null) {
...@@ -361,29 +228,24 @@ public class ZipFileIndex { ...@@ -361,29 +228,24 @@ public class ZipFileIndex {
} }
/** /**
* Returns the ZipFileIndexEntry for an absolute path, if there is one. * Returns the ZipFileIndexEntry for a path, if there is one.
*/ */
Entry getZipIndexEntry(RelativePath path) { synchronized Entry getZipIndexEntry(RelativePath path) {
lock.lock();
try { try {
checkIndex(); checkIndex();
DirectoryEntry de = directories.get(path.dirname()); DirectoryEntry de = directories.get(path.dirname());
String lookFor = path.basename(); String lookFor = path.basename();
return de == null ? null : de.getEntry(lookFor); return (de == null) ? null : de.getEntry(lookFor);
} }
catch (IOException e) { catch (IOException e) {
return null; return null;
} }
finally {
lock.unlock();
}
} }
/** /**
* Returns a javac List of filenames within an absolute path in the ZipFileIndex. * Returns a javac List of filenames within a directory in the ZipFileIndex.
*/ */
public com.sun.tools.javac.util.List<String> getFiles(RelativeDirectory path) { public synchronized com.sun.tools.javac.util.List<String> getFiles(RelativeDirectory path) {
lock.lock();
try { try {
checkIndex(); checkIndex();
...@@ -398,13 +260,9 @@ public class ZipFileIndex { ...@@ -398,13 +260,9 @@ public class ZipFileIndex {
catch (IOException e) { catch (IOException e) {
return com.sun.tools.javac.util.List.<String>nil(); return com.sun.tools.javac.util.List.<String>nil();
} }
finally {
lock.unlock();
}
} }
public List<String> getDirectories(RelativeDirectory path) { public synchronized List<String> getDirectories(RelativeDirectory path) {
lock.lock();
try { try {
checkIndex(); checkIndex();
...@@ -420,13 +278,9 @@ public class ZipFileIndex { ...@@ -420,13 +278,9 @@ public class ZipFileIndex {
catch (IOException e) { catch (IOException e) {
return com.sun.tools.javac.util.List.<String>nil(); return com.sun.tools.javac.util.List.<String>nil();
} }
finally {
lock.unlock();
}
} }
public Set<RelativeDirectory> getAllDirectories() { public synchronized Set<RelativeDirectory> getAllDirectories() {
lock.lock();
try { try {
checkIndex(); checkIndex();
if (allDirs == Collections.EMPTY_SET) { if (allDirs == Collections.EMPTY_SET) {
...@@ -438,9 +292,6 @@ public class ZipFileIndex { ...@@ -438,9 +292,6 @@ public class ZipFileIndex {
catch (IOException e) { catch (IOException e) {
return Collections.<RelativeDirectory>emptySet(); return Collections.<RelativeDirectory>emptySet();
} }
finally {
lock.unlock();
}
} }
/** /**
...@@ -450,8 +301,7 @@ public class ZipFileIndex { ...@@ -450,8 +301,7 @@ public class ZipFileIndex {
* @param path A path within the zip. * @param path A path within the zip.
* @return True if the path is a file or dir, false otherwise. * @return True if the path is a file or dir, false otherwise.
*/ */
public boolean contains(RelativePath path) { public synchronized boolean contains(RelativePath path) {
lock.lock();
try { try {
checkIndex(); checkIndex();
return getZipIndexEntry(path) != null; return getZipIndexEntry(path) != null;
...@@ -459,14 +309,9 @@ public class ZipFileIndex { ...@@ -459,14 +309,9 @@ public class ZipFileIndex {
catch (IOException e) { catch (IOException e) {
return false; return false;
} }
finally {
lock.unlock();
}
} }
public boolean isDirectory(RelativePath path) throws IOException { public synchronized boolean isDirectory(RelativePath path) throws IOException {
lock.lock();
try {
// The top level in a zip file is always a directory. // The top level in a zip file is always a directory.
if (path.getPath().length() == 0) { if (path.getPath().length() == 0) {
lastReferenceTimeStamp = System.currentTimeMillis(); lastReferenceTimeStamp = System.currentTimeMillis();
...@@ -476,27 +321,15 @@ public class ZipFileIndex { ...@@ -476,27 +321,15 @@ public class ZipFileIndex {
checkIndex(); checkIndex();
return directories.get(path) != null; return directories.get(path) != null;
} }
finally {
lock.unlock();
}
}
public long getLastModified(RelativeFile path) throws IOException { public synchronized long getLastModified(RelativeFile path) throws IOException {
lock.lock();
try {
Entry entry = getZipIndexEntry(path); Entry entry = getZipIndexEntry(path);
if (entry == null) if (entry == null)
throw new FileNotFoundException(); throw new FileNotFoundException();
return entry.getLastModified(); return entry.getLastModified();
} }
finally {
lock.unlock();
}
}
public int length(RelativeFile path) throws IOException { public synchronized int length(RelativeFile path) throws IOException {
lock.lock();
try {
Entry entry = getZipIndexEntry(path); Entry entry = getZipIndexEntry(path);
if (entry == null) if (entry == null)
throw new FileNotFoundException(); throw new FileNotFoundException();
...@@ -513,61 +346,33 @@ public class ZipFileIndex { ...@@ -513,61 +346,33 @@ public class ZipFileIndex {
return entry.size; return entry.size;
} }
} }
finally {
lock.unlock();
}
}
public byte[] read(RelativeFile path) throws IOException { public synchronized byte[] read(RelativeFile path) throws IOException {
lock.lock();
try {
Entry entry = getZipIndexEntry(path); Entry entry = getZipIndexEntry(path);
if (entry == null) if (entry == null)
throw new FileNotFoundException("Path not found in ZIP: " + path.path); throw new FileNotFoundException("Path not found in ZIP: " + path.path);
return read(entry); return read(entry);
} }
finally {
lock.unlock();
}
}
byte[] read(Entry entry) throws IOException { synchronized byte[] read(Entry entry) throws IOException {
lock.lock();
try {
openFile(); openFile();
byte[] result = readBytes(entry); byte[] result = readBytes(entry);
closeFile(); closeFile();
return result; return result;
} }
finally {
lock.unlock();
}
}
public int read(RelativeFile path, byte[] buffer) throws IOException { public synchronized int read(RelativeFile path, byte[] buffer) throws IOException {
lock.lock();
try {
Entry entry = getZipIndexEntry(path); Entry entry = getZipIndexEntry(path);
if (entry == null) if (entry == null)
throw new FileNotFoundException(); throw new FileNotFoundException();
return read(entry, buffer); return read(entry, buffer);
} }
finally {
lock.unlock();
}
}
int read(Entry entry, byte[] buffer) synchronized int read(Entry entry, byte[] buffer)
throws IOException { throws IOException {
lock.lock();
try {
int result = readBytes(entry, buffer); int result = readBytes(entry, buffer);
return result; return result;
} }
finally {
lock.unlock();
}
}
private byte[] readBytes(Entry entry) throws IOException { private byte[] readBytes(Entry entry) throws IOException {
byte[] header = getHeader(entry); byte[] header = getHeader(entry);
...@@ -638,14 +443,14 @@ public class ZipFileIndex { ...@@ -638,14 +443,14 @@ public class ZipFileIndex {
/* /*
* Inflate using the java.util.zip.Inflater class * Inflate using the java.util.zip.Inflater class
*/ */
private static Inflater inflater; private SoftReference<Inflater> inflaterRef;
private int inflate(byte[] src, byte[] dest) { private int inflate(byte[] src, byte[] dest) {
Inflater inflater = (inflaterRef == null ? null : inflaterRef.get());
// construct the inflater object or reuse an existing one // construct the inflater object or reuse an existing one
if (inflater == null) if (inflater == null)
inflater = new Inflater(true); inflaterRef = new SoftReference<Inflater>(inflater = new Inflater(true));
synchronized (inflater) {
inflater.reset(); inflater.reset();
inflater.setInput(src); inflater.setInput(src);
try { try {
...@@ -654,7 +459,6 @@ public class ZipFileIndex { ...@@ -654,7 +459,6 @@ public class ZipFileIndex {
return -1; return -1;
} }
} }
}
/** /**
* return the two bytes buf[pos], buf[pos+1] as an unsigned integer in little * return the two bytes buf[pos], buf[pos+1] as an unsigned integer in little
...@@ -855,14 +659,10 @@ public class ZipFileIndex { ...@@ -855,14 +659,10 @@ public class ZipFileIndex {
* @return long * @return long
*/ */
public long getZipFileLastModified() throws IOException { public long getZipFileLastModified() throws IOException {
lock.lock(); synchronized (this) {
try {
checkIndex(); checkIndex();
return zipFileLastModified; return zipFileLastModified;
} }
finally {
lock.unlock();
}
} }
/** ------------------------------------------------------------------------ /** ------------------------------------------------------------------------
...@@ -1028,8 +828,7 @@ public class ZipFileIndex { ...@@ -1028,8 +828,7 @@ public class ZipFileIndex {
} }
boolean ret = false; boolean ret = false;
lock.lock(); synchronized (this) {
try {
triedToReadIndex = true; triedToReadIndex = true;
RandomAccessFile raf = null; RandomAccessFile raf = null;
try { try {
...@@ -1071,9 +870,6 @@ public class ZipFileIndex { ...@@ -1071,9 +870,6 @@ public class ZipFileIndex {
readFromIndex = true; readFromIndex = true;
} }
} }
finally {
lock.unlock();
}
return ret; return ret;
} }
...@@ -1144,8 +940,8 @@ public class ZipFileIndex { ...@@ -1144,8 +940,8 @@ public class ZipFileIndex {
raf.seek(currFP); raf.seek(currFP);
// Now write each of the files in the DirectoryEntry // Now write each of the files in the DirectoryEntry
List<Entry> entries = de.getEntriesAsCollection(); List<Entry> list = de.getEntriesAsCollection();
for (Entry zfie : entries) { for (Entry zfie : list) {
// Write the name bytes // Write the name bytes
byte [] zfieNameBytes = zfie.name.getBytes("UTF-8"); byte [] zfieNameBytes = zfie.name.getBytes("UTF-8");
int zfieNameBytesLen = zfieNameBytes.length; int zfieNameBytesLen = zfieNameBytes.length;
...@@ -1191,13 +987,9 @@ public class ZipFileIndex { ...@@ -1191,13 +987,9 @@ public class ZipFileIndex {
} }
public boolean writeZipIndex() { public boolean writeZipIndex() {
lock.lock(); synchronized (this) {
try {
return writeIndex(); return writeIndex();
} }
finally {
lock.unlock();
}
} }
private File getIndexFile() { private File getIndexFile() {
...@@ -1328,7 +1120,7 @@ public class ZipFileIndex { ...@@ -1328,7 +1120,7 @@ public class ZipFileIndex {
return hash; return hash;
} }
@Override
public String toString() { public String toString() {
return isDir ? ("Dir:" + dir + " : " + name) : return isDir ? ("Dir:" + dir + " : " + name) :
(dir + ":" + name); (dir + ":" + name);
......
/*
* Copyright (c) 2007, 2011, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Oracle designates this
* particular file as subject to the "Classpath" exception as provided
* by Oracle in the LICENSE file that accompanied this code.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
package com.sun.tools.javac.file;
import com.sun.tools.javac.file.RelativePath.RelativeDirectory;
import com.sun.tools.javac.util.Context;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
/** A cache for ZipFileIndex objects. */
public class ZipFileIndexCache {
private final Map<File, ZipFileIndex> map =
new HashMap<File, ZipFileIndex>();
/** Get a shared instance of the cache. */
private static ZipFileIndexCache sharedInstance;
public synchronized static ZipFileIndexCache getSharedInstance() {
if (sharedInstance == null)
sharedInstance = new ZipFileIndexCache();
return sharedInstance;
}
/** Get a context-specific instance of a cache. */
public static ZipFileIndexCache instance(Context context) {
ZipFileIndexCache instance = context.get(ZipFileIndexCache.class);
if (instance == null)
context.put(ZipFileIndexCache.class, instance = new ZipFileIndexCache());
return instance;
}
/**
* Returns a list of all ZipFileIndex entries
*
* @return A list of ZipFileIndex entries, or an empty list
*/
public List<ZipFileIndex> getZipFileIndexes() {
return getZipFileIndexes(false);
}
/**
* Returns a list of all ZipFileIndex entries
*
* @param openedOnly If true it returns a list of only opened ZipFileIndex entries, otherwise
* all ZipFileEntry(s) are included into the list.
* @return A list of ZipFileIndex entries, or an empty list
*/
public synchronized List<ZipFileIndex> getZipFileIndexes(boolean openedOnly) {
List<ZipFileIndex> zipFileIndexes = new ArrayList<ZipFileIndex>();
zipFileIndexes.addAll(map.values());
if (openedOnly) {
for(ZipFileIndex elem : zipFileIndexes) {
if (!elem.isOpen()) {
zipFileIndexes.remove(elem);
}
}
}
return zipFileIndexes;
}
public synchronized ZipFileIndex getZipFileIndex(File zipFile,
RelativeDirectory symbolFilePrefix,
boolean useCache, String cacheLocation,
boolean writeIndex) throws IOException {
ZipFileIndex zi = getExistingZipIndex(zipFile);
if (zi == null || (zi != null && zipFile.lastModified() != zi.zipFileLastModified)) {
zi = new ZipFileIndex(zipFile, symbolFilePrefix, writeIndex,
useCache, cacheLocation);
map.put(zipFile, zi);
}
return zi;
}
public synchronized ZipFileIndex getExistingZipIndex(File zipFile) {
return map.get(zipFile);
}
public synchronized void clearCache() {
map.clear();
}
public synchronized void clearCache(long timeNotUsed) {
Iterator<File> cachedFileIterator = map.keySet().iterator();
while (cachedFileIterator.hasNext()) {
File cachedFile = cachedFileIterator.next();
ZipFileIndex cachedZipIndex = map.get(cachedFile);
if (cachedZipIndex != null) {
long timeToTest = cachedZipIndex.lastReferenceTimeStamp + timeNotUsed;
if (timeToTest < cachedZipIndex.lastReferenceTimeStamp || // Overflow...
System.currentTimeMillis() > timeToTest) {
map.remove(cachedFile);
}
}
}
}
public synchronized void removeFromCache(File file) {
map.remove(file);
}
/** Sets already opened list of ZipFileIndexes from an outside client
* of the compiler. This functionality should be used in a non-batch clients of the compiler.
*/
public synchronized void setOpenedIndexes(List<ZipFileIndex>indexes) throws IllegalStateException {
if (map.isEmpty()) {
String msg =
"Setting opened indexes should be called only when the ZipFileCache is empty. "
+ "Call JavacFileManager.flush() before calling this method.";
throw new IllegalStateException(msg);
}
for (ZipFileIndex zfi : indexes) {
map.put(zfi.zipFile, zfi);
}
}
}
/* /*
* Copyright (c) 2008, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2008, 2011, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
...@@ -38,6 +38,7 @@ import com.sun.tools.javac.file.JavacFileManager; ...@@ -38,6 +38,7 @@ import com.sun.tools.javac.file.JavacFileManager;
import com.sun.tools.javac.file.RelativePath.RelativeFile; import com.sun.tools.javac.file.RelativePath.RelativeFile;
import com.sun.tools.javac.file.ZipFileIndex; import com.sun.tools.javac.file.ZipFileIndex;
import com.sun.tools.javac.file.ZipFileIndexArchive; import com.sun.tools.javac.file.ZipFileIndexArchive;
import com.sun.tools.javac.file.ZipFileIndexCache;
import com.sun.tools.javac.util.Context; import com.sun.tools.javac.util.Context;
public class T6725036 { public class T6725036 {
...@@ -57,8 +58,8 @@ public class T6725036 { ...@@ -57,8 +58,8 @@ public class T6725036 {
JarEntry je = j.getJarEntry(TEST_ENTRY_NAME.getPath()); JarEntry je = j.getJarEntry(TEST_ENTRY_NAME.getPath());
long jarEntryTime = je.getTime(); long jarEntryTime = je.getTime();
ZipFileIndex zfi = ZipFileIndexCache zfic = ZipFileIndexCache.getSharedInstance();
ZipFileIndex.getZipFileIndex(rt_jar, null, false, null, false); ZipFileIndex zfi = zfic.getZipFileIndex(rt_jar, null, false, null, false);
long zfiTime = zfi.getLastModified(TEST_ENTRY_NAME); long zfiTime = zfi.getLastModified(TEST_ENTRY_NAME);
check(je, jarEntryTime, zfi + ":" + TEST_ENTRY_NAME.getPath(), zfiTime); check(je, jarEntryTime, zfi + ":" + TEST_ENTRY_NAME.getPath(), zfiTime);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册