diff --git a/agkyra/syncer/messaging.py b/agkyra/syncer/messaging.py index 516d6a8901c61559fdf36cb5d25d0c76104605ad..33494238670eb33e9f56a5f6efaa8ce449b2f27d 100644 --- a/agkyra/syncer/messaging.py +++ b/agkyra/syncer/messaging.py @@ -85,8 +85,8 @@ class HeartbeatNoDecideMessage(Message): Message.__init__(self, *args, **kwargs) self.objname = kwargs["objname"] self.heartbeat = kwargs["heartbeat"] - self.logger.warning("Object '%s' already handled; aborting." - % self.objname) + self.logger.debug("Object '%s' already handled; aborting deciding." + % self.objname) class HeartbeatReplayDecideMessage(Message): diff --git a/agkyra/syncer/pithos_client.py b/agkyra/syncer/pithos_client.py index 1093b1e2b5d47c50c6891fe228828b7f3f7e23bd..42f37f9fa8010f2693fb87e20b6e578f7b4e67f8 100644 --- a/agkyra/syncer/pithos_client.py +++ b/agkyra/syncer/pithos_client.py @@ -74,8 +74,8 @@ class PithosSourceHandle(object): headers = dict() with open(fetched_fspath, mode='wb+') as fil: try: - logger.info("Downloading object: '%s', to: '%s'" % - (self.objname, fetched_fspath)) + logger.debug("Downloading object: '%s', to: '%s'" % + (self.objname, fetched_fspath)) self.endpoint.download_object( self.objname, fil, @@ -93,12 +93,12 @@ class PithosSourceHandle(object): "pithos_type": actual_type} self.check_update_source_state(actual_info) if actual_info == {}: - logger.info("Downloading object: '%s', object is gone." - % self.objname) + logger.debug("Downloading object: '%s', object is gone." + % self.objname) os.unlink(fetched_fspath) elif actual_info["pithos_type"] == common.T_DIR: - logger.info("Downloading object: '%s', object is dir." - % self.objname) + logger.debug("Downloading object: '%s', object is dir." + % self.objname) os.unlink(fetched_fspath) os.mkdir(fetched_fspath) return fetched_fspath diff --git a/agkyra/syncer/syncer.py b/agkyra/syncer/syncer.py index d2a936fef136cf730f1c6c3dab3a9838ffa91317..3ebcec027dc52d58b3564664bf1fcded59d68c93 100644 --- a/agkyra/syncer/syncer.py +++ b/agkyra/syncer/syncer.py @@ -122,7 +122,7 @@ class FileSyncer(object): self._do_probe_file(db, archive, objname, ident) def _do_probe_file(self, db, archive, objname, ident): - logger.info("Probing archive: %s, object: '%s'" % (archive, objname)) + logger.debug("Probing archive: %s, object: '%s'" % (archive, objname)) client = self.clients[archive] db_state = db.get_state(archive, objname) ref_state = db.get_state(self.SYNC, objname) @@ -242,7 +242,7 @@ class FileSyncer(object): def _do_decide_file_sync(self, db, objname, master, slave, ident, dry_run=False): - logger.info("Deciding object: '%s'" % objname) + logger.debug("Deciding object: '%s'" % objname) master_state = db.get_state(master, objname) slave_state = db.get_state(slave, objname) sync_state = db.get_state(self.SYNC, objname) @@ -333,7 +333,7 @@ class FileSyncer(object): max_alive_threads = self.settings.max_alive_sync_threads new_threads = max_alive_threads - alive_threads if new_threads > 0: - logger.info("Can start max %s syncs" % new_threads) + logger.debug("Can start max %s syncs" % new_threads) for i in range(new_threads): try: tpl = self.sync_queue.get(block=False)