Beginning of allowing overlap on single thread

kriszyp · Mar 7, 2024 · 9ee40d0 · 9ee40d0
1 parent 49847c6
commit 9ee40d0
Showing 1 changed file with 12 additions and 4 deletions.
diff --git a/src/writer.cpp b/src/writer.cpp
@@ -431,6 +431,12 @@ bool WriteWorker::threadSafeCallsEnabled = false;
 void txn_visible(const void* data) {
 	auto worker = (WriteWorker*) data;
 	worker->SendUpdate();
+	/*if (worker->txn) {
+		worker->txn = nullptr;
+		worker->interruptionStatus = 0;
+		pthread_cond_signal(worker->envForTxn->writingCond); // in case there a sync txn waiting for us
+		pthread_mutex_unlock(worker->envForTxn->writingLock);
+	}*/
 }
 
 
@@ -493,10 +499,12 @@ void WriteWorker::Write() {
 	if (rc == MDB_EMPTY_TXN)
 		rc = 0;
 #endif
-	txn = nullptr;
-    interruptionStatus = 0;
-    pthread_cond_signal(envForTxn->writingCond); // in case there a sync txn waiting for us
-	pthread_mutex_unlock(envForTxn->writingLock);
+	if (txn) {
+		txn = nullptr;
+		interruptionStatus = 0;
+		pthread_cond_signal(envForTxn->writingCond); // in case there a sync txn waiting for us
+		pthread_mutex_unlock(envForTxn->writingLock);
+	}
 	if (rc || resultCode) {
 		std::atomic_fetch_or((std::atomic<uint32_t>*) instructions, (uint32_t) TXN_HAD_ERROR);
 		if (rc)