Function TestQueue_SetAppendSeq

pkg/queue/queue_test.go:130–172

(t *testing.T)

}

func TestQueue_SetAppendSeq(t *testing.T) {
	ctrl := gomock.NewController(t)
	defer ctrl.Finish()

	dir := filepath.Join(t.TempDir(), t.Name())
	q, err := NewQueue(dir, 1024)
	assert.NoError(t, err)
	assert.NotNil(t, q)

	err = q.Put([]byte("123"))
	assert.NoError(t, err)
	assert.Equal(t, int64(0), q.AppendedSeq())

	err = q.Put([]byte("456"))
	assert.NoError(t, err)
	assert.Equal(t, int64(1), q.AppendedSeq())

	q.SetAppendedSeq(0)
	err = q.Put([]byte("78910"))
	assert.NoError(t, err)
	assert.Equal(t, int64(1), q.AppendedSeq())

	data, err := q.Get(1)
	assert.NoError(t, err)
	assert.Equal(t, []byte("78910"), data)

	q.SetAppendedSeq(100000000)
	err = q.Put([]byte("100000001"))
	assert.NoError(t, err)
	assert.Equal(t, int64(100000001), q.AppendedSeq())

	data, err = q.Get(100000001)
	assert.NoError(t, err)
	assert.Equal(t, []byte("100000001"), data)

	q1 := q.(*queue)
	metaPage := page.NewMockMappedPage(ctrl)
	q1.metaPage = metaPage
	metaPage.EXPECT().PutUint64(gomock.Any(), gomock.Any()).MaxTimes(2)
	metaPage.EXPECT().Sync().Return(fmt.Errorf("err"))
	q.SetAppendedSeq(1)
	q.Close()
}

func TestQueue_new_err(t *testing.T) {
	ctrl := gomock.NewController(t)