Skip to content

chore: Update pion/ice fork to resolve goroutine leak #78

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 13 commits into from
Jan 28, 2022
Merged

chore: Update pion/ice fork to resolve goroutine leak #78

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
18eac83
chore: Update pion/ice fork to resolve goroutine leak
kylecarbs Jan 27, 2022
ebb94b8
Flush remote too
kylecarbs Jan 27, 2022
de209c7
Add logs for setting the description
kylecarbs Jan 27, 2022
6f7e3af
Try locking only on remote
kylecarbs Jan 27, 2022
a918c93
Remove local bufferring in favor of remote
kylecarbs Jan 27, 2022
44cad06
Remove unused flush func
kylecarbs Jan 27, 2022
d62797e
Set candidates flushed to true
kylecarbs Jan 27, 2022
982fde3
Defer flush until the end of negotiation
kylecarbs Jan 27, 2022
e154d6e
Buffer ICE candidates
kylecarbs Jan 27, 2022
a2a4da4
Add comment clarifying channel buffer
kylecarbs Jan 27, 2022
aa1e664
Flush after handshake
kylecarbs Jan 27, 2022
7b3e89d
Move away from fork
kylecarbs Jan 27, 2022
f3717ca
Ignore pion/ice leaks
kylecarbs Jan 27, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add comment clarifying channel buffer
  • Loading branch information
@kylecarbs
kylecarbs committed Jan 27, 2022
commit a2a4da4f70ffbedacc80f87c09da5380abc30af6
20 changes: 11 additions & 9 deletions peer/conn.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -62,15 +62,17 @@ func newWithClientOrServer(servers []webrtc.ICEServer, client bool, opts *ConnOp
return nil, xerrors.Errorf("create peer connection: %w", err)
}
conn := &Conn{
pingChannelID: 1,
pingEchoChannelID: 2,
opts: opts,
rtc: rtc,
offerrer: client,
closed: make(chan struct{}),
dcOpenChannel: make(chan *webrtc.DataChannel),
dcDisconnectChannel: make(chan struct{}),
dcFailedChannel: make(chan struct{}),
pingChannelID: 1,
pingEchoChannelID: 2,
opts: opts,
rtc: rtc,
offerrer: client,
closed: make(chan struct{}),
dcOpenChannel: make(chan *webrtc.DataChannel),
dcDisconnectChannel: make(chan struct{}),
dcFailedChannel: make(chan struct{}),
// This channel needs to be bufferred otherwise slow consumers
// of this will cause a connection failure.
localCandidateChannel: make(chan webrtc.ICECandidateInit, 16),
pendingRemoteCandidates: make([]webrtc.ICECandidateInit, 0),
localSessionDescriptionChannel: make(chan webrtc.SessionDescription),
Expand Down
4 changes: 3 additions & 1 deletion peer/conn_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,9 @@ var (
)

func TestMain(m *testing.M) {
goleak.VerifyTestMain(m)
// pion/ice doesn't properly close immediately. The solution for this isn't yet known. See:
// https://github.com/pion/ice/pull/413
goleak.VerifyTestMain(m, goleak.IgnoreTopFunction("github.com/pion/ice/v2.(*Agent).startOnConnectionStateChangeRoutine.func1 "))
}

func TestConn(t *testing.T) {
Expand Down