mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Pablo BaeyensandGitHub
974da01f71
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description This: - Renames the `benchmark` target to `timebenchmark` and passes the `MEMBENCH` env variable on the original `benchmark` target (it was duplicated) - Adds `testutil.SkipMemoryBench` to a bunch of tests that are not there for measuring time but rather for measuring allocations - Bumps number of iterations on one queue benchmark to bump total time taken by the test <!-- Issue number if applicable --> #### Link to tracking issue Fixes #14216, updates #14111
174 lines
4.3 KiB
Go
174 lines
4.3 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
// Code generated by "internal/cmd/pdatagen/main.go". DO NOT EDIT.
|
|
// To regenerate this file run "make genpdata".
|
|
|
|
package pcommon
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
"go.opentelemetry.io/collector/internal/testutil"
|
|
"go.opentelemetry.io/collector/pdata/internal"
|
|
)
|
|
|
|
func TestNewFloat64Slice(t *testing.T) {
|
|
ms := NewFloat64Slice()
|
|
assert.Equal(t, 0, ms.Len())
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
assert.Equal(t, 3, ms.Len())
|
|
assert.Equal(t, []float64{1.1, 2.2, 3.3}, ms.AsRaw())
|
|
ms.SetAt(1, float64(5.5))
|
|
assert.Equal(t, []float64{1.1, 5.5, 3.3}, ms.AsRaw())
|
|
ms.FromRaw([]float64{3.3})
|
|
assert.Equal(t, 1, ms.Len())
|
|
assert.InDelta(t, float64(3.3), ms.At(0), 0.01)
|
|
|
|
cp := NewFloat64Slice()
|
|
ms.CopyTo(cp)
|
|
ms.SetAt(0, float64(2.2))
|
|
assert.InDelta(t, float64(2.2), ms.At(0), 0.01)
|
|
assert.InDelta(t, float64(3.3), cp.At(0), 0.01)
|
|
ms.CopyTo(cp)
|
|
assert.InDelta(t, float64(2.2), cp.At(0), 0.01)
|
|
|
|
mv := NewFloat64Slice()
|
|
ms.MoveTo(mv)
|
|
assert.Equal(t, 0, ms.Len())
|
|
assert.Equal(t, 1, mv.Len())
|
|
assert.InDelta(t, float64(2.2), mv.At(0), 0.01)
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
ms.MoveTo(mv)
|
|
assert.Equal(t, 3, mv.Len())
|
|
assert.InDelta(t, float64(1.1), mv.At(0), 0.01)
|
|
mv.MoveTo(mv)
|
|
assert.Equal(t, 3, mv.Len())
|
|
assert.InDelta(t, float64(1.1), mv.At(0), 0.01)
|
|
}
|
|
|
|
func TestFloat64SliceReadOnly(t *testing.T) {
|
|
raw := []float64{1.1, 2.2, 3.3}
|
|
sharedState := internal.NewState()
|
|
sharedState.MarkReadOnly()
|
|
ms := Float64Slice(internal.NewFloat64SliceWrapper(&raw, sharedState))
|
|
|
|
assert.Equal(t, 3, ms.Len())
|
|
assert.InDelta(t, float64(1.1), ms.At(0), 0.01)
|
|
assert.Panics(t, func() { ms.Append(1.1) })
|
|
assert.Panics(t, func() { ms.EnsureCapacity(2) })
|
|
assert.Equal(t, raw, ms.AsRaw())
|
|
assert.Panics(t, func() { ms.FromRaw(raw) })
|
|
|
|
ms2 := NewFloat64Slice()
|
|
ms.CopyTo(ms2)
|
|
assert.Equal(t, ms.AsRaw(), ms2.AsRaw())
|
|
assert.Panics(t, func() { ms2.CopyTo(ms) })
|
|
|
|
assert.Panics(t, func() { ms.MoveTo(ms2) })
|
|
assert.Panics(t, func() { ms2.MoveTo(ms) })
|
|
}
|
|
|
|
func TestFloat64SliceAppend(t *testing.T) {
|
|
ms := NewFloat64Slice()
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
ms.Append(5.5, 5.5)
|
|
assert.Equal(t, 5, ms.Len())
|
|
assert.InDelta(t, float64(5.5), ms.At(4), 0.01)
|
|
}
|
|
|
|
func TestFloat64SliceEnsureCapacity(t *testing.T) {
|
|
ms := NewFloat64Slice()
|
|
ms.EnsureCapacity(4)
|
|
assert.Equal(t, 4, cap(*ms.getOrig()))
|
|
ms.EnsureCapacity(2)
|
|
assert.Equal(t, 4, cap(*ms.getOrig()))
|
|
}
|
|
|
|
func TestFloat64SliceAll(t *testing.T) {
|
|
ms := NewFloat64Slice()
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
assert.NotEmpty(t, ms.Len())
|
|
|
|
var c int
|
|
for i, v := range ms.All() {
|
|
assert.Equal(t, ms.At(i), v, "element should match")
|
|
c++
|
|
}
|
|
assert.Equal(t, ms.Len(), c, "All elements should have been visited")
|
|
}
|
|
|
|
func TestFloat64SliceMoveAndAppendTo(t *testing.T) {
|
|
// Test moving from an empty slice
|
|
ms := NewFloat64Slice()
|
|
ms2 := NewFloat64Slice()
|
|
ms.MoveAndAppendTo(ms2)
|
|
assert.Equal(t, NewFloat64Slice(), ms2)
|
|
assert.Equal(t, ms.Len(), 0)
|
|
|
|
// Test moving to empty slice
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
ms.MoveAndAppendTo(ms2)
|
|
assert.Equal(t, ms2.Len(), 3)
|
|
|
|
// Test moving to a non empty slice
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
ms.MoveAndAppendTo(ms2)
|
|
assert.Equal(t, ms2.Len(), 6)
|
|
}
|
|
|
|
func TestFloat64SliceRemoveIf(t *testing.T) {
|
|
emptySlice := NewFloat64Slice()
|
|
emptySlice.RemoveIf(func(el float64) bool {
|
|
t.Fail()
|
|
return false
|
|
})
|
|
|
|
ms := NewFloat64Slice()
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
pos := 0
|
|
ms.RemoveIf(func(el float64) bool {
|
|
pos++
|
|
return pos%2 == 1
|
|
})
|
|
assert.Equal(t, pos/2, ms.Len())
|
|
}
|
|
|
|
func TestFloat64SliceRemoveIfAll(t *testing.T) {
|
|
ms := NewFloat64Slice()
|
|
ms.FromRaw([]float64{1.1, 2.2, 3.3})
|
|
ms.RemoveIf(func(el float64) bool {
|
|
return true
|
|
})
|
|
assert.Equal(t, 0, ms.Len())
|
|
}
|
|
|
|
func TestFloat64SliceEqual(t *testing.T) {
|
|
ms := NewFloat64Slice()
|
|
ms2 := NewFloat64Slice()
|
|
assert.True(t, ms.Equal(ms2))
|
|
|
|
ms.Append(1.1, 2.2, 3.3)
|
|
assert.False(t, ms.Equal(ms2))
|
|
|
|
ms2.Append(1.1, 2.2, 3.3)
|
|
assert.True(t, ms.Equal(ms2))
|
|
}
|
|
|
|
func BenchmarkFloat64SliceEqual(b *testing.B) {
|
|
testutil.SkipMemoryBench(b)
|
|
ms := NewFloat64Slice()
|
|
ms.Append(1.1, 2.2, 3.3)
|
|
cmp := NewFloat64Slice()
|
|
cmp.Append(1.1, 2.2, 3.3)
|
|
|
|
b.ResetTimer()
|
|
b.ReportAllocs()
|
|
|
|
for n := 0; n < b.N; n++ {
|
|
_ = ms.Equal(cmp)
|
|
}
|
|
}
|