Method reBuildCacheKeys

client/blockcache/bcache/manage.go:423–444

(dir string, store *DiskStore)

}

func (bm *bcacheManager) reBuildCacheKeys(dir string, store *DiskStore) {
	if _, err := os.Stat(dir); err != nil {
		log.LogErrorf("cache dir %s is not exists", dir)
		return
	}
	log.LogDebugf("reBuildCacheKeys(%s)", dir)
	c := make(chan keyPair)
	keyPrefix := filepath.Join(dir, Basedir)
	go func() {
		filepath.Walk(dir, bm.walker(c, keyPrefix, true))
		close(c)
	}()

	for value := range c {
		bm.Lock()
		element := bm.lrulist.PushBack(value.it)
		bm.bcacheKeys[value.key] = element
		bm.Unlock()
		log.LogDebugf("updateStat(%v)", value.it.size)
		store.updateStat(value.it.size)
	}
}

func (bm *bcacheManager) walker(c chan keyPair, prefix string, initial bool) filepath.WalkFunc {
	return func(path string, info os.FileInfo, err error) error {