Update src/rust/src/demuxer/demux.rs

steel-bucket · prateekmedia · web-flow · commit caf04de427ad · 2025-09-06T20:11:22.000+05:30
Co-authored-by: Prateek Sunal &lt;prtksunal@gmail.com&gt;
diff --git a/src/rust/src/demuxer/demux.rs b/src/rust/src/demuxer/demux.rs
@@ -99,9 +99,11 @@ impl CcxDemuxer<'_> {
             } else {
                 self.pids_seen[..MAX_PID].fill(0);
             }
-            // Set each min_pts[i] to u64::MAX for i in 0..=MAX_PSI_PID.
-            for i in 0..=MAX_PSI_PID {
-                if !self.min_pts.is_empty() {
+            if self.min_pts.len() != MAX_PSI_PID + 1 {
+                self.min_pts.resize(MAX_PSI_PID + 1, u64::MAX);
+            } else {
+                // Set each min_pts[i] to u64::MAX for i in 0..=MAX_PSI_PID.
+                for i in 0..=MAX_PSI_PID {
                     self.min_pts[i] = u64::MAX;
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -99,9 +99,11 @@ impl CcxDemuxer<'_> {`
`99`	`99`	`} else {`
`100`	`100`	`self.pids_seen[..MAX_PID].fill(0);`
`101`	`101`	`}`
`102`		`- // Set each min_pts[i] to u64::MAX for i in 0..=MAX_PSI_PID.`
`103`		`- for i in 0..=MAX_PSI_PID {`
`104`		`- if !self.min_pts.is_empty() {`
	`102`	`+ if self.min_pts.len() != MAX_PSI_PID + 1 {`
	`103`	`+ self.min_pts.resize(MAX_PSI_PID + 1, u64::MAX);`
	`104`	`+ } else {`
	`105`	`+ // Set each min_pts[i] to u64::MAX for i in 0..=MAX_PSI_PID.`
	`106`	`+ for i in 0..=MAX_PSI_PID {`
`105`	`107`	`self.min_pts[i] = u64::MAX;`
`106`	`108`	`}`
`107`	`109`	`}`