-
Notifications
You must be signed in to change notification settings - Fork 359
Expand file tree
/
Copy pathbinding_test.go
More file actions
86 lines (74 loc) · 2.36 KB
/
binding_test.go
File metadata and controls
86 lines (74 loc) · 2.36 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
// SPDX-FileCopyrightText: 2026 The Pion community <https://pion.ly>
// SPDX-License-Identifier: MIT
package client
import (
"net"
"testing"
"github.com/stretchr/testify/assert"
)
func TestBindingManager(t *testing.T) {
t.Run("number assignment", func(t *testing.T) {
bm := newBindingManager()
var chanNum uint16
for i := range uint16(10) {
chanNum = bm.assignChannelNumber()
assert.Equal(t, minChannelNumber+i, chanNum, "should match")
}
bm.next = uint16(0x7ff0)
for i := range uint16(16) {
chanNum = bm.assignChannelNumber()
assert.Equal(t, 0x7ff0+i, chanNum, "should match")
}
// Back to min
chanNum = bm.assignChannelNumber()
assert.Equal(t, minChannelNumber, chanNum, "should match")
})
t.Run("method test", func(t *testing.T) {
lo := net.IPv4(127, 0, 0, 1)
count := 100
bm := newBindingManager()
for i := range count {
addr := &net.UDPAddr{IP: lo, Port: 10000 + i}
b0 := bm.create(addr)
b1, ok := bm.findByAddr(addr)
assert.True(t, ok, "should succeed")
b2, ok := bm.findByNumber(b0.number)
assert.True(t, ok, "should succeed")
assert.Equal(t, b0, b1, "should match")
assert.Equal(t, b0, b2, "should match")
}
all := bm.all()
for _, b := range all {
found, ok := bm.findByNumber(b.number)
assert.True(t, ok, "should exist")
assert.Equal(t, b, found, "should match")
}
assert.Equal(t, count, len(all), "should match")
assert.Equal(t, count, bm.size(), "should match")
assert.Equal(t, count, len(bm.addrMap), "should match")
for i := range count {
addr := &net.UDPAddr{IP: lo, Port: 10000 + i}
if i%2 == 0 {
assert.True(t, bm.deleteByAddr(addr), "should return true")
} else {
assert.True(t, bm.deleteByNumber(minChannelNumber+uint16(i)), "should return true") // nolint:gosec // G115
}
}
assert.Equal(t, 0, bm.size(), "should match")
assert.Equal(t, 0, len(bm.addrMap), "should match")
assert.Equal(t, 0, len(bm.all()), "should match")
})
t.Run("failure test", func(t *testing.T) {
addr := &net.UDPAddr{IP: net.IPv4(127, 0, 0, 1), Port: 7777}
m := newBindingManager()
var ok bool
_, ok = m.findByAddr(addr)
assert.False(t, ok, "should fail")
_, ok = m.findByNumber(uint16(5555))
assert.False(t, ok, "should fail")
ok = m.deleteByAddr(addr)
assert.False(t, ok, "should fail")
ok = m.deleteByNumber(uint16(5555))
assert.False(t, ok, "should fail")
})
}