   ([test node]
    (info "recovering" node)
    (start-daemon! test :recover (jepsen/primary test))
-   (await-initialization node)))
+   (await-start node)))
 
 (defn rejoin!
   "Rejoins a voltdb node. Serialized to work around a bug in voltdb where

                         (meh (c/exec :tail :-n 10
                                      (str voltroot "/log/volt.log")))
                         "\n\n")))

           (c/sudo username
                   (c/cd voltroot
                         ; hack hack hack

                         (Thread/sleep 7000)
                         (c/exec :tail :-n 1 :-f "log/volt.log"
                                 | :grep :-m 1 "completed initialization"
                                 | :xargs (c/lit "echo \"\" >> log/volt.log \\;")))

                   (info node "started"))))
(defn await-rejoin
  "Blocks until the logfile reports 'Node rejoin completed'"
  [node]
  (info "Waiting for" node "to rejoin")
  (c/sudo username
          (c/cd voltroot
                ; hack hack hack
                (Thread/sleep 12000)
                (c/exec :tail :-n 1 :-f "log/volt.log"
                        | :grep :-m 1 "Node rejoin completed"
                        | :xargs (c/lit "echo \"\" >> log/volt.log \\;")))
          (info node "rejoined")))

(defn init-daemon!
  "Starts the daemon with the given command."
  [test cmd host]
  (c/sudo username
          (c/cd voltroot
                (cu/start-daemon! {:logfile (str base-dir "/log/stdout.log")
                                   :pidfile (str base-dir "/pidfile")
                                   :chdir   base-dir}
                                  (str base-dir "/bin/voltdb")
                                  (str "init")
                                  :--config (str base-dir "/deployment.xml")
                                  :--force
                                  :--dir (str base-dir) ))))
(defn start-daemon!
  "Starts the daemon with the given command."
  [test cmd host]

           (future
             (try
               (dotimes [i 50000]
;                 (call! conn "MENTIONS.insert" i (rand-int 1000))
                 ; If we go TOO fast we'll start forcing other ops to time
                 ; out. If we go too slow we won't get a long enough log.
                 (Thread/sleep 1)
