Add more debugging information when decompression fails, #116

src/compression.cpp

@@ -117,7 +117,7 @@ void Compression::decompress(MDB_val& data, bool &isValid, bool canAllocate) {
         dictionary, decompressTarget - dictionary);
     //fprintf(stdout, "first uncompressed byte %X %X %X %X %X %X\n", uncompressedData[0], uncompressedData[1], uncompressedData[2], uncompressedData[3], uncompressedData[4], uncompressedData[5]);
     if (written < 0) {
-        //fprintf(stderr, "Failed to decompress data %u %u %u %u\n", charData[0], data.mv_size, compressionHeaderSize, uncompressedLength);
+        fprintf(stderr, "Failed to decompress data %u %u %u %u %u %u %u %u\n", compressionHeaderSize, uncompressedLength, charData[0], charData[1], charData[2], charData[3], charData[4], charData[5]);
         if (canAllocate)
             Nan::ThrowError("Failed to decompress data");
         isValid = false;
@@ -247,4 +247,4 @@ extern "C" EXTERN uint64_t newCompression(char* dictionary, uint32_t dictSize, u
     compression->acceleration = 1;
     compression->compressionThreshold = threshold;
     return (uint64_t) compression;
-}
+}

test/index.test.js

@@ -931,6 +931,29 @@ describe('lmdb-js', function() {
       console.log(dbBinary.getBinaryLocation(3))
       console.log(dbBinary.getBinaryLocation(4))
     });
+    it('open and close with compression', async function() {
+      let data = ''
+      for (let i = 0; i < 100; i++) {
+        data += Math.random()
+      }
+      for (let i = 0; i < 100; i++) {
+        let db = open(testDirPath + '/test-close.mdb', {
+//          name: 'test-close',
+          compression: true,
+          overlappingSync: true,
+        });
+        let v = db.get('key')
+        v = db.get('key1')
+        v = db.get('key2')
+        v = db.get('key3')
+        db.put('key', data);
+        let promise = db.close();
+        db.put('key1', data);
+        await db.put('key2', data);
+        db.put('key3', data);
+        await promise;
+      }
+    })
     after(function(done) {
       db.get('key1');
       let iterator = db.getRange({})[Symbol.iterator]()