From 65757e0f57f93103d87fdf9534c5ca25b66d14b7 Mon Sep 17 00:00:00 2001 From: Aravinda VK Date: Mon, 5 May 2014 11:04:00 +0530 Subject: geo-rep: Changelog History consumption more fixes Number of parallel threads to process changelog history is made configurable via sync_jobs Change-Id: Idcd8e655d9df540cfa48648b9e98af941f95e9d0 Signed-off-by: Aravinda VK Reviewed-on: http://review.gluster.org/7660 Reviewed-by: Venky Shankar Tested-by: Venky Shankar --- geo-replication/syncdaemon/resource.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) (limited to 'geo-replication/syncdaemon/resource.py') diff --git a/geo-replication/syncdaemon/resource.py b/geo-replication/syncdaemon/resource.py index f0f6692cae2..185722f5df0 100644 --- a/geo-replication/syncdaemon/resource.py +++ b/geo-replication/syncdaemon/resource.py @@ -685,8 +685,9 @@ class Server(object): Changes.cl_done(clfile) @classmethod - def history_changelog(cls, changelog_path, start, end): - return Changes.cl_history_changelog(changelog_path, start, end) + def history_changelog(cls, changelog_path, start, end, num_parallel): + return Changes.cl_history_changelog(changelog_path, start, end, + num_parallel) @classmethod def history_changelog_scan(cls): @@ -1312,6 +1313,12 @@ class GLUSTER(AbstractUrl, SlaveLocal, SlaveRemote): # g3 ==> changelog History g1.register() try: + (workdir, logfile) = g2.setup_working_dir() + # register with the changelog library + # 9 == log level (DEBUG) + # 5 == connection retries + brickserver.changelog_register(gconf.local_path, + workdir, logfile, 9, 5) g2.register() g3.register() except ChangelogException as e: -- cgit