From 3ce82c5d6119d066c8cea39d9d902adccf98305c Mon Sep 17 00:00:00 2001 From: Yohann D'ANELLO Date: Tue, 13 Oct 2020 10:10:25 +0200 Subject: [PATCH] Allocate memory for UDP buffers only once --- stream/webrtc/ingest.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/stream/webrtc/ingest.go b/stream/webrtc/ingest.go index 4ba9170..51e0112 100644 --- a/stream/webrtc/ingest.go +++ b/stream/webrtc/ingest.go @@ -4,15 +4,14 @@ package webrtc import ( "bufio" "fmt" + "github.com/pion/rtp" + "github.com/pion/webrtc/v3" + "gitlab.crans.org/nounous/ghostream/stream/srt" "gitlab.crans.org/nounous/ghostream/stream/telnet" "io" "log" "net" "os/exec" - - "github.com/pion/rtp" - "github.com/pion/webrtc/v3" - "gitlab.crans.org/nounous/ghostream/stream/srt" ) var ( @@ -124,8 +123,8 @@ func registerStream(srtPacket *srt.Packet) { // Receive video go func() { + inboundRTPPacket := make([]byte, 1500) // UDP MTU for { - inboundRTPPacket := make([]byte, 1500) // UDP MTU n, _, err := videoListener.ReadFromUDP(inboundRTPPacket) if err != nil { log.Printf("Failed to read from UDP: %s", err) @@ -156,8 +155,8 @@ func registerStream(srtPacket *srt.Packet) { // Receive audio go func() { + inboundRTPPacket := make([]byte, 1500) // UDP MTU for { - inboundRTPPacket := make([]byte, 1500) // UDP MTU n, _, err := audioListener.ReadFromUDP(inboundRTPPacket) if err != nil { log.Printf("Failed to read from UDP: %s", err)