Method openBFileForHashReading

internal/utils/bfs/fs.go:277–309

(hash string)

}

func (this *FS) openBFileForHashReading(hash string) (*BlocksFile, error) {
	err := CheckHashErr(hash)
	if err != nil {
		return nil, err
	}

	bPath, bName, err := this.bPathForHash(hash)
	if err != nil {
		return nil, err
	}

	err = this.waitBFile(bPath)
	if err != nil {
		return nil, err
	}

	this.mu.Lock()
	bFile, ok := this.bMap[bName]
	if ok {
		// 调整当前BFile所在位置
		item, itemOk := this.bItemMap[bName]
		if itemOk {
			this.bList.Remove(item)
			this.bList.Push(item)
		}
		this.mu.Unlock()
		return bFile, nil
	}

	this.mu.Unlock()

	return this.openBFile(bPath, bName)
}

func (this *FS) openBFile(bPath string, bName string) (*BlocksFile, error) {
	// check closing queue