andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fixes

Browse Source
This commit is contained in:
Andrea Cavalli 2023-04-18 19:30:18 +02:00
parent 977dd472c1
commit 7ac452d52a
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java
View File

@ -91,8 +91,8 @@ public final class OptimisticRocksDBColumn extends AbstractRocksDBColumn<Optimis
boolean committedSuccessfully; boolean committedSuccessfully;
int retries = 0; int retries = 0;
ExponentialPageLimits retryTime = null; ExponentialPageLimits retryTime = null;
Buf prevData = null; Buf prevData;
Buf newData = null; Buf newData;
boolean changed; boolean changed;
do { do {
var prevDataArray = tx.getForUpdate(readOptions, cfh, keyArray, true); var prevDataArray = tx.getForUpdate(readOptions, cfh, keyArray, true);

5
src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java
View File

@ -59,8 +59,8 @@ public final class PessimisticRocksDBColumn extends AbstractRocksDBColumn<Transa
} }
try (var txOpts = new TransactionOptions(); try (var txOpts = new TransactionOptions();
var tx = beginTransaction(writeOptions, txOpts)) { var tx = beginTransaction(writeOptions, txOpts)) {
Buf prevData = null; Buf prevData;
Buf newData = null; Buf newData;
boolean changed; boolean changed;
if (logger.isTraceEnabled()) { if (logger.isTraceEnabled()) {
logger.trace(MARKER_ROCKSDB, "Reading {} (before update lock)", LLUtils.toStringSafe(key)); logger.trace(MARKER_ROCKSDB, "Reading {} (before update lock)", LLUtils.toStringSafe(key));
@ -79,6 +79,7 @@ public final class PessimisticRocksDBColumn extends AbstractRocksDBColumn<Transa
prevData = Buf.wrap(prevDataArray); prevData = Buf.wrap(prevDataArray);
} else { } else {
readValueNotFoundWithoutBloomBufferSize.record(0); readValueNotFoundWithoutBloomBufferSize.record(0);
prevData = null;
} }
if (prevData != null) { if (prevData != null) {
prevData.freeze(); prevData.freeze();