             (>!! offer-head peer)))
         (recur)))))
 
-(defn dead-peer-ch-loop [sync sync-ch dead-tail evict-head offer-head]
+(defn dead-peer-ch-loop [sync sync-ch dead-tail evict-head offer-head dead-ch]
   (loop []
     (when-let [peer-node (<!! dead-tail)]
       (when (mark-peer-death sync sync-ch peer-node)

            (>!! offer-head job-id)))
        (recur)))))

(defn ack-ch-loop [sync sync-ch ack-tail]
  (loop []
    (when-let [ack-node (:path (<!! ack-tail))]
      (acknowledge-task sync sync-ch ack-node)
      (recur))))

(defn evict-ch-loop [sync sync-ch evict-tail offer-head shutdown-head]
  (loop []
    (when (<!! evict-tail)
      (let [offset (extensions/next-offset sync :evict-log)]


(defn offer-ch-loop
  [sync sync-ch revoke-delay offer-tail ack-head exhaust-head
   complete-head revoke-head dead-ch]
  (loop []
    (when (<!! offer-tail)
      (let [offset (extensions/next-offset sync :offer-log)]
