diff options
| author | Aravinda VK <avishwan@redhat.com> | 2016-10-20 15:05:38 +0530 | 
|---|---|---|
| committer | Aravinda VK <avishwan@redhat.com> | 2016-10-24 00:01:48 -0700 | 
| commit | cdc30ed8eacb6772e0dabb863ef51cef794d60dd (patch) | |
| tree | b7583e7fcda8c4871c1e4632c4ae86e7133fe6dc /geo-replication/syncdaemon/master.py | |
| parent | ec64ce2e1684003f4e7a20d4372e414bfbddb6fb (diff) | |
geo-rep: Logging improvements
- Redundant log messages removed.
- Worker and connected slave node details added in "starting worker" log
- Added log for Monitor state change
- Added log for Worker status change(Initializing/Active/Passive/Faulty)
- Added log for Crawl status Change
- Added log for config set and reset
- Added log for checkpoint set, reset and completion
BUG: 1359612
Change-Id: Icc7173ff3c93de4b862bdb1a61760db7eaf14271
Signed-off-by: Aravinda VK <avishwan@redhat.com>
Reviewed-on: http://review.gluster.org/15684
Smoke: Gluster Build System <jenkins@build.gluster.org>
NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
CentOS-regression: Gluster Build System <jenkins@build.gluster.org>
Reviewed-by: Kotresh HR <khiremat@redhat.com>
Diffstat (limited to 'geo-replication/syncdaemon/master.py')
| -rw-r--r-- | geo-replication/syncdaemon/master.py | 20 | 
1 files changed, 8 insertions, 12 deletions
diff --git a/geo-replication/syncdaemon/master.py b/geo-replication/syncdaemon/master.py index b5ddac05c29..2c4d8c581a4 100644 --- a/geo-replication/syncdaemon/master.py +++ b/geo-replication/syncdaemon/master.py @@ -98,7 +98,7 @@ def gmaster_builder(excrawl=None):          modemixin = 'normal'      changemixin = 'xsync' if gconf.change_detector == 'xsync' \                    else excrawl or gconf.change_detector -    logging.info('setting up %s change detection mode' % changemixin) +    logging.debug('setting up %s change detection mode' % changemixin)      modemixin = getattr(this, modemixin.capitalize() + 'Mixin')      crawlmixin = getattr(this, 'GMaster' + changemixin.capitalize() + 'Mixin')      sendmarkmixin = boolify( @@ -391,10 +391,8 @@ class GMasterCommon(object):          self.slave = slave          self.jobtab = {}          if boolify(gconf.use_tarssh): -            logging.info("using 'tar over ssh' as the sync engine")              self.syncer = Syncer(slave, self.slave.tarssh, [2])          else: -            logging.info("using 'rsync' as the sync engine")              # partial transfer (cf. rsync(1)), that's normal              self.syncer = Syncer(slave, self.slave.rsync, [23, 24])          # crawls vs. turns: @@ -535,9 +533,9 @@ class GMasterCommon(object):          volinfo_sys = self.volinfo_hook()          self.volinfo = volinfo_sys[self.KNAT]          inter_master = volinfo_sys[self.KFGN] -        logging.info("%s master with volume id %s ..." % -                     (inter_master and "intermediate" or "primary", -                      self.uuid)) +        logging.debug("%s master with volume id %s ..." % +                      (inter_master and "intermediate" or "primary", +                       self.uuid))          gconf.configinterface.set('volume_id', self.uuid)          if self.volinfo:              if self.volinfo['retval']: @@ -546,7 +544,6 @@ class GMasterCommon(object):          else:              raise GsyncdError("master volinfo unavailable")          self.lastreport['time'] = time.time() -        logging.info('crawl interval: %d seconds' % self.sleep_interval)          t0 = time.time()          crawl = self.should_crawl() @@ -557,9 +554,9 @@ class GMasterCommon(object):              self.start = time.time()              should_display_info = self.start - self.lastreport['time'] >= 60              if should_display_info: -                logging.info("%d crawls, %d turns", -                             self.crawls - self.lastreport['crawls'], -                             self.turns - self.lastreport['turns']) +                logging.debug("%d crawls, %d turns", +                              self.crawls - self.lastreport['crawls'], +                              self.turns - self.lastreport['turns'])                  self.lastreport.update(crawls=self.crawls,                                         turns=self.turns,                                         time=self.start) @@ -1240,7 +1237,6 @@ class GMasterChangeloghistoryMixin(GMasterChangelogMixin):                          repr(end_time), self.get_entry_stime()))          if not data_stime or data_stime == URXTIME: -            logging.info("stime not available, abandoning history crawl")              raise NoStimeAvailable()          # Changelogs backend path is hardcoded as @@ -1322,10 +1318,10 @@ class GMasterXsyncMixin(GMasterChangelogMixin):          self.stimes = []          self.sleep_interval = 60          self.tempdir = self.setup_working_dir() +        logging.info('Working dir: %s' % self.tempdir)          self.tempdir = os.path.join(self.tempdir, 'xsync')          self.processed_changelogs_dir = self.tempdir          self.name = "xsync" -        logging.info('xsync temp directory: %s' % self.tempdir)          try:              os.makedirs(self.tempdir)          except OSError:  | 
