Function OpenFS

internal/utils/bfs/fs.go:41–72

OpenFS 打开文件系统

(dir string, options *FSOptions)

// OpenFS 打开文件系统
func OpenFS(dir string, options *FSOptions) (*FS, error) {
	if !IsEnabled() {
		return nil, errors.New("the fs only works under 64 bit system")
	}

	if options == nil {
		options = DefaultFSOptions
	} else {
		options.EnsureDefaults()
	}

	var locker = fsutils.NewLocker(dir + "/fs")
	err := locker.Lock()
	if err != nil {
		return nil, err
	}

	var fs = &FS{
		dir:          dir,
		bMap:         map[string]*BlocksFile{},
		bList:        linkedlist.NewList[string](),
		bItemMap:     map[string]*linkedlist.Item[string]{},
		closingBMap:  map[string]zero.Zero{},
		closingBChan: make(chan *BlocksFile, 32),
		mu:           &sync.RWMutex{},
		opt:          options,
		syncTicker:   time.NewTicker(1 * time.Second),
		locker:       locker,
	}
	go fs.init()
	return fs, nil
}

func (this *FS) init() {
	go func() {