Function TestDataFile2

datafile_test.go:91–133

(t *testing.T)

}

func TestDataFile2(t *testing.T) {
	fm := NewFileManager(FileIO, 1024, 0.5, 256*MB)
	tmpdir := t.TempDir()
	filePath2 := filepath.Join(tmpdir, "foo2")
	df, err := fm.GetDataFile(filePath2, 64)
	assert.Nil(t, err)
	defer func() { _ = os.Remove(filePath2) }()
	headerSize := entry.Meta.Size()
	content := entry.Encode()[0 : headerSize-1]
	_, err = df.WriteAt(content, 0)
	if err != nil {
		t.Error("err TestDataFile_All WriteAt")
	}

	payloadSize := entry.Meta.PayloadSize()
	e, err := df.ReadEntry(0, payloadSize)
	if err == nil || e != nil {
		t.Error("err TestDataFile_All ReadAt")
	}

	filePath3 := filepath.Join(tmpdir, "foo3")

	df2, err := fm.GetDataFile(filePath3, 64)
	defer func() { _ = os.Remove(filePath3) }()
	assert.Nil(t, err)

	headerSize = entry.Meta.Size()
	content = entry.Encode()[0 : headerSize+1]
	_, err = df2.WriteAt(content, 0)
	assert.Nil(t, err)

	e, err = df2.ReadEntry(0, payloadSize)
	if err == nil || e != nil {
		t.Error("err TestDataFile_All ReadAt")
	}

	err = df.Release()
	assert.Nil(t, err)
	err = df2.Release()
	assert.Nil(t, err)
	err = fm.Close()
	assert.Nil(t, err)
}

func TestDataFile_ReadRecord(t *testing.T) {
	fm := NewFileManager(FileIO, 1024, 0.5, 256*MB)