andi/perfdb
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Activity

do not force changes to disk

Browse Source 
diskBlock.force() makes insertion speed very slow, because it adds
two digit ms to tree changes. I disabled it for now. The tree is not
crash resistent anyway.
This commit is contained in:
Andreas Huber
2018-11-19 19:22:27 +01:00
parent afd1e36066
commit 6f48a25d53
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
block-storage/src/main/java/org/lucares/pdb/map/PersistentMap.java
View File

@@ -12,10 +12,10 @@ import java.util.Stack;
import java.util.UUID; import java.util.UUID;
import org.lucares.collections.LongList; import org.lucares.collections.LongList;
import org.lucares.pdb.blockstorage.intsequence.VariableByteEncoder;
import org.lucares.pdb.diskstorage.DiskBlock; import org.lucares.pdb.diskstorage.DiskBlock;
import org.lucares.pdb.diskstorage.DiskStorage; import org.lucares.pdb.diskstorage.DiskStorage;
import org.lucares.utils.Preconditions; import org.lucares.utils.Preconditions;
import org.lucares.utils.byteencoder.VariableByteEncoder;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -24,7 +24,7 @@ public class PersistentMap<K, V> implements AutoCloseable {
private static final Logger LOGGER = LoggerFactory.getLogger(PersistentMap.class); private static final Logger LOGGER = LoggerFactory.getLogger(PersistentMap.class);
// the maximum key // the maximum key
private static final byte[] MAX_KEY; static final byte[] MAX_KEY;
static { static {
MAX_KEY = new byte[20]; MAX_KEY = new byte[20];
Arrays.fill(MAX_KEY, Byte.MAX_VALUE); Arrays.fill(MAX_KEY, Byte.MAX_VALUE);
@@ -308,7 +308,7 @@ public class PersistentMap<K, V> implements AutoCloseable {
final byte[] newBuffer = node.serialize(); final byte[] newBuffer = node.serialize();
System.arraycopy(newBuffer, 0, buffer, 0, buffer.length); System.arraycopy(newBuffer, 0, buffer, 0, buffer.length);
diskBlock.writeAsync(); diskBlock.writeAsync();
diskBlock.force(); // diskBlock.force(); // makes writing nodes slower by factor 800 (sic!)
} }
public synchronized void print() throws IOException { public synchronized void print() throws IOException {