clear video info

pedroSG94 · Oct 13, 2024 · 51f186d · 51f186d
1 parent c626938
commit 51f186d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/rtmp/src/main/java/com/pedro/rtmp/rtmp/CommandsManager.kt b/rtmp/src/main/java/com/pedro/rtmp/rtmp/CommandsManager.kt
@@ -247,7 +247,7 @@ abstract class CommandsManager {
   abstract suspend fun sendPublishImp(socket: RtmpSocket)
   abstract suspend fun sendCloseImp(socket: RtmpSocket)
 
-  fun reset() {
+  fun reset(clear: Boolean) {
     startTs = 0
     timestamp = 0
     streamId = 0
@@ -256,5 +256,10 @@ abstract class CommandsManager {
     sessionHistory.reset()
     acknowledgementSequence = 0
     bytesRead = 0
+    if (clear) {
+      sps = null
+      pps = null
+      vps = null
+    }
   }
 }
diff --git a/rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt b/rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt
@@ -517,7 +517,7 @@ class RtmpClient(private val connectChecker: ConnectChecker) {
 
   private suspend fun closeConnection() {
     socket?.close()
-    commandsManager.reset()
+    commandsManager.reset(false)
   }
 
   @JvmOverloads
@@ -563,7 +563,7 @@ class RtmpClient(private val connectChecker: ConnectChecker) {
     scope.cancel()
     scope = CoroutineScope(Dispatchers.IO)
     publishPermitted = false
-    commandsManager.reset()
+    commandsManager.reset(clear)
   }
 
   fun sendVideo(videoBuffer: ByteBuffer, info: MediaCodec.BufferInfo) {