From 63d598d4443f906b34bedaf49e870b7a2be1a5c8 Mon Sep 17 00:00:00 2001 From: houxiao <houxiao@454eff88-639b-444f-9e54-f578c98de674> Date: 星期四, 06 四月 2017 12:14:30 +0800 Subject: [PATCH] bug fix for android device --- VisitFace/RtspNativeCodec/app/src/main/cpp/FaceCache.cpp | 183 +++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 183 insertions(+), 0 deletions(-) diff --git a/VisitFace/RtspNativeCodec/app/src/main/cpp/FaceCache.cpp b/VisitFace/RtspNativeCodec/app/src/main/cpp/FaceCache.cpp index bca2543..160ed07 100644 --- a/VisitFace/RtspNativeCodec/app/src/main/cpp/FaceCache.cpp +++ b/VisitFace/RtspNativeCodec/app/src/main/cpp/FaceCache.cpp @@ -1,3 +1,186 @@ #include "FaceCache.h" +#include "PipeLine.h" +#include "MaterialBuffer.h" +#include "PL_SensetimeFaceTrack.h" #include <logger.h> #include <Logger/src/logger.hpp> + +#include <opencv/cv.h> +#include <opencv/cxcore.h> +#include <opencv/highgui.h> + +#include <vector> + +#include "PbFaceList.pb.h" + +struct FcPmBreackerContext +{ + uint8_t frameYUV[1920*1080*4]; + size_t frameYUVSize; + + uint8_t frameRGB[1920*1080*4]; + size_t frameRGBSize; + + size_t width; + size_t height; + + st_ff_vect_t faceFeatures; + + bool dataAvailable; + + FcPmBreackerContext() : + frameYUV(), frameYUVSize(0), frameRGB(), frameRGBSize(0), + faceFeatures(), width(0), height(0), dataAvailable(false) + { + } + + void reset() + { + frameYUVSize = 0; + frameRGBSize = 0; + width = 0; + height = 0; + dataAvailable = false; + faceFeatures.clear(); + } + + bool convertYUV420ToRGB() + { + } +}; + +bool fc_pm_breaker_ptr(const PipeMaterial* pm, void* args) +{ + FcPmBreackerContext* ctx = (FcPmBreackerContext*)args; + + const st_ff_vect_t& faceFeatures(*(const st_ff_vect_t*)(pm->buffer)); + + ctx->faceFeatures = faceFeatures; + + ctx->dataAvailable &= true; + return false; +} + +bool fc_pm_breaker_frame(const PipeMaterial* pm, void* args) +{ + FcPmBreackerContext* ctx = (FcPmBreackerContext*)args; + + const MB_Frame* lastFrame((const MB_Frame*)(pm->buffer)); + if (lastFrame->type != MB_Frame::MBFT_YUV420) + { + ctx->dataAvailable &= false; + return false; + } + + if (lastFrame->buffSize == 0) + { + ctx->dataAvailable &= false; + return false; + } + + ctx->frameYUVSize = lastFrame->buffSize; + ctx->width = lastFrame->width; + ctx->height = lastFrame->height; + memcpy(ctx->frameYUV, lastFrame->buffer, ctx->frameYUVSize); + + ctx->dataAvailable &= true; + return false; +} + +#ifdef USE_ST_SDK +FaceCache::FaceCache() : _ctx(new FcPmBreackerContext) +{ +} + +FaceCache::~FaceCache() +{ + delete (FcPmBreackerContext*)_ctx; +} +#endif + +// returns count of face +int FaceCache::cachePm(const PipeMaterial& pm) +{ + if (_ctx == nullptr) + _ctx = new FcPmBreackerContext; + + FcPmBreackerContext& ctx(*(FcPmBreackerContext*)_ctx); + ctx.reset(); + ctx.dataAvailable = true; + pm.breake(PipeMaterial::PMT_PTR, MB_Frame::MBFT__FIRST, fc_pm_breaker_ptr, _ctx); + pm.breake(PipeMaterial::PMT_FRAME, MB_Frame::MBFT__FIRST, fc_pm_breaker_frame, _ctx); + + if (ctx.dataAvailable) + return ctx.faceFeatures.size(); + else + return 0; +} + +bool FaceCache::getFaceListPb(uint8_t* buffer, size_t& buffMaxSize) +{ + FcPmBreackerContext& ctx(*(FcPmBreackerContext*)_ctx); + + PbFaceList pbFaceList; + pbFaceList.set_image_count(ctx.faceFeatures.size()); + pbFaceList.set_src_width(ctx.width); + pbFaceList.set_src_height(ctx.height); + + cv::Mat yMat(cv::Size(ctx.width, ctx.height), CV_8UC1, ctx.frameYUV); + + for (int i = 0; i < ctx.faceFeatures.size(); i++) + { + const FaceRect& faceRect(ctx.faceFeatures[i].rect); + cv::Mat roiMat(yMat, cv::Rect(faceRect.leftTop.x, faceRect.leftTop.y, faceRect.rightBottom.x - faceRect.leftTop.x, faceRect.rightBottom.y - faceRect.leftTop.y)); + + PbFaceList_FaceListImage pbFaceListImage; + pbFaceListImage.set_idx(i); + pbFaceListImage.set_size(roiMat.elemSize()); + pbFaceListImage.set_type(PbFaceList_FaceListImage_ImageType_IT_Y); + pbFaceListImage.set_width(roiMat.cols); + pbFaceListImage.set_height(roiMat.rows); + pbFaceListImage.set_top_left_x(faceRect.leftTop.x); + pbFaceListImage.set_top_left_y(faceRect.leftTop.y); + + pbFaceListImage.set_img(0, roiMat.ptr(), roiMat.elemSize()); + } + + + return false; +} + +bool FaceCache::getFaceListImage(int* buffIdx, size_t& count, uint8_t* buffImg, size_t& buffImgMaxSize) +{ + FcPmBreackerContext& ctx(*(FcPmBreackerContext*)_ctx); + + if (ctx.frameRGBSize == 0) + { + if (! ctx.convertYUV420ToRGB()) + return false; + } + + count = 0; + uint8_t* pBuff = buffImg; + size_t totalSize = 0; + + cv::Mat rgbMat(cv::Size(ctx.width, ctx.height), CV_8UC3, ctx.frameRGB); + for (st_ff_vect_t::const_iterator ffiter = ctx.faceFeatures.begin(); ffiter != ctx.faceFeatures.end(); ++ffiter) + { + const FaceRect& faceRect(ffiter->rect); + cv::Mat roiMat(rgbMat, cv::Rect(faceRect.leftTop.x, faceRect.leftTop.y, faceRect.rightBottom.x - faceRect.leftTop.x, faceRect.rightBottom.y - faceRect.leftTop.y)); + + //isContinuous + size_t s = roiMat.elemSize(); + if (totalSize + s <= buffImgMaxSize) + { + memcpy(pBuff, roiMat.ptr(), s); + *buffIdx = int(totalSize); + + pBuff += s; + totalSize += s; + count++; + buffIdx++; + } + } + + return (count != 0); +} -- Gitblit v1.8.0