From 2a133cdde0055a72ed22cdbd9f6f3a50f4fca739 Mon Sep 17 00:00:00 2001
From: Giorgos Korfiatis <gkorf@grnet.gr>
Date: Tue, 6 Oct 2015 18:35:26 +0300
Subject: [PATCH] move some loggings to debug
---
agkyra/syncer/messaging.py | 4 ++--
agkyra/syncer/pithos_client.py | 12 ++++++------
agkyra/syncer/syncer.py | 6 +++---
3 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/agkyra/syncer/messaging.py b/agkyra/syncer/messaging.py
index 516d6a8..3349423 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 1093b1e..42f37f9 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 d2a936f..3ebcec0 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)
--
GitLab