From ee4453fb506bd548cd4eb17f9f8a1be3132e498e Mon Sep 17 00:00:00 2001 From: vinllen Date: Tue, 9 Jul 2019 16:49:17 +0800 Subject: [PATCH] polish log print2 --- src/redis-shake/dump.go | 4 ++-- src/redis-shake/sync.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/redis-shake/dump.go b/src/redis-shake/dump.go index 9c3998e..5d4e146 100644 --- a/src/redis-shake/dump.go +++ b/src/redis-shake/dump.go @@ -141,10 +141,10 @@ func (dd *dbDumper) sendCmd(master, auth_type, passwd string, tlsEnable bool) (n select { case nsize = <-wait: if nsize == 0 { - log.Infof("routine[%v] + waiting rdb done", dd.id) + log.Infof("routine[%v] + waiting source rdb", dd.id) } case <-time.After(time.Second): - log.Infof("routine[%v] - waiting rdb done", dd.id) + log.Infof("routine[%v] - waiting source rdb", dd.id) } } return c, nsize diff --git a/src/redis-shake/sync.go b/src/redis-shake/sync.go index 534fc8c..24f1266 100644 --- a/src/redis-shake/sync.go +++ b/src/redis-shake/sync.go @@ -264,12 +264,12 @@ func (ds *dbSyncer) sendSyncCmd(master, auth_type, passwd string, tlsEnable bool select { case nsize := <-wait: if nsize == 0 { - log.Infof("dbSyncer[%v] + waiting rdb done", ds.id) + log.Infof("dbSyncer[%v] + waiting source rdb", ds.id) } else { return c, nsize } case <-time.After(time.Second): - log.Infof("dbSyncer[%v] - waiting rdb done", ds.id) + log.Infof("dbSyncer[%v] - waiting source rdb", ds.id) } } }