wip

Author: wader

format/mpeg/mpeg_ts.go

@@ -73,14 +73,8 @@ func (tb *tsBuffer) Reset() {
 
 func tsContinuityUpdate(tcm map[int]int, pid int, current int) bool {
 	prev, prevFound := tcm[pid]
-	valid := (prevFound && ((prev+1)&0xf == current)) || current == 0
-	if valid {
-		tcm[pid] = current
-		return true
-	}
-	if prevFound {
-		delete(tcm, pid)
-	}
+	valid := prevFound && ((prev+1)&0xf == current)
+	tcm[pid] = current
 	return valid
 }
 

format/mpeg/mpeg_ts_packet.go

@@ -59,9 +59,9 @@ func tsPacketDecode(d *decode.D) any {
 
 		switch {
 		case prevFound && (prev+1)&0xf == current:
-			s.Description = "valid"
+			s.Description = "continuous"
 		case prevFound:
-			s.Description = "invalid"
+			s.Description = "non-continuous"
 		default:
 			s.Description = "unknown"
 		}