diff --git a/agkyra/syncer/setup.py b/agkyra/syncer/setup.py index f9d9046254b6b873f7d187b8ded3c11c3296485e..713f2c87ff213644cf034e1227adf9586a5fd34d 100644 --- a/agkyra/syncer/setup.py +++ b/agkyra/syncer/setup.py @@ -145,6 +145,8 @@ class SyncerSettings(): if not db_existed: self.get_db(initialize=True) + self.mtime_lag = 0 + if not db_existed: self.set_localfs_enabled(True) self.create_local_dirs() @@ -168,7 +170,6 @@ class SyncerSettings(): self.endpoint.CONNECTION_RETRY_LIMIT = self.connection_retry_limit self.messager = Messager() - self.mtime_lag = 0 #self.determine_mtime_lag() def create_local_dirs(self): self.create_dir(self.local_root_path) @@ -184,6 +185,9 @@ class SyncerSettings(): return 1.1 return 0 + def set_mtime_lag(self): + self.mtime_lag = self.determine_mtime_lag() + def get_db(self, initialize=False): dbs = getattr(thread_local_data, "dbs", None) if dbs is not None: @@ -253,6 +257,8 @@ class SyncerSettings(): def _set_localfs_enabled(self, db, enabled): db.set_config("localfs_enabled", enabled) + if enabled: + self.set_mtime_lag() @transaction() def set_pithos_enabled(self, enabled):