Make spaces used in tests synchronous

Synchronous replication should be enabled per-space using the `is_sync` option.
This option has been accidentally lost in a commit "Rewrite client in a
register workload" 3214905

Closes #51

Author: ligurio

src/tarantool/counter.clj

@@ -31,7 +31,9 @@
           (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
                             " (id INT NOT NULL PRIMARY KEY,
                             count INT NOT NULL)")]))
-          (sql/insert! conn table-name {:id 0 :count 0}))
+          (sql/insert! conn table-name {:id 0 :count 0})
+          (let [table (clojure.string/upper-case table-name)]
+            (j/execute! conn [(str "SELECT LUA('return box.space." table ":alter{ is_sync = true } or 1')")])))
       (assoc this :conn conn :node node)))
 
   (invoke! [this test op]

src/tarantool/register.clj

@@ -37,10 +37,13 @@
   (setup! [this test node]
     (let [conn (cl/open node test)]
       (assert conn)
-      (cl/with-conn-failure-retry conn
-        (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
-                          " (id INT NOT NULL PRIMARY KEY,
-                          value INT NOT NULL)")]))
+      (if (= node (jepsen/primary test))
+        (cl/with-conn-failure-retry conn
+          (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
+                            " (id INT NOT NULL PRIMARY KEY,
+                            value INT NOT NULL)")])
+          (let [table (clojure.string/upper-case table-name)]
+            (j/execute! conn [(str "SELECT LUA('return box.space." table ":alter{ is_sync = true } or 1')")]))))
       (assoc this :conn conn :node node)))
 
   (invoke! [this test op]

src/tarantool/sets.clj

@@ -26,12 +26,15 @@
 
   (setup! [this test node]
     (let [conn (cl/open node test)]
-    (assert conn)
-    (cl/with-conn-failure-retry conn
-      (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
-                        " (id INT NOT NULL PRIMARY KEY AUTOINCREMENT,
-                        value INT NOT NULL)")]))
-      (assoc this :conn conn :node node)))
+      (assert conn)
+      (if (= node (jepsen/primary test))
+        (cl/with-conn-failure-retry conn
+          (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
+                            " (id INT NOT NULL PRIMARY KEY AUTOINCREMENT,
+                            value INT NOT NULL)")])
+          (let [table (clojure.string/upper-case table-name)]
+            (j/execute! conn [(str "SELECT LUA('return box.space." table ":alter{ is_sync = true } or 1')")]))))
+    (assoc this :conn conn :node node)))
 
   (invoke! [this test op]
     (let [[k v] (:value op)]