69 lines
1.8 KiB
Go
69 lines
1.8 KiB
Go
package srt
|
|
|
|
import (
|
|
"log"
|
|
|
|
"github.com/haivision/srtgo"
|
|
)
|
|
|
|
func handleStreamer(s *srtgo.SrtSocket, name string, clientDataChannels *[]chan Packet, forwardingChannel chan Packet) {
|
|
log.Printf("New SRT streamer for stream %s", name)
|
|
|
|
// Create a new buffer
|
|
// UDP packet cannot be larger than MTU (1500)
|
|
buff := make([]byte, 1500)
|
|
|
|
// Setup stream forwarding
|
|
forwardingChannel <- Packet{StreamName: name, PacketType: "register", Data: nil}
|
|
|
|
// Read RTP packets forever and send them to the WebRTC Client
|
|
for {
|
|
// 5s timeout
|
|
n, err := s.Read(buff, 5000)
|
|
if err != nil {
|
|
log.Println("Error occured while reading SRT socket:", err)
|
|
break
|
|
}
|
|
|
|
if n == 0 {
|
|
// End of stream
|
|
log.Printf("Received no bytes, stopping stream.")
|
|
break
|
|
}
|
|
|
|
// Send raw packet to other streams
|
|
// Copy data in another buffer to ensure that the data would not be overwritten
|
|
data := make([]byte, n)
|
|
copy(data, buff[:n])
|
|
forwardingChannel <- Packet{StreamName: name, PacketType: "sendData", Data: data}
|
|
for _, dataChannel := range *clientDataChannels {
|
|
dataChannel <- Packet{StreamName: name, PacketType: "sendData", Data: data}
|
|
}
|
|
}
|
|
|
|
forwardingChannel <- Packet{StreamName: name, PacketType: "close", Data: nil}
|
|
}
|
|
|
|
func handleViewer(s *srtgo.SrtSocket, name string, dataChannel chan Packet, dataChannels *[]chan Packet) {
|
|
// FIXME Should not pass all dataChannels to one viewer
|
|
|
|
log.Printf("New SRT viewer for stream %s", name)
|
|
|
|
// Receive packets from channel and send them
|
|
for {
|
|
packet := <-dataChannel
|
|
if packet.PacketType == "sendData" {
|
|
_, err := s.Write(packet.Data, 10000)
|
|
if err != nil {
|
|
s.Close()
|
|
for i, channel := range *dataChannels {
|
|
if channel == dataChannel {
|
|
*dataChannels = append((*dataChannels)[:i], (*dataChannels)[i+1:]...)
|
|
}
|
|
}
|
|
return
|
|
}
|
|
}
|
|
}
|
|
}
|