Method Init

internal/caches/list_file_sqlite.go:50–107

()

}

func (this *SQLiteFileList) Init() error {
	// 检查目录是否存在
	_, err := os.Stat(this.dir)
	if err != nil {
		err = os.MkdirAll(this.dir, 0777)
		if err != nil {
			return err
		}
		remotelogs.Println("CACHE", "create cache dir '"+this.dir+"'")
	}

	var dir = this.dir
	if dir == "/" {
		// 防止sqlite提示authority错误
		dir = ""
	}

	remotelogs.Println("CACHE", "loading database from '"+dir+"' ...")
	var wg = &sync.WaitGroup{}
	var locker = sync.Mutex{}
	var lastErr error

	for i := 0; i < CountFileDB; i++ {
		wg.Add(1)
		go func(i int) {
			defer wg.Done()

			var db = NewSQLiteFileListDB()
			dbErr := db.Open(dir + "/db-" + types.String(i) + ".db")
			if dbErr != nil {
				lastErr = dbErr
				return
			}

			dbErr = db.Init()
			if dbErr != nil {
				lastErr = dbErr
				return
			}

			locker.Lock()
			this.dbList[i] = db
			locker.Unlock()
		}(i)
	}
	wg.Wait()

	if lastErr != nil {
		return lastErr
	}

	// 升级老版本数据库
	goman.New(func() {
		this.upgradeOldDB()
	})

	return nil
}