レコーダの同期を取るための処理を追加

Author: nobuo-kobayashi

dConnectDevicePlugin/dConnectDeviceUVC/app/src/main/java/org/deviceconnect/android/deviceplugin/uvc/profile/UVCMediaStreamRecordingProfile.java

@@ -17,6 +17,7 @@
 import org.deviceconnect.android.deviceplugin.uvc.profile.utils.H265Profile;
 import org.deviceconnect.android.deviceplugin.uvc.recorder.Broadcaster;
 import org.deviceconnect.android.deviceplugin.uvc.recorder.MediaRecorder;
+import org.deviceconnect.android.deviceplugin.uvc.recorder.MediaRecorderManager;
 import org.deviceconnect.android.deviceplugin.uvc.recorder.PreviewServer;
 import org.deviceconnect.android.deviceplugin.uvc.recorder.uvc.UvcRecorder;
 import org.deviceconnect.android.deviceplugin.uvc.service.UVCService;
@@ -370,6 +371,13 @@ public boolean onRequest(final Intent request, final Intent response) {
                     return true;
                 }
 
+                MediaRecorderManager mrm = service.getMediaRecorderManager();
+                if (!mrm.canUseRecorder(recorder)) {
+                    // 他のカメラが使用中の場合はエラーを返却
+                    MessageUtils.setIllegalDeviceStateError(response, "Other recorder are being used.");
+                    return true;
+                }
+
                 recorder.requestPermission(new MediaRecorder.PermissionCallback() {
                     @Override
                     public void onAllowed() {
@@ -484,9 +492,22 @@ public boolean onRequest(final Intent request, final Intent response) {
                     return true;
                 }
 
+                MediaRecorderManager mrm = service.getMediaRecorderManager();
+                if (!mrm.canUseRecorder(recorder)) {
+                    // 他のカメラが使用中の場合はエラーを返却
+                    MessageUtils.setIllegalDeviceStateError(response, "Other recorder are being used.");
+                    return true;
+                }
+
                 recorder.requestPermission(new MediaRecorder.PermissionCallback() {
                     @Override
                     public void onAllowed() {
+                        // TODO 排他的に処理を行うようにします。
+                        if (recorder instanceof UvcRecorder) {
+                            // 使用していない場合は停止する
+                            mrm.stopCameraRecorder(recorder);
+                        }
+
                         Broadcaster b = recorder.startBroadcaster(broadcastURI);
                         if (b != null) {
                             setResult(response, DConnectMessage.RESULT_OK);

dConnectDevicePlugin/dConnectDeviceUVC/app/src/main/java/org/deviceconnect/android/deviceplugin/uvc/recorder/MediaRecorderManager.java

@@ -10,6 +10,7 @@
 import org.deviceconnect.android.deviceplugin.uvc.recorder.mjpeg.UvcMjpgRecorder;
 import org.deviceconnect.android.deviceplugin.uvc.recorder.uncompressed.UvcUncompressedRecorder;
 import org.deviceconnect.android.deviceplugin.uvc.recorder.uvc.UvcRecorder;
+import org.deviceconnect.android.libmedia.streaming.gles.EGLSurfaceDrawingThread;
 import org.deviceconnect.android.libmedia.streaming.util.WeakReferenceList;
 import org.deviceconnect.android.libuvc.Parameter;
 import org.deviceconnect.android.libuvc.UVCCamera;
@@ -106,6 +107,59 @@ public void destroy() {
         mUvcRecorderList.clear();
     }
 
+    /**
+     * レコーダが使用できるか確認します.
+     *
+     * @param recorder レコーダ
+     * @return 使用できる場合はtrue、それ以外はfalse
+     */
+    public boolean canUseRecorder(UvcRecorder recorder) {
+        for (UvcRecorder uvcRecorder : getUvcRecorderList()) {
+            if (uvcRecorder == recorder) {
+                continue;
+            }
+            if (uvcRecorder.isPreviewRunning() || uvcRecorder.isBroadcasterRunning() ||
+                    uvcRecorder.getState() == MediaRecorder.State.RECORDING) {
+                // カメラが使用中
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 使用するレコーダ以外のレコーダを停止します。
+     *
+     * プレビュー配信中などの停止できない場合には、停止しません。
+     * その場合には、カメラを使用できないので注意が必要になります。
+     *
+     * @param useRecorder 使用するレコーダ
+     */
+    public void stopCameraRecorder(MediaRecorder useRecorder) {
+        for (MediaRecorder recorder : getUvcRecorderList()) {
+            if (recorder == useRecorder) {
+                continue;
+            }
+
+            if (recorder instanceof UvcRecorder) {
+                if (!recorder.isPreviewRunning() && !recorder.isBroadcasterRunning() &&
+                        recorder.getState() != MediaRecorder.State.RECORDING) {
+                    // 強制的にカメラを停止
+                    EGLSurfaceDrawingThread drawingThread = recorder.getSurfaceDrawingThread();
+                    drawingThread.stop(true);
+
+                    // カメラの処理は別スレッドで行われているので、ここで少し待機します
+                    try {
+                        Thread.sleep(200);
+                    } catch (InterruptedException e) {
+                        // ignore.
+                    }
+                }
+            }
+        }
+    }
+
+
     /**
      * レコーダのリストを取得します.
      *

dConnectDevicePlugin/dConnectDeviceUVC/app/src/main/java/org/deviceconnect/android/deviceplugin/uvc/recorder/uvc/UvcSurfaceDrawingThread.java

@@ -65,7 +65,7 @@ protected void onStopped() {
         stopCamera();
     }
 
-    private void startCamera(SurfaceTexture surfaceTexture) {
+    private synchronized void startCamera(SurfaceTexture surfaceTexture) {
         try {
             UvcRecorder.UvcSettings settings = (UvcRecorder.UvcSettings) mRecorder.getSettings();
 
@@ -100,7 +100,7 @@ public void onError(UVCPlayerException e) {
         }
     }
 
-    private void stopCamera() {
+    private synchronized void stopCamera() {
         if (mPlayer != null) {
             try {
                 mPlayer.stop();