mirror of
https://github.com/xfrr/goffmpeg.git
synced 2025-10-05 14:46:51 +08:00
Adding back the ffmpeg process cmd handle
This commit is contained in:
@@ -19,6 +19,7 @@ import (
|
||||
|
||||
type Transcoder struct {
|
||||
stdErrPipe io.ReadCloser
|
||||
process *exec.Cmd
|
||||
mediafile *models.Mediafile
|
||||
configuration ffmpeg.Configuration
|
||||
}
|
||||
@@ -27,6 +28,10 @@ func (t *Transcoder) SetProcessStderrPipe(v io.ReadCloser) {
|
||||
t.stdErrPipe = v
|
||||
}
|
||||
|
||||
func (t *Transcoder) SetProcess(cmd *exec.Cmd) {
|
||||
t.process = cmd
|
||||
}
|
||||
|
||||
func (t *Transcoder) SetMediaFile(v *models.Mediafile) {
|
||||
t.mediafile = v
|
||||
}
|
||||
@@ -36,6 +41,9 @@ func (t *Transcoder) SetConfiguration(v ffmpeg.Configuration) {
|
||||
}
|
||||
|
||||
/*** GETTERS ***/
|
||||
func (t Transcoder) Process() *exec.Cmd{
|
||||
return t.process
|
||||
}
|
||||
|
||||
func (t Transcoder) MediaFile() *models.Mediafile {
|
||||
return t.mediafile
|
||||
@@ -123,7 +131,7 @@ func (t *Transcoder) Run() <-chan error {
|
||||
proc.Stdout = out
|
||||
|
||||
err = proc.Start()
|
||||
|
||||
t.SetProcess(proc)
|
||||
go func(err error, out *bytes.Buffer, errStream io.ReadCloser) {
|
||||
defer func() {
|
||||
if errStream != nil {
|
||||
|
Reference in New Issue
Block a user