use locator db to speed up file search

[photosort.git] / src / bunch.py

diff --git a/src/bunch.py b/src/bunch.py
index 228131a9e1ec5e6b8157f86813b9fbffceb15634..689d9b0d53fd7ea696063cdc1fe6dec3989f592c 100644 (file)
--- a/src/bunch.py
+++ b/src/bunch.py
@@ -23,7 +23,8 @@ class Bunch:
                     source_idx,
                     DirTrigger(src_dir_cfg['path'], src_dir_cfg['cool_time'],
                                src_dir_cfg['max_time']),
                     source_idx,
                     DirTrigger(src_dir_cfg['path'], src_dir_cfg['cool_time'],
                                src_dir_cfg['max_time']),

-                    Migrator(src_dir_cfg['path'], cfg['dst_dir']['path']),
+                    Migrator(src_dir_cfg['path'], cfg['dst_dir']['path'],
+                             os.path.join(cfg['cache_dir'], "%d.db" % idx)),

                     src_dir_cfg['cleanup']
                 )
             )
                     src_dir_cfg['cleanup']
                 )
             )


@@ -40,6 +41,8 @@ class Bunch:
         logging.info("Stopping bunch #%d...", self._idx)
         self._stop = True
         self._worker_thread.join()
         logging.info("Stopping bunch #%d...", self._idx)
         self._stop = True
         self._worker_thread.join()

+        for src in self._sources:
+            src.migrator.close()

         logging.info("Stopped bunch #%d.", self._idx)
 
     def is_running(self):
         logging.info("Stopped bunch #%d.", self._idx)
 
     def is_running(self):