Commit f111450b authored by Giorgos Korfiatis's avatar Giorgos Korfiatis

Reduce level of probe/decide messages

parent 48b85188
......@@ -65,8 +65,8 @@ class AlreadyProbedMessage(Message):
self.archive = kwargs["archive"]
self.objname = kwargs["objname"]
self.serial = kwargs["serial"]
self.logger.warning("Serial mismatch in probing archive: %s, "
"object: '%s'" % (self.archive, self.objname))
self.logger.debug("Already probed archive: %s, "
"object: '%s'" % (self.archive, self.objname))
class HeartbeatNoProbeMessage(Message):
......@@ -75,9 +75,9 @@ class HeartbeatNoProbeMessage(Message):
self.archive = kwargs["archive"]
self.objname = kwargs["objname"]
self.heartbeat = kwargs["heartbeat"]
self.logger.warning("Object '%s' is being synced; "
"Probe in archive %s aborted." %
(self.objname, self.archive))
self.logger.debug("Object '%s' is being synced; "
"Probe in archive %s aborted." %
(self.objname, self.archive))
class HeartbeatNoDecideMessage(Message):
......
......@@ -306,14 +306,14 @@ class FileSyncer(object):
objname=objname, heartbeat=beat, logger=logger)
self.messager.put(msg)
return None
logger.warning("Ignoring previous run: %s %s" %
(objname, beat))
logger.debug("Ignoring previous run: %s %s" %
(objname, beat))
if decision_serial != sync_serial:
with self.failed_serials.lock() as d:
failed_sync = d.get((decision_serial, objname))
if failed_sync is None:
logger.warning(
logger.debug(
"Already decided: '%s', decision: %s, sync: %s" %
(objname, decision_serial, sync_serial))
if decision_serial == master_serial:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment