sctp/association_rack_options_test.go at master · pion/sctp · GitHub

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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
// SPDX-FileCopyrightText: 2026 The Pion community <https://pion.ly>
// SPDX-License-Identifier: MIT

//go:build !js

package sctp

import (
	"testing"
	"time"

	"github.com/stretchr/testify/assert"
)

func TestRACKOptions_Validation(t *testing.T) {
	t.Run("min rtt wnd <= 0", func(t *testing.T) {
		var cfg Config
		err := WithRACKOptions(WithRackMinRTTWnd(0)).applyServer(&cfg)
		assert.Error(t, err)
		assert.ErrorIs(t, err, errInvalidRackMinRTTWnd)
	})

	t.Run("reo wnd floor < 0", func(t *testing.T) {
		var cfg Config
		err := WithRACKOptions(WithRackReoWndFloor(-1 * time.Millisecond)).applyServer(&cfg)
		assert.Error(t, err)
		assert.ErrorIs(t, err, errInvalidRackReoWndFloor)
	})

	t.Run("wc del ack <= 0", func(t *testing.T) {
		var cfg Config
		err := WithRACKOptions(WithRackWCDelAck(0)).applyServer(&cfg)
		assert.Error(t, err)
		assert.ErrorIs(t, err, errInvalidRackWcDelAck)
	})
}

func TestRACKOptions_AtomicApply_NoPartialMutationOnError(t *testing.T) {
	var cfg Config
	cfg.rack.rackWCDelAck = 123 * time.Millisecond

	err := WithRACKOptions(
		WithRackWCDelAck(50*time.Millisecond),
		WithRackWCDelAck(0), // invalid
	).applyServer(&cfg)

	assert.Error(t, err)
	assert.Equal(t, 123*time.Millisecond, cfg.rack.rackWCDelAck)
}

func TestRACKOptions_ApplyToConfig(t *testing.T) {
	var cfg Config

	err := WithRACKOptions(
		WithRackMinRTTWnd(10*time.Second),
		WithRackReoWndFloor(2*time.Millisecond),
		WithRackWCDelAck(50*time.Millisecond),
	).applyServer(&cfg)
	assert.NoError(t, err)

	assert.NotNil(t, cfg.rack.rackMinRTTWnd)
	assert.Equal(t, 2*time.Millisecond, cfg.rack.rackReoWndFloor)
	assert.Equal(t, 50*time.Millisecond, cfg.rack.rackWCDelAck)
}

func TestRACKOptions_EndToEnd_DefaultsAndOverrides(t *testing.T) {
	t.Run("defaults when not configured", func(t *testing.T) {
		aClient, aServer, err := association(t, udpPiper)
		assert.NoError(t, err)
		defer func() {
			_ = aClient.Close()
			_ = aServer.Close()
		}()

		assert.NotNil(t, aClient.rack.rackMinRTTWnd)
		assert.NotNil(t, aServer.rack.rackMinRTTWnd)

		assert.Equal(t, time.Duration(0), aClient.rack.rackReoWndFloor)
		assert.Equal(t, time.Duration(0), aServer.rack.rackReoWndFloor)

		assert.Equal(t, 200*time.Millisecond, aClient.rack.rackWCDelAck)
		assert.Equal(t, 200*time.Millisecond, aServer.rack.rackWCDelAck)
	})

	t.Run("overrides when configured", func(t *testing.T) {
		aClient, aServer, err := association(
			t,
			udpPiper,
			WithRACKOptions(
				WithRackMinRTTWnd(5*time.Second),
				WithRackReoWndFloor(3*time.Millisecond),
				WithRackWCDelAck(75*time.Millisecond),
			),
		)
		assert.NoError(t, err)
		defer func() {
			_ = aClient.Close()
			_ = aServer.Close()
		}()

		assert.NotNil(t, aClient.rack.rackMinRTTWnd)
		assert.NotNil(t, aServer.rack.rackMinRTTWnd)

		assert.Equal(t, 3*time.Millisecond, aClient.rack.rackReoWndFloor)
		assert.Equal(t, 3*time.Millisecond, aServer.rack.rackReoWndFloor)

		assert.Equal(t, 75*time.Millisecond, aClient.rack.rackWCDelAck)
		assert.Equal(t, 75*time.Millisecond, aServer.rack.rackWCDelAck)
	})
}