     (if (not (compare-and-set! state :initialized :started))
       (io! (log/warn (str "Could not start from: @state")))
       (do
-        (record-start recorder)
+        (rec/record-start recorder)
         (doseq [worker @workers]
-          (if-let [res-ch (work worker)]
+          (if-let [res-ch (wrkr/work worker)]
             (handle-result this res-ch)))
         (compare-and-set! broadcast-task nil
                           (broadcast-at-interval this 200)))))

   (set-interval millis #(broadcast-state this)))
         
  (stats [this]
    (processed-stats recorder)))

(defn create-workers-for-benchmark
  "Creates a vector of workers instantiated via worker-fn, which

(ns engulf.benchmark
  (:require [engulf.utils :as utils]
            [clojure.tools.logging :as log]
            [engulf.ning-client :as ning-client]
            [engulf.recorder :as rec]
            [engulf.worker :as wrkr])
  (:use clojure.tools.logging
        noir-async.utils
        lamina.core
        [engulf.utils :only [send-bench-msg]])
  (:import java.util.concurrent.atomic.AtomicLong
           java.net.URL))

