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

Experimenting with packetFinished

Browse source
This commit is contained in:
Rohit Singh 2024-04-23 18:57:04 +01:00
parent 5b3a50fca8
commit bfdd769753
1 changed files with 41 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -203,7 +203,46 @@ public final class MpeghReader implements ElementaryStreamReader {
@Override
public void packetFinished() {
// Do nothing.
if(!headerDataFinished && headerScratchBytes.getPosition() > 0 && state == STATE_READING_PACKET_HEADER) {
try {
int position = headerScratchBytes.getPosition();
parseHeader();
// write the packet header to output
headerScratchBytes.setPosition(0);
headerScratchBytes.setLimit(position);
output.sampleData(headerScratchBytes, header.headerLength);
state = STATE_READING_PACKET_PAYLOAD;
if (shouldParsePacket(header.packetType)) {
// prepare data scratch buffer
dataScratchBytes.reset(header.packetLength);
// read bytes from the end of the header scratch buffer into the data scratch buffer
if (headerScratchBytes.getPosition() != position) {
copyData(headerScratchBytes, dataScratchBytes, header.packetLength);
}
}
// read bytes from the end of the header scratch buffer and write them into the output
if (headerScratchBytes.getPosition() != position) {
int bytesToRead = min(headerScratchBytes.bytesLeft(), header.packetLength - payloadBytesRead);
output.sampleData(headerScratchBytes, bytesToRead);
payloadBytesRead += bytesToRead;
}
if (payloadBytesRead == header.packetLength) {
if (header.packetType == MpeghUtil.MhasPacketHeader.PACTYP_MPEGH3DACFG) {
parseConfig(new ParsableBitArray(dataScratchBytes.getData()));
} else if (header.packetType == MpeghUtil.MhasPacketHeader.PACTYP_AUDIOTRUNCATION) {
truncationSamples =
MpeghUtil.parseAudioTruncationInfo(
new ParsableBitArray(dataScratchBytes.getData()));
} else if (header.packetType == MpeghUtil.MhasPacketHeader.PACTYP_MPEGH3DAFRAME) {
finalizeFrame();
}
// MHAS packet payload finished -> obtain a new packet header
state = STATE_READING_PACKET_HEADER;
}
headerScratchBytes.setLimit(MAX_MHAS_PACKET_HEADER_SIZE);
} catch (ParserException parserException) {
}
}
}
/**
@ -259,7 +298,7 @@ public final class MpeghReader implements ElementaryStreamReader {
* @throws ParserException if a valid {@link MpeghUtil.Mpegh3daConfig} cannot be parsed.
*/
private void parseHeader() throws ParserException {
headerScratchBits.reset(headerScratchBytes.getData());
headerScratchBits.reset(headerScratchBytes.getData(), headerScratchBytes.getPosition());
// parse the MHAS packet header
MpeghUtil.parseMhasPacketHeader(headerScratchBits, header);