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

Discard transaction data

Browse Source
This commit is contained in:
Andrea Cavalli 2021-10-21 10:01:29 +02:00
parent 1f04241ac6
commit fb43fa78af
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -148,6 +148,7 @@ public final class OptimisticRocksDBColumn extends AbstractRocksDBColumn<Optimis
sentCurData = newData == null ? null : newData.send(); sentCurData = newData == null ? null : newData.send();
if (!committedSuccessfully) { if (!committedSuccessfully) {
tx.undoGetForUpdate(cfh, keyArray); tx.undoGetForUpdate(cfh, keyArray);
tx.rollback();
if (sentPrevData != null) { if (sentPrevData != null) {
sentPrevData.close(); sentPrevData.close();
} }