.idea/misc.xml

@@ -16,5 +16,5 @@
     </option>
   </component>
   <component name="ExternalStorageConfigurationManager" enabled="true" />
-  <component name="ProjectRootManager" version="2" languageLevel="JDK_16_PREVIEW" project-jdk-name="11" project-jdk-type="JavaSDK" />
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_16" project-jdk-name="16" project-jdk-type="JavaSDK" />
 </project>

app/build.gradle

@@ -1,18 +1,15 @@
 plugins {
     id 'com.android.application'
-    id 'org.jetbrains.kotlin.android'
-    id 'org.jetbrains.kotlin.plugin.parcelize'
-    id 'org.jetbrains.kotlin.kapt'
 }
+apply plugin: 'kotlin-android'
 
 android {
-    ndkVersion "21.3.6528147"
+    compileSdk 32
-    compileSdk 33
 
     defaultConfig {
         applicationId "com.ray650128.gstreamer_demo_app"
         minSdk 26
-        targetSdk 33
+        targetSdk 32
         versionCode 1
         versionName "1.0"
 
@@ -29,32 +26,23 @@ android {
         sourceCompatibility JavaVersion.VERSION_1_8
         targetCompatibility JavaVersion.VERSION_1_8
     }
-    kotlinOptions {
+
-        jvmTarget = '1.8'
-    }
-    lint {
-        abortOnError false
-        checkReleaseBuilds false
-    }
     viewBinding.enabled = true
-    namespace 'com.ray650128.gstreamer_demo_app'
 }
 
 dependencies {
 
-    implementation 'androidx.core:core-ktx:1.9.0'
+    implementation 'androidx.appcompat:appcompat:1.0.0'
-    implementation 'androidx.appcompat:appcompat:1.5.1'
+    implementation 'androidx.constraintlayout:constraintlayout:1.1.3'
-    implementation 'com.google.android.material:material:1.7.0'
-    implementation 'androidx.constraintlayout:constraintlayout:2.1.4'
-    implementation 'androidx.legacy:legacy-support-v4:1.0.0'
-    implementation 'androidx.gridlayout:gridlayout:1.0.0'
-    testImplementation 'junit:junit:4.13.2'
-    androidTestImplementation 'androidx.test.ext:junit:1.1.5'
-    androidTestImplementation 'androidx.test.espresso:espresso-core:3.5.1'
-
     implementation project(path: ':gstreamer_player')
-
+    implementation 'androidx.gridlayout:gridlayout:1.0.0'
-    // Android Jetpack lib
+    implementation 'androidx.viewpager2:viewpager2:1.0.0'
-    implementation("androidx.fragment:fragment-ktx:1.5.5")
+    testImplementation 'junit:junit:4.13.2'
-    implementation("androidx.activity:activity-ktx:1.6.1")
+    androidTestImplementation 'androidx.test.ext:junit:1.1.1'
+    androidTestImplementation 'androidx.test.espresso:espresso-core:3.1.0'
+    implementation "androidx.core:core-ktx:+"
+    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
 }
+repositories {
+    mavenCentral()
+}

app/src/main/java/com/ray650128/gstreamer_demo_app/GridVideoFragment.kt

@@ -0,0 +1,227 @@
+package com.ray650128.gstreamer_demo_app
+
+import android.graphics.Color
+import android.os.Bundle
+import android.util.DisplayMetrics
+import android.util.Log
+import android.view.LayoutInflater
+import android.view.View
+import android.view.ViewGroup
+import androidx.fragment.app.Fragment
+import androidx.gridlayout.widget.GridLayout
+import com.hisharp.gstreamer_player.GstCallback
+import com.hisharp.gstreamer_player.GstLibrary
+import com.hisharp.gstreamer_player.GstStatus
+import com.ray650128.gstreamer_demo_app.databinding.FragmentGridVideoBinding
+import kotlin.math.sqrt
+
+
+class GridVideoFragment : Fragment(), GstCallback {
+
+    private var mPageNum: Int = 0
+    private var splitMode = 0
+    private var streamType = STREAM_SUB
+    private var isClickable = true
+
+    private var data: ArrayList<String> = ArrayList()
+
+    private lateinit var binding: FragmentGridVideoBinding
+
+    private var gstPlayers: ArrayList<GstLibrary?> = ArrayList()
+
+    private var videoViews: ArrayList<VideoView> = ArrayList()
+
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+
+        if (arguments != null) {
+            mPageNum = requireArguments().getInt(ARG_PAGE_NUM)
+            splitMode = requireArguments().getInt(ARG_SPLIT_MODE)
+            isClickable = requireArguments().getBoolean(ARG_CLICKABLE)
+            streamType = requireArguments().getInt(ARG_STREAM_TYPE)
+            data = requireArguments().getStringArrayList(ARG_STREAM_URLS) ?: arrayListOf()
+        }
+    }
+
+    override fun onCreateView(inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle?): View {
+        binding = FragmentGridVideoBinding.inflate(inflater, container, false)
+        return binding.root
+    }
+
+    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
+        super.onViewCreated(view, savedInstanceState)
+
+        initView()
+    }
+
+    override fun onPause() {
+        stopAll()
+        super.onPause()
+        Log.d("${TAG}_$mPageNum", "onPause()")
+    }
+
+    override fun onResume() {
+        super.onResume()
+        playAll()
+        Log.d("${TAG}_$mPageNum", "onResume()")
+    }
+
+    override fun onStop() {
+        super.onStop()
+        Log.d("${TAG}_$mPageNum", "onStop()")
+    }
+
+    override fun onStart() {
+        super.onStart()
+        Log.d("${TAG}_$mPageNum", "onStart()")
+    }
+
+    override fun onDestroyView() {
+        Log.d("${TAG}_$mPageNum", "onDestroyView()")
+        super.onDestroyView()
+    }
+
+    override fun onDestroy() {
+        for (i in gstPlayers.indices) {
+            gstPlayers[i]?.release()
+            gstPlayers[i] = null
+        }
+        Log.d("${TAG}_$mPageNum", "onDestroy()")
+        super.onDestroy()
+    }
+
+    private fun initView() {
+        val maxRow = sqrt(splitMode.toFloat()).toInt()
+        val maxCol = sqrt(splitMode.toFloat()).toInt()
+
+        val displayMetrics = DisplayMetrics()
+        requireActivity().windowManager.defaultDisplay.getMetrics(displayMetrics)
+        val screenWidth = displayMetrics.widthPixels
+
+        val cellWidth = when (splitMode) {
+            1 -> (screenWidth / maxRow)
+            else -> (screenWidth / maxRow) - maxRow.dp
+        }
+
+        val cellHeight = (cellWidth * (0.62)).toInt()
+        Log.e(TAG, "cellWidth: $cellWidth, cellHeight: $cellHeight")
+
+        // 生成 VideoView 分割畫面
+        binding.apply {
+            baseView.rowCount = maxRow
+            baseView.columnCount = maxCol
+
+            for (col in 0 until maxCol) {
+                for (row in 0 until maxRow) {
+                    val videoView = VideoView(requireContext()).apply {
+                        layoutParams = GridLayout.LayoutParams().apply {
+                            height = cellHeight
+                            width = cellWidth
+
+                            topMargin = 0.dp
+                            bottomMargin = 0.dp
+                            marginEnd = 0.dp
+                            marginStart = 0.dp
+
+                            // 調整間距
+                            when (splitMode) {
+                                4 -> {
+                                    when (col) {
+                                        0 -> bottomMargin = 2.dp
+                                        1 -> topMargin = 2.dp
+                                    }
+                                    when (row) {
+                                        0 -> marginEnd = 2.dp
+                                        1 -> marginStart = 2.dp
+                                    }
+                                }
+                                9 -> {
+                                    if (col == 1) {
+                                        topMargin = 4.dp
+                                        bottomMargin = 4.dp
+                                    }
+                                    if (row == 1) {
+                                        marginEnd = 4.dp
+                                        marginStart = 4.dp
+                                    }
+                                }
+                            }
+                        }
+                    }
+                    baseView.addView(videoView)
+                    videoViews.add(videoView)
+                }
+            }
+        }
+
+        for (index in videoViews.indices) {
+            gstPlayers.add(GstLibrary(requireContext(), data[index]))
+            gstPlayers[index]?.setSurfaceView(videoViews[index].videoView)
+            gstPlayers[index]?.setOnStatusChangeListener(this)
+        }
+    }
+
+    private fun playAll() {
+        for (index in data.indices) {
+            gstPlayers[index]?.apply {
+                play()
+            }
+        }
+    }
+
+    private fun stopAll() {
+        for (index in data.indices) {
+            try {
+                gstPlayers[index]?.stop()
+            } catch (e: IllegalStateException) {
+                e.printStackTrace()
+            }
+        }
+    }
+
+    override fun onStatus(gstInstance: GstLibrary, gstStatus: GstStatus?) {
+        val index = gstPlayers.indexOf(gstInstance)
+        when (gstStatus) {
+            GstStatus.PAUSE -> videoViews[index].isPlaying = false
+            GstStatus.PLAYING -> videoViews[index].isPlaying = true
+            else -> {}
+        }
+        Log.d("${TAG}_$mPageNum", "GstPlayer #$index status: $gstStatus")
+    }
+
+    override fun onMessage(gstInstance: GstLibrary, message: String?) {
+        val index = gstPlayers.indexOf(gstInstance)
+        Log.d("${TAG}_$mPageNum", "GstPlayer #$index: $message")
+    }
+
+    companion object {
+        private val TAG = GridVideoFragment::class.java.simpleName
+        private const val ARG_PAGE_NUM = "page_number"
+        private const val ARG_SPLIT_MODE = "split_mode"
+        private const val ARG_CLICKABLE = "clickable"
+        private const val ARG_STREAM_TYPE = "stream_type"
+        private const val ARG_STREAM_URLS = "stream_urls"
+
+        const val STREAM_MAIN = 1
+        const val STREAM_SUB = 2
+
+        /**
+         * 透過傳入的參數，生成新的 Fragment 實例
+         *
+         * @param pageNumber 該 Fragment 頁碼
+         * @param splitMode 畫面分割模式(9/4/1分割)
+         * @return 透過傳入的參數，生成新的 Fragment 實例
+         */
+        fun newInstance(pageNumber: Int, splitMode: Int, streamUrls: ArrayList<String>, isClickable: Boolean = true, streamType: Int = STREAM_SUB): GridVideoFragment {
+            val fragment = GridVideoFragment()
+            val args = Bundle()
+            args.putInt(ARG_PAGE_NUM, pageNumber)
+            args.putInt(ARG_SPLIT_MODE, splitMode)
+            args.putBoolean(ARG_CLICKABLE, isClickable)
+            args.putInt(ARG_STREAM_TYPE, streamType)
+            args.putStringArrayList(ARG_STREAM_URLS, streamUrls)
+            fragment.arguments = args
+            return fragment
+        }
+    }
+}

app/src/main/java/com/ray650128/gstreamer_demo_app/MainActivity.kt

@@ -1,109 +1,75 @@
 package com.ray650128.gstreamer_demo_app
 
-import android.content.Context
+import android.annotation.SuppressLint
 import android.graphics.Color
+import androidx.appcompat.app.AppCompatActivity
+import com.hisharp.gstreamer_player.GstCallback
+import com.ray650128.gstreamer_demo_app.MainActivity
+import com.hisharp.gstreamer_player.GstLibrary
+import com.hisharp.gstreamer_player.GStreamerSurfaceView
 import android.os.Bundle
 import android.util.Log
+import android.view.View
 import android.view.WindowManager
-import android.widget.Toast
+import com.hisharp.gstreamer_player.GstStatus
-import androidx.activity.viewModels
-import androidx.appcompat.app.AppCompatActivity
-import androidx.viewpager2.widget.ViewPager2
 import com.ray650128.gstreamer_demo_app.databinding.ActivityMainBinding
-import com.ray650128.gstreamer_demo_app.model.Device
+import java.util.ArrayList
-import kotlinx.coroutines.MainScope
+import java.util.function.Consumer
-import kotlinx.coroutines.launch
-import org.freedesktop.gstreamer.GStreamer
 
 class MainActivity : AppCompatActivity() {
 
     private lateinit var binding: ActivityMainBinding
 
-    private val viewModel: MainViewModel by viewModels()
+    private lateinit var splitVideoViewAdapter: ViewPager2Adapter
 
-    private val mContext: Context by lazy { this }
+    @SuppressLint("AuthLeak")
-
+    private val defaultMediaUris = arrayListOf(
-    private var splitMode = 1
+        arrayListOf(
-
+            "rtsp://admin:admin@211.23.78.226:8574/v02",
-    private lateinit var splitVideoViewAdapter: VideoViewAdapter
+            "rtsp://admin:admin@211.23.78.226:8575/v02",
-
+            "rtsp://admin:admin@192.168.0.77:554/media/video2",
-    private var videos: List<List<Device>>? = null
+            "rtsp://admin:123456@192.168.0.80:554/profile2",
-
+            "rtsp://admin:123456@192.168.0.83:554/profile2",
-    private var currentPage = 0
+            "rtsp://admin:123456@192.168.0.84:554/profile2",
+            "rtsp://admin:admin@192.168.0.86:554/v2",
+            "rtsp://admin:admin@192.168.0.89:554/v02",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c8/s1/live",
+        ),
+        arrayListOf(
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c1/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c2/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c3/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c4/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c5/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c6/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c7/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c8/s1/live",
+            "rtsp://admin:1q2w3e4r!@60.249.32.50:554/unicast/c9/s1/live"
+        )
+    )
 
     override fun onCreate(savedInstanceState: Bundle?) {
         window.addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON)
         super.onCreate(savedInstanceState)
-
         binding = ActivityMainBinding.inflate(layoutInflater)
         setContentView(binding.root)
 
-        initContentView()
+        splitVideoViewAdapter = ViewPager2Adapter(supportFragmentManager, lifecycle)
 
-        initObservers()
+        binding.viewPager.apply {
-    }
-
-    private fun initContentView() = binding.apply {
-        //region Content area
-        splitVideoViewAdapter = VideoViewAdapter(supportFragmentManager, lifecycle)
-
-        viewPager.apply {
             adapter = splitVideoViewAdapter
             offscreenPageLimit = 1
-            registerOnPageChangeCallback(object: ViewPager2.OnPageChangeCallback() {
-                override fun onPageSelected(position: Int) {
-                    super.onPageSelected(position)
-                    currentPage = position
-                }
-            })
         }
 
-        button.setOnClickListener {
+        reloadVideoViews()
-            viewModel.setSplitMode(MainViewModel.PAGE_MODE_ONE)
-            Log.e(TAG, "+++ split style: 1")
-        }
-
-        button2.setOnClickListener {
-            viewModel.setSplitMode(MainViewModel.PAGE_MODE_FOUR)
-            Log.e(TAG, "+++ split style: 4")
-        }
-
-        button3.setOnClickListener {
-            viewModel.setSplitMode(MainViewModel.PAGE_MODE_NINE)
-            Log.e(TAG, "+++ split style: 9")
-        }
-        //endregion
     }
 
-    private fun initObservers() {
+    private fun reloadVideoViews() {
-        viewModel.splitMode.observe(this) {
-            splitMode = it
-            Log.e(TAG, "Split count: $it")
-        }
-
-        viewModel.cameraList.observe(this) { list ->
-            this.videos = list
-            reloadVideoViews(this.videos)
-            currentPage = 0
-        }
-    }
-
-    private fun reloadVideoViews(list: List<List<Device>>?) = MainScope().launch {
-        binding.viewPager.setCurrentItem(0, false)
         splitVideoViewAdapter.clear()
-        // 如果群組內沒有裝置，則顯示底圖
+
-        if (list.isNullOrEmpty()) {
+        for (index in defaultMediaUris.indices) {
-            binding.viewPager.setBackgroundResource(R.drawable.bg_not_in_playing)
+            val gridFragment = GridVideoFragment.newInstance(index, 9, defaultMediaUris[index])
-        } else {
+            splitVideoViewAdapter.add(index, gridFragment)
-            binding.viewPager.setBackgroundColor(Color.TRANSPARENT)
-            for (i in list.indices) {
-                val splitFragment = SplitViewFragment.newInstance(
-                    pageNumber = i,
-                    splitMode = splitMode,
-                    pageData = ArrayList(list[i])
-                )
-                splitVideoViewAdapter.add(i, splitFragment)
-            }
         }
     }
 

app/src/main/java/com/ray650128/gstreamer_demo_app/MainViewModel.kt

@@ -1,97 +0,0 @@
-package com.ray650128.gstreamer_demo_app
-
-import androidx.lifecycle.MediatorLiveData
-import androidx.lifecycle.MutableLiveData
-import androidx.lifecycle.ViewModel
-import com.ray650128.gstreamer_demo_app.model.Device
-
-class MainViewModel: ViewModel() {
-
-    private val uriList: List<Device> by lazy {
-        listOf(
-            Device(
-                name = "192.168.0.73",
-                rtspUrl = "rtsp://admin:hs22601576@@192.168.0.73:554/media/video2"
-            ),
-            Device(
-                name = "192.168.0.77",
-                rtspUrl = "rtsp://admin:admin@192.168.0.77:554/media/video2"
-            ),
-            Device(
-                name = "192.168.0.79",
-                rtspUrl = "rtsp://admin:1q2w3e4r!@192.168.0.79:554/media/video2"
-            ),
-            Device(
-                name = "192.168.0.88",
-                rtspUrl = "rtsp://admin:1q2w3e4r~@211.23.78.226:8588/media/video2"
-            ),
-            Device(
-                name = "192.168.0.74",
-                rtspUrl = "rtsp://admin:admin@211.23.78.226:8574/v02"
-            ),
-            Device(
-                name = "192.168.0.75",
-                rtspUrl = "rtsp://admin:admin@211.23.78.226:8575/v02"
-            ),
-            Device(
-                name = "192.168.0.76",
-                rtspUrl = "rtsp://admin:123456@211.23.78.226:8576/profile2"
-            ),
-            Device(
-                name = "192.168.0.82",
-                rtspUrl = "rtsp://admin:123456@192.168.0.82:554/profile2"
-            ),
-            Device(
-                name = "192.168.0.84",
-                rtspUrl = "rtsp://admin:123456@192.168.0.84:554/profile2"
-            ),
-            Device(
-                name = "192.168.0.95",
-                rtspUrl = "rtsp://admin:123456@192.168.0.95:554/profile2"
-            )
-        )
-    }
-
-    private var splitModeInt: Int = PAGE_MODE_ONE
-
-    val splitMode: MutableLiveData<Int> by lazy { MutableLiveData<Int>() }
-
-    val cameraList: MediatorLiveData<List<List<Device>>> by lazy {
-        MediatorLiveData<List<List<Device>>>().apply {
-            addSource(splitMode) {
-                postValue(updateCameraList(uriList))
-            }
-        }
-    }
-
-    init {
-        setSplitMode(PAGE_MODE_ONE)
-    }
-
-    fun setSplitMode(mode: Int) {
-        splitModeInt = mode
-        splitMode.postValue(splitModeInt)
-    }
-
-    private fun updateCameraList(dbData: List<Device>?): List<List<Device>>? {
-        if (dbData.isNullOrEmpty()) return null
-        val tmpData = ArrayList<List<Device>>()
-        for (index in uriList.indices step (splitModeInt)) {
-            if (index == uriList.size) break
-            val tmpSubData = ArrayList<Device>()
-            for (subIndex in 0 until (splitModeInt)) {
-                val dataIndex = index + subIndex
-                if (dataIndex !in uriList.indices) break
-                tmpSubData.add(uriList[dataIndex])
-            }
-            tmpData.add(tmpSubData)
-        }
-        return tmpData
-    }
-
-    companion object {
-        const val PAGE_MODE_ONE = 1
-        const val PAGE_MODE_FOUR = 4
-        const val PAGE_MODE_NINE = 9
-    }
-}

app/src/main/java/com/ray650128/gstreamer_demo_app/SplitViewFragment.kt

@@ -1,206 +0,0 @@
-package com.ray650128.gstreamer_demo_app
-
-import android.os.Bundle
-import android.util.Log
-import android.view.LayoutInflater
-import android.view.View
-import android.view.ViewGroup
-import androidx.fragment.app.Fragment
-import androidx.gridlayout.widget.GridLayout
-import com.ray650128.gstreamer_demo_app.databinding.FragmentSplitViewBinding
-import com.ray650128.gstreamer_demo_app.model.Device
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.MainScope
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.launch
-import kotlin.math.sqrt
-
-class SplitViewFragment : Fragment() {
-
-    private var mPageNum: Int = 0
-    private var splitMode = MainViewModel.PAGE_MODE_ONE
-    private var streamType = VideoView.SUB_STREAM
-    private var isClickable = true
-
-    private lateinit var binding: FragmentSplitViewBinding
-
-    private var data: ArrayList<Device> = ArrayList()
-
-    private var videoViews: ArrayList<VideoView> = ArrayList()
-
-    override fun onCreate(savedInstanceState: Bundle?) {
-        super.onCreate(savedInstanceState)
-
-        if (arguments != null) {
-            mPageNum = requireArguments().getInt(ARG_PAGE_NUM)
-            splitMode = requireArguments().getInt(ARG_SPLIT_MODE)
-            isClickable = requireArguments().getBoolean(ARG_CLICKABLE)
-            streamType = requireArguments().getInt(ARG_STREAM_TYPE)
-            data = requireArguments().getParcelableArrayList(ARG_PAGE_DATA) ?: arrayListOf(Device())
-        }
-    }
-
-    override fun onCreateView(inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle?): View {
-        binding = FragmentSplitViewBinding.inflate(inflater, container, false)
-        return binding.root
-    }
-
-    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
-        super.onViewCreated(view, savedInstanceState)
-
-        initView()
-    }
-
-    override fun onPause() {
-        super.onPause()
-        stopAll()
-        Log.d("${TAG}_$mPageNum", "onPause()")
-    }
-
-    override fun onResume() {
-        super.onResume()
-        playAll()
-        Log.d("${TAG}_$mPageNum", "onResume()")
-    }
-
-    private fun initView() {
-        // 生成 VideoView 分割畫面
-        binding.apply {
-            val maxRow = sqrt(splitMode.toFloat()).toInt()
-            val maxCol = sqrt(splitMode.toFloat()).toInt()
-            //Log.d(TAG, "maxRow: $maxRow, maxCol: $maxCol")
-
-            baseView.rowCount = maxRow
-            baseView.columnCount = maxCol
-            Log.e("${TAG}_$mPageNum", "baseView.rowCount: ${baseView.rowCount}, baseView.columnCount: ${baseView.columnCount}")
-
-            baseView.post {
-                for (col in 0 until maxCol) {
-                    for (row in 0 until maxRow) {
-                        val videoView = VideoView(requireContext())
-                        val layoutParam = GridLayout.LayoutParams().apply {
-                            topMargin = 0.dp
-                            bottomMargin = 0.dp
-                            marginEnd = 0.dp
-                            marginStart = 0.dp
-
-                            // 調整間距
-                            when (splitMode) {
-                                MainViewModel.PAGE_MODE_FOUR -> {
-                                    when (col) {
-                                        0 -> bottomMargin = 2.dp
-                                        1 -> topMargin = 2.dp
-                                    }
-                                    when (row) {
-                                        0 -> marginEnd = 2.dp
-                                        1 -> marginStart = 2.dp
-                                    }
-                                    width = (baseView.width / maxRow) - maxRow.dp
-                                    height = (baseView.height / maxCol) - maxCol.dp
-                                }
-                                MainViewModel.PAGE_MODE_NINE -> {
-                                    if (col == 1) {
-                                        topMargin = 4.dp
-                                        bottomMargin = 4.dp
-                                    }
-                                    if (row == 1) {
-                                        marginEnd = 4.dp
-                                        marginStart = 4.dp
-                                    }
-                                    width = (baseView.width / maxRow) - maxRow.dp
-                                    height = (baseView.height / maxCol) - maxCol.dp
-                                }
-                                MainViewModel.PAGE_MODE_ONE -> {
-                                    width = (baseView.width / maxRow)
-                                    height = (baseView.height / maxCol)
-                                }
-                            }
-                        }
-                        baseView.addView(videoView, layoutParam)
-                        videoViews.add(videoView)
-                    }
-                }
-
-                setAllUrl()
-            }
-        }
-
-        if (isClickable) {
-            for (position in videoViews.indices) {
-                videoViews[position].setOnClickListener {
-                    if (position >= data.size) return@setOnClickListener
-                    /*if (!videoViews[position].isPlaying) {
-                        if (!videoViews[position].isLoading) {
-                            videoViews[position].play()
-                        }
-                        return@setSafeOnClickListener
-                    }
-                    stopAll()
-                    val item = data[position]
-                    val bundle = Bundle().apply {
-                        putInt(MonitoringActivity.BUNDLE_DEVICE_ID, item.id)
-                        putInt(MonitoringActivity.BUNDLE_CHANNEL_ID, item.channelId)
-                    }
-                    gotoActivity(MonitoringActivity::class.java, bundle)*/
-                    //Log.d("${TAG}_$mPageNum", "check: $item")
-                }
-            }
-        }
-    }
-
-    private fun setAllUrl() {
-        for (index in data.indices) {
-            videoViews[index].setData(data[index])
-            videoViews[index].setTextVisible((splitMode != MainViewModel.PAGE_MODE_NINE))
-        }
-    }
-
-    fun playAll() = MainScope().launch(Dispatchers.Main) {
-        if (videoViews.isEmpty()) return@launch
-        for (index in data.indices) {
-            videoViews[index].play()
-            delay(300)
-        }
-    }
-
-    fun stopAll() = MainScope().launch(Dispatchers.Main) {
-        for (index in data.indices) {
-            videoViews[index].stop()
-            delay(300)
-        }
-    }
-
-    companion object {
-        private val TAG = SplitViewFragment::class.java.simpleName
-        private const val ARG_PAGE_NUM = "page_number"
-        private const val ARG_SPLIT_MODE = "split_mode"
-        private const val ARG_CLICKABLE = "clickable"
-        private const val ARG_PAGE_DATA = "page_data"
-        private const val ARG_STREAM_TYPE = "stream_type"
-
-        /**
-         * 透過傳入的參數，生成新的 Fragment 實例
-         *
-         * @param pageNumber 該 Fragment 頁碼
-         * @param splitMode 畫面分割模式(9/4/1分割)
-         * @return 透過傳入的參數，生成新的 Fragment 實例
-         */
-        fun newInstance(
-            pageNumber: Int,
-            splitMode: Int,
-            isClickable: Boolean = true,
-            pageData: ArrayList<Device>,
-            streamType: Int = VideoView.SUB_STREAM
-        ): SplitViewFragment {
-            val fragment = SplitViewFragment()
-            val args = Bundle()
-            args.putInt(ARG_PAGE_NUM, pageNumber)
-            args.putInt(ARG_SPLIT_MODE, splitMode)
-            args.putBoolean(ARG_CLICKABLE, isClickable)
-            args.putParcelableArrayList(ARG_PAGE_DATA, pageData)
-            args.putInt(ARG_STREAM_TYPE, streamType)
-            fragment.arguments = args
-            return fragment
-        }
-    }
-}

app/src/main/java/com/ray650128/gstreamer_demo_app/VideoView.kt

@@ -1,23 +1,15 @@
 package com.ray650128.gstreamer_demo_app
 
 import android.content.Context
-import android.os.Handler
-import android.os.Looper
-import android.os.Message
 import android.util.AttributeSet
 import android.util.Log
 import android.view.LayoutInflater
-import android.view.SurfaceHolder
-import android.view.SurfaceView
 import androidx.constraintlayout.widget.ConstraintLayout
 import androidx.core.view.isVisible
-import com.hisharp.gstreamer_player.GstCallback
+import com.hisharp.gstreamer_player.GStreamerSurfaceView
-import com.hisharp.gstreamer_player.GstLibrary
-import com.hisharp.gstreamer_player.GstStatus
 import com.ray650128.gstreamer_demo_app.databinding.ItemVideoViewBinding
-import com.ray650128.gstreamer_demo_app.model.Device
 
-class VideoView : ConstraintLayout, SurfaceHolder.Callback, GstCallback {
+class VideoView : ConstraintLayout {
 
     constructor(context: Context) : super(context) {
         initView(context)
@@ -33,13 +25,7 @@ class VideoView : ConstraintLayout, SurfaceHolder.Callback, GstCallback {
 
     private lateinit var view: ItemVideoViewBinding
 
-    private var data: Device? = null
+    //private var data: Device? = null
-
-    var isLoading: Boolean = false
-        set(value) {
-            view.pbLoading.isVisible = value
-            field = value
-        }
 
     var isPlaying: Boolean = false
         set(value) {
@@ -47,116 +33,26 @@ class VideoView : ConstraintLayout, SurfaceHolder.Callback, GstCallback {
             field = value
         }
 
-    private val videoView: SurfaceView by lazy { view.videoView }
+    val videoView: GStreamerSurfaceView by lazy { view.videoView }
-
-    private lateinit var gstLibrary: GstLibrary
-
-    private var streamType = MAIN_STREAM
-
-    private var retryCount = 0
-
-    private val mHandler: MyHandler by lazy {
-        MyHandler(Looper.getMainLooper())
-    }
 
     private fun initView(context: Context) {
         val layoutInflater = LayoutInflater.from(context)
         view = ItemVideoViewBinding.inflate(layoutInflater, this, true)
         view.baseView.clipToOutline = true
-
-        videoView.holder.addCallback(this)
-        gstLibrary = GstLibrary(context)
-        gstLibrary.setOnStatusChangeListener(this)
     }
 
-    fun setData(device: Device?) {
+    /*fun setData(device: Device?) {
         if (device == null) {
             view.textDeviceName.isVisible = false
-            isPlaying = false
             return
         }
         this.data = device
-        this.tag = device.name
+        view.textDeviceName.text = if (device.channelId == -1) device.deviceName else device.channelName
-        view.textDeviceName.text = device.name
         view.textDeviceName.isVisible = true
-        gstLibrary.setRtspUrl(this.data?.rtspUrl)
+        Log.d(TAG, "Set device to: $device")
-        Log.d("${TAG}_$tag", "Set device to: $device")
+    }*/
-    }
-
-    fun setTextVisible(isVisible: Boolean) {
-        view.textDeviceName.isVisible = isVisible
-    }
-
-    fun play() {
-        videoView.postInvalidate()
-        gstLibrary.play()
-        retryCount = 0
-    }
-
-    fun stop() {
-        isPlaying = false
-        if (this::gstLibrary.isInitialized) {
-            gstLibrary.stop()
-        }
-        retryCount = 999
-    }
-
-    override fun surfaceCreated(holder: SurfaceHolder) {
-        Log.d("${TAG}_$tag", "Surface created: " + holder.surface)
-    }
-
-    override fun surfaceChanged(holder: SurfaceHolder, format: Int, width: Int, height: Int) {
-        Log.d("${TAG}_$tag", "Surface changed to format: $format, width: $width, height: $height")
-        if (this::gstLibrary.isInitialized) {
-            gstLibrary.setSurfaceHolder(holder)
-        }
-    }
-
-    override fun surfaceDestroyed(p0: SurfaceHolder) {
-        Log.d("${TAG}_$tag", "Surface destroyed")
-        // TODO: 如果呼叫 releaseSurface()，會閃退
-        /*if (this::gstLibrary.isInitialized) {
-            gstLibrary.releaseSurface()
-        }*/
-    }
-
-    override fun onStatus(gstStatus: GstStatus?) {  // onStatus 不是在主執行緒，因此透過 Handler 發訊息到主執行緒去執行
-        when (gstStatus) {
-            GstStatus.PLAYING -> mHandler.sendMessage(Message().apply { what = MSG_PLAY })
-            GstStatus.PAUSE -> mHandler.sendMessage(Message().apply { what = MSG_PAUSE })
-            GstStatus.ERROR_WHEN_OPENING -> mHandler.sendMessage(Message().apply { what = MSG_PAUSE })
-            else -> {}
-        }
-        Log.e("${TAG}_$tag", "onStatus: $gstStatus")
-    }
-
-    override fun onMessage(message: String?) {
-        Log.e("${TAG}_$tag", "onMessage: $message")
-    }
-
-    inner class MyHandler(looper: Looper): Handler(looper) {
-        override fun handleMessage(msg: Message) {
-            when(msg.what) {
-                MSG_PAUSE -> {
-                    isPlaying = false
-                    isLoading = false
-                }
-                MSG_PLAY -> {
-                    isLoading = false
-                    isPlaying = true
-                }
-            }
-        }
-    }
 
     companion object {
         private val TAG = VideoView::class.java.simpleName
-
-        const val MAIN_STREAM = 1
-        const val SUB_STREAM = 2
-
-        private const val MSG_PAUSE = 1
-        private const val MSG_PLAY = 2
-
     }
 }

app/src/main/java/com/ray650128/gstreamer_demo_app/ViewPager2Adapter.kt

@@ -1,31 +1,31 @@
 package com.ray650128.gstreamer_demo_app
 
 import android.annotation.SuppressLint
+import androidx.fragment.app.Fragment
 import androidx.fragment.app.FragmentManager
 import androidx.lifecycle.Lifecycle
 import androidx.viewpager2.adapter.FragmentStateAdapter
 
-class VideoViewAdapter(
+class ViewPager2Adapter(
     fragmentManager: FragmentManager,
     lifecycle: Lifecycle
 ) : FragmentStateAdapter(fragmentManager, lifecycle) {
 
-    private var fragments: MutableList<SplitViewFragment> = arrayListOf()
+    private var fragments: MutableList<Fragment> = arrayListOf()
 
     override fun getItemCount(): Int {
         return fragments.size
     }
-
+    override fun createFragment(position: Int): Fragment {
-    override fun createFragment(position: Int): SplitViewFragment {
         return fragments[position]
     }
 
-    fun add(index: Int, fragment: SplitViewFragment) {
+    fun add(index: Int, fragment: Fragment) {
         fragments.add(index, fragment)
         notifyItemChanged(index)
     }
 
-    fun refreshFragment(index: Int, fragment: SplitViewFragment) {
+    fun refreshFragment(index: Int, fragment: Fragment) {
         fragments[index] = fragment
         notifyItemChanged(index)
     }
@@ -41,22 +41,6 @@ class VideoViewAdapter(
         notifyDataSetChanged()
     }
 
-    fun stop(index: Int) {
-        stop(fragments[index])
-    }
-
-    private fun stop(fragment: SplitViewFragment) {
-        fragment.stopAll()
-    }
-
-    /*fun play(index: Int) {
-        play(fragments[index])
-    }
-
-    private fun play(fragment: SplitViewFragment) {
-        fragment.playAll()
-    }*/
-
     override fun getItemId(position: Int): Long {
         return fragments[position].hashCode().toLong()
     }

app/src/main/java/com/ray650128/gstreamer_demo_app/model/Device.kt

@@ -1,11 +0,0 @@
-package com.ray650128.gstreamer_demo_app.model
-
-import android.os.Parcelable
-import kotlinx.parcelize.Parcelize
-
-@Parcelize
-data class Device(
-    val name: String = "",
-    val rtspUrl: String = "",
-    var isPlaying: Boolean = false
-): Parcelable

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

@@ -19,40 +19,5 @@
         tools:layout_conversion_absoluteHeight="0dp"
         tools:layout_conversion_absoluteWidth="411dp" />
 
-    <Button
-        android:id="@+id/button"
-        android:layout_width="wrap_content"
-        android:layout_height="wrap_content"
-        android:layout_marginStart="16dp"
-        android:layout_marginTop="16dp"
-        android:text="1"
-        app:layout_constraintEnd_toStartOf="@+id/button2"
-        app:layout_constraintHorizontal_bias="0.5"
-        app:layout_constraintStart_toStartOf="parent"
-        app:layout_constraintTop_toBottomOf="@+id/viewPager" />
-
-    <Button
-        android:id="@+id/button2"
-        android:layout_width="wrap_content"
-        android:layout_height="wrap_content"
-        android:layout_marginTop="16dp"
-        android:text="4"
-        app:layout_constraintEnd_toStartOf="@+id/button3"
-        app:layout_constraintHorizontal_bias="0.5"
-        app:layout_constraintStart_toEndOf="@+id/button"
-        app:layout_constraintTop_toBottomOf="@+id/viewPager" />
-
-    <Button
-        android:id="@+id/button3"
-        android:layout_width="wrap_content"
-        android:layout_height="wrap_content"
-        android:layout_marginTop="16dp"
-        android:layout_marginEnd="16dp"
-        android:text="9"
-        app:layout_constraintEnd_toEndOf="parent"
-        app:layout_constraintHorizontal_bias="0.5"
-        app:layout_constraintStart_toEndOf="@+id/button2"
-        app:layout_constraintTop_toBottomOf="@+id/viewPager" />
-
 
 </androidx.constraintlayout.widget.ConstraintLayout>

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

@@ -1,12 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<androidx.gridlayout.widget.GridLayout xmlns:android="http://schemas.android.com/apk/res/android"
-    xmlns:app="http://schemas.android.com/apk/res-auto"
-    xmlns:tools="http://schemas.android.com/tools"
-    android:id="@+id/baseView"
-    android:layout_width="match_parent"
-    android:layout_height="match_parent"
-    android:layout_gravity="center"
-    app:columnCount="3"
-    app:rowCount="3"
-    app:useDefaultMargins="false"
-    tools:context=".SplitViewFragment" />

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

@@ -1,13 +1,14 @@
 <?xml version="1.0" encoding="utf-8"?>
 <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
     xmlns:app="http://schemas.android.com/apk/res-auto"
+    xmlns:tools="http://schemas.android.com/tools"
     android:id="@+id/baseView"
     android:layout_width="match_parent"
     android:layout_height="match_parent"
     android:background="@drawable/bg_video_view"
     android:outlineProvider="background">
 
-    <SurfaceView
+    <com.hisharp.gstreamer_player.GStreamerSurfaceView
         android:id="@+id/videoView"
         android:layout_width="match_parent"
         android:layout_height="match_parent"
@@ -21,7 +22,6 @@
         android:layout_width="0dp"
         android:layout_height="0dp"
         android:scaleType="fitXY"
-        android:visibility="gone"
         app:layout_constraintBottom_toBottomOf="parent"
         app:layout_constraintEnd_toEndOf="parent"
         app:layout_constraintStart_toStartOf="parent"
@@ -34,16 +34,16 @@
         android:layout_height="wrap_content"
         android:layout_marginStart="8dp"
         android:layout_marginBottom="4dp"
+        android:drawableLeft="@drawable/ic_ip_cam_name"
         android:drawablePadding="6dp"
         android:ellipsize="end"
         android:maxLines="1"
-        android:text=""
+        android:text="TextView"
         android:textColor="@android:color/white"
         android:textSize="16sp"
         android:visibility="gone"
-        app:layout_constraintBottom_toBottomOf="parent"
+        app:layout_constraintBottom_toBottomOf="@+id/videoView"
-        app:layout_constraintStart_toStartOf="parent"
+        app:layout_constraintStart_toStartOf="parent" />
-        app:drawableStartCompat="@drawable/ic_ip_cam_name" />
 
     <ProgressBar
         android:id="@+id/pbLoading"
@@ -51,7 +51,7 @@
         android:layout_width="64dp"
         android:layout_height="0dp"
         android:visibility="gone"
-        app:layout_constraintBottom_toBottomOf="parent"
+        app:layout_constraintBottom_toBottomOf="@+id/videoView"
         app:layout_constraintDimensionRatio="h,1:1"
         app:layout_constraintEnd_toEndOf="parent"
         app:layout_constraintStart_toStartOf="parent"

build.gradle

@@ -1,16 +1,25 @@
 // Top-level build file where you can add configuration options common to all sub-projects/modules.
 
 buildscript {
+    ext.kotlin_version = '1.7.10'
     repositories {
-        mavenCentral()
+        jcenter()
+        google()
+    }
+    dependencies {
+        classpath 'com.android.tools.build:gradle:7.1.0'
+        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
+
+        // NOTE: Do not place your application dependencies here; they belong
+        // in the individual module build.gradle files
     }
 }
 
-plugins {
+allprojects {
-    id 'com.android.application' version '7.3.1' apply false
+    repositories {
-    id 'com.android.library' version '7.3.1' apply false
+        jcenter()
-    id 'org.jetbrains.kotlin.android' version '1.7.10' apply false
+        google()
-    id 'org.jetbrains.kotlin.plugin.parcelize' version '1.7.0' apply false
+    }
 }
 
 task clean(type: Delete) {

gradle.properties

@@ -1,21 +1,2 @@
-# Project-wide Gradle settings.
-# IDE (e.g. Android Studio) users:
-# Gradle settings configured through the IDE *will override*
-# any settings specified in this file.
-# For more details on how to configure your build environment visit
-# http://www.gradle.org/docs/current/userguide/build_environment.html
-# Specifies the JVM arguments used for the daemon process.
-# The setting is particularly useful for tweaking memory settings.
-org.gradle.jvmargs=-Xmx2048m -Dfile.encoding=UTF-8
-# When configured, Gradle will run in incubating parallel mode.
-# This option should only be used with decoupled projects. More details, visit
-# http://www.gradle.org/docs/current/userguide/multi_project_builds.html#sec:decoupled_projects
-# org.gradle.parallel=true
-# AndroidX package structure to make it clearer which packages are bundled with the
-# Android operating system, and which are packaged with your app"s APK
-# https://developer.android.com/topic/libraries/support-library/androidx-rn
-android.useAndroidX=true
-# Automatically convert third-party libraries to use AndroidX
 android.enableJetifier=true
-# Kotlin code style for this project: "official" or "obsolete":
+android.useAndroidX=true
-kotlin.code.style=official

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
-#Thu Mar 24 14:41:01 CST 2022
+#Sat Apr 21 19:58:19 WEST 2018
 distributionBase=GRADLE_USER_HOME
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.4-bin.zip
 distributionPath=wrapper/dists
-zipStorePath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-7.3.3-all.zip

gstreamer_player/build.gradle

@@ -1,13 +1,11 @@
 apply plugin: 'com.android.library'
 
 android {
-    ndkVersion "21.3.6528147"
+    compileSdkVersion 32
-
-    compileSdkVersion 33
 
     defaultConfig {
         minSdkVersion 15
-        targetSdkVersion 33
+        targetSdkVersion 32
         versionCode 1
         versionName "1.0"
 
@@ -23,10 +21,7 @@ android {
                 if (gstRoot == null)
                     throw new GradleException('GSTREAMER_ROOT_ANDROID must be set, or "gstAndroidRoot" must be defined in your gradle.properties in the top level directory of the unpacked universal GStreamer Android binaries')
 
-                arguments "NDK_APPLICATION_MK=jni/Application.mk",
+                arguments "NDK_APPLICATION_MK=jni/Application.mk", "GSTREAMER_JAVA_SRC_DIR=src", "GSTREAMER_ROOT_ANDROID=$gstRoot", "GSTREAMER_ASSETS_DIR=src/assets"
-                        "GSTREAMER_JAVA_SRC_DIR=src",
-                        "GSTREAMER_ROOT_ANDROID=$gstRoot",
-                        "GSTREAMER_ASSETS_DIR=src/assets"
 
                 targets "gst_player"
 
@@ -70,6 +65,6 @@ afterEvaluate {
 
 dependencies {
     implementation fileTree(dir: 'libs', include: ['*.jar'])
-    testImplementation 'junit:junit:4.13.2'
+    testImplementation 'junit:junit:4.12'
-    //implementation 'androidx.appcompat:appcompat:1.6.0'
+    implementation 'androidx.appcompat:appcompat:1.0.0'
 }

gstreamer_player/jni/gst_player.c

@@ -253,7 +253,8 @@ static void *app_function(void *userdata) {
     /* Build pipeline */
     data->pipeline = gst_parse_launch("playbin", &error);
     if (error) {
-        gchar *message = g_strdup_printf("Unable to build pipeline: %s", error->message);
+        gchar *message =
+                g_strdup_printf("Unable to build pipeline: %s", error->message);
         g_clear_error(&error);
         set_ui_message(message, data);
         g_free(message);
@@ -279,9 +280,12 @@ static void *app_function(void *userdata) {
     g_signal_connect (G_OBJECT(bus), "message::error", (GCallback) error_cb,
                       data);
     g_signal_connect (G_OBJECT(bus), "message::eos", (GCallback) eos_cb, data);
-    g_signal_connect (G_OBJECT(bus), "message::state-changed", (GCallback) state_changed_cb, data);
+    g_signal_connect (G_OBJECT(bus), "message::state-changed",
-    g_signal_connect (G_OBJECT(bus), "message::buffering", (GCallback) buffering_cb, data);
+                      (GCallback) state_changed_cb, data);
-    g_signal_connect (G_OBJECT(bus), "message::clock-lost", (GCallback) clock_lost_cb, data);
+    g_signal_connect (G_OBJECT(bus), "message::buffering",
+                      (GCallback) buffering_cb, data);
+    g_signal_connect (G_OBJECT(bus), "message::clock-lost",
+                      (GCallback) clock_lost_cb, data);
     gst_object_unref(bus);
 
     /* Create a GLib Main Loop and set it to run */
@@ -348,8 +352,8 @@ void gst_native_set_uri(JNIEnv *env, jobject thiz, jstring uri) {
         gst_element_set_state(data->pipeline, GST_STATE_READY);
     g_object_set(data->pipeline, "uri", char_uri, NULL);
     (*env)->ReleaseStringUTFChars(env, uri, char_uri);
-    g_object_set(data->pipeline, "latency", 250, NULL);
+    data->is_live |=
-    data->is_live = (gst_element_set_state(data->pipeline, data->target_state) == GST_STATE_CHANGE_NO_PREROLL);
+            (gst_element_set_state(data->pipeline, data->target_state) == GST_STATE_CHANGE_NO_PREROLL);
 }
 
 /* Set pipeline to PLAYING state */
@@ -359,7 +363,7 @@ static void gst_native_play(JNIEnv *env, jobject thiz) {
         return;
     GST_DEBUG ("Setting state to PLAYING");
     data->target_state = GST_STATE_PLAYING;
-    data->is_live = (gst_element_set_state(data->pipeline, GST_STATE_PLAYING) == GST_STATE_CHANGE_NO_PREROLL);
+    data->is_live |= (gst_element_set_state(data->pipeline, GST_STATE_PLAYING) == GST_STATE_CHANGE_NO_PREROLL);
 }
 
 /* Set pipeline to PAUSED state */
@@ -369,15 +373,19 @@ static void gst_native_pause(JNIEnv *env, jobject thiz) {
         return;
     GST_DEBUG ("Setting state to PAUSED");
     data->target_state = GST_STATE_PAUSED;
-    data->is_live = (gst_element_set_state(data->pipeline, GST_STATE_PAUSED) == GST_STATE_CHANGE_NO_PREROLL);
+    data->is_live |=(gst_element_set_state(data->pipeline, GST_STATE_PAUSED) == GST_STATE_CHANGE_NO_PREROLL);
 }
 
 /* Static class initializer: retrieve method and field IDs */
 static jboolean gst_native_class_init(JNIEnv *env, jclass klass) {
-    custom_data_field_id = (*env)->GetFieldID(env, klass, "native_custom_data", "J");
+    custom_data_field_id =
-    set_message_method_id = (*env)->GetMethodID(env, klass, "setMessage", "(Ljava/lang/String;)V");
+            (*env)->GetFieldID(env, klass, "native_custom_data", "J");
-    on_gstreamer_initialized_method_id = (*env)->GetMethodID(env, klass, "onGStreamerInitialized", "()V");
+    set_message_method_id =
-    on_media_size_changed_method_id = (*env)->GetMethodID(env, klass, "onMediaSizeChanged", "(II)V");
+            (*env)->GetMethodID(env, klass, "setMessage", "(Ljava/lang/String;)V");
+    on_gstreamer_initialized_method_id =
+            (*env)->GetMethodID(env, klass, "onGStreamerInitialized", "()V");
+    on_media_size_changed_method_id =
+            (*env)->GetMethodID(env, klass, "onMediaSizeChanged", "(II)V");
 
     if (!custom_data_field_id || !set_message_method_id
         || !on_gstreamer_initialized_method_id || !on_media_size_changed_method_id) {
@@ -406,6 +414,7 @@ static void gst_native_surface_init(JNIEnv *env, jobject thiz, jobject surface)
                        data->native_window);
             if (data->pipeline) {
                 gst_video_overlay_expose(GST_VIDEO_OVERLAY (data->pipeline));
+                gst_video_overlay_expose(GST_VIDEO_OVERLAY (data->pipeline));
             }
             return;
         } else {

gstreamer_player/res/layout/main.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    android:layout_width="match_parent"
+    android:layout_height="match_parent"
+    android:gravity="center_vertical"
+    android:orientation="vertical" >
+
+    <TextView
+        android:id="@+id/textview_message"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:layout_marginBottom="16dip"
+        android:gravity="center_horizontal" />
+
+    <LinearLayout
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:layout_marginBottom="16dip"
+        android:gravity="center_horizontal"
+        android:orientation="horizontal" >
+
+        <ImageButton
+            android:id="@+id/button_play"
+            android:layout_width="wrap_content"
+            android:layout_height="wrap_content"
+            android:contentDescription="@string/button_play"
+            android:src="@android:drawable/ic_media_play"
+            android:text="@string/button_play" />
+
+        <ImageButton
+            android:id="@+id/button_stop"
+            android:layout_width="wrap_content"
+            android:layout_height="wrap_content"
+            android:contentDescription="@string/button_stop"
+            android:src="@android:drawable/ic_media_pause"
+            android:text="@string/button_stop" />
+
+    </LinearLayout>
+
+    <com.hisharp.gstreamer_player.GStreamerSurfaceView
+        android:id="@+id/surface_video"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:layout_gravity="center_vertical|center_horizontal" />
+
+</LinearLayout>

gstreamer_player/res/values/strings.xml

@@ -1,4 +1,12 @@
 <?xml version="1.0" encoding="utf-8"?>
 <resources>
-
+    <string name="app_name">GStreamer tutorial 5</string>
+    <string name="button_play">Play</string>
+    <string name="button_stop">Stop</string>
+    <string name="button_select">Select</string>
+    <string name="button_cancel">Cancel</string>
+    <string name="filechooser_name">Select a file</string>
+    <string name="location">Location</string>
+    <string name="cant_read_folder">folder cannot be read</string>
+    <string name="icon">Icon</string>
 </resources>

gstreamer_player/src/com/hisharp/gstreamer_player/GstCallback.java

@@ -1,6 +1,6 @@
 package com.hisharp.gstreamer_player;
 
 public interface GstCallback {
-    void onStatus(GstStatus gstStatus);
+    void onStatus(GstLibrary gstInstance, GstStatus gstStatus);
-    void onMessage(String message);
+    void onMessage(GstLibrary gstInstance, String message);
 }

gstreamer_player/src/com/hisharp/gstreamer_player/GstLibrary.java

@@ -10,19 +10,21 @@ import android.view.SurfaceView;
 
 import org.freedesktop.gstreamer.GStreamer;
 
-import java.io.Closeable;
+public class GstLibrary implements SurfaceHolder.Callback {
-import java.io.IOException;
-
-public class GstLibrary implements Closeable {
 
     final Context mAppContext;
 
     private GstCallback gstCallback;
 
-    private String rtspUrl;
+    private GStreamerSurfaceView surfaceView;
 
-    public GstLibrary(Context context) {
+    private final Handler mainHandler = new Handler(Looper.getMainLooper());
+
+    private final String rtspUrl;
+
+    public GstLibrary(Context context, String rtspUrl) {
         this.mAppContext = context.getApplicationContext();
+        this.rtspUrl = rtspUrl;
 
         // Initialize GStreamer and warn if it fails
         try {
@@ -39,6 +41,7 @@ public class GstLibrary implements Closeable {
     private native void nativeFinalize(); // Destroy pipeline and shutdown native code
     private native void nativeSetUri(String uri); // Set the URI of the media to play
     private native void nativePlay();     // Set pipeline to PLAYING
+    private native void nativeSetPosition(int milliseconds); // Seek to the indicated position, in milliseconds
     private native void nativePause();    // Set pipeline to PAUSED
     private static native boolean nativeClassInit(); // Initialize native class: cache Method IDs for callbacks
     private native void nativeSurfaceInit(Object surface); // A new surface is available
@@ -55,19 +58,18 @@ public class GstLibrary implements Closeable {
         nativePause();
     }
 
-    public void setRtspUrl(String rtspUrl) {
+    public void release() {
-        this.rtspUrl = rtspUrl;
+        nativeFinalize();
-    }
-
-    public void releaseSurface() {
-        nativeSurfaceFinalize();
     }
 
     public void setOnStatusChangeListener(GstCallback callback) {
         this.gstCallback = callback;
     }
 
-    public void setSurfaceHolder(SurfaceHolder holder) {
+    public void setSurfaceView(GStreamerSurfaceView surfaceView) {
+        this.surfaceView = surfaceView;
+        SurfaceHolder holder = this.surfaceView.getHolder();
+        holder.addCallback(this);
         nativeSurfaceInit(holder.getSurface());
     }
 
@@ -75,17 +77,13 @@ public class GstLibrary implements Closeable {
     private void setMessage(final String message) {
         if (gstCallback == null) return;
         if (message.contains("State changed to PAUSED")) {
-            gstCallback.onStatus(GstStatus.PAUSE);
+            gstCallback.onStatus(this, GstStatus.PAUSE);
         } else if (message.contains("State changed to PLAYING")) {
-            gstCallback.onStatus(GstStatus.PLAYING);
+            gstCallback.onStatus(this, GstStatus.PLAYING);
         } else if (message.contains("Could not open resource for reading and writing")) {
-            gstCallback.onStatus(GstStatus.ERROR_WHEN_OPENING);
+            gstCallback.onStatus(this, GstStatus.ERROR);
-        } else if (message.contains("GStreamer encountered a general supporting library error")) {
-            gstCallback.onStatus(GstStatus.ERROR);
-        } else if (message.contains("Unhandled error")) {
-            gstCallback.onStatus(GstStatus.ERROR);
         }
-        gstCallback.onMessage(message);
+        gstCallback.onMessage(this, message);
     }
 
     // Called from native code. Native code calls this once it has created its pipeline and
@@ -94,24 +92,26 @@ public class GstLibrary implements Closeable {
         Log.i ("GStreamer", "GStreamer initialized:");
 
         if (gstCallback != null) {
-            gstCallback.onStatus(GstStatus.READY);
+            gstCallback.onStatus(this, GstStatus.READY);
         }
 
         // Restore previous playing state
-        if (rtspUrl != null) {
+        nativeSetUri (rtspUrl);
-            nativeSetUri(rtspUrl);
+        nativeSetPosition (0);
-        }
     }
 
+    // Called from native code
+    private void setCurrentPosition(final int position, final int duration) {}
+
     // Called from native code when the size of the media changes or is first detected.
     // Inform the video surface about the new size and recalculate the layout.
     private void onMediaSizeChanged (int width, int height) {
         Log.i ("GStreamer", "Media size changed to " + width + "x" + height);
-        /*mainHandler.post(() -> {
+        mainHandler.post(() -> {
             surfaceView.media_width = width;
             surfaceView.media_height = height;
             surfaceView.requestLayout();
-        });*/
+        });
     }
 
     static {
@@ -120,12 +120,19 @@ public class GstLibrary implements Closeable {
         nativeClassInit();
     }
 
-    @Override
+    public void surfaceChanged(SurfaceHolder holder, int format, int width,
-    public void close() throws IOException {
+            int height) {
-        try {
+        Log.d("GStreamer", "Surface changed to format " + format + " width "
-            nativeFinalize();
+                + width + " height " + height);
-        } catch (Exception e) {
+        nativeSurfaceInit (holder.getSurface());
-            e.printStackTrace();
+    }
-        }
+
+    public void surfaceCreated(SurfaceHolder holder) {
+        Log.d("GStreamer", "Surface created: " + holder.getSurface());
+    }
+
+    public void surfaceDestroyed(SurfaceHolder holder) {
+        Log.d("GStreamer", "Surface destroyed");
+        nativeSurfaceFinalize();
     }
 }

gstreamer_player/src/com/hisharp/gstreamer_player/GstStatus.java

@@ -4,6 +4,5 @@ public enum GstStatus {
     READY,
     PAUSE,
     PLAYING,
-    ERROR,
+    ERROR
-    ERROR_WHEN_OPENING
 }

settings.gradle

@@ -1,19 +1,2 @@
-pluginManagement {
-    repositories {
-        gradlePluginPortal()
-        google()
-        mavenCentral()
-        maven { url 'https://jitpack.io' }
-    }
-}
-dependencyResolutionManagement {
-    repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)
-    repositories {
-        google()
-        mavenCentral()
-        jcenter() // Warning: this repository is going to shut down soon
-        maven {url "https://jitpack.io"}
-    }
-}
 include ':gstreamer_player'
 include ':app'