From 88c21b872799a1ae9dd7dd7d20f3811d749d9418 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期五, 26 七月 2019 14:04:22 +0800 Subject: [PATCH] add rec --- apipassive.go | 52 ++++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 40 insertions(+), 12 deletions(-) diff --git a/apipassive.go b/apipassive.go index 61e67cf..5f866f5 100644 --- a/apipassive.go +++ b/apipassive.go @@ -5,33 +5,44 @@ #include "libcffmpeg.h" */ import "C" -import "unsafe" +import ( + "unsafe" +) // FireRecorder fire recorder -func (h *GoFFMPEG) FireRecorder(id int64) { - C.wrap_fn_fire_recorder(h.ffmpeg, C.long(id)) +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(output string, mind, maxd int) { +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, out, C.int(mind), C.int(maxd)) + C.wrap_fn_recorder(h.ffmpeg, csid, out, C.int(mind), C.int(maxd)) } // GetInfoRecorder info -func (h *GoFFMPEG) GetInfoRecorder() (int, string) { +func (h *GoFFMPEG) GetInfoRecorder() (string, int, string) { var i C.int = -1 var l C.int + var sid *C.char + p := C.wrap_fn_info_recorder(h.ffmpeg, &sid, &i, &l) + // if p == nil { + // return -1, "" + // } + path := C.GoString(p) + C.free(unsafe.Pointer(p)) - p := C.wrap_fn_info_recorder(h.ffmpeg, &i, &l) - if i == -1 { - return -1, "" - } - defer C.free(unsafe.Pointer(p)) + goid := C.GoString(sid) + C.free(unsafe.Pointer(sid)) + // fmt.Println("Go get info : ", path, " len: ", l) - return int(i), C.GoString(p) + return goid, int(i), path } // BuildDecoder build decoder @@ -55,3 +66,20 @@ return d, wid, hei } + +//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 +} -- Gitblit v1.8.0