From f8706cd470ebace34b5a4923205a46abfebcc902 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Thu, 4 Dec 2025 12:22:52 +0530 Subject: [PATCH] Update pion/ice to stop gather first on close (#4123) * Update pion/ice to stop gather first on close * fix data race in test --- go.mod | 2 +- go.sum | 4 ++-- test/client/client.go | 5 ++++- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/go.mod b/go.mod index 82446e7ff..3c73a9e29 100644 --- a/go.mod +++ b/go.mod @@ -33,7 +33,7 @@ require ( github.com/ory/dockertest/v3 v3.12.0 github.com/pion/datachannel v1.5.10 github.com/pion/dtls/v3 v3.0.8 - github.com/pion/ice/v4 v4.0.12 + github.com/pion/ice/v4 v4.0.13 github.com/pion/interceptor v0.1.42 github.com/pion/rtcp v1.2.16 github.com/pion/rtp v1.8.25 diff --git a/go.sum b/go.sum index 146794b78..ad1b9c4fc 100644 --- a/go.sum +++ b/go.sum @@ -242,8 +242,8 @@ github.com/pion/datachannel v1.5.10 h1:ly0Q26K1i6ZkGf42W7D4hQYR90pZwzFOjTq5AuCKk github.com/pion/datachannel v1.5.10/go.mod h1:p/jJfC9arb29W7WrxyKbepTU20CFgyx5oLo8Rs4Py/M= github.com/pion/dtls/v3 v3.0.8 h1:ZrPUrvPVDaTJDM8Vu1veatzXebLlsIWeT7Vaate/zwM= github.com/pion/dtls/v3 v3.0.8/go.mod h1:abApPjgadS/ra1wvUzHLc3o2HvoxppAh+NZkyApL4Os= -github.com/pion/ice/v4 v4.0.12 h1:vuI3h9OD5M0Z+V304qLC1/o16ahHVnDgqNCWbONv6s0= -github.com/pion/ice/v4 v4.0.12/go.mod h1:tAp574oAufhHRHr8EO1xgPmVKVDBROX+708WggYD6NE= +github.com/pion/ice/v4 v4.0.13 h1:1cdmd80gmLdnVTM2bXzw2CBebvXvkGNEaWi/CuDK9WQ= +github.com/pion/ice/v4 v4.0.13/go.mod h1:Xo5f5DBbEjQac+6pR7i83AGuwoGxnxwXkOOvHFVnfnM= github.com/pion/interceptor v0.1.42 h1:0/4tvNtruXflBxLfApMVoMubUMik57VZ+94U0J7cmkQ= github.com/pion/interceptor v0.1.42/go.mod h1:g6XYTChs9XyolIQFhRHOOUS+bGVGLRfgTCUzH29EfVU= github.com/pion/logging v0.2.4 h1:tTew+7cmQ+Mc1pTBLKH2puKsOvhm32dROumOZ655zB8= diff --git a/test/client/client.go b/test/client/client.go index 641b79cbd..b8c3d2037 100644 --- a/test/client/client.go +++ b/test/client/client.go @@ -711,7 +711,10 @@ func (c *RTCClient) SubscribedDataTracks() map[livekit.ParticipantID]map[uint16] c.lock.Lock() defer c.lock.Unlock() tracks := make(map[livekit.ParticipantID]map[uint16]*DataTrackRemote, len(c.subscribedDataTracks)) - maps.Copy(tracks, c.subscribedDataTracks) + for publisherID, sts := range c.subscribedDataTracks { + tracks[publisherID] = make(map[uint16]*DataTrackRemote) + maps.Copy(tracks[publisherID], sts) + } return tracks }