houxiao
2017-05-12 22fe3eb94f8e65ebad5d55b12c371a0b69bfc04a
VisitFace/RtspNativeCodec/app/src/main/cpp/CameraWrapper.cpp
@@ -37,6 +37,11 @@
bool CameraWrapper::initPl()
{
    PipeLine::register_global_elem_creator("PL_RTSPClient", create_PL_RTSPClient);
    PipeLine::register_global_elem_creator("PL_AndroidMediaCodecDecoder", create_PL_AndroidMediaCodecDecoder);
    PipeLine::register_global_elem_creator("PL_AndroidSurfaceViewRender", create_PL_AndroidSurfaceViewRender);
    PipeLine::register_global_elem_creator("PL_SensetimeFaceTrack", create_PL_SensetimeFaceTrack);
   PL_RTSPClient* rtspClient = (PL_RTSPClient*)pipeLine->push_elem("PL_RTSPClient");
   bool ret = rtspClient->init(&rtspConfig);
   if (!ret)
@@ -53,6 +58,14 @@
      return  false;
   }
    PL_AndroidSurfaceViewRender* asvRender = (PL_AndroidSurfaceViewRender*)pipeLine->push_elem("PL_AndroidSurfaceViewRender");
    ret = asvRender->init(&asvrConfig);
    if (!ret)
    {
        LOG_ERROR << "asvRender.init error" << LOG_ENDL;
        return  false;
    }
#ifdef USE_ST_SDK
   PL_SensetimeFaceTrack* sfTrack = (PL_SensetimeFaceTrack*)pipeLine->push_elem("PL_SensetimeFaceTrack");
   ret = sfTrack->init(&sftConfig);
@@ -64,6 +77,35 @@
#endif
   return true;
}
static void invokeCallback(CameraWrapper& cameraWrapper, int faceCount)
{
    //jni thread may not able to invoke java callback
    // double check it's all ok
    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;
    cameraWrapper.javaEnv->CallStaticVoidMethod(cameraWrapper.faceCallbackClazz, cameraWrapper.faceCallbackFunc, cameraWrapper.cameraIdx, faceCount);
    if (cameraWrapper.javaEnv->ExceptionCheck())
        cameraWrapper.javaEnv->ExceptionDescribe();
    cameraWrapper.javaVM->DetachCurrentThread();
}
/*static*/ void* CameraWrapper::live_daemon_thd(void* arg)
@@ -84,19 +126,18 @@
      if (cameraWrapper.faceCacheLocked)
         continue;
      
      PipeMaterial pm;
#ifdef USE_ST_SDK
        PipeMaterial pm;
      ret = last->gain(pm);
      if (!ret)
         continue;
      int faceCount = cameraWrapper.faceCache.cachePm(pm);
      if (faceCount != 0 && cameraWrapper.faceCallback != 0)
      {
         // #todo jni thread may not able to invoke java callback
         //env->CallVoidMethod(obj, callback, cameraIdx , faceCount);
      }
      if (faceCount > 0 && cameraWrapper.faceCallbackFunc != 0)
            invokeCallback(cameraWrapper, faceCount);
#endif
   }
   
   LOG_INFO << "CameraWrapper::live_daemon_thd stop, ret=" << LOG_ENDL;