mirror of
https://github.com/hanzokms/turn.git
synced 2026-10-30 20:50:36 +00:00
106 lines
2.3 KiB
Go
106 lines
2.3 KiB
Go
// SPDX-FileCopyrightText: 2023 The Pion community <https://pion.ly>
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package proto
|
|
|
|
import (
|
|
"errors"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/pion/stun/v3"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func BenchmarkLifetime(b *testing.B) {
|
|
b.Run("AddTo", func(b *testing.B) {
|
|
b.ReportAllocs()
|
|
m := new(stun.Message)
|
|
for i := 0; i < b.N; i++ {
|
|
l := Lifetime{time.Second}
|
|
if err := l.AddTo(m); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
m.Reset()
|
|
}
|
|
})
|
|
b.Run("GetFrom", func(b *testing.B) {
|
|
m := new(stun.Message)
|
|
assert.NoError(b, Lifetime{time.Minute}.AddTo(m))
|
|
for i := 0; i < b.N; i++ {
|
|
l := Lifetime{}
|
|
if err := l.GetFrom(m); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
func TestLifetime(t *testing.T) { //nolint:cyclop
|
|
t.Run("String", func(t *testing.T) {
|
|
l := Lifetime{time.Second * 10}
|
|
if l.String() != "10s" {
|
|
t.Errorf("bad string %s, expedted 10s", l)
|
|
}
|
|
})
|
|
t.Run("NoAlloc", func(t *testing.T) {
|
|
stunMsg := &stun.Message{}
|
|
if wasAllocs(func() {
|
|
// On stack.
|
|
l := Lifetime{
|
|
Duration: time.Minute,
|
|
}
|
|
l.AddTo(stunMsg) //nolint
|
|
stunMsg.Reset()
|
|
}) {
|
|
t.Error("Unexpected allocations")
|
|
}
|
|
|
|
l := &Lifetime{time.Second}
|
|
if wasAllocs(func() {
|
|
// On heap.
|
|
l.AddTo(stunMsg) //nolint
|
|
stunMsg.Reset()
|
|
}) {
|
|
t.Error("Unexpected allocations")
|
|
}
|
|
})
|
|
t.Run("AddTo", func(t *testing.T) {
|
|
m := new(stun.Message)
|
|
lifetime := Lifetime{time.Second * 10}
|
|
if err := lifetime.AddTo(m); err != nil {
|
|
t.Error(err)
|
|
}
|
|
m.WriteHeader()
|
|
t.Run("GetFrom", func(t *testing.T) {
|
|
decoded := new(stun.Message)
|
|
if _, err := decoded.Write(m.Raw); err != nil {
|
|
t.Fatal("failed to decode message:", err)
|
|
}
|
|
life := Lifetime{}
|
|
if err := life.GetFrom(decoded); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if life != lifetime {
|
|
t.Errorf("Decoded %q, expected %q", life, lifetime)
|
|
}
|
|
if wasAllocs(func() {
|
|
life.GetFrom(decoded) //nolint
|
|
}) {
|
|
t.Error("Unexpected allocations")
|
|
}
|
|
t.Run("HandleErr", func(t *testing.T) {
|
|
m := new(stun.Message)
|
|
nHandle := new(Lifetime)
|
|
if err := nHandle.GetFrom(m); !errors.Is(err, stun.ErrAttributeNotFound) {
|
|
t.Errorf("%v should be not found", err)
|
|
}
|
|
m.Add(stun.AttrLifetime, []byte{1, 2, 3})
|
|
if !stun.IsAttrSizeInvalid(nHandle.GetFrom(m)) {
|
|
t.Error("IsAttrSizeInvalid should be true")
|
|
}
|
|
})
|
|
})
|
|
})
|
|
}
|