Method consumeHead

internal/caches/open_file_cache.go:180–210

()

}

func (this *OpenFileCache) consumeHead() {
	var delta = 1

	if this.count > 100 {
		delta = 2
	}

	for i := 0; i < delta; i++ {
		var head = this.poolList.Head()
		if head == nil {
			break
		}

		var headPool = head.Value
		headFile, consumed, consumedSize := headPool.Get()
		if consumed {
			this.count--
			this.usedSize -= consumedSize

			if headFile != nil {
				_ = headFile.Close()
			}
		}

		if headPool.Len() == 0 {
			delete(this.poolMap, headPool.filename)
			this.poolList.Remove(head)
			_ = this.watcher.Remove(headPool.filename)
		}
	}
}