Function TestDataFile1

datafile_test.go:58–89

(t *testing.T)

}

func TestDataFile1(t *testing.T) {
	if runtime.GOOS == "windows" {
		t.Skip()
	}
	fm := NewFileManager(MMap, 1024, 0.5, 256*MB)
	defer func() { _ = fm.Close() }()
	df, err := fm.GetDataFile(filePath, 1024)
	defer func() { _ = os.Remove(filePath) }()
	if err != nil {
		t.Fatal(err)
	}

	n, err := df.WriteAt(entry.Encode(), 0)
	if err != nil {
		t.Error("err TestDataFile_All WriteAt")
	}

	payloadSize := entry.Meta.PayloadSize()
	e, err := df.ReadEntry(n, payloadSize)
	assert.Nil(t, e)
	assert.Error(t, err, ErrEntryZero)

	e, err = df.ReadEntry(0, payloadSize)
	if err != nil || string(e.Key) != "key_0001" || string(e.Value) != "val_0001" || e.Meta.Timestamp != 1547707905 {
		t.Error("err TestDataFile_All ReadAt")
	}

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

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