-
Notifications
You must be signed in to change notification settings - Fork 185
Open
Description
func DeleteCache(prefix string) error {
fmt.Println("DeleteCache:" + prefix)
iter, err := db.NewIterator(lotusdb.IteratorOptions{
Prefix: []byte(prefix),
})
if err != nil {
return err
}
fmt.Println("DeleteCache: NewIterator ")
batch := db.NewBatch(lotusdb.BatchOptions{
WriteOptions: lotusdb.WriteOptions{
Sync: false,
},
})
for iter.Valid() {
fmt.Println("DeleteCache: Valid")
key := append([]byte(nil), iter.Key()...)
fmt.Println("DeleteRandHtml=>" + string(key))
err = batch.Delete(key)
if err != nil {
return err
}
iter.Next()
}
fmt.Println("DeleteCache: 循环完成 ")
err = batch.Commit()
if err != nil {
return err
}
err = iter.Close()
if err != nil {
return err
}
return nil
}
在输出了 DeleteCache: NewIterator 之后程序就卡死了
Metadata
Metadata
Assignees
Labels
No labels