Method openBFileForHashWriting

internal/utils/bfs/fs.go:242–275

(hash string)

}

func (this *FS) openBFileForHashWriting(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
	}

	this.mu.RLock()
	bFile, ok := this.bMap[bName]
	this.mu.RUnlock()
	if ok {
		// 调整当前BFile所在位置
		this.mu.Lock()

		if bFile.IsClosing() {
			// TODO 需要重新等待打开
		}

		item, itemOk := this.bItemMap[bName]
		if itemOk {
			this.bList.Remove(item)
			this.bList.Push(item)
		}
		this.mu.Unlock()

		return bFile, nil
	}

	return this.openBFile(bPath, bName)
}

func (this *FS) openBFileForHashReading(hash string) (*BlocksFile, error) {
	err := CheckHashErr(hash)