ynerant
/
ghostream
mirror of https://gitlab.crans.org/nounous/ghostream.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Allocate memory for UDP buffers only once

This commit is contained in:
Yohann D'ANELLO 2020-10-13 10:10:25 +02:00
parent 32f877508d
commit 3ce82c5d61
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
stream/webrtc/ingest.go
View File

@ -4,15 +4,14 @@ package webrtc
import ( import (
"bufio" "bufio"
"fmt" "fmt"
"github.com/pion/rtp"
"github.com/pion/webrtc/v3"
"gitlab.crans.org/nounous/ghostream/stream/srt"
"gitlab.crans.org/nounous/ghostream/stream/telnet" "gitlab.crans.org/nounous/ghostream/stream/telnet"
"io" "io"
"log" "log"
"net" "net"
"os/exec" "os/exec"
"github.com/pion/rtp"
"github.com/pion/webrtc/v3"
"gitlab.crans.org/nounous/ghostream/stream/srt"
) )
var ( var (
@ -124,8 +123,8 @@ func registerStream(srtPacket *srt.Packet) {
// Receive video // Receive video
go func() { go func() {
inboundRTPPacket := make([]byte, 1500) // UDP MTU
for { for {
inboundRTPPacket := make([]byte, 1500) // UDP MTU
n, _, err := videoListener.ReadFromUDP(inboundRTPPacket) n, _, err := videoListener.ReadFromUDP(inboundRTPPacket)
if err != nil { if err != nil {
log.Printf("Failed to read from UDP: %s", err) log.Printf("Failed to read from UDP: %s", err)
@ -156,8 +155,8 @@ func registerStream(srtPacket *srt.Packet) {
// Receive audio // Receive audio
go func() { go func() {
inboundRTPPacket := make([]byte, 1500) // UDP MTU
for { for {
inboundRTPPacket := make([]byte, 1500) // UDP MTU
n, _, err := audioListener.ReadFromUDP(inboundRTPPacket) n, _, err := audioListener.ReadFromUDP(inboundRTPPacket)
if err != nil { if err != nil {
log.Printf("Failed to read from UDP: %s", err) log.Printf("Failed to read from UDP: %s", err)