Don't increment the lock when the queue is empty.

This will deadlock the entire loop.
creationix · Jun 30, 2010 · a7e2eb7 · a7e2eb7
1 parent 81d8d9f
commit a7e2eb7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/nstore.js b/lib/nstore.js
@@ -140,8 +140,9 @@ function nStore(filename) {
 
   var lock = 0;
   function checkQueue() {
+    if (writeQueue.length === 0) { return; }
     lock++;
-    if (lock > 1 || writeQueue.length === 0) { return; }
+    if (lock > 1) { return; }
 
     // Merge the line buffers into a single large buffer
     var buffer = new Buffer(queueSize);
@@ -198,7 +199,7 @@ function nStore(filename) {
 
       // Unlock and try the loop again
       lock = 0;
-      checkQueue();
+      process.nextTick(checkQueue);
     });
 
   }