From 23293da176d631ceb6c115aeb7c1681a92b03f4e Mon Sep 17 00:00:00 2001 From: vinllen Date: Wed, 24 Jul 2019 15:06:21 +0800 Subject: [PATCH] add more debug log in RDB --- src/redis-shake/restore.go | 3 ++- src/redis-shake/sync.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/redis-shake/restore.go b/src/redis-shake/restore.go index 6286a58..1c1f15e 100644 --- a/src/redis-shake/restore.go +++ b/src/redis-shake/restore.go @@ -173,9 +173,10 @@ func (dr *dbRestorer) restoreRDBFile(reader *bufio.Reader, target []string, auth if filter.FilterKey(string(e.Key)) { continue } - utils.RestoreRdbEntry(c, e) log.Debugf("routine[%v] restore key[%s] with value length[%v]", dr.id, e.Key, len(e.Value)) + utils.RestoreRdbEntry(c, e) + log.Debugf("routine[%v] restore key[%s] ok", dr.id, e.Key) } } }() diff --git a/src/redis-shake/sync.go b/src/redis-shake/sync.go index a3e126f..4054a2e 100644 --- a/src/redis-shake/sync.go +++ b/src/redis-shake/sync.go @@ -438,8 +438,9 @@ func (ds *dbSyncer) syncRDBFile(reader *bufio.Reader, target []string, auth_type continue } } - utils.RestoreRdbEntry(c, e) log.Debugf("dbSyncer[%v] restore key[%s] with value length[%v]", ds.id, e.Key, len(e.Value)) + utils.RestoreRdbEntry(c, e) + log.Debugf("routine[%v] restore key[%s] ok", ds.id, e.Key) } } }()