summaryrefslogtreecommitdiffstats
path: root/geo-replication
diff options
context:
space:
mode:
Diffstat (limited to 'geo-replication')
-rw-r--r--geo-replication/syncdaemon/configinterface.py17
-rw-r--r--geo-replication/syncdaemon/resource.py9
2 files changed, 14 insertions, 12 deletions
diff --git a/geo-replication/syncdaemon/configinterface.py b/geo-replication/syncdaemon/configinterface.py
index adcefb8ab52..b5935dfdc14 100644
--- a/geo-replication/syncdaemon/configinterface.py
+++ b/geo-replication/syncdaemon/configinterface.py
@@ -235,7 +235,7 @@ class GConffile(object):
self.config.readfp(fp)
self._normconfig()
- def get_realtime(self, opt):
+ def get_realtime(self, opt, default_value=None):
try:
sres = os.stat(self.path)
except (OSError, IOError):
@@ -249,7 +249,7 @@ class GConffile(object):
sres[ST_INO] != self.ino or self.mtime != sres[ST_MTIME]:
self._load()
- return self.get(opt, printValue=False)
+ return self.get(opt, printValue=False, default_value=default_value)
def section(self, rx=False):
"""get the section name of the section representing .peers
@@ -348,7 +348,7 @@ class GConffile(object):
if self.config.has_section(self.section()):
update_from_sect(self.section(), MultiDict(dct, *self.auxdicts))
- def get(self, opt=None, printValue=True):
+ def get(self, opt=None, printValue=True, default_value=None):
"""print the matching key/value pairs from .config,
or if @opt given, the value for @opt (according to the
logic described in .update_to)
@@ -357,12 +357,13 @@ class GConffile(object):
self.update_to(d, allow_unresolved=True)
if opt:
opt = norm(opt)
- v = d.get(opt)
- if v:
- if printValue:
+ v = d.get(opt, default_value)
+
+ if printValue:
+ if v is not None:
print(v)
- else:
- return v
+ else:
+ return v
else:
for k, v in d.iteritems():
if k == '__name__':
diff --git a/geo-replication/syncdaemon/resource.py b/geo-replication/syncdaemon/resource.py
index 37b9043fc88..3722d21a0fd 100644
--- a/geo-replication/syncdaemon/resource.py
+++ b/geo-replication/syncdaemon/resource.py
@@ -1037,8 +1037,10 @@ class SlaveRemote(object):
(boolify(gconf.sync_acls) and ['--acls'] or []) + \
['.'] + list(args)
- if boolify(gconf.configinterface.get_realtime(
- "log_rsync_performance")):
+ log_rsync_performance = boolify(gconf.configinterface.get_realtime(
+ "log_rsync_performance", default_value=False))
+
+ if log_rsync_performance:
# use stdout=PIPE only when log_rsync_performance enabled
# Else rsync will write to stdout and nobody is their
# to consume. If PIPE is full rsync hangs.
@@ -1057,8 +1059,7 @@ class SlaveRemote(object):
for errline in stderr.strip().split("\n")[:-1]:
logging.error("SYNC Error(Rsync): %s" % errline)
- if boolify(gconf.configinterface.get_realtime(
- "log_rsync_performance")):
+ if log_rsync_performance:
rsync_msg = []
for line in stdout.split("\n"):
if line.startswith("Number of files:") or \