   "Create a new benchmark. You must call start on this to begin"
   [url concurrency requests]
   (let [client (ning-client/create-client {:max-conns-per-host concurrency})
-        worker-fn (partial create-single-url-worker client url)]
+        worker-fn (partial wrkr/create-single-url-worker client url)]
     (create-benchmark client url concurrency requests worker-fn)))
 
 (defn replace-current-benchmark

(ns engulf.benchmark
  (:require [engulf.utils :as utils]
            [clojure.tools.logging :as log]
            [engulf.ning-client :as ning-client])
  (:use clojure.tools.logging
        noir-async.utils
        lamina.core
        [engulf.utils :only [send-bench-msg]]
        [engulf.worker :only [work warmup create-single-url-worker]]
        [engulf.recorder :only [create-recorder
                                record-result
                                record-error
                                record-start
                                processed-stats
                                record-end]])
  (:import java.util.concurrent.atomic.AtomicLong
           java.net.URL))


    (when (compare-and-set! state :started :stopped)
      (do
        (ning-client/close-client client)
        (rec/record-end recorder)
        (doseq [worker @workers]
          (swap! (:state worker) (fn [s] :stopped)))
        (broadcast-state this))))
