From 6fc0c051d0d74034395e7654ca16a5670db8268f Mon Sep 17 00:00:00 2001
From: Jan Steemann <jan@arangodb.com>
Date: Thu, 3 Jul 2014 17:12:25 +0200
Subject: [PATCH] added test case

---
 UnitTests/Makefile.unittests                |  1 +
 js/server/tests/recovery/resume-recovery.js | 93 +++++++++++++++++++++
 2 files changed, 94 insertions(+)
 create mode 100644 js/server/tests/recovery/resume-recovery.js

diff --git a/UnitTests/Makefile.unittests b/UnitTests/Makefile.unittests
index a7275ef1cf..765b4fb37a 100755
--- a/UnitTests/Makefile.unittests
+++ b/UnitTests/Makefile.unittests
@@ -207,6 +207,7 @@ unittests-recovery:
 	@echo "================================================================================"
 	@echo
 
+	$(MAKE) execute-recovery-test PID=$(PID) RECOVERY_SCRIPT="resume-recovery"
 	$(MAKE) execute-recovery-test PID=$(PID) RECOVERY_SCRIPT="foxx-directories"
 	$(MAKE) execute-recovery-test PID=$(PID) RECOVERY_SCRIPT="collection-rename"
 	$(MAKE) execute-recovery-test PID=$(PID) RECOVERY_SCRIPT="collection-properties"
diff --git a/js/server/tests/recovery/resume-recovery.js b/js/server/tests/recovery/resume-recovery.js
new file mode 100644
index 0000000000..b12e421f3a
--- /dev/null
+++ b/js/server/tests/recovery/resume-recovery.js
@@ -0,0 +1,93 @@
+
+var db = require("org/arangodb").db;
+var internal = require("internal");
+var jsunity = require("jsunity");
+
+
+function runSetup () {
+  internal.debugClearFailAt();
+  
+  db._drop("UnitTestsRecovery");
+  var c = db._create("UnitTestsRecovery"), i, j;
+  c.ensureSkiplist("value2");
+
+  for (i = 0; i < 10000; ++i) {
+    c.save({ _key: "test" + i, value1: "test" + i, value2: i });
+  }
+
+  internal.wal.flush(true, true);
+
+  internal.debugSetFailAt("CollectorThreadProcessQueuedOperations");
+  
+  for (j = 0; j < 4; ++j) {
+    for (i = 0; i < 10000; ++i) {
+      c.save({ _key: "foo-" + i + "-" + j, value1: "test" + i, value2: "abc" + i });
+    }
+  
+    internal.wal.flush(true, false);
+  }
+
+  c.save({ _key: "crashme" }, true);
+
+  internal.debugSegfault("crashing server");
+}
+
+////////////////////////////////////////////////////////////////////////////////
+/// @brief test suite
+////////////////////////////////////////////////////////////////////////////////
+
+function recoverySuite () {
+  jsunity.jsUnity.attachAssertions();
+
+  return {
+    setUp: function () {
+    },
+    tearDown: function () {
+    },
+
+////////////////////////////////////////////////////////////////////////////////
+/// @brief test whether we can restore the trx data
+////////////////////////////////////////////////////////////////////////////////
+    
+    testResumeRecovery : function () {
+      var c = db._collection("UnitTestsRecovery"), i, j, doc;
+      var idx = c.getIndexes()[1];
+        
+      assertEqual(50001, c.count());
+
+      for (i = 0; i < 10000; ++i) {
+        doc = c.document("test" + i);
+        assertEqual("test" + i, doc.value1);
+        assertEqual(i, doc.value2);
+        assertEqual(1, c.byExampleSkiplist(idx.id, { value2: i }).toArray().length);
+      }
+
+      for (j = 0; j < 4; ++j) {
+        for (i = 0; i < 10000; ++i) {
+          doc = c.document("foo-" + i + "-" + j);
+          assertEqual("test" + i, doc.value1);
+          assertEqual("abc" + i, doc.value2);
+        
+          assertEqual(4, c.byExampleSkiplist(idx.id, { value2: "abc" + i }).toArray().length);
+        }
+      }
+    }
+        
+  };
+}
+
+////////////////////////////////////////////////////////////////////////////////
+/// @brief executes the test suite
+////////////////////////////////////////////////////////////////////////////////
+
+function main (argv) {
+  if (argv[1] === "setup") {
+    runSetup();
+    return 0;
+  }
+  else {
+    jsunity.run(recoverySuite);
+    return jsunity.done() ? 0 : 1;
+  }
+}
+