Method Init

internal/caches/storage_file.go:233–353

Init 初始化

()

// Init 初始化
func (this *FileStorage) Init() error {
	this.locker.Lock()
	defer this.locker.Unlock()

	var before = time.Now()

	// 配置
	var options = serverconfigs.NewHTTPFileCacheStorage()
	optionsJSON, err := json.Marshal(this.policy.Options)
	if err != nil {
		return err
	}
	err = json.Unmarshal(optionsJSON, options)
	if err != nil {
		return err
	}
	this.options = options

	if !filepath.IsAbs(this.options.Dir) {
		this.options.Dir = Tea.Root + Tea.DS + this.options.Dir
	}

	this.options.Dir = filepath.Clean(this.options.Dir)
	var dir = this.options.Dir

	var subDirs = []*FileDir{}
	for _, subDir := range this.options.SubDirs {
		subDirs = append(subDirs, &FileDir{
			Path:     subDir.Path,
			Capacity: subDir.Capacity,
			IsFull:   false,
		})
	}
	this.subDirs = subDirs
	if len(subDirs) > 0 {
		this.checkDiskSpace()
	}

	if len(dir) == 0 {
		return errors.New("[CACHE]cache storage dir can not be empty")
	}

	// read list
	var list ListInterface
	var sqliteIndexesDir = dir + "/p" + types.String(this.policy.Id) + "/.indexes"
	_, sqliteIndexesDirErr := os.Stat(sqliteIndexesDir)
	if sqliteIndexesDirErr == nil || !teaconst.EnableKVCacheStore {
		list = NewSQLiteFileList(sqliteIndexesDir)
		err = list.Init()
		if err != nil {
			return err
		}
		list.(*SQLiteFileList).SetOldDir(dir + "/p" + types.String(this.policy.Id))
	} else {
		list = NewKVFileList(dir + "/p" + types.String(this.policy.Id) + "/.stores")
		err = list.Init()
		if err != nil {
			return err