From cd3fe8cc1ae9028acb4f630ed16c12f4fb327f3c Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 10 十月 2019 17:35:12 +0800
Subject: [PATCH] add interface out

---
 goffmpeg.go |   94 +++++++++++++++++++++++++++++++----------------
 1 files changed, 62 insertions(+), 32 deletions(-)

diff --git a/goffmpeg.go b/goffmpeg.go
index b497fac..dedb2bf 100644
--- a/goffmpeg.go
+++ b/goffmpeg.go
@@ -7,35 +7,84 @@
 */
 import "C"
 import (
+	"errors"
 	"fmt"
 	"unsafe"
 )
 
-// GoFFMPEG handle for c
-type GoFFMPEG struct {
-	lib    C.libcffmpeg
-	ffmpeg C.cffmpeg
-}
+var libcffmpeg C.libcffmpeg
 
-// New create handle
-func New() *GoFFMPEG {
-	soFile := C.CString("./runtime/libcffmpeg.so")
+// InitFFmpeg init ffmepg
+func InitFFmpeg(soFileGo string) error {
+	soFile := C.CString(soFileGo)
 	defer C.free(unsafe.Pointer(soFile))
 	lib := C.init_libcffmpeg(soFile)
 	if lib == nil {
-		fmt.Println("open libcffmpeg.so error")
+		fmt.Println("open error: ", soFileGo)
+		return errors.New("init ffmpeg error")
+	}
+	libcffmpeg = lib
+	return nil
+}
+
+// FreeFFmpeg free ffmpeg
+func FreeFFmpeg() {
+	if libcffmpeg != nil {
+		C.release_libcffmpeg(libcffmpeg)
+	}
+}
+
+// GoFFMPEG handle for c
+type GoFFMPEG struct {
+	ffmpeg C.cffmpeg
+}
+
+// New 2nd new
+func New(GB, CPU bool) *GoFFMPEG {
+
+	f := C.wrap_fn_create()
+
+	if f == nil {
 		return nil
 	}
+	if GB {
+		C.wrap_fn_run_gb28181(f)
+	}
+	if CPU {
+		C.wrap_fn_use_cpu(f)
+	}
+
 	return &GoFFMPEG{
-		lib:    lib,
-		ffmpeg: C.wrap_fn_create(),
+		ffmpeg: f,
+	}
+}
+
+// NewWithLog log
+func NewWithLog(GB, CPU bool, ffmpegLog string) *GoFFMPEG {
+	lf := C.CString(ffmpegLog)
+	defer C.free(unsafe.Pointer(lf))
+
+	f := C.wrap_fn_create2(lf)
+	if f == nil {
+		return nil
+	}
+	if GB {
+		C.wrap_fn_run_gb28181(f)
+	}
+	if CPU {
+		C.wrap_fn_use_cpu(f)
+	}
+
+	return &GoFFMPEG{
+		ffmpeg: f,
 	}
 }
 
 // Free free handle
 func (h *GoFFMPEG) Free() {
-	C.wrap_fn_destroy(h.ffmpeg)
-	C.release_libcffmpeg(h.lib)
+	if h.ffmpeg != nil {
+		C.wrap_fn_destroy(h.ffmpeg)
+	}
 }
 
 // Run ffmpeg
@@ -44,23 +93,4 @@
 	defer C.free(unsafe.Pointer(in))
 
 	C.wrap_fn_run(h.ffmpeg, in)
-}
-
-// DecodeJPEG decode jpeg file
-func (h *GoFFMPEG) DecodeJPEG(input string) ([]byte, int, int) {
-	in := C.CString(input)
-	defer C.free(unsafe.Pointer(in))
-
-	var width C.int
-	var height C.int
-	p := C.wrap_fn_decode_jpeg(h.ffmpeg, in, &width, &height)
-	defer C.free(p)
-
-	if width > 0 && height > 0 {
-		data := C.GoBytes(p, width*height*3)
-		wid := int(width)
-		hei := int(height)
-		return data, wid, hei
-	}
-	return nil, 0, 0
 }

--
Gitblit v1.8.0