sjs/media
1
0
Fork 0
mirror of https://github.com/samsonjs/media.git synced 2026-03-25 09:25:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix for packet header split over 2 PES packets

Browse source
This commit is contained in:
Rohit Singh 2024-04-26 10:38:32 +02:00
parent 3d974793f9
commit c34c3db87f
1 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
libraries/extractor/src/main/java/androidx/media3/extractor/ts/MpeghReader.java
View file

@ -77,6 +77,7 @@ public final class MpeghReader implements ElementaryStreamReader {
private final ParsableBitArray headerScratchBits;
private final ParsableByteArray dataScratchBytes;
private boolean headerDataFinished;
private int payloadBytesRead;
private int frameBytes;
@ -99,6 +100,7 @@ public final class MpeghReader implements ElementaryStreamReader {
standardFrameLength = C.LENGTH_UNSET;
mainStreamLabel = C.INDEX_UNSET;
rapPending = true;
headerDataFinished = true;
timeUs = C.TIME_UNSET;
timeUsPending = C.TIME_UNSET;
}
@ -116,6 +118,7 @@ public final class MpeghReader implements ElementaryStreamReader {
mainStreamLabel = C.INDEX_UNSET;
configFound = false;
dataPending = false;
headerDataFinished = true;
rapPending = true;
timeUs = C.TIME_UNSET;
timeUsPending = C.TIME_UNSET;
@ -134,7 +137,7 @@ public final class MpeghReader implements ElementaryStreamReader {
this.flags = flags;
// check if data is pending (an MPEG-H frame could not be completed)
if (!rapPending && frameBytes != 0) {
if (!rapPending && (frameBytes != 0 || !headerDataFinished)) {
dataPending = true;
}
@ -172,11 +175,19 @@ public final class MpeghReader implements ElementaryStreamReader {
// Prepare dataScratchBytes to read new MHAS packet
dataScratchBytes.reset(header.packetLength);
// Signalize packet header processed completely
headerDataFinished = true;
// MHAS packet header finished -> obtain the packet payload
state = STATE_READING_PACKET_PAYLOAD;
} else if (headerScratchBytes.limit() < MAX_MHAS_PACKET_HEADER_SIZE) {
headerScratchBytes.setLimit(headerScratchBytes.limit() + 1);
// Signalize pending packet header processing
headerDataFinished = false;
}
} else {
// Signalize pending packet header processing
headerDataFinished = false;
}
break;
case STATE_READING_PACKET_PAYLOAD: