Function TestEnumerateIsSorted

pkg/blobserver/files/enumerate_test.go:130–202

(t *testing.T)

}

func TestEnumerateIsSorted(t *testing.T) {
	ds, root := NewTestStorage(t)
	defer os.RemoveAll(root)

	const blobsToMake = 250
	t.Logf("Uploading test blobs...")
	for i := 0; i < blobsToMake; i++ {
		blob := &test.Blob{Contents: fmt.Sprintf("blob-%d", i)}
		blob.MustUpload(t, ds)
	}

	// Make some fake blobs in other partitions to confuse the
	// enumerate code.
	// TODO(bradfitz): remove this eventually.
	fakeDir := root + "/partition/queue-indexer/sha1/1f0/710"
	if err := os.MkdirAll(fakeDir, 0755); err != nil {
		t.Fatalf("error creating fakedir: %v", err)
	}
	if err := os.WriteFile(
		fakeDir+"/sha1-1f07105465650aa243cfc1b1bbb1c68ea95c6812.dat",
		[]byte("fake file"),
		0644,
	); err != nil {
		t.Fatalf("error writing fake blob: %v", err)
	}

	// And the same for a "cache" directory, used by the default configuration.
	fakeDir = root + "/cache/sha1/1f0/710"
	if err := os.MkdirAll(fakeDir, 0755); err != nil {
		t.Fatalf("error creating cachedir: %v", err)
	}
	if err := os.WriteFile(
		fakeDir+"/sha1-1f07105465650aa243cfc1b1bbb1c68ea95c6812.dat",
		[]byte("fake file"),
		0644,
	); err != nil {
		t.Fatalf("error writing fake file: %v", err)
	}

	var tests = []struct {
		limit int
		after string
	}{
		{200, ""},
		{blobsToMake, ""},
		{200, "sha1-2"},
		{200, "sha1-3"},
		{200, "sha1-4"},
		{200, "sha1-5"},
		{200, "sha1-e"},
		{200, "sha1-f"},
		{200, "sha1-ff"},
	}
	for _, test := range tests {
		limit := test.limit
		ch := make(chan blob.SizedRef)
		errCh := make(chan error)
		go func() {