Method waitBFile

internal/utils/bfs/fs.go:418–442

(bPath string)

}

func (this *FS) waitBFile(bPath string) error {
	this.mu.RLock()
	_, isClosing := this.closingBMap[bPath]
	this.mu.RUnlock()
	if !isClosing {
		return nil
	}

	var maxWaits = 30_000
	for {
		this.mu.RLock()
		_, isClosing = this.closingBMap[bPath]
		this.mu.RUnlock()
		if !isClosing {
			break
		}
		time.Sleep(1 * time.Millisecond)
		maxWaits--

		if maxWaits < 0 {
			return errors.New("open blocks file timeout")
		}
	}
	return nil
}