From 109ffe9a777658936a38d0c146579a67c60a0d17 Mon Sep 17 00:00:00 2001 From: xuxiuxi <xuxiuxi@454eff88-639b-444f-9e54-f578c98de674> Date: 星期四, 11 五月 2017 17:48:48 +0800 Subject: [PATCH] --- VisitFace/RtspNativeCodec/app/src/main/cpp/RtspNativeCodecJNI.cpp | 265 ++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 242 insertions(+), 23 deletions(-) diff --git a/VisitFace/RtspNativeCodec/app/src/main/cpp/RtspNativeCodecJNI.cpp b/VisitFace/RtspNativeCodec/app/src/main/cpp/RtspNativeCodecJNI.cpp index 439e16c..bc88de2 100644 --- a/VisitFace/RtspNativeCodec/app/src/main/cpp/RtspNativeCodecJNI.cpp +++ b/VisitFace/RtspNativeCodec/app/src/main/cpp/RtspNativeCodecJNI.cpp @@ -10,6 +10,15 @@ #include <pthread.h> +#include <ev_proto.h> +#include <face_daemon_proto.h> + +#include <stdlib.h> + +#include "DebugNetwork.h" + +#include <mediastreamer2/include/mediastreamer2/msjava.h> + std::stringstream logss; //std::fstream logss("/storage/sdcard/log.log", std::fstream::out); //std::fstream logss("/storage/emulated/0/log.log", std::fstream::out); @@ -22,7 +31,7 @@ void Java_cn_com_basic_face_util_RtspFaceNative_init(JNIEnv *env, jclass clazz) { - g_logger.set_level(VERBOSE); + g_logger.set_level(INFO); #ifdef USE_ST_SDK PipeLine::register_global_elem_creator("PL_SensetimeFaceTrack", create_PL_SensetimeFaceTrack); @@ -51,8 +60,130 @@ env->ReleaseStringUTFChars(ipaddr, utf8); } +static jclass _jcOutputSurface = nullptr; +static jmethodID _jmOutputSurface_ctor = nullptr; +static jmethodID _jmOutputSurface_getSurface = nullptr; +static jmethodID _jmOutputSurface_readPixels = nullptr; +static jmethodID _jmOutputSurface_awaitNewImage = nullptr; +static jmethodID _jmOutputSurface_drawImage = nullptr; +static jmethodID _jmOutputSurface_makeCurrent = nullptr; + +static jobject _jobjOutputSurface = nullptr; +static jobject _jobjSurface = nullptr; +static JNIEnv *_env = nullptr; + +void readPixels(void* surface, uint8_t* buf, size_t& maxSize) +{ + //ANativeWindow* window = (ANativeWindow*)surface; + + CameraWrapper& cameraWrapper(g_CameraWrappers[0]); + + int getEnvStat = cameraWrapper.javaVM->GetEnv((void **)&(cameraWrapper.javaEnv), JNI_VERSION_1_6); + if (getEnvStat == JNI_EDETACHED) + { + //LOG_WARN << "GetEnv: not attached" << std::endl; + if (cameraWrapper.javaVM->AttachCurrentThread(&(cameraWrapper.javaEnv), NULL) != 0) + LOG_WARN << "Failed to attach" << LOG_ENDL; + else + getEnvStat = JNI_OK; + } + else if (getEnvStat == JNI_OK) + { + } + else if (getEnvStat == JNI_EVERSION) + LOG_WARN << "GetEnv: version not supported" << LOG_ENDL; + else if (getEnvStat == JNI_ERR) + LOG_WARN << "GetEnv: JNI_ERR" << LOG_ENDL; + + if (maxSize==0) + { + //cameraWrapper.javaEnv->CallVoidMethod(_jobjOutputSurface, _jmOutputSurface_makeCurrent); + } + else + { + //cameraWrapper.javaEnv->CallVoidMethod(_jobjOutputSurface, _jmOutputSurface_awaitNewImage); + //cameraWrapper.javaEnv->CallVoidMethod(_jobjOutputSurface, _jmOutputSurface_drawImage); +// + //jbyteArray jbarrBuffer = (jbyteArray)cameraWrapper.javaEnv->CallObjectMethod(_jobjOutputSurface, _jmOutputSurface_readPixels); + //if (jbarrBuffer != nullptr) + // cameraWrapper.javaEnv->GetByteArrayRegion(jbarrBuffer, 0, 640 * 480 * 2, (jbyte*)buf); + } + + if (cameraWrapper.javaEnv->ExceptionCheck()) + cameraWrapper.javaEnv->ExceptionDescribe(); + + cameraWrapper.javaVM->DetachCurrentThread(); +} + + +/* +static void* createDecodeSurface() +{ + CameraWrapper& cameraWrapper(g_CameraWrappers[0]); + + //OutputSurface outputSurface = null; + //outputSurface = new OutputSurface(mWidth, mHeight); + //outputSurface.getSurface(); + //outputSurface.release(); + + + //int getEnvStat = cameraWrapper.javaVM->GetEnv((void **)&(cameraWrapper.javaEnv), JNI_VERSION_1_6); + //if (getEnvStat == JNI_EDETACHED) + //{ + // //LOG_WARN << "GetEnv: not attached" << std::endl; + // if (cameraWrapper.javaVM->AttachCurrentThread(&(cameraWrapper.javaEnv), NULL) != 0) + // LOG_WARN << "Failed to attach" << LOG_ENDL; + // else + // getEnvStat = JNI_OK; + //} + //else if (getEnvStat == JNI_OK) + //{ + //} + //else if (getEnvStat == JNI_EVERSION) + // LOG_WARN << "GetEnv: version not supported" << LOG_ENDL; + //else if (getEnvStat == JNI_ERR) + // LOG_WARN << "GetEnv: JNI_ERR" << LOG_ENDL; + + //void* ret = nullptr; + //{ + // jclass jcOutputSurface = _jcOutputSurface = cameraWrapper.javaEnv->FindClass("com/example/nativecodec/OutputSurface"); + // _jcOutputSurface = static_cast<jclass>( cameraWrapper.javaEnv->NewGlobalRef( jcOutputSurface )); +// + // jmethodID jmOutputSurface_ctor = _jmOutputSurface_ctor = cameraWrapper.javaEnv->GetMethodID(jcOutputSurface, "<init>", "(II)V"); + // jmethodID jmOutputSurface_getSurface = _jmOutputSurface_getSurface = cameraWrapper.javaEnv->GetMethodID(jcOutputSurface, "getSurface", "()Landroid/view/Surface;"); + // jmethodID jmOutputSurface_readPixels = _jmOutputSurface_readPixels = cameraWrapper.javaEnv->GetMethodID(jcOutputSurface, "readPixels", "()[B"); +// + // jmethodID jmOutputSurface_awaitNewImage = _jmOutputSurface_awaitNewImage = cameraWrapper.javaEnv->GetMethodID(jcOutputSurface, "awaitNewImage", "()V"); + // jmethodID jmOutputSurface_drawImage = _jmOutputSurface_drawImage = cameraWrapper.javaEnv->GetMethodID(jcOutputSurface, "drawImage", "()V"); + // jmethodID jmOutputSurface_makeCurrent = _jmOutputSurface_makeCurrent = cameraWrapper.javaEnv->GetMethodID(jcOutputSurface, "makeCurrent", "()V"); +// + // jobject jobjOutputSurface = _jobjOutputSurface = cameraWrapper.javaEnv->NewObject(jcOutputSurface , jmOutputSurface_ctor, 1920, 1088); + // _jobjOutputSurface = static_cast<jobject>( cameraWrapper.javaEnv->NewGlobalRef( jobjOutputSurface )); +// + // jobject jobjSurface = _jobjSurface = cameraWrapper.javaEnv->CallObjectMethod(jobjOutputSurface, jmOutputSurface_getSurface); + // ret = ANativeWindow_fromSurface(cameraWrapper.javaEnv, jobjSurface); + // cameraWrapper.amcdConfig.readPixels_callback = readPixels; + //} + + //if (cameraWrapper.javaEnv->ExceptionCheck()) + // cameraWrapper.javaEnv->ExceptionDescribe(); +// + //cameraWrapper.javaVM->DetachCurrentThread(); + + //return ret; +} +*/ + +static void* getSurfaceHolderGetSurface(JNIEnv* env, jobject jobjSurfaceHolder) +{ + jclass jcSurfaceHolder = env->FindClass("android/view/SurfaceHolder"); + jmethodID jmSurfaceHolder_getSurface = env->GetMethodID(jcSurfaceHolder, "getSurface", "()Landroid/view/Surface;"); + jobject surface = env->CallObjectMethod(jobjSurfaceHolder, jmSurfaceHolder_getSurface); + return surface; +} + // set the surface -void Java_cn_com_basic_face_util_RtspFaceNative_setSurface(JNIEnv *env, jclass clazz, jint cameraIdx, jobject surface) +void Java_cn_com_basic_face_util_RtspFaceNative_setSurface(JNIEnv *env, jclass clazz, jint cameraIdx, jobject surfaceDecoder, jobject surfaceRender) { LOG_DEBUG << "@@@ Java_cn_com_basic_face_util_RtspFaceNative_setSurface" << LOG_ENDL; assert(cameraIdx > 0 && cameraIdx <= CAMERA_COUNT); @@ -60,14 +191,25 @@ CameraWrapper& cameraWrapper(g_CameraWrappers[cameraIdx]); - // obtain a native window from a Java surface - if (cameraWrapper.window) - { - ANativeWindow_release((ANativeWindow*)(cameraWrapper.window)); - cameraWrapper.window = NULL; + // obtain a native windowRender from a Java surface + if (cameraWrapper.windowDecode != nullptr) + { + ANativeWindow_release((ANativeWindow*)(cameraWrapper.windowDecode)); + cameraWrapper.windowDecode = NULL; } - cameraWrapper.window = ANativeWindow_fromSurface(env, surface); - LOGP(DEBUG, "@@@ setsurface %p", cameraWrapper.window); + cameraWrapper.windowDecode = ANativeWindow_fromSurface(env, surfaceDecoder); + //cameraWrapper.windowDecode = getSurfaceHolderGetSurface(env, surfaceDecoder); + //cameraWrapper.windowDecode = ANativeWindow_fromSurface(env, (jobject)getSurfaceHolderGetSurface(env, surfaceDecoder)); + + if (cameraWrapper.windowRender != nullptr) + { + ANativeWindow_release((ANativeWindow*)(cameraWrapper.windowRender)); + cameraWrapper.windowRender = NULL; + } + cameraWrapper.windowRender = ANativeWindow_fromSurface(env, surfaceRender); + //cameraWrapper.windowRender = ANativeWindow_fromSurface(env, (jobject)getSurfaceHolderGetSurface(env, surfaceRender)); + + LOGP(DEBUG, "@@@ setsurface %p,%p", cameraWrapper.windowDecode, cameraWrapper.windowRender); } jboolean Java_cn_com_basic_face_util_RtspFaceNative_createPlayer(JNIEnv* env, jclass clazz, jint cameraIdx, jstring uri) @@ -92,22 +234,28 @@ { cameraWrapper.amcdConfig.ak_mime = "video/avc"; - cameraWrapper.amcdConfig.ak_width = 640; - cameraWrapper.amcdConfig.ak_height = 480; - cameraWrapper.amcdConfig.windowSurface = nullptr; // cameraWrapper.window - cameraWrapper.amcdConfig.releaseOutputBuffIdx = true; + cameraWrapper.amcdConfig.ak_width = 1920; + cameraWrapper.amcdConfig.ak_height = 1088; + //cameraWrapper.amcdConfig.windowSurfaceDecode = cameraWrapper.windowDecode; //cameraWrapper.windowDecode; + //cameraWrapper.amcdConfig.windowSurfaceRender = cameraWrapper.windowRender; //cameraWrapper.windowRender; + cameraWrapper.amcdConfig.releaseOutputBuffIdx = true; + cameraWrapper.amcdConfig.releaseOutputBuffIdxInPay = false; cameraWrapper.amcdConfig.generateDecodedDataPerFrame = 1; - cameraWrapper.amcdConfig.renderFromOutputBuffIdx = false;//true - cameraWrapper.amcdConfig.renderFromOutputBuff = false; + + //cameraWrapper.amcdConfig.createSurface_callback = createDecodeSurface; + //cameraWrapper.amcdConfig.readPixels_callback = readPixels; + #ifndef USE_ST_SDK - cameraWrapper.amcdConfig.releaseOutputBuffIdxInPay = true; +cameraWrapper.amcdConfig.releaseOutputBuffIdxInPay = true;//#todo #endif } { - cameraWrapper.asvrConfig.windowSurface = cameraWrapper.window; + cameraWrapper.asvrConfig.windowSurface = cameraWrapper.windowRender; cameraWrapper.asvrConfig.outputOriginFrame = true; cameraWrapper.asvrConfig.outputRenderFrame = true; + cameraWrapper.asvrConfig.scaleToWidth = 640; + cameraWrapper.asvrConfig.scaleToHeight = 480; } { @@ -115,7 +263,9 @@ cameraWrapper.sftConfig.detect_face_cnt_limit = MAX_FACE; cameraWrapper.sftConfig.draw_face_rect = false; cameraWrapper.sftConfig.draw_face_feature_point = false; - cameraWrapper.sftConfig.generate_face_feature = true; + cameraWrapper.sftConfig.generate_face_feature = true; + cameraWrapper.sftConfig.explode_feature_rect_x = 30; + cameraWrapper.sftConfig.explode_feature_rect_y = 40; cameraWrapper.sftConfig.doTrackPerFrame = 50; } @@ -137,6 +287,8 @@ cameraWrapper.stop(); } + +//#todo remove //see: https://github.com/BelledonneCommunications/mediastreamer2/blob/master/src/android/android_mediacodec.cpp static int handle_java_exception(JNIEnv *env) { if (env->ExceptionCheck()) { @@ -146,7 +298,7 @@ } return 0; } - +//#todo remove static bool _loadClass(JNIEnv *env, const char *className, jclass *_class) { *_class = env->FindClass(className); if(handle_java_exception(env) == -1 || *_class == NULL) { @@ -156,6 +308,7 @@ return true; } +//#todo remove static bool _getStaticMethodID(JNIEnv *env, jclass _class, const char *name, const char *sig, jmethodID *method) { *method = env->GetStaticMethodID(_class, name, sig); if(handle_java_exception(env) == -1 || *method == NULL) { @@ -177,6 +330,8 @@ // set for multithread callback env->GetJavaVM(&(cameraWrapper.javaVM)); cameraWrapper.javaEnv = env; + + //ms_set_jvm(cameraWrapper.javaVM); std::string _className; { @@ -221,7 +376,7 @@ cameraWrapper.releaseFace(); } -jint Java_cn_com_basic_face_util_RtspFaceNative_getFaceList(JNIEnv* env, jclass clazz, jint cameraIdx, jobject faceListPb) +jint Java_cn_com_basic_face_util_RtspFaceNative_getFaceList(JNIEnv* env, jclass clazz, jint cameraIdx, jint dbId, jobject faceListPb) { LOG_DEBUG << "@@@ Java_cn_com_basic_face_util_RtspFaceNative_getFaceList" << LOG_ENDL; assert(cameraIdx > 0 && cameraIdx <= CAMERA_COUNT); @@ -232,11 +387,12 @@ // Y channel of YUV420p, packed in protobuf uint8_t buffer[MAX_FACE * MAX_FACE_WIDTH * MAX_FACE_HEIGHT] = {0}; size_t buffSize = sizeof(buffer); - //const size_t arrSize = env->GetArrayLength(faceListPb); - bool ret = false; + bool ret = false; #ifdef USE_ST_SDK - ret = cameraWrapper.faceCache.getFaceListPb(buffer, buffSize); + uint8_t * pBufPB = buffer + sizeof(EVPHeader) + sizeof(FDP_FaceDetectPB); + buffSize = sizeof(buffer) - sizeof(EVPHeader) - sizeof(FDP_FaceDetectPB); + ret = cameraWrapper.faceCache.getFaceListPb(pBufPB, buffSize); #endif if (!ret) @@ -247,12 +403,38 @@ LOG_INFO << "Face captured " << LOG_ENDL; + EVPHeader* evpHeader = new (buffer) EVPHeader; + evpHeader->proto = EVPProto::EVPP_PROTOBUF; + evpHeader->cmd = FaceDaemonCommand::FDC_SENSETIMEFACEDETECT_PB; + evpHeader->size = sizeof(EVPHeader) + sizeof(FDP_FaceDetectPB) + buffSize; + buffSize = evpHeader->size; + + FDP_FaceDetectPB* fdpFaceDetectPB = new (buffer + sizeof(EVPHeader)) FDP_FaceDetectPB(dbId); + + evpHeader->hton(); + fdpFaceDetectPB->hton(); + + //{ + // static size_t f = 0; + // char fname[50]; + // sprintf(fname, "/sdcard/facelist-%d-%d-%u.pb", dbId, cameraIdx, ++f); + // FILE *pFile = fopen(fname, "wb"); + // fwrite(buffer, 1, buffSize, pFile); + // fclose(pFile); + // if (f > 10)exit(0); + //} + jclass jcRefByteArray = env->FindClass("cn/com/basic/face/util/RefByteArray"); jfieldID jfRefByteArray_arr = env->GetFieldID(jcRefByteArray, "arr","[B"); jbyteArray jbaFaceListPb = env->NewByteArray(buffSize); env->SetByteArrayRegion(jbaFaceListPb, 0, buffSize, (const jbyte*)buffer); env->SetObjectField(faceListPb, jfRefByteArray_arr, jbaFaceListPb); + +#ifdef ENABLE_DEBUG_SENDFACEDETECT + dbgSendFaceDetect(buffer, buffSize); +#endif + return buffSize; } @@ -382,4 +564,41 @@ return jobjArrayList_Imgs; } +void Java_cn_com_basic_face_util_RtspFaceNative_dbgFaceAdd(JNIEnv* env, jclass clazz, jobject faceImage) +{ + jclass jcNativeImg = env->FindClass("cn/com/basic/face/util/NativeImg"); + jmethodID jmNativeImg_ctor = env->GetMethodID(jcNativeImg, "<init>", "()V"); + jfieldID jfNativeImg_size = env->GetFieldID(jcNativeImg, "size","I"); + jfieldID jfNativeImg_type = env->GetFieldID(jcNativeImg, "type","I"); + jfieldID jfNativeImg_width = env->GetFieldID(jcNativeImg, "width","I"); + jfieldID jfNativeImg_height = env->GetFieldID(jcNativeImg, "height","I"); + jfieldID jfNativeImg_image = env->GetFieldID(jcNativeImg, "image","[B"); + + NativeImgIdx imgidx; + imgidx.size = env->GetIntField(faceImage, jfNativeImg_size); + imgidx.type = env->GetIntField(faceImage, jfNativeImg_type); + imgidx.width = env->GetIntField(faceImage, jfNativeImg_width); + imgidx.height = env->GetIntField(faceImage, jfNativeImg_height); + + uint8_t buffer[MAX_FACE * MAX_FACE_WIDTH * MAX_FACE_HEIGHT * 3]; + size_t buffSize = 0; + + jbyteArray jbaFaceImage = (jbyteArray)env->GetObjectField(faceImage, jfNativeImg_image); + env->GetByteArrayRegion(jbaFaceImage, 0, imgidx.size, (jbyte*)buffer); + +#ifdef ENABLE_DEBUG_SENDFACEADD + dbgSendFaceAdd(imgidx, buffer); +#endif +} + +jstring Java_cn_com_basic_face_util_RtspFaceNative_dbgGetLog(JNIEnv *env, jclass clazz) +{ + return env->NewStringUTF(g_dbgLog.c_str()); +} + +//void Java_cn_com_basic_face_util_RtspFaceNative_dbgReadTexture(JNIEnv* env, jclass clazz) +//{ +// dbgReadTexture(); +//} + } -- Gitblit v1.8.0