Bufferize reading
This commit is contained in:
parent
8427377d51
commit
4f947ad651
|
@ -31,7 +31,7 @@ func ingest(name string, q *messaging.Quality) {
|
|||
return
|
||||
}
|
||||
|
||||
// Start ffmpag to convert videoInput to audio UDP
|
||||
// Start ffmpeg to convert videoInput to audio UDP
|
||||
ffmpeg, ffmpegOut, err := startFFmpeg(videoInput, firstPort)
|
||||
if err != nil {
|
||||
log.Printf("Error while starting ffmpeg: %s", err)
|
||||
|
@ -40,7 +40,7 @@ func ingest(name string, q *messaging.Quality) {
|
|||
|
||||
// Receive video
|
||||
go func() {
|
||||
h264, _ := h264reader.NewReader(*ffmpegOut)
|
||||
h264, _ := h264reader.NewReader(bufio.NewReader(*ffmpegOut))
|
||||
var spsAndPpsCache []byte
|
||||
|
||||
for {
|
||||
|
|
Loading…
Reference in New Issue