Function TestMemoryResourceWriteReadScattered

gapis/memory/pool_test.go:174–209

Write layout: 0 1 2 3 4 5 6 7 8 9 10 11 ┌────╔════╤════╤════╗────┬────┬────┬────┬────┬────┬────┬────┐ 0 │ ║A 10│ 11 │ 12 ║ │ │ │ │ │ │ │ │ └────╚════╧════╧════╝────┴────┴────┴────┴────┴────┴────┴────┘ ┌────┬────┬────┬────┬────┬────┬────╔════╤

(t *testing.T)

//   └────┴────┴────┴────┴────┴────┴────┴────╚════╝────┴────┴────┘
//
func TestMemoryResourceWriteReadScattered(t *testing.T) {
	ctx := log.Testing(t)
	ctx = database.Put(ctx, database.NewInMemory(ctx))
	resA, _ := database.Store(ctx, []byte{10, 11, 12})
	resB, _ := database.Store(ctx, []byte{20, 21, 22, 23})
	resC, _ := database.Store(ctx, []byte{30, 31})
	resD, _ := database.Store(ctx, []byte{40, 41, 42})
	resE, _ := database.Store(ctx, []byte{50})

	p := Pool{}
	p.Write(1, Resource(resA, 3))
	p.Write(7, Resource(resB, 4))
	p.Write(2, Resource(resC, 2))
	p.Write(2, Resource(resD, 3))
	p.Write(8, Resource(resE, 1))

	for _, test := range []struct {
		rng      Range
		expected []byte
	}{
		{Range{Base: 0, Size: 12}, []byte{0, 10, 40, 41, 42, 00, 00, 20, 50, 22, 23, 00}},
		{Range{Base: 1, Size: 10}, []byte{10, 40, 41, 42, 00, 00, 20, 50, 22, 23}},
		{Range{Base: 2, Size: 3}, []byte{40, 41, 42}},
		{Range{Base: 5, Size: 2}, []byte{0, 0}},
		{Range{Base: 8, Size: 1}, []byte{50}},
	} {
		slice := p.Slice(test.rng)
		checkData(ctx, slice, test.expected)

		gotID, err := slice.ResourceID(ctx)
		assert.For(ctx, "err").ThatError(err).Succeeded()

		expectedID, _ := database.Store(ctx, test.expected)
		assert.For(ctx, "id").That(gotID).Equals(expectedID)
	}
}

func TestPoolSliceReaderErrorPropagation(t *testing.T) {
	ctx := log.Testing(t)