diff --git a/src/redis-shake/dump.go b/src/redis-shake/dump.go index 36d7f8f..9c3998e 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] +", dd.id) + log.Infof("routine[%v] + waiting rdb done", dd.id) } case <-time.After(time.Second): - log.Infof("routine[%v] -", dd.id) + log.Infof("routine[%v] - waiting rdb done", dd.id) } } return c, nsize diff --git a/src/redis-shake/sync.go b/src/redis-shake/sync.go index a0da347..534fc8c 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] +", ds.id) + log.Infof("dbSyncer[%v] + waiting rdb done", ds.id) } else { return c, nsize } case <-time.After(time.Second): - log.Infof("dbSyncer[%v] -", ds.id) + log.Infof("dbSyncer[%v] - waiting rdb done", ds.id) } } }