add protection for cpp video frame observer class

Author: Xia Ning

Android/APIExample/README.zh.md

@@ -23,7 +23,7 @@
 3. 复制后台的 **App Id** 并备注，稍后启动应用时会用到它
 4. 在项目页面生成临时 **Access Token** (24小时内有效)并备注，注意生成的Token只能适用于对应的频道名。
 
-5. 打开 `Android/APIExample` 并编辑 `app/src/main/res/values/string-config.xml`，将你的 AppID 和 Token 分别替换到 `<#Your App Id#>` 与 `<#Temp Access Token#>`
+5. 打开 `Android/APIExample` 并编辑 `app/src/main/res/values/string_config.xml`，将你的 AppID 和 Token 分别替换到 `<#Your App Id#>` 与 `<#Temp Access Token#>`
 
     ```
     <string name="agora_app_id" translatable="false">YOUR APP ID</string>
@@ -33,6 +33,10 @@
 
 然后你就可以编译并运行项目了。
 
+> 为提高项目的安全性，Agora 使用 Token（动态密钥）对即将加入频道的用户进行鉴权。
+>
+> 临时 Token 仅作为演示和测试用途。在生产环境中，你需要自行部署服务器签发 Token，详见[生成 Token](https://docs.agora.io/cn/Interactive Broadcast/token_server)。
+
 ## 联系我们
 
 - 如果你遇到了困难，可以先参阅 [常见问题](https://docs.agora.io/cn/faq)

Android/APIExample/lib-raw-data/src/main/cpp/io_agora_advancedvideo_rawdata_MediaPreProcessing.cpp

@@ -27,6 +27,7 @@ void *_javaDirectPlayBufferPlayAudio = nullptr;
 void *_javaDirectPlayBufferBeforeMixAudio = nullptr;
 void *_javaDirectPlayBufferMixAudio = nullptr;
 map<int, void *> decodeBufferMap;
+volatile bool mAvailable = false;
 
 static JavaVM *gJVM = nullptr;
 
@@ -68,6 +69,13 @@ class AgoraVideoFrameObserver : public agora::media::IVideoFrameObserver
         memcpy((uint8_t *) _byteBufferObject + widthAndHeight * 5 / 4, videoFrame.vBuffer,
                widthAndHeight / 4);
 
+
+        if (!mAvailable)
+        {
+            // check gCallBack is available.
+            return;
+        }
+
         if (uid == 0)
         {
             env->CallVoidMethod(gCallBack, jmethodID, videoFrame.type, width, height, length,
@@ -204,6 +212,12 @@ class AgoraAudioFrameObserver : public agora::media::IAudioFrameObserver
         int len = audioFrame.samples * audioFrame.bytesPerSample;
         memcpy(_byteBufferObject, audioFrame.buffer, (size_t) len); // * sizeof(int16_t)
 
+        if (!mAvailable)
+        {
+            // check gCallBack is available.
+            return;
+        }
+
         if (uid == 0)
         {
             env->CallVoidMethod(gCallBack, jmethodID, audioFrame.type, audioFrame.samples,
@@ -364,12 +378,14 @@ JNIEXPORT void JNICALL Java_io_agora_advancedvideo_rawdata_MediaPreProcessing_se
         captureVideoMethodId = env->GetMethodID(gCallbackClass, "onCaptureVideoFrame",
                                                 "(IIIIIIIIJ)V");
         preEncodeVideoMethodId = env->GetMethodID(gCallbackClass, "onPreEncodeVideoFrame",
-                                                "(IIIIIIIIJ)V");
+                                                  "(IIIIIIIIJ)V");
         renderVideoMethodId = env->GetMethodID(gCallbackClass, "onRenderVideoFrame",
                                                "(IIIIIIIIIJ)V");
 
         __android_log_print(ANDROID_LOG_DEBUG, "setCallback", "setCallback done successfully");
     }
+
+    mAvailable = true;
 }
 
 JNIEXPORT void JNICALL
@@ -425,6 +441,8 @@ Java_io_agora_advancedvideo_rawdata_MediaPreProcessing_setVideoDecodeByteBuffer
 JNIEXPORT void JNICALL Java_io_agora_advancedvideo_rawdata_MediaPreProcessing_releasePoint
         (JNIEnv *env, jclass)
 {
+    mAvailable = false;
+
     agora::util::AutoPtr<agora::media::IMediaEngine> mediaEngine;
     mediaEngine.queryInterface(rtcEngine, agora::INTERFACE_ID_TYPE::AGORA_IID_MEDIA_ENGINE);