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/monitor.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/monitor.py')
| -rw-r--r-- | geo-replication/syncdaemon/monitor.py | 8 | 
1 files changed, 4 insertions, 4 deletions
diff --git a/geo-replication/syncdaemon/monitor.py b/geo-replication/syncdaemon/monitor.py index 7eddd26d5ea..f13e5e79eab 100644 --- a/geo-replication/syncdaemon/monitor.py +++ b/geo-replication/syncdaemon/monitor.py @@ -269,8 +269,8 @@ class Monitor(object):              # Spawn the worker and agent in lock to avoid fd leak              self.lock.acquire() -            logging.info('-' * conn_timeout) -            logging.info('starting gsyncd worker') +            logging.info('starting gsyncd worker(%s). Slave node: %s' % +                         (w[0]['dir'], remote_host))              # Couple of pipe pairs for RPC communication b/w              # worker and changelog agent. @@ -452,7 +452,7 @@ def distribute(*resources):                                        new_stime_xattr_name)      else:          raise GsyncdError("unknown slave type " + slave.url) -    logging.info('slave bricks: ' + repr(sbricks)) +    logging.debug('slave bricks: ' + repr(sbricks))      if isinstance(si, FILE):          slaves = [slave.url]      else: @@ -477,7 +477,7 @@ def distribute(*resources):                                 slaves[idx % len(slaves)],                                 get_subvol_num(idx, mvol, is_hot),                                 is_hot)) -    logging.info('worker specs: ' + repr(workerspex)) +    logging.debug('worker specs: ' + repr(workerspex))      return workerspex, suuid, slave_vol, slave_host, master  | 
