 (def incomplete 
   (atom #{}))
 
+(def bad-values
+  (atom #{}))
+
 (def n-messages-total 100000)
 
 (try

                                     (let [v (<!! out-chan)]
                                       (when (and v (not= v :done)) 
                                         (swap! incomplete disj v)
                                         (recur))))
        kill-ch (chan 1)
        ; it can take 3 * batch-timeout to make it through a full circuit, however
        ; there will be circumstances where the peers left alone, so lets try 2* for now
        chaos-kill-ms (* 2 batch-timeout)
        mess-with-peers-ch (go-loop []
                                    (let [[v ch] (alts!! [(timeout chaos-kill-ms) kill-ch])]
                                      (when-not (= ch kill-ch) 
                                        (try 
                                          (when-let [non-input-peers (->> (get (:allocations @(:replica test-env)) job-id)

  (let [load-data-ch (thread 
                       (loop [ls (repeatedly n-messages-total (fn [] {:id (java.util.UUID/randomUUID)}))]
                         (when-let [segment (first ls)]
                           (swap! incomplete conj (int-2 (int-1 segment)))
                           (>!! in-chan segment)
                           (recur (rest ls))))
                       (>!! in-chan :done)
