Write via leader only

Author: ligurio

src/tarantool/counter.clj

@@ -38,8 +38,9 @@
     (cl/with-error-handling op
       (cl/with-txn-aborts op
         (case (:f op)
-          :add (do (j/execute! conn
-                      [(str "UPDATE " table-name " SET count = count + ? WHERE id = 0") (:value op)])
+          :add (let [con (cl/open (jepsen/primary test) test)]
+                 (do (j/execute! con
+                      [(str "UPDATE " table-name " SET count = count + ? WHERE id = 0") (:value op)]))
                (assoc op :type :ok))
 
           :read (let [value (:COUNT

src/tarantool/register.clj

@@ -59,7 +59,7 @@
        :cas (let [[old new] (:value op)
                   con (cl/open (jepsen/primary test) test)
                   table (clojure.string/upper-case table-name)]
-                  (assoc op :type (if (->> (j/execute! conn
+                  (assoc op :type (if (->> (j/execute! con
                                              [(str "SELECT _CAS(1, " old ", " new ", '" table "')")])
                                            (first)
                                            (vals)

src/tarantool/sets.clj

@@ -37,8 +37,9 @@
     (cl/with-error-handling op
       (cl/with-txn-aborts op
         (case (:f op)
-          :add  (do (sql/insert! conn table-name {:value v})
-                    (assoc op :type :ok))
+          :add (let [con (cl/open (jepsen/primary test) test)]
+                 (do (sql/insert! con table-name {:value v})
+                    (assoc op :type :ok)))
 
           :read (->> (sql/query conn [(str "SELECT * FROM " table-name)])
                      (mapv :VALUE)