lmdb - npm Package Compare versions

Comparing version 3.0.0-beta.11 to 3.0.0-beta.12

package.json

 {
   "name": "lmdb",
   "author": "Kris Zyp",
-  "version": "3.0.0-beta.11",
+  "version": "3.0.0-beta.12",
   "description": "Simple, efficient, scalable, high-performance LMDB interface",
@@ -113,9 +113,9 @@ "license": "MIT",
   "optionalDependencies": {
-    "@lmdb/lmdb-darwin-arm64": "3.0.0-beta.11",
-    "@lmdb/lmdb-darwin-x64": "3.0.0-beta.11",
-    "@lmdb/lmdb-linux-arm": "3.0.0-beta.11",
-    "@lmdb/lmdb-linux-arm64": "3.0.0-beta.11",
-    "@lmdb/lmdb-linux-x64": "3.0.0-beta.11",
-    "@lmdb/lmdb-win32-x64": "3.0.0-beta.11"
+    "@lmdb/lmdb-darwin-arm64": "3.0.0-beta.12",
+    "@lmdb/lmdb-darwin-x64": "3.0.0-beta.12",
+    "@lmdb/lmdb-linux-arm": "3.0.0-beta.12",
+    "@lmdb/lmdb-linux-arm64": "3.0.0-beta.12",
+    "@lmdb/lmdb-linux-x64": "3.0.0-beta.12",
+    "@lmdb/lmdb-win32-x64": "3.0.0-beta.12"
   }
 }

read.js

@@ -398,2 +398,4 @@ import { RangeIterable }  from './util/RangeIterable.js';
 			let snapshot = options.snapshot;
+			if (snapshot === false && this.dupSort && includeValues) throw new Error('Can not disable snapshot on a' +
+				' dupSort data store');
 			let compression = this.compression;
@@ -501,2 +503,6 @@ iterable.iterate = () => {
 						txn.renewingRefCount--;
+					if (txn.refCount <= 1 && txn.notCurrent) {
+						cursor.close(); // this must be closed before the transaction is aborted or it can cause a
+						// segmentation fault
+					}
 					if (txn.done) txn.done();
@@ -507,5 +513,3 @@ else if (--txn.refCount <= 0 && txn.notCurrent) {
 					}
-					if (txn.refCount <= 0 && txn.notCurrent) {
-						cursor.close();
-					} else {
+					if (!txn.isDone) {
 						if (db.availableCursor || txn != readTxn) {
@@ -512,0 +516,0 @@ cursor.close();

write.js

@@ -584,13 +584,19 @@ import { getAddress, getBufferAddress, write, compress, lmdbError } from './native.js';
 	function finishBatch() {
-		dynamicBytes.uint32[(dynamicBytes.position + 1) << 1] = 0; // clear out the next slot
-		let writeStatus = atomicStatus(dynamicBytes.uint32, (dynamicBytes.position++) << 1, 2); // atomically write the end block
-		nextResolution.flagPosition += 2;
+		let bytes = dynamicBytes;
+		let uint32 = bytes.uint32;
+		let nextPosition = (bytes.position + 1);
+		let writeStatus;
+		if (nextPosition > newBufferThreshold) {
+			allocateInstructionBuffer(nextPosition);
+			nextResolution.flagPosition = dynamicBytes.position << 1;
+			nextResolution.uint32 = dynamicBytes.uint32;
+			writeStatus = atomicStatus(uint32, bytes.position << 1, 2); // atomically write the end block
+		} else {
+			uint32[nextPosition << 1] = 0; // clear out the next slot
+			writeStatus = atomicStatus(uint32, (bytes.position++) << 1, 2); // atomically write the end block
+			nextResolution.flagPosition += 2;
+		}
 		if (writeStatus & WAITING_OPERATION) {
 			write(env.address, 0);
 		}
-		if (dynamicBytes.position > newBufferThreshold) {
-			allocateInstructionBuffer(dynamicBytes.position);
-			nextResolution.flagPosition = dynamicBytes.position << 1;
-			nextResolution.uint32 = dynamicBytes.uint32;
-		}
 	}
@@ -597,0 +603,0 @@ function clearWriteTxn(parentTxn) {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

2482349

increased by0.14%

Lines of code

6623

increased by0.3%

No dependency changes