   (reset! defed-path path)
   (reset! data-path (str path "/" start-time "/"))
   (when keep-imported? (remove-imported @data-path))
-  (println "Starting backup server at:" @data-path)
-  #_(a/go-loop [] (apply collect-log (a/<! pending-logs))))
+  (println "Starting backup server at:" @data-path))
 
 (defn convert-server-name-for-file [^String str] (.replace str ":" "-"))
 

        replica-accessors (vec (map (fn [n] (let [file-path (str base-path n ".dat")
                                                  file-ins (File. file-path)]
                                              (when-not (.exists file-ins) (.createNewFile file-ins))
                                              (BufferedRandomAccessFile. file-path "rw")))
                                     (range trunks)))
        ;log-appenders (vec (map (fn [n] (atom (io/output-stream
        ;                                        (str base-path n "-" timestamp ".mlog"))))
        ;                         (range trunks)))
        sync-timestamps (vec (map (fn [_] (atom 0)) (range trunks)))
        log-switches (vec (map (fn [_] (ReentrantLock.)) (range trunks)))
        pending-chan (a/chan 500)

(defn finish-trunk-sync [sid trunk-id tail-loc timestamp]
  (let [client (get @clients sid)]
    (a/>!! (:pending-chan client) [1 trunk-id tail-loc]))
  (reset! (get-in (get @clients sid) [:sync-time trunk-id]) timestamp))

(defn list-recover-dir []
  (let [path-file (File. ^String @defed-path)
