File tree Expand file tree Collapse file tree
src/full_check/full_check Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -29,6 +29,7 @@ func (p *FullCheck) ScanFromSourceRedis(allKeys chan<- []*common.Key) {
2929 copier .Copy (& singleHost , & p .SourceHost )
3030 // set single host address
3131 singleHost .Addr = []string {singleHost .Addr [index ]}
32+ singleHost .DBType = common .TypeDB
3233 // build client by single db
3334 if sourceClient , err = client .NewRedisClient (singleHost , p .currentDB ); err != nil {
3435 panic (common .Logger .Critical (err ))
@@ -42,6 +43,8 @@ func (p *FullCheck) ScanFromSourceRedis(allKeys chan<- []*common.Key) {
4243 }
4344 defer sourceClient .Close ()
4445
46+ common .Logger .Infof ("build connection[%v]" , sourceClient .String ())
47+
4548 for {
4649 var reply interface {}
4750 var err error
@@ -96,6 +99,7 @@ func (p *FullCheck) ScanFromSourceRedis(allKeys chan<- []*common.Key) {
9699 Tp : common .EndKeyType ,
97100 ConflictType : common .EndConflict ,
98101 })
102+ // common.Logger.Debugf("read key: %v", string(bytes))
99103 }
100104 p .IncrScanStat (len (keysInfo ))
101105 allKeys <- keysInfo
You can’t perform that action at this time.
0 commit comments