Added feature to stream only the stream from front camera

app/src/main/java/com/pedro/rtpstreamer/openglexample/OpenGlRtmpActivity.java

@@ -107,6 +107,8 @@ protected void onCreate(Bundle savedInstanceState) {
     bRecord.setOnClickListener(this);
     Button switchCamera = findViewById(R.id.switch_camera);
     switchCamera.setOnClickListener(this);
+    findViewById(R.id.b_pause_stream).setOnClickListener(this);
+    findViewById(R.id.b_resume_stream).setOnClickListener(this);
     etUrl = findViewById(R.id.et_rtp_url);
     etUrl.setHint(R.string.hint_rtmp);
     rtmpCamera1 = new RtmpCamera1(openGlView, this);
@@ -405,6 +407,18 @@ public void onClick(View view) {
           rtmpCamera1.switchCamera();
         } catch (CameraOpenException e) {
           Toast.makeText(this, e.getMessage(), Toast.LENGTH_SHORT).show();
+        } finally {
+          rtmpCamera1.setIsStreamFlipHorizontal(rtmpCamera1.isFrontCamera());
+        }
+        break;
+      case R.id.b_pause_stream:
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT) {
+          rtmpCamera1.pauseStream();
+        }
+        break;
+      case R.id.b_resume_stream:
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT) {
+          rtmpCamera1.resumeStream();
         }
         break;
       case R.id.b_record:

app/src/main/res/layout/activity_open_gl.xml

@@ -13,8 +13,6 @@
       app:aspectRatioMode="adjust"
       app:AAEnabled="false"
       app:numFilters="1"
-      app:isFlipHorizontal="false"
-      app:isFlipVertical="false"
       />
 
   <EditText
@@ -29,6 +27,30 @@
       />
 
   <LinearLayout
+      android:layout_width="match_parent"
+      android:layout_height="wrap_content"
+      android:layout_above="@+id/bottom_buttons"
+      android:gravity="center"
+      android:orientation="horizontal">
+
+    <Button
+        android:id="@+id/b_pause_stream"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:layout_marginRight="5dp"
+        android:text="@string/pause_stream" />
+
+    <Button
+        android:id="@+id/b_resume_stream"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:layout_marginRight="5dp"
+        android:text="@string/resume_stream" />
+
+  </LinearLayout>
+
+  <LinearLayout
+      android:id="@+id/bottom_buttons"
       android:layout_width="match_parent"
       android:layout_height="wrap_content"
       android:orientation="horizontal"

app/src/main/res/values/strings.xml

@@ -27,6 +27,8 @@
   <string name="select_file">Select file</string>
   <string name="start_record">Start record</string>
   <string name="stop_record">Stop record</string>
+  <string name="pause_stream">Pause stream</string>
+  <string name="resume_stream">Resume stream</string>
   <string name="resync_file">ReSync file</string>
   <!--menu-->
   <string name="microphone">Microphone</string>

encoder/build.gradle

@@ -1,6 +1,6 @@
 apply plugin: 'com.android.library'
 apply plugin: 'com.github.dcendents.android-maven'
-group = 'com.github.pedroSG94'
+group='com.github.marcin-adamczewski'
 
 android {
   compileSdkVersion 29

encoder/src/main/java/com/pedro/encoder/input/gl/render/ManagerRender.java

@@ -62,8 +62,9 @@ public void drawOffScreen() {
   }
 
   public void drawScreen(int width, int height, boolean keepAspectRatio, int mode, int rotation,
-      boolean isPreview) {
-    screenRender.draw(width, height, keepAspectRatio, mode, rotation, isPreview);
+      boolean isPreview, boolean flipStreamHorizontal, boolean flipStreamVertical) {
+    screenRender.draw(width, height, keepAspectRatio, mode, rotation,
+            isPreview, flipStreamHorizontal, flipStreamVertical);
   }
 
   public void release() {

encoder/src/main/java/com/pedro/encoder/input/gl/render/ScreenRender.java

@@ -78,12 +78,11 @@ public void initGl(Context context) {
   }
 
   public void draw(int width, int height, boolean keepAspectRatio, int mode, int rotation,
-      boolean isPreview) {
+      boolean isPreview, boolean flipStreamHorizontal, boolean flipStreamVertical) {
     GlUtil.checkGlError("drawScreen start");
 
-    if (mode == 2 || mode == 3) { //stream rotation is enabled
-      SizeCalculator.updateMatrix(rotation, width, height, isPreview, isPortrait, MVPMatrix);
-    }
+    SizeCalculator.updateMatrix(rotation, width, height, isPreview,
+            isPortrait, flipStreamHorizontal, flipStreamVertical, MVPMatrix);
     SizeCalculator.calculateViewPort(keepAspectRatio, mode, width, height, streamWidth,
         streamHeight);
 

encoder/src/main/java/com/pedro/encoder/input/gl/render/SimpleCameraRender.java

@@ -90,8 +90,9 @@ public void drawFrame(int width, int height, boolean keepAspectRatio, int mode,
     GlUtil.checkGlError("drawFrame start");
     surfaceTexture.getTransformMatrix(STMatrix);
 
-    if (mode == 2 || mode == 3) { //stream rotation is enabled
-      SizeCalculator.updateMatrix(rotation, width, height, isPreview, isPortrait, MVPMatrix);
+    if(mode == 2 || mode == 3) {
+      SizeCalculator.updateMatrix(rotation, width, height, isPreview,
+              isPortrait, false, false, MVPMatrix);
     }
     SizeCalculator.calculateViewPort(keepAspectRatio, mode, width, height, streamWidth,
         streamHeight);

encoder/src/main/java/com/pedro/encoder/input/video/Camera1ApiManager.java

@@ -11,6 +11,8 @@
 import android.view.SurfaceView;
 import android.view.TextureView;
 
+import androidx.annotation.Nullable;
+
 import com.pedro.encoder.Frame;
 import java.io.IOException;
 import java.util.Iterator;

encoder/src/main/java/com/pedro/encoder/utils/gl/SizeCalculator.java

@@ -36,12 +36,16 @@ public static void calculateViewPort(boolean keepAspectRatio, int mode, int prev
   }
 
   public static void updateMatrix(int rotation, int width, int height, boolean isPreview,
-      boolean isPortrait, float[] MVPMatrix) {
+                                  boolean isPortrait, boolean flipStreamHorizontal,
+                                  boolean flipStreamVertical, float[] MVPMatrix) {
     Matrix.setIdentityM(MVPMatrix, 0);
     PointF scale = getScale(rotation, width, height, isPortrait, isPreview);
     Matrix.scaleM(MVPMatrix, 0, scale.x, scale.y, 1f);
     if (!isPreview && !isPortrait) rotation += 90;
     Matrix.rotateM(MVPMatrix, 0, rotation, 0f, 0f, -1f);
+    if (!isPreview) {
+      Matrix.scaleM(MVPMatrix, 0, flipStreamHorizontal ? -1 : 1, flipStreamVertical ? -1 : 1, 1f);
+    }
   }
 
   private static PointF getScale(int rotation, int width, int height, boolean isPortrait,

encoder/src/main/java/com/pedro/encoder/video/VideoEncoder.java

@@ -176,6 +176,20 @@ public void run() {
     Log.i(TAG, "started");
   }
 
+  @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+  public void pause() {
+    Bundle params = new Bundle();
+    params.putInt(MediaCodec.PARAMETER_KEY_SUSPEND, 1);
+    codec.setParameters(params);
+  }
+
+  @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+  public void resume() {
+    Bundle params = new Bundle();
+    params.putInt(MediaCodec.PARAMETER_KEY_SUSPEND, 0);
+    codec.setParameters(params);
+  }
+
   @Override
   protected void stopImp() {
     if (handlerThread != null) {

rtmp/build.gradle

@@ -1,6 +1,6 @@
 apply plugin: 'com.android.library'
 apply plugin: 'com.github.dcendents.android-maven'
-group = 'com.github.pedroSG94'
+group='com.github.marcin-adamczewski'
 
 android {
   compileSdkVersion 29

rtplibrary/build.gradle

@@ -1,6 +1,6 @@
 apply plugin: 'com.android.library'
 apply plugin: 'com.github.dcendents.android-maven'
-group = 'com.github.pedroSG94'
+group='com.github.marcin-adamczewski'
 
 android {
   compileSdkVersion 29

rtplibrary/src/main/java/com/pedro/rtplibrary/base/Camera1Base.java

@@ -459,6 +459,40 @@ public void startStream(String url) {
     onPreview = true;
   }
 
+  /**
+   * Pauses only video part of a stream keeping preview on.
+   */
+  @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+  public void pauseStreamVideo() {
+    videoEncoder.pause();
+  }
+
+  /**
+   * Resumes video part of a stream.
+   */
+  @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+  public void resumeStreamVideo() {
+    videoEncoder.resume();
+  }
+
+  /**
+   * Pauses both video and audio part of a stream keeping preview on.
+   */
+  @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+  public void pauseStream() {
+    pauseStreamVideo();
+    disableAudio();
+  }
+
+  /**
+   * Resumes both video and audio part of a stream.
+   */
+  @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+  public void resumeStream() {
+    resumeStreamVideo();
+    enableAudio();
+  }
+
   private void startEncoders() {
     videoEncoder.start();
     audioEncoder.start();
@@ -656,6 +690,14 @@ public void switchCamera() throws CameraOpenException {
     }
   }
 
+  public void setIsStreamFlipVertical(boolean isStreamFlipVertical) {
+    glInterface.setIsFlipStreamVertical(isStreamFlipVertical);
+  }
+
+  public void setIsStreamFlipHorizontal(boolean isStreamFlipHorizontal) {
+    glInterface.setIsFlipStreamHorizontal(isStreamFlipHorizontal);
+  }
+
   public GlInterface getGlInterface() {
     if (glInterface != null) {
       return glInterface;

rtplibrary/src/main/java/com/pedro/rtplibrary/base/Camera2Base.java

@@ -432,6 +432,36 @@ public void startStream(String url) {
     onPreview = true;
   }
 
+  /**
+   * Pauses only video part of a stream keeping preview on.
+   */
+  public void pauseStreamVideo() {
+    videoEncoder.pause();
+  }
+
+  /**
+   * Resumes video part of a stream.
+   */
+  public void resumeStreamVideo() {
+    videoEncoder.resume();
+  }
+
+  /**
+   * Pauses both video and audio part of a stream keeping preview on.
+   */
+  public void pauseStream() {
+    pauseStreamVideo();
+    disableAudio();
+  }
+
+  /**
+   * Resumes both video and audio part of a stream.
+   */
+  public void resumeStream() {
+    resumeStreamVideo();
+    enableAudio();
+  }
+
   private void startEncoders() {
     videoEncoder.start();
     audioEncoder.start();
@@ -686,12 +716,21 @@ public int getStreamHeight() {
    *
    * @throws CameraOpenException If the other camera doesn't support same resolution.
    */
+
   public void switchCamera() throws CameraOpenException {
     if (isStreaming() || onPreview) {
       cameraManager.switchCamera();
     }
   }
 
+  public void setIsStreamFlipVertical(boolean isStreamFlipVertical) {
+    glInterface.setIsFlipStreamVertical(isStreamFlipVertical);
+  }
+
+  public void setIsStreamFlipHorizontal(boolean isStreamFlipHorizontal) {
+    glInterface.setIsFlipStreamHorizontal(isStreamFlipHorizontal);
+  }
+
   public GlInterface getGlInterface() {
     if (glInterface != null) {
       return glInterface;

rtplibrary/src/main/java/com/pedro/rtplibrary/view/GlInterface.java

@@ -100,4 +100,8 @@ public interface GlInterface {
   void stop();
 
   void setFps(int fps);
+
+  void setIsFlipStreamHorizontal(boolean isStreamFlipHorizontal);
+
+  void setIsFlipStreamVertical(boolean isStreamFlipVertical);
 }

rtplibrary/src/main/java/com/pedro/rtplibrary/view/LightOpenGlView.java

@@ -133,6 +133,16 @@ public void enableAA(boolean AAEnabled) {
 
   }
 
+  @Override
+  public void setIsFlipStreamHorizontal(boolean isStreamFlipHorizontal) {
+
+  }
+
+  @Override
+  public void setIsFlipStreamVertical(boolean isStreamFlipVertical) {
+
+  }
+
   @Override
   public void setRotation(int rotation) {
     simpleCameraRender.setRotation(rotation);

rtplibrary/src/main/java/com/pedro/rtplibrary/view/OffScreenGlThread.java

@@ -39,7 +39,8 @@ public class OffScreenGlThread
   private int encoderWidth, encoderHeight;
   private boolean loadAA = false;
   private int streamRotation;
-
+  private boolean isStreamFlipHorizontal = false;
+  private boolean isStreamFlipVertical = false;
   private boolean AAEnabled = false;
   private FpsLimiter fpsLimiter = new FpsLimiter();
   //used with camera
@@ -178,7 +179,8 @@ public void run() {
           surfaceManager.makeCurrent();
           textureManager.updateFrame();
           textureManager.drawOffScreen();
-          textureManager.drawScreen(encoderWidth, encoderHeight, false, 0, 0, true);
+          textureManager.drawScreen(encoderWidth, encoderHeight, false, 0, 0,
+                  true, isStreamFlipHorizontal, isStreamFlipVertical);
           if (takePhotoCallback != null) {
             takePhotoCallback.onTakePhoto(
                 GlUtil.getBitmap(encoderWidth, encoderHeight, encoderWidth, encoderHeight));
@@ -190,7 +192,7 @@ public void run() {
             if (surfaceManagerEncoder != null && !fpsLimiter.limitFPS()) {
               surfaceManagerEncoder.makeCurrent();
               textureManager.drawScreen(encoderWidth, encoderHeight, false, 0, streamRotation,
-                  false);
+                  false, isStreamFlipHorizontal, isStreamFlipVertical);
               surfaceManagerEncoder.swapBuffer();
             }
           }
@@ -218,4 +220,14 @@ public void onFrameAvailable(SurfaceTexture surfaceTexture) {
       sync.notifyAll();
     }
   }
+
+  @Override
+  public void setIsFlipStreamHorizontal(boolean isStreamFlipHorizontal) {
+    this.isStreamFlipHorizontal = isStreamFlipHorizontal;
+  }
+
+  @Override
+  public void setIsFlipStreamVertical(boolean isStreamFlipVertical) {
+    this.isStreamFlipVertical = isStreamFlipVertical;
+  }
 }