package/go-gst
1
0
Fork 0
mirror of https://github.com/go-gst/go-gst.git synced 2025-10-05 16:06:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

cleanup appsink example

Browse Source
This commit is contained in:
tinyzimmer
2020-10-05 11:38:05 +03:00
parent be723a423e
commit f9dd27f86a
1 changed files with 13 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
examples/gif-encoder/main.go
View File

@@ -36,6 +36,7 @@ func encodeGif(mainLoop *gst.MainLoop) error {
if err != nil { if err != nil {
return err return err
} }
defer pipeline.Destroy()
// Create a filesrc and a decodebin element for the pipeline. // Create a filesrc and a decodebin element for the pipeline.
elements, err := gst.NewElementMany("filesrc", "decodebin") elements, err := gst.NewElementMany("filesrc", "decodebin")
@@ -115,6 +116,9 @@ func encodeGif(mainLoop *gst.MainLoop) error {
// will be a new jpeg image from the pipeline. // will be a new jpeg image from the pipeline.
var frameNum int var frameNum int
appSink.SetCallbacks(&app.SinkCallbacks{ appSink.SetCallbacks(&app.SinkCallbacks{
// We need to define an EOS callback on the sink for when we receive an EOS
// upstream. This gives us an opportunity to cleanup and then signal the pipeline
// that we are ready to be shut down.
EOSFunc: func(sink *app.Sink) { EOSFunc: func(sink *app.Sink) {
fmt.Println("\nWriting the results of the gif to", outFile) fmt.Println("\nWriting the results of the gif to", outFile)
file, err := os.Create(outFile) file, err := os.Create(outFile)
@@ -126,6 +130,7 @@ func encodeGif(mainLoop *gst.MainLoop) error {
if err := gif.EncodeAll(file, outGif); err != nil { if err := gif.EncodeAll(file, outGif); err != nil {
fmt.Println("Could not encode images to gif format!", err) fmt.Println("Could not encode images to gif format!", err)
} }
// Signal the pipeline that we've completed EOS
pipeline.GetPipelineBus().Post(gst.NewEOSMessage(appSink)) pipeline.GetPipelineBus().Post(gst.NewEOSMessage(appSink))
}, },
NewSampleFunc: func(sink *app.Sink) gst.FlowReturn { NewSampleFunc: func(sink *app.Sink) gst.FlowReturn {
@@ -181,47 +186,37 @@ func encodeGif(mainLoop *gst.MainLoop) error {
srcPad.Link(queue.GetStaticPad("sink")) srcPad.Link(queue.GetStaticPad("sink"))
}) })
fmt.Println("Encoding video to gif")
// Now that the pipeline is all set up we can start it. // Now that the pipeline is all set up we can start it.
pipeline.SetState(gst.StatePlaying) pipeline.SetState(gst.StatePlaying)
// Add a watch on the bus on the pipeline and catch any errors // Add a watch on the bus on the pipeline and catch any errors
// that happen. // that happen.
var isError bool var pipelineErr error
pipeline.GetPipelineBus().AddWatch(func(msg *gst.Message) bool { pipeline.GetPipelineBus().AddWatch(func(msg *gst.Message) bool {
switch msg.Type() { switch msg.Type() {
case gst.MessageEOS: case gst.MessageEOS:
mainLoop.Quit() mainLoop.Quit()
case gst.MessageError: case gst.MessageError:
err := msg.ParseError() gerr := msg.ParseError()
fmt.Println("ERROR:", err.Error()) fmt.Println("ERROR:", gerr.Error())
if debug := err.DebugString(); debug != "" { if debug := gerr.DebugString(); debug != "" {
fmt.Println("DEBUG") fmt.Println("DEBUG")
fmt.Println(debug) fmt.Println(debug)
} }
mainLoop.Quit() mainLoop.Quit()
isError = true pipelineErr = gerr
return false return false
} }
return true return true
}) })
fmt.Println("Encoding video to gif")
// Iterate on the main loop until the pipeline is finished. // Iterate on the main loop until the pipeline is finished.
mainLoop.Run() mainLoop.Run()
// Print an extra line since we were doing fancy carriage return stuff return pipelineErr
// from th app sink
fmt.Println()
// If no error happened on the pipeline. Write the results of the gif
// to the destination.
if !isError {
}
return pipeline.Destroy()
} }
func main() { func main() {