Function TestFS_OpenFileWriter_Close

internal/utils/bfs/fs_test.go:126–197

(t *testing.T)

}

func TestFS_OpenFileWriter_Close(t *testing.T) {
	if !testutils.IsSingleTesting() {
		return
	}

	fs, openErr := bfs.OpenFS(Tea.Root+"/data/bfs/test", &bfs.FSOptions{
		MaxOpenFiles: 99,
	})
	if openErr != nil {
		t.Fatal(openErr)
	}
	defer func() {
		_ = fs.Close()
	}()

	var count = 2
	if testutils.IsSingleTesting() {
		count = 100
	}

	for i := 0; i < count; i++ {
		//t.Log("open", i)
		writer, err := fs.OpenFileWriter(bfs.Hash(types.String(i)), -1, false)
		if err != nil {
			t.Fatal(err)
		}
		_ = writer.Close()
	}

	t.Log(len(fs.TestBMap()), "block files, pid:", os.Getpid())

	var p = func() {
		var bNames []string
		fs.TestBList().Range(func(item *linkedlist.Item[string]) (goNext bool) {
			bNames = append(bNames, item.Value)
			return true
		})

		if len(bNames) != len(fs.TestBMap()) {
			t.Fatal("len(bNames)!=len(bMap)")
		}

		if len(bNames) < 10 {
			t.Log("["+types.String(len(bNames))+"]", bNames)
		} else {
			t.Log("["+types.String(len(bNames))+"]", bNames[:10], "...")
		}
	}

	p()

	{
		writer, err := fs.OpenFileWriter(bfs.Hash(types.String(10)), -1, false)
		if err != nil {
			t.Fatal(err)
		}
		_ = writer.Close()
	}