projects
/
nihav.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
realmedia: clear non-existing timestamps in .ra
[nihav.git]
/
nihav-realmedia
/
src
/
demuxers
/
realmedia.rs
diff --git
a/nihav-realmedia/src/demuxers/realmedia.rs
b/nihav-realmedia/src/demuxers/realmedia.rs
index 14183c9cc4ac54fca43069cf4b3a10d7c9b5cbed..b2ea95896e1c4372c5f2d96a4e6a6791e0fa7a63 100644
(file)
--- a/
nihav-realmedia/src/demuxers/realmedia.rs
+++ b/
nihav-realmedia/src/demuxers/realmedia.rs
@@
-1247,7
+1247,8
@@
impl<'a> DemuxCore<'a> for RealAudioDemuxer<'a> {
fn get_frame(&mut self, strmgr: &mut StreamManager) -> DemuxerResult<NAPacket> {
if !self.queued_pkts.is_empty() {
fn get_frame(&mut self, strmgr: &mut StreamManager) -> DemuxerResult<NAPacket> {
if !self.queued_pkts.is_empty() {
- let pkt = self.queued_pkts.pop().unwrap();
+ let mut pkt = self.queued_pkts.pop().unwrap();
+ pkt.ts.pts = None;
return Ok(pkt);
}
if (self.data_end != 0) && (self.src.tell() >= self.data_end) {
return Ok(pkt);
}
if (self.data_end != 0) && (self.src.tell() >= self.data_end) {
@@
-1257,10
+1258,13
@@
impl<'a> DemuxCore<'a> for RealAudioDemuxer<'a> {
let stream = streamres.unwrap();
if let Some(ref mut astr) = self.stream {
loop {
let stream = streamres.unwrap();
if let Some(ref mut astr) = self.stream {
loop {
- let ret = astr.read_apackets(&mut self.queued_pkts, self.src, stream.clone(), 0, false, self.blk_size);
+ let
mut
ret = astr.read_apackets(&mut self.queued_pkts, self.src, stream.clone(), 0, false, self.blk_size);
if let Err(DemuxerError::TryAgain) = ret {
continue;
}
if let Err(DemuxerError::TryAgain) = ret {
continue;
}
+ if let Ok(ref mut pkt) = ret {
+ pkt.ts.pts = None;
+ }
return ret;
}
}
return ret;
}
}