Method sync

internal/utils/bfs/blocks_file.go:365–390

(force bool)

}

func (this *BlocksFile) sync(force bool) error {
	if !force {
		if this.writtenBytes < this.opt.BytesPerSync {
			return nil
		}
	}

	if this.writtenBytes > 0 {
		AckWriteThread()
		err := this.fp.Sync()
		ReleaseWriteThread()
		if err != nil {
			return err
		}
	}

	this.writtenBytes = 0

	this.syncAt = time.Now()

	if force {
		return this.mFile.SyncUnsafe()
	}

	return nil
}

func (this *BlocksFile) closeReaderPool() {
	for {