MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of git@git.labs.intellij.net:idea/community

Browse Source
This commit is contained in:
Dmitry Jemerov
2010-07-19 23:50:40 +04:00
parent be9442d2b5 26ef9d9499
commit a2cae2b70e
1 changed files with 21 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/util/src/com/intellij/util/io/PersistentHashMap.java
+21 -2
View File
@@ -32,7 +32,7 @@ import java.util.Collection;
*/
public class PersistentHashMap<Key, Value> extends PersistentEnumerator<Key>{
private static final Logger LOG = Logger.getInstance("#com.intellij.util.io.PersistentHashMap");
private static final int APPEND_CACHE_DATA_THRESHOLD = 20 * 1024 * 1024; // 20 MB
private PersistentHashMapValueStorage myValueStorage;
private final DataExternalizer<Value> myValueExternalizer;
private static final long NULL_ADDR = 0;
@@ -50,6 +50,10 @@ public class PersistentHashMap<Key, Value> extends PersistentEnumerator<Key>{
super(new ByteArrayOutputStream());
}
public int getBufferSize() {
return ((ByteArrayOutputStream)out).size();
}
public void writeTo(OutputStream stream) throws IOException {
((ByteArrayOutputStream)out).writeTo(stream);
}
@@ -63,6 +67,8 @@ public class PersistentHashMap<Key, Value> extends PersistentEnumerator<Key>{
}
}
private int myBytesInMemoryCount = 0;
private final LimitedPool<AppendStream> myStreamPool = new LimitedPool<AppendStream>(10, new LimitedPool.ObjectFactory<AppendStream>() {
public AppendStream create() {
return new AppendStream();
@@ -92,6 +98,8 @@ public class PersistentHashMap<Key, Value> extends PersistentEnumerator<Key>{
updateValueId(id, headerRecord);
myStreamPool.recycle(value);
myBytesInMemoryCount -= bytes.length;
}
catch (IOException e) {
throw new RuntimeException(e);
@@ -187,7 +195,18 @@ public class PersistentHashMap<Key, Value> extends PersistentEnumerator<Key>{
public synchronized void appendData(Key key, ValueDataAppender appender) throws IOException {
synchronized (ourLock) {
markDirty(true);
appender.append(myAppendCache.get(key));
final AppendStream stream = myAppendCache.get(key);
final int sizeBefore = stream.getBufferSize();
appender.append(stream);
myBytesInMemoryCount += (stream.getBufferSize() - sizeBefore);
if (myBytesInMemoryCount > APPEND_CACHE_DATA_THRESHOLD) {
LOG.warn(
"PersistentHashMap: OVER " + APPEND_CACHE_DATA_THRESHOLD + " BYTES IN APPEND STREAM CACHE, FORCING CACHE FLUSH (not optimal serialization format?) File: " + getDataFile(myFile).getPath()
);
myAppendCache.clear();
}
}
}