Function waitForCompactionCleanup

store_test.go:2237–2255

Since file deletions happen asynchronously, sometimes it is possible that the deleted file still lingers around. To ensure this does not cause test failures, retry a few times before just returning the contents of the directory.

(tmpDir string, secsToWait int)

// To ensure this does not cause test failures, retry a few times
// before just returning the contents of the directory.
func waitForCompactionCleanup(tmpDir string, secsToWait int) (
	fileInfos []os.FileInfo, err error) {
	fileInfos, err = ioutil.ReadDir(tmpDir)
	if err != nil {
		return
	}
	for retry := secsToWait; retry > 0 && len(fileInfos) != 1; retry-- {
		file, erro := os.Open(tmpDir)
		if erro != nil {
			return fileInfos, erro
		}
		file.Sync()
		file.Close()

		time.Sleep(1 * time.Second)
		fileInfos, err = ioutil.ReadDir(tmpDir)
	}
	return
}

func TestCompactionWithAndWithoutRegularSync(t *testing.T) {
	numItems := 1000000