Use Fifo sink

Signed-off-by: Lukas Bachschwell <lukas@lbsfilm.at>
s00500 · May 16, 2021 · 06962bd · 06962bd
1 parent e95a150
commit 06962bd
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 3 deletions.
diff --git a/flush.sh b/flush.sh
@@ -0,0 +1,4 @@
+exec 5<>stream.fifo
+cat <&5 >/dev/null & cat_pid=$!
+sleep 1
+kill "$cat_pid"
diff --git a/main.go b/main.go
@@ -77,8 +77,8 @@ func openStream(dev *gousb.Device) {
 	if useGstreamer != nil && *useGstreamer {
 		sink = GstSink{}
 	} else {
-		sink = FFPlaySink{}
-
+		//sink = FFPlaySink{}
+		sink = FifoSink{Path: fmt.Sprintf("stream%d-%d.fifo", dev.Desc.Bus, dev.Desc.Address)}
 	}
 	ffmpegIn, stopPlayer := sink.StartInstance()
 	// claim interface

diff --git a/sinks.go b/sinks.go
@@ -2,6 +2,7 @@ package main
 
 import (
 	"io"
+	"os"
 	"os/exec"
 	"syscall"
 
@@ -34,7 +35,7 @@ type GstSink struct {
 }
 
 func (sink GstSink) StartInstance() (io.WriteCloser, func()) {
-	args := []string{"fdsrc", "fd=0", "!", "decodebin", "!", "videoconvert", "!", "autovideosink"}
+	args := []string{"fdsrc", "fd=0", "!", "decodebin3", "!", "videoconvert", "n-threads=8", "!", "autovideosink", "sync=false"}
 	cmd := exec.Command("gst-launch-1.0", args...)
 	stdin, err := cmd.StdinPipe()
 	if err != nil {
@@ -63,3 +64,22 @@ func (sink UdpSink) StartInstance() (io.WriteCloser, func()) {
 		cmd.Process.Signal(syscall.SIGKILL) // Not ellegant... could try sigterm and wait before...
 	}
 }
+
+type FifoSink struct {
+	Path string
+}
+
+func (sink FifoSink) StartInstance() (io.WriteCloser, func()) {
+	os.Remove(sink.Path)
+	err := syscall.Mkfifo(sink.Path, 0666)
+	if err != nil {
+		log.Fatal("Make named pipe file error:", err)
+	}
+	f, err := os.OpenFile(sink.Path, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0777)
+	log.MustFatal(err)
+
+	return f, func() {
+		f.Close()
+		os.Remove(sink.Path)
+	}
+}