Method shiftOpenFiles

internal/utils/bfs/fs.go:373–416

弹出超出BFile数量限制的BFile

()

// 弹出超出BFile数量限制的BFile
func (this *FS) shiftOpenFiles() {
	var l = this.bList.Len()
	var count = l - this.opt.MaxOpenFiles
	if count <= 0 {
		return
	}

	var bNames []string
	var searchCount int
	this.bList.Range(func(item *linkedlist.Item[string]) (goNext bool) {
		searchCount++

		var bName = item.Value
		var bFile = this.bMap[bName]
		if bFile.CanClose() {
			bNames = append(bNames, bName)
			count--
		}
		return count > 0 && searchCount < 8 && searchCount < l-8
	})

	for _, bName := range bNames {
		var bFile = this.bMap[bName]
		var item = this.bItemMap[bName]

		// clean
		delete(this.bMap, bName)
		delete(this.bItemMap, bName)
		this.bList.Remove(item)

		// add to closing queue
		this.closingBMap[bFile.Filename()] = zero.Zero{}

		// MUST run in goroutine
		go func(bFile *BlocksFile) {
			// 因为 closingBChan 可能已经关闭
			defer func() {
				recover()
			}()

			this.closingBChan <- bFile
		}(bFile)
	}
}

func (this *FS) waitBFile(bPath string) error {
	this.mu.RLock()