                   (let [retention (get rollups seconds-per-point
                                        (:retention archive))]
                     (process-archive ra-file file archive mstore tenant path
-                                     from to retention options points-fn))))))
+                                     from to retention options processor))))))
           (finally
             (.close ra-file)))))))
 

   (format (str "%s: rollup: %s, period: %s, path: %s, time: %s, "
                "value: %s, ttl: %s") msg rollup period path time value ttl)))

(defn- migrate-points
  "Migrate points."
  [mstore options tenant rollup period retention path series]
  (let [min-ttl (:min-ttl options default-min-ttl)
        run (:run options false)]
    (doseq [point series]
      (let [time (first point)
            value (last point)
            ttl (calc-ttl time retention)]
        (when (> ttl min-ttl)
          (log-point "Migrating point" rollup period path time value ttl)
          (when run
            (mstore/insert mstore tenant rollup period path time value
                           ttl)))))))

(defn- validate-value
  "Validate a value."


(defn- process
  "Process a Whisper database."
  [source tenant cass-host es-url options processor-fn start-title title]
  (wlog/set-logging! options)
  (try
    (wlog/info start-title)
