diff --git a/modules/pagoda/model_cycle.go b/modules/pagoda/model_cycle.go index 57b675e54..a81507c10 100644 --- a/modules/pagoda/model_cycle.go +++ b/modules/pagoda/model_cycle.go @@ -77,6 +77,7 @@ func (this *ModelCycle) getCycelData() (data *pb.DBCycelData) { cycelData *pb.DBCycelData err error ) + this.conflock.RLock() cycelData = this.cycelData this.conflock.RUnlock() @@ -133,6 +134,15 @@ func (this *ModelCycle) refreshCycelData() (data *pb.DBCycelData, err error) { "itype": data.Itype, "etime": data.Etime, }) + tableName := fmt.Sprintf("%s-%s", db.CrossTag(), this.TableName) + // 清理缓存的redis 数据 + _, err = this.DBModel.Redis.Keys(tableName) + if err == nil { + if model, err := this.module.GetCrossDBModel(this.TableName); err == nil { + err = model.Redis.Delete(tableName) + } + } + return }