Commitf399ded

committed

Terminate connections when they reach DC limit (#443)

(cherry picked from commita8ef208)(cherry picked from commit5aae0ce)

1 parent177839f commitf399dedCopy full SHA for f399ded

File tree

-0

lines changed

-0

lines changed

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -65,6 +65,15 @@ func (d *DialerCache) evict() {`
`65`	`65`
`66`	`66`	`// If we're no longer signaling, the connection is pending close.`
`67`	`67`	`evict:=dialer.rtc.SignalingState()==webrtc.SignalingStateClosed`
	`68`	`+`
	`69`	`+// HACK: since the pion package can't reuse data channel IDs we need`
	`70`	`+// to terminate the connection once we approach the critical number.`
	`71`	`+// We're working on adding data channel ID reuse support upstream.`
	`72`	`+stats,ok:=dialer.rtc.GetStats().GetConnectionStats(dialer.rtc)`
	`73`	`+ifok&&stats.DataChannelsRequested>32500 {`
	`74`	`+evict=true`
	`75`	`+}`
	`76`	`+`
`68`	`77`	`ifdialer.activeConnections()==0&&time.Since(d.atime[key])>=d.ttl {`
`69`	`78`	`evict=true`
`70`	`79`	`}else {`

Comments

(0)