diff --git a/tests/transcoding_test.go b/tests/transcoding_test.go index ababd45..ffa292a 100755 --- a/tests/transcoding_test.go +++ b/tests/transcoding_test.go @@ -3,6 +3,7 @@ package test import ( "testing" "github.com/xfrr/goffmpeg/transcoder" + "fmt" ) func TestInputNotFound(t *testing.T) { @@ -227,3 +228,27 @@ func TestTranscodingWMV(t *testing.T) { return } } + +func TestTranscodingProgress(t *testing.T) { + + var inputPath = "/data/test.mp4" + var outputPath = "/data/testmp4.mp4" + + trans := new(transcoder.Transcoder) + + err := trans.Initialize(inputPath, outputPath) + if err != nil { + t.Error(err) + return + } + + done := trans.Run(true) + for val := range trans.Output() { + fmt.Printf("%+v\n", val) + } + err = <- done + if err != nil { + t.Error(err) + return + } +} diff --git a/transcoder/transcoder.go b/transcoder/transcoder.go index 8e429d2..146e435 100644 --- a/transcoder/transcoder.go +++ b/transcoder/transcoder.go @@ -117,7 +117,9 @@ func (t *Transcoder) Initialize(inputPath string, outputPath string) (error) { func (t *Transcoder) Run(progress bool) <-chan error { done := make(chan error) command := t.GetCommand() - + if !progress { + command = append([]string{"-nostats", "-loglevel", "0"}, command...) + } proc := exec.Command(t.configuration.FfmpegBin, command...) if progress { errStream, err := proc.StderrPipe()