Function TestMutableMap

posting/list_test.go:1546–1679

(t *testing.T)

}

func TestMutableMap(t *testing.T) {
	create_pl := func(startTs, commitTs, uid uint64, op uint32) *pb.PostingList {
		return &pb.PostingList{
			Postings: []*pb.Posting{
				{
					Uid:      uid,
					Op:       op,
					StartTs:  startTs,
					CommitTs: commitTs,
				},
			},
			CommitTs: commitTs,
		}
	}

	create_deleteAll_pl := func(startTs, commitTs uint64) *pb.PostingList {
		return &pb.PostingList{
			Postings: []*pb.Posting{
				{
					Value:    []byte(x.Star),
					Op:       Del,
					StartTs:  startTs,
					CommitTs: commitTs,
				},
			},
			CommitTs: commitTs,
		}
	}

	t.Run("Populate delete all tests", func(t *testing.T) {
		ml := newMutableLayer()
		ml.insertCommittedPostings(create_pl(10, 11, 1, Set))
		ml.insertCommittedPostings(create_deleteAll_pl(8, 9))
		ml.insertCommittedPostings(create_pl(6, 7, 1, Set))
		ml.insertCommittedPostings(create_deleteAll_pl(4, 5))
		ml.insertCommittedPostings(create_pl(2, 3, 1, Set))
		ml.insertCommittedPostings(create_deleteAll_pl(1, 2))

		require.Equal(t, uint64(9), ml.deleteAllMarker)
		require.Equal(t, 1, ml.length)

		ml.setCurrentEntries(11, create_deleteAll_pl(11, 0))
		require.Equal(t, true, math.MaxUint64 == ml.deleteAllMarker)
		require.Equal(t, 1, ml.length)

		require.Equal(t, uint64(11), ml.populateDeleteAll(11))
		require.Equal(t, uint64(9), ml.populateDeleteAll(10))
		require.Equal(t, uint64(5), ml.populateDeleteAll(5))
		require.Equal(t, uint64(2), ml.populateDeleteAll(4))

	})

	// Need to insert postings in reverse order
	t.Run("Current Entries has deleteAll", func(t *testing.T) {
		ml := newMutableLayer()
		ml.insertCommittedPostings(create_pl(1, 2, 1, Set))
		ml.setCurrentEntries(3, create_deleteAll_pl(3, 0))