From 7ac452d52a92b577989db49bc4222fa0ac726960 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Tue, 18 Apr 2023 19:30:18 +0200
Subject: [PATCH] fixes

---
 .../dbengine/database/disk/OptimisticRocksDBColumn.java      | 4 ++--
 .../dbengine/database/disk/PessimisticRocksDBColumn.java     | 5 +++--
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java
index 6e20127..25c4073 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java
@@ -91,8 +91,8 @@ public final class OptimisticRocksDBColumn extends AbstractRocksDBColumn<Optimis
 				boolean committedSuccessfully;
 				int retries = 0;
 				ExponentialPageLimits retryTime = null;
-				Buf prevData = null;
-				Buf newData = null;
+				Buf prevData;
+				Buf newData;
 				boolean changed;
 				do {
 					var prevDataArray = tx.getForUpdate(readOptions, cfh, keyArray, true);
diff --git a/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java
index 2ac4abb..18238d8 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java
@@ -59,8 +59,8 @@ public final class PessimisticRocksDBColumn extends AbstractRocksDBColumn<Transa
 			}
 			try (var txOpts = new TransactionOptions();
 					var tx = beginTransaction(writeOptions, txOpts)) {
-				Buf prevData = null;
-				Buf newData = null;
+				Buf prevData;
+				Buf newData;
 				boolean changed;
 				if (logger.isTraceEnabled()) {
 					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);
 					} else {
 						readValueNotFoundWithoutBloomBufferSize.record(0);
+						prevData = null;
 					}
 					if (prevData != null) {
 						prevData.freeze();