Fixed bug of duplicated connection

Author: Poter

app/src/main/java/com/potterhsu/rtsplibrary/demo/MainActivity.java

@@ -4,7 +4,6 @@
 import android.graphics.Bitmap;
 import android.graphics.Color;
 import android.os.Bundle;
-import android.os.PowerManager;
 import android.view.View;
 import android.widget.EditText;
 import android.widget.ImageView;
@@ -74,7 +73,23 @@ public void onBtnPlayClick(View view) {
         new Thread(new Runnable() {
             @Override
             public void run() {
-                rtspClient.play(endpoint);
+                while (true) {
+                    if (rtspClient.play(endpoint) == 0)
+                        break;
+
+                    runOnUiThread(new Runnable() {
+                        @Override
+                        public void run() {
+                            Toast.makeText(MainActivity.this, "Connection error, retry after 3 seconds", Toast.LENGTH_SHORT).show();
+                        }
+                    });
+
+                    try {
+                        Thread.sleep(3000);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
             }
         }).start();
     }

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

@@ -20,6 +20,7 @@
         android:id="@+id/edtEndpoint"
         android:layout_width="match_parent"
         android:layout_height="wrap_content"
+        android:text="rtsp://"
         android:hint="Endpoint" />
 
     <Button

library/src/main/cpp/native-lib.cpp

@@ -140,8 +140,9 @@ Java_com_potterhsu_rtsplibrary_RtspClient_play(
     av_read_pause(context);
     avio_close(oc->pb);
     avformat_free_context(oc);
+    avformat_close_input(&context);
 
-    return JNI_OK;
+    return isStop ? JNI_OK : JNI_ERR;
 }
 
 extern "C"

library/src/main/java/com/potterhsu/rtsplibrary/RtspClient.java

@@ -18,6 +18,12 @@ public RtspClient(NativeCallback callback) {
     }
 
     private native int initialize(NativeCallback callback);
+
+    /**
+     * Play stream synchronously.
+     * @param endpoint resource endpoint
+     * @return 0 if exit normally or -1 otherwise
+     */
     public native int play(String endpoint);
     public native void stop();
     public native void dispose();