temporary commit

Closes #16
Closes #17
Closes #21
Closes #25
Closes #34

Author: ligurio

src/tarantool/db.clj

@@ -246,6 +246,31 @@
       (stop! test node)
       (wipe! test node))
 
+    ;db/Primary
+    ;(setup-primary! [_ test node])
+
+    ;(primaries      [_ test]
+    ;  (->> (node-state test)
+    ;       (filter (comp #{:leader} :role))
+    ;       (map :node)))
+
+    db/Process
+    (start! [_ test node]
+      (start! node {}))
+              ;{:initial-cluster-state (if @(:initialized? test)
+              ;                          :existing
+              ;                          :new)
+              ; :nodes                 @(:members test)}))
+
+    (kill! [_ test node]
+      (c/su
+        ;(cu/stop-daemon! binary pidfile)))
+        (cu/grepkill! :kill "tarantool")))
+
+    db/Pause
+      (pause!  [_ test node] (c/su (cu/grepkill! :stop "tarantool")))
+      (resume! [_ test node] (c/su (cu/grepkill! :cont "tarantool")))
+
     db/LogFiles
     (log-files [_ test node]
       [logfile])))

src/tarantool/runner.clj

@@ -118,7 +118,7 @@
 
 (def crash-pattern
   "An egrep pattern we use to find crashes in the Tarantool logs."
-  "Segmentation fault|too long WAL write|F>")
+  "Segmentation fault|too long WAL write|F>|ER_TUPLE_FOUND")
 
 (defn logged-crashes
   "Takes a test, and returns a map of nodes to strings from their Tarantool logs

src/tarantool/sets.clj

@@ -6,6 +6,7 @@
                     [checker :as checker]
                     [generator :as gen]
                     [independent :as independent]]
+            [clojure.tools.logging :refer [info warn]]
             [next.jdbc :as j]
             [next.jdbc.sql :as sql]
             [tarantool.client :as cl]
@@ -38,7 +39,9 @@
       (cl/with-txn-aborts op
         (case (:f op)
           :add (let [con (cl/open (jepsen/primary test) test)]
-                 (do (sql/insert! con table-name {:value v})
+                 (info (jepsen/primary test))
+                 ;(do (sql/insert! con table-name {:value v})
+                 (do (j/execute! con [(str "INSERT INTO " table-name "(value) VALUES (" v ")")])
                     (assoc op :type :ok)))
 
           :read (->> (sql/query conn [(str "SELECT * FROM " table-name)])