Function TestEncodeMemory

query/outputnode_test.go:26–53

(t *testing.T)

)

func TestEncodeMemory(t *testing.T) {
	//	if testing.Short() {
	t.Skip("Skipping TestEncodeMemory")
	//	}
	var wg sync.WaitGroup

	for range runtime.NumCPU() {
		enc := newEncoder()
		n := enc.newNode(0)
		require.NotNil(t, n)
		for i := range 15000 {
			require.NoError(t, enc.AddValue(n, enc.idForAttr(fmt.Sprintf("very long attr name %06d", i)),
				types.ValueForType(types.StringID)))
			enc.AddListChild(n,
				enc.newNode(enc.idForAttr(fmt.Sprintf("another long child %06d", i))))
		}
		wg.Add(1)
		go func() {
			defer wg.Done()
			for range 1000 {
				enc.buf.Reset()
				require.NoError(t, enc.encode(n))
			}
		}()
	}

	wg.Wait()
}

func TestNormalizeJSONLimit(t *testing.T) {
	// Set default normalize limit.