Function TestHeadTailBuffer_ConcurrentWrites

agent/agentproc/headtail_test.go:184–213

(t *testing.T)

}

func TestHeadTailBuffer_ConcurrentWrites(t *testing.T) {
	t.Parallel()

	buf := agentproc.NewHeadTailBuffer()

	const goroutines = 10
	const writes = 1000
	var wg sync.WaitGroup
	wg.Add(goroutines)

	for g := range goroutines {
		go func() {
			defer wg.Done()
			line := fmt.Sprintf("goroutine-%d: data\n", g)
			for range writes {
				_, err := buf.Write([]byte(line))
				assert.NoError(t, err)
			}
		}()
	}

	wg.Wait()

	// Verify totals are consistent.
	require.Greater(t, buf.TotalWritten(), 0)
	require.Greater(t, buf.Len(), 0)

	out, _ := buf.Output()
	require.NotEmpty(t, out)
}

func TestHeadTailBuffer_TruncationInfoFields(t *testing.T) {
	t.Parallel()