From f558e9c621d4226c62f7ef8db5cd268ddacee6ce Mon Sep 17 00:00:00 2001 From: streamer45 Date: Thu, 19 Dec 2024 17:52:35 -0600 Subject: [PATCH] Enable SCTP optimization on client side --- client/rtc.go | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/client/rtc.go b/client/rtc.go index b6af48d..ddda1ba 100644 --- a/client/rtc.go +++ b/client/rtc.go @@ -33,13 +33,11 @@ const ( pingInterval = time.Second ) -var ( - rtpVideoExtensions = []string{ - "urn:ietf:params:rtp-hdrext:sdes:mid", - "urn:ietf:params:rtp-hdrext:sdes:rtp-stream-id", - "urn:ietf:params:rtp-hdrext:sdes:repaired-rtp-stream-id", - } -) +var rtpVideoExtensions = []string{ + "urn:ietf:params:rtp-hdrext:sdes:mid", + "urn:ietf:params:rtp-hdrext:sdes:rtp-stream-id", + "urn:ietf:params:rtp-hdrext:sdes:repaired-rtp-stream-id", +} func (c *Client) handleWSEventSignal(evData map[string]any) error { data, ok := evData["data"].(string) @@ -213,7 +211,10 @@ func (c *Client) initRTCSession() error { } } - api := webrtc.NewAPI(webrtc.WithMediaEngine(&m), webrtc.WithInterceptorRegistry(&i)) + s := webrtc.SettingEngine{} + s.EnableSCTPZeroChecksum(true) + + api := webrtc.NewAPI(webrtc.WithMediaEngine(&m), webrtc.WithInterceptorRegistry(&i), webrtc.WithSettingEngine(s)) pc, err := api.NewPeerConnection(cfg) if err != nil {