diff --git a/go.mod b/go.mod index 9a19b25fc..5535f6473 100644 --- a/go.mod +++ b/go.mod @@ -27,14 +27,14 @@ require ( github.com/mitchellh/go-homedir v1.1.0 github.com/olekukonko/tablewriter v0.0.5 github.com/pion/dtls/v2 v2.2.10 - github.com/pion/ice/v2 v2.3.15 + github.com/pion/ice/v2 v2.3.16 github.com/pion/interceptor v0.1.25 github.com/pion/rtcp v1.2.14 github.com/pion/rtp v1.8.5 github.com/pion/sctp v1.8.16 github.com/pion/sdp/v3 v3.0.9 github.com/pion/transport/v2 v2.2.4 - github.com/pion/turn/v2 v2.1.5 + github.com/pion/turn/v2 v2.1.6 github.com/pion/webrtc/v3 v3.2.38 github.com/pkg/errors v0.9.1 github.com/prometheus/client_golang v1.19.0 diff --git a/go.sum b/go.sum index dc97b17ca..decbb3e53 100644 --- a/go.sum +++ b/go.sum @@ -168,8 +168,8 @@ github.com/pion/datachannel v1.5.5/go.mod h1:iMz+lECmfdCMqFRhXhcA/219B0SQlbpoR2V github.com/pion/dtls/v2 v2.2.7/go.mod h1:8WiMkebSHFD0T+dIU+UeBaoV7kDhOW5oDCzZ7WZ/F9s= github.com/pion/dtls/v2 v2.2.10 h1:u2Axk+FyIR1VFTPurktB+1zoEPGIW3bmyj3LEFrXjAA= github.com/pion/dtls/v2 v2.2.10/go.mod h1:d9SYc9fch0CqK90mRk1dC7AkzzpwJj6u2GU3u+9pqFE= -github.com/pion/ice/v2 v2.3.15 h1:oCGVqnd6OWmJr4I6eQwSWn8VJDF45wIXFTjV3tyyris= -github.com/pion/ice/v2 v2.3.15/go.mod h1:KXJJcZK7E8WzrBEYnV4UtqEZsGeWfHxsNqhVcVvgjxw= +github.com/pion/ice/v2 v2.3.16 h1:ajKSorlci0Vos36tFpfYZaTTNcmZrh6giN0YSuRjSQ8= +github.com/pion/ice/v2 v2.3.16/go.mod h1:KXJJcZK7E8WzrBEYnV4UtqEZsGeWfHxsNqhVcVvgjxw= github.com/pion/interceptor v0.1.25 h1:pwY9r7P6ToQ3+IF0bajN0xmk/fNw/suTgaTdlwTDmhc= github.com/pion/interceptor v0.1.25/go.mod h1:wkbPYAak5zKsfpVDYMtEfWEy8D4zL+rpxCxPImLOg3Y= github.com/pion/logging v0.2.2 h1:M9+AIj/+pxNsDfAT64+MAVgJO0rsyLnoJKCqf//DoeY= @@ -206,8 +206,8 @@ github.com/pion/transport/v3 v3.0.1/go.mod h1:UY7kiITrlMv7/IKgd5eTUcaahZx5oUN3l9 github.com/pion/transport/v3 v3.0.2 h1:r+40RJR25S9w3jbA6/5uEPTzcdn7ncyU44RWCbHkLg4= github.com/pion/transport/v3 v3.0.2/go.mod h1:nIToODoOlb5If2jF9y2Igfx3PFYWfuXi37m0IlWa/D0= github.com/pion/turn/v2 v2.1.3/go.mod h1:huEpByKKHix2/b9kmTAM3YoX6MKP+/D//0ClgUYR2fY= -github.com/pion/turn/v2 v2.1.5 h1:tTyy7TM3DCoX9IxTt/yHc/bThiRLyXK3T1YbNcgx9k4= -github.com/pion/turn/v2 v2.1.5/go.mod h1:huEpByKKHix2/b9kmTAM3YoX6MKP+/D//0ClgUYR2fY= +github.com/pion/turn/v2 v2.1.6 h1:Xr2niVsiPTB0FPtt+yAWKFUkU1eotQbGgpTIld4x1Gc= +github.com/pion/turn/v2 v2.1.6/go.mod h1:huEpByKKHix2/b9kmTAM3YoX6MKP+/D//0ClgUYR2fY= github.com/pion/webrtc/v3 v3.2.38 h1:oA52VJAJhOjSi1JpKjf0CM+cCiZ3b7jBxvsoOiajeDU= github.com/pion/webrtc/v3 v3.2.38/go.mod h1:AQ8p56OLbm3MjhYovYdgPuyX6oc+JcKx/HFoCGFcYzA= github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= diff --git a/pkg/sfu/downtrackspreader.go b/pkg/sfu/downtrackspreader.go index 3768592f3..68fc7b411 100644 --- a/pkg/sfu/downtrackspreader.go +++ b/pkg/sfu/downtrackspreader.go @@ -96,9 +96,7 @@ func (d *DownTrackSpreader) Broadcast(writer func(TrackSender)) { // 100µs is enough to amortize the overhead and provide sufficient load balancing. // WriteRTP takes about 50µs on average, so we write to 2 down tracks per loop. step := uint64(2) - utils.ParallelExec(downTracks, threshold, step, func(dt TrackSender) { - writer(dt) - }) + utils.ParallelExec(downTracks, threshold, step, writer) } func (d *DownTrackSpreader) DownTrackCount() int { diff --git a/pkg/utils/opsqueue.go b/pkg/utils/opsqueue.go index 2513f0b8c..30f9f4b39 100644 --- a/pkg/utils/opsqueue.go +++ b/pkg/utils/opsqueue.go @@ -32,8 +32,8 @@ type OpsQueueParams struct { type UntypedQueueOp func() -func (it UntypedQueueOp) run() { - it() +func (op UntypedQueueOp) run() { + op() } type OpsQueue struct { @@ -49,8 +49,8 @@ type typedQueueOp[T any] struct { arg T } -func (it typedQueueOp[T]) run() { - it.fn(it.arg) +func (op typedQueueOp[T]) run() { + op.fn(op.arg) } type TypedOpsQueue[T any] struct {