From f93ee1a42e8c47e472332287b7350b66a6b0fa11 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期五, 24 七月 2020 18:28:57 +0800
Subject: [PATCH] 保存触发id之后的视频作为触发视频
---
goffmpeg.go | 214 +++++++++++++++--------------------------------------
1 files changed, 62 insertions(+), 152 deletions(-)
diff --git a/goffmpeg.go b/goffmpeg.go
index 1efcb8d..bca75d2 100644
--- a/goffmpeg.go
+++ b/goffmpeg.go
@@ -13,6 +13,8 @@
)
const (
+ // ScaleNone self add no scale raw frame data
+ ScaleNone = 0
// ScaleFastBilinear SWS_FAST_BILINEAR
ScaleFastBilinear = 1
// ScaleBilinear SWS_BILINEAR
@@ -37,6 +39,12 @@
ScaleSpline = 0x400
)
+// SrcFormat format NV
+const SrcFormat = 23
+
+// DstFormat format
+const DstFormat = 3
+
var libcffmpeg C.libcffmpeg
// InitFFmpeg init ffmepg
@@ -59,34 +67,45 @@
}
}
-// Config config
-type Config struct {
- Scale int
- Width int
- Height int
- GB bool
- CPU bool
-}
-
// GoFFMPEG handle for c
type GoFFMPEG struct {
ffmpeg C.cffmpeg
}
// New 2nd new
-func New(conf Config) *GoFFMPEG {
- f := C.wrap_fn_create()
+func New(GB, CPU bool) *GoFFMPEG {
+
+ f := C.wrap_fn_create(unsafe.Pointer(libcffmpeg))
+
if f == nil {
return nil
}
- if conf.Scale != 0 && conf.Width != 0 && conf.Height != 0 {
- C.wrap_fn_scale(f, C.int(conf.Width), C.int(conf.Height), C.int(conf.Scale))
+ if GB {
+ C.wrap_fn_run_gb28181(unsafe.Pointer(libcffmpeg), f)
}
- if conf.GB {
- C.wrap_fn_run_gb28181(f)
+ if CPU {
+ C.wrap_fn_use_cpu(unsafe.Pointer(libcffmpeg), f)
}
- if conf.CPU {
- C.wrap_fn_use_cpu(f)
+
+ return &GoFFMPEG{
+ 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(unsafe.Pointer(libcffmpeg), lf)
+ if f == nil {
+ return nil
+ }
+ if GB {
+ C.wrap_fn_run_gb28181(unsafe.Pointer(libcffmpeg), f)
+ }
+ if CPU {
+ C.wrap_fn_use_cpu(unsafe.Pointer(libcffmpeg), f)
}
return &GoFFMPEG{
@@ -96,7 +115,9 @@
// Free free handle
func (h *GoFFMPEG) Free() {
- C.wrap_fn_destroy(h.ffmpeg)
+ if h.ffmpeg != nil {
+ C.wrap_fn_destroy(unsafe.Pointer(libcffmpeg), h.ffmpeg)
+ }
}
// Run ffmpeg
@@ -104,150 +125,39 @@
in := C.CString(input)
defer C.free(unsafe.Pointer(in))
- C.wrap_fn_run(h.ffmpeg, in)
+ C.wrap_fn_run(unsafe.Pointer(libcffmpeg), h.ffmpeg, in)
}
-// DecodeJPEG decode jpeg file
-func DecodeJPEG(input string) ([]byte, int, int) {
+// Run2 ffmpeg
+func (h *GoFFMPEG) Run2(input string, minDuration 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(in, &width, &height)
- defer C.free(p)
+ C.wrap_fn_run(unsafe.Pointer(libcffmpeg), h.ffmpeg, in)
+}
- if width > 0 && height > 0 {
- data := C.GoBytes(p, width*height*3)
- wid := int(width)
- hei := int(height)
- return data, wid, hei
+// FPS fps
+func (h *GoFFMPEG) FPS() int {
+ return int(C.wrap_fn_fps(unsafe.Pointer(libcffmpeg), h.ffmpeg))
+}
+
+// ReleaseC release c memory
+func ReleaseC(p unsafe.Pointer) {
+ if p == nil {
+ return
}
- return nil, 0, 0
-}
-
-// FireRecorder fire recorder
-func (h *GoFFMPEG) FireRecorder(sid string, id int64) {
- csid := C.CString(sid)
- defer C.free(unsafe.Pointer(csid))
- C.wrap_fn_fire_recorder(h.ffmpeg, csid, C.long(id))
-}
-
-// BuildRecorder build recorder
-func (h *GoFFMPEG) BuildRecorder(sid, output string, mind, maxd int) {
- out := C.CString(output)
- defer C.free(unsafe.Pointer(out))
- csid := C.CString(sid)
- defer C.free(unsafe.Pointer(csid))
-
- C.wrap_fn_recorder(h.ffmpeg, csid, out, C.int(mind), C.int(maxd))
-}
-
-// GetInfoRecorder info
-func (h *GoFFMPEG) GetInfoRecorder() (string, int, string) {
- var i C.int = -1
-
- var id *C.char
- var idl C.int
-
- var p *C.char
- var pl C.int
-
- C.wrap_fn_info_recorder(h.ffmpeg, &i, &id, &idl, &p, &pl)
- // if p == nil {
- // return -1, ""
- // }
- gID := C.GoString(id)
- C.free(unsafe.Pointer(id))
- path := C.GoString(p)
C.free(unsafe.Pointer(p))
-
- // fmt.Println("Go get info : ", path, " len: ", l)
-
- return gID, int(i), path
}
-// BuildDecoder build decoder
-func (h *GoFFMPEG) BuildDecoder() {
- C.wrap_fn_decoder(h.ffmpeg)
-}
+// GetGBJpg Get GB28181 Jpg
+func GetGBJpg(rtspUrl string) []byte {
+ rtsp := C.CString(rtspUrl)
+ defer C.free(unsafe.Pointer(rtsp))
+ var jpgLen C.int
-// GetPicDecoder get pic from decoder
-func (h *GoFFMPEG) GetPicDecoder() ([]byte, int, int, int64) {
- var width C.int
- var height C.int
- var fid C.long
+ pic := C.wrap_fn_get_gb28181_pic(unsafe.Pointer(libcffmpeg), rtsp, &jpgLen)
+ defer C.free(unsafe.Pointer(pic))
- p := C.wrap_fn_decoder_pic(h.ffmpeg, &width, &height, &fid)
- if width == 0 && height == 0 {
- return nil, 0, 0, 0
- }
- defer C.free(unsafe.Pointer(p))
- d := C.GoBytes(p, width*height*3)
- wid := int(width)
- hei := int(height)
- gfid := int64(fid)
- return d, wid, hei, gfid
-}
-
-//GetAVPacket get AVPacket
-func (h *GoFFMPEG) GetAVPacket() ([]byte, int, int) {
- var key C.int
- var size C.int
-
- p := C.wrap_fn_get_avpacket(h.ffmpeg, &size, &key)
- if size <= 0 {
- return nil, 0, -1
- }
- defer C.free(unsafe.Pointer(p))
- d := C.GoBytes(p, size)
- s := int(size)
- k := int(key)
-
- return d, s, k
-}
-
-///////////////for encoder
-
-// GoEncoder encoder
-type GoEncoder struct {
- enc C.cencoder
-}
-
-// NewEncoder encoder
-func NewEncoder(w, h, fps, br, sFlag, gi int) *GoEncoder {
- if w <= 0 || h <= 0 {
- return nil
- }
-
- return &GoEncoder{
- enc: C.wrap_fn_create_encoder(C.int(w), C.int(h), C.int(fps), C.int(br), C.int(sFlag), C.int(gi)),
- }
-}
-
-// Free free
-func (e *GoEncoder) Free() {
- C.wrap_fn_destroy_encoder(e.enc)
-}
-
-// Encode pic
-func (e *GoEncoder) Encode(in []byte, w, h int) ([]byte, int, bool) {
-
- var size C.int
- var key C.int
- cin := C.CBytes(in)
- defer C.free(cin)
-
- p := C.wrap_fn_encode(e.enc, cin, C.int(w), C.int(h), &size, &key)
- defer C.free(p)
- if p != nil && size > 0 {
- b := C.GoBytes(p, size)
-
- isKey := false
- if key > 0 {
- isKey = true
- }
- return b, int(size), isKey
- }
- return nil, 0, false
+ retJpg := C.GoBytes(unsafe.Pointer(pic), jpgLen)
+ return retJpg
}
--
Gitblit v1.8.0