Function TestDecoderSetConcurrency

decoder/decoder_test.go:294–352

(t *testing.T)

}

func TestDecoderSetConcurrency(t *testing.T) {
	in := append([]byte{0x8, 0x0, 0x0, 0x0}, zeroPaddedString("bananas", 32)...)

	labels := []config.Label{
		{
			Name: "number",
			Size: 4,
			Decoders: []config.Decoder{
				{
					Name: "uint",
				},
			},
		},
		{
			Name: "fruit",
			Size: 32,
			Decoders: []config.Decoder{
				{
					Name: "string",
				},
				{
					Name: "regexp",
					Regexps: []string{
						"^bananas$",
						"$is-banana-even-fruit$",
					},
				},
			},
		},
	}

	s, err := NewSet(0, nil)
	if err != nil {
		t.Fatal(err)
	}

	count := 1000

	wg := sync.WaitGroup{}
	wg.Add(count)

	for range count {
		go func() {
			defer wg.Done()

			_, err := s.DecodeLabelsForMetrics(in, "concurrency", labels)
			if err != nil {
				t.Error(err)
			}

			_, err = s.DecodeLabelsForTracing(in, labels)
			if err != nil {
				t.Error(err)
			}
		}()
	}

	wg.Wait()