media/libstagefright/rtsp/AMPEG4ElementaryAssembler.cpp - third_party/android/platform/frameworks/av - Git at Google

 /*
  * Copyright (C) 2010 The Android Open Source Project
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 //#define LOG_NDEBUG 0
 #define LOG_TAG "AMPEG4ElementaryAssembler"
 #include <utils/Log.h>

 #include "AMPEG4ElementaryAssembler.h"

 #include "ARTPSource.h"
 #include "ASessionDescription.h"

 #include <media/stagefright/foundation/ABitReader.h>
 #include <media/stagefright/foundation/ABuffer.h>
 #include <media/stagefright/foundation/ADebug.h>
 #include <media/stagefright/foundation/AMessage.h>
 #include <media/stagefright/foundation/ByteUtils.h>
 #include <media/stagefright/foundation/hexdump.h>

 #include <ctype.h>
 #include <stdint.h>

 namespace android {

 static bool GetAttribute(const char *s, const char *key, AString *value) {
     value->clear();

     size_t keyLen = strlen(key);

     for (;;) {
         while (isspace(*s)) {
             ++s;
         }

         const char *colonPos = strchr(s, ';');

         size_t len =
             (colonPos == NULL) ? strlen(s) : colonPos - s;

         if (len >= keyLen + 1 && s[keyLen] == '='
                 && !strncasecmp(s, key, keyLen)) {
             value->setTo(&s[keyLen + 1], len - keyLen - 1);
             return true;
         }

         if (colonPos == NULL) {
             return false;
         }

         s = colonPos + 1;
     }
 }

 static bool GetIntegerAttribute(
         const char *s, const char *key, unsigned *x) {
     *x = 0;

     AString val;
     if (!GetAttribute(s, key, &val)) {
         return false;
     }

     s = val.c_str();
     char *end;
     unsigned y = strtoul(s, &end, 10);

     if (end == s || *end != '\0') {
         return false;
     }

     *x = y;

     return true;
 }

 static bool GetSampleRateIndex(int32_t sampleRate, size_t *tableIndex) {
     static const int32_t kSampleRateTable[] = {
         96000, 88200, 64000, 48000, 44100, 32000,
         24000, 22050, 16000, 12000, 11025, 8000
     };
     const size_t kNumSampleRates =
         sizeof(kSampleRateTable) / sizeof(kSampleRateTable[0]);

     *tableIndex = 0;
     for (size_t index = 0; index < kNumSampleRates; ++index) {
         if (sampleRate == kSampleRateTable[index]) {
             *tableIndex = index;
             return true;
         }
     }

     return false;
 }

 // static
 AMPEG4ElementaryAssembler::AMPEG4ElementaryAssembler(
         const sp<AMessage> &notify, const AString &desc, const AString &params)
     : mNotifyMsg(notify),
       mIsGeneric(false),
       mParams(params),
       mSizeLength(0),
       mIndexLength(0),
       mIndexDeltaLength(0),
       mCTSDeltaLength(0),
       mDTSDeltaLength(0),
       mRandomAccessIndication(false),
       mStreamStateIndication(0),
       mAuxiliaryDataSizeLength(0),
       mHasAUHeader(false),
       mChannelConfig(0),
       mSampleRateIndex(0),
       mAccessUnitRTPTime(0),
       mNextExpectedSeqNoValid(false),
       mNextExpectedSeqNo(0),
       mAccessUnitDamaged(false) {
     mIsGeneric = !strncasecmp(desc.c_str(),"mpeg4-generic/", 14);

     if (mIsGeneric) {
         AString value;
         CHECK(GetAttribute(params.c_str(), "mode", &value));

         if (!GetIntegerAttribute(params.c_str(), "sizeLength", &mSizeLength)) {
             mSizeLength = 0;
         }

         if (!GetIntegerAttribute(
                     params.c_str(), "indexLength", &mIndexLength)) {
             mIndexLength = 0;
         }

         if (!GetIntegerAttribute(
                     params.c_str(), "indexDeltaLength", &mIndexDeltaLength)) {
             mIndexDeltaLength = 0;
         }

         if (!GetIntegerAttribute(
                     params.c_str(), "CTSDeltaLength", &mCTSDeltaLength)) {
             mCTSDeltaLength = 0;
         }

         if (!GetIntegerAttribute(
                     params.c_str(), "DTSDeltaLength", &mDTSDeltaLength)) {
             mDTSDeltaLength = 0;
         }

         unsigned x;
         if (!GetIntegerAttribute(
                     params.c_str(), "randomAccessIndication", &x)) {
             mRandomAccessIndication = false;
         } else {
             CHECK(x == 0 || x == 1);
             mRandomAccessIndication = (x != 0);
         }

         if (!GetIntegerAttribute(
                     params.c_str(), "streamStateIndication",
                     &mStreamStateIndication)) {
             mStreamStateIndication = 0;
         }

         if (!GetIntegerAttribute(
                     params.c_str(), "auxiliaryDataSizeLength",
                     &mAuxiliaryDataSizeLength)) {
             mAuxiliaryDataSizeLength = 0;
         }

         mHasAUHeader =
             mSizeLength > 0
             || mIndexLength > 0
             || mIndexDeltaLength > 0
             || mCTSDeltaLength > 0
             || mDTSDeltaLength > 0
             || mRandomAccessIndication
             || mStreamStateIndication > 0;

         int32_t sampleRate, numChannels;
         ASessionDescription::ParseFormatDesc(
                 desc.c_str(), &sampleRate, &numChannels);

         mChannelConfig = numChannels;
         CHECK(GetSampleRateIndex(sampleRate, &mSampleRateIndex));
     }
 }

 AMPEG4ElementaryAssembler::~AMPEG4ElementaryAssembler() {
 }

 struct AUHeader {
     unsigned mSize;
     unsigned mSerial;
 };

 bool AMPEG4ElementaryAssembler::initCheck() {
     if(mSizeLength == 0 || mIndexLength == 0 || mIndexDeltaLength == 0) {
         android_errorWriteLog(0x534e4554, "124777537");
         return false;
     }
     return true;
 }

 ARTPAssembler::AssemblyStatus AMPEG4ElementaryAssembler::addPacket(
         const sp<ARTPSource> &source) {
     List<sp<ABuffer> > *queue = source->queue();

     if (queue->empty()) {
         return NOT_ENOUGH_DATA;
     }

     if (mNextExpectedSeqNoValid) {
         List<sp<ABuffer> >::iterator it = queue->begin();
         while (it != queue->end()) {
             if ((uint32_t)(*it)->int32Data() >= mNextExpectedSeqNo) {
                 break;
             }

             it = queue->erase(it);
         }

         if (queue->empty()) {
             return NOT_ENOUGH_DATA;
         }
     }

     sp<ABuffer> buffer = *queue->begin();

     if (!mNextExpectedSeqNoValid) {
         mNextExpectedSeqNoValid = true;
         mNextExpectedSeqNo = (uint32_t)buffer->int32Data();
     } else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) {
         ALOGV("Not the sequence number I expected");

         return WRONG_SEQUENCE_NUMBER;
     }

     uint32_t rtpTime;
     CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTime));

     if (mPackets.size() > 0 && rtpTime != mAccessUnitRTPTime) {
         submitAccessUnit();
     }
     mAccessUnitRTPTime = rtpTime;

     if (!mIsGeneric) {
         mPackets.push_back(buffer);
     } else {
         // hexdump(buffer->data(), buffer->size());
         if (buffer->size() < 2) {
             android_errorWriteLog(0x534e4554, "124783982");
             queue->erase(queue->begin());
             return MALFORMED_PACKET;
         }

         unsigned AU_headers_length = U16_AT(buffer->data());  // in bits

         if (buffer->size() < 2 + (AU_headers_length + 7) / 8) {
             android_errorWriteLog(0x534e4554, "124783982");
             queue->erase(queue->begin());
             return MALFORMED_PACKET;
         }

         List<AUHeader> headers;

         ABitReader bits(buffer->data() + 2, buffer->size() - 2);
         unsigned numBitsLeft = AU_headers_length;

         unsigned AU_serial = 0;
         for (;;) {
             if (numBitsLeft < mSizeLength) { break; }

             unsigned AU_size = bits.getBits(mSizeLength);
             numBitsLeft -= mSizeLength;

             size_t n = headers.empty() ? mIndexLength : mIndexDeltaLength;
             if (numBitsLeft < n) { break; }

             unsigned AU_index = bits.getBits(n);
             numBitsLeft -= n;

             if (headers.empty()) {
                 AU_serial = AU_index;
             } else {
                 AU_serial += 1 + AU_index;
             }

             if (mCTSDeltaLength > 0) {
                 if (numBitsLeft < 1) {
                     break;
                 }
                 --numBitsLeft;
                 if (bits.getBits(1)) {
                     if (numBitsLeft < mCTSDeltaLength) {
                         break;
                     }
                     bits.skipBits(mCTSDeltaLength);
                     numBitsLeft -= mCTSDeltaLength;
                 }
             }

             if (mDTSDeltaLength > 0) {
                 if (numBitsLeft < 1) {
                     break;
                 }
                 --numBitsLeft;
                 if (bits.getBits(1)) {
                     if (numBitsLeft < mDTSDeltaLength) {
                         break;
                     }
                     bits.skipBits(mDTSDeltaLength);
                     numBitsLeft -= mDTSDeltaLength;
                 }
             }

             if (mRandomAccessIndication) {
                 if (numBitsLeft < 1) {
                     break;
                 }
                 bits.skipBits(1);
                 --numBitsLeft;
             }

             if (mStreamStateIndication > 0) {
                 if (numBitsLeft < mStreamStateIndication) {
                     break;
                 }
                 bits.skipBits(mStreamStateIndication);
             }

             AUHeader header;
             header.mSize = AU_size;
             header.mSerial = AU_serial;
             headers.push_back(header);
         }

         size_t offset = 2 + (AU_headers_length + 7) / 8;

         if (mAuxiliaryDataSizeLength > 0) {
             ABitReader bits(buffer->data() + offset, buffer->size() - offset);

             unsigned auxSize = bits.getBits(mAuxiliaryDataSizeLength);
             if (buffer->size() < auxSize) {
                 ALOGE("b/123940919 auxSize %u", auxSize);
                 android_errorWriteLog(0x534e4554, "123940919");
                 queue->erase(queue->begin());
                 return MALFORMED_PACKET;
             }

             offset += (mAuxiliaryDataSizeLength + auxSize + 7) / 8;
         }

         for (List<AUHeader>::iterator it = headers.begin();
              it != headers.end(); ++it) {
             const AUHeader &header = *it;

             if (buffer->size() < header.mSize) {
                 ALOGE("b/123940919 AU_size %u", header.mSize);
                 android_errorWriteLog(0x534e4554, "123940919");
                 queue->erase(queue->begin());
                 return MALFORMED_PACKET;
             }
             if (buffer->size() < offset + header.mSize) {
                 android_errorWriteLog(0x534e4554, "124783982");
                 queue->erase(queue->begin());
                 return MALFORMED_PACKET;
             }

             sp<ABuffer> accessUnit = new ABuffer(header.mSize);
             memcpy(accessUnit->data(), buffer->data() + offset, header.mSize);

             offset += header.mSize;

             CopyTimes(accessUnit, buffer);
             mPackets.push_back(accessUnit);
         }

         if (offset != buffer->size()) {
             ALOGW("potentially malformed packet (offset %zu, size %zu)",
                     offset, buffer->size());
         }
     }

     queue->erase(queue->begin());
     ++mNextExpectedSeqNo;

     return OK;
 }

 void AMPEG4ElementaryAssembler::submitAccessUnit() {
     CHECK(!mPackets.empty());

     ALOGV("Access unit complete (%zu nal units)", mPackets.size());

     sp<ABuffer> accessUnit;

     if (mIsGeneric) {
         accessUnit = MakeADTSCompoundFromAACFrames(
                 OMX_AUDIO_AACObjectLC - 1,
                 mSampleRateIndex,
                 mChannelConfig,
                 mPackets);
     } else {
         accessUnit = MakeCompoundFromPackets(mPackets);
     }

 #if 0
     printf(mAccessUnitDamaged ? "X" : ".");
     fflush(stdout);
 #endif

     if (mAccessUnitDamaged) {
         accessUnit->meta()->setInt32("damaged", true);
     }

     mPackets.clear();
     mAccessUnitDamaged = false;

     sp<AMessage> msg = mNotifyMsg->dup();
     msg->setBuffer("access-unit", accessUnit);
     msg->post();
 }

 ARTPAssembler::AssemblyStatus AMPEG4ElementaryAssembler::assembleMore(
         const sp<ARTPSource> &source) {
     AssemblyStatus status = addPacket(source);
     if (status == MALFORMED_PACKET) {
         ALOGI("access unit is damaged");
         mAccessUnitDamaged = true;
     }
     return status;
 }

 void AMPEG4ElementaryAssembler::packetLost() {
     CHECK(mNextExpectedSeqNoValid);
     ALOGV("packetLost (expected %d)", mNextExpectedSeqNo);

     ++mNextExpectedSeqNo;

     mAccessUnitDamaged = true;
 }

 void AMPEG4ElementaryAssembler::onByeReceived() {
     sp<AMessage> msg = mNotifyMsg->dup();
     msg->setInt32("eos", true);
     msg->post();
 }

 }  // namespace android
	/*
	* Copyright (C) 2010 The Android Open Source Project
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	//#define LOG_NDEBUG 0
	#define LOG_TAG "AMPEG4ElementaryAssembler"
	#include <utils/Log.h>

	#include "AMPEG4ElementaryAssembler.h"

	#include "ARTPSource.h"
	#include "ASessionDescription.h"

	#include <media/stagefright/foundation/ABitReader.h>
	#include <media/stagefright/foundation/ABuffer.h>
	#include <media/stagefright/foundation/ADebug.h>
	#include <media/stagefright/foundation/AMessage.h>
	#include <media/stagefright/foundation/ByteUtils.h>
	#include <media/stagefright/foundation/hexdump.h>

	#include <ctype.h>
	#include <stdint.h>

	namespace android {

	static bool GetAttribute(const char s, const char key, AString *value) {
	value->clear();

	size_t keyLen = strlen(key);

	for (;;) {
	while (isspace(*s)) {
	++s;
	}

	const char *colonPos = strchr(s, ';');

	size_t len =
	(colonPos == NULL) ? strlen(s) : colonPos - s;

	if (len >= keyLen + 1 && s[keyLen] == '='
	&& !strncasecmp(s, key, keyLen)) {
	value->setTo(&s[keyLen + 1], len - keyLen - 1);
	return true;
	}

	if (colonPos == NULL) {
	return false;
	}

	s = colonPos + 1;
	}
	}

	static bool GetIntegerAttribute(
	const char s, const char key, unsigned *x) {
	*x = 0;

	AString val;
	if (!GetAttribute(s, key, &val)) {
	return false;
	}

	s = val.c_str();
	char *end;
	unsigned y = strtoul(s, &end, 10);

	if (end == s \|\| *end != '\0') {
	return false;
	}

	*x = y;

	return true;
	}

	static bool GetSampleRateIndex(int32_t sampleRate, size_t *tableIndex) {
	static const int32_t kSampleRateTable[] = {
	96000, 88200, 64000, 48000, 44100, 32000,
	24000, 22050, 16000, 12000, 11025, 8000
	};
	const size_t kNumSampleRates =
	sizeof(kSampleRateTable) / sizeof(kSampleRateTable[0]);

	*tableIndex = 0;
	for (size_t index = 0; index < kNumSampleRates; ++index) {
	if (sampleRate == kSampleRateTable[index]) {
	*tableIndex = index;
	return true;
	}
	}

	return false;
	}

	// static
	AMPEG4ElementaryAssembler::AMPEG4ElementaryAssembler(
	const sp<AMessage> &notify, const AString &desc, const AString &params)
	: mNotifyMsg(notify),
	mIsGeneric(false),
	mParams(params),
	mSizeLength(0),
	mIndexLength(0),
	mIndexDeltaLength(0),
	mCTSDeltaLength(0),
	mDTSDeltaLength(0),
	mRandomAccessIndication(false),
	mStreamStateIndication(0),
	mAuxiliaryDataSizeLength(0),
	mHasAUHeader(false),
	mChannelConfig(0),
	mSampleRateIndex(0),
	mAccessUnitRTPTime(0),
	mNextExpectedSeqNoValid(false),
	mNextExpectedSeqNo(0),
	mAccessUnitDamaged(false) {
	mIsGeneric = !strncasecmp(desc.c_str(),"mpeg4-generic/", 14);

	if (mIsGeneric) {
	AString value;
	CHECK(GetAttribute(params.c_str(), "mode", &value));

	if (!GetIntegerAttribute(params.c_str(), "sizeLength", &mSizeLength)) {
	mSizeLength = 0;
	}

	if (!GetIntegerAttribute(
	params.c_str(), "indexLength", &mIndexLength)) {
	mIndexLength = 0;
	}

	if (!GetIntegerAttribute(
	params.c_str(), "indexDeltaLength", &mIndexDeltaLength)) {
	mIndexDeltaLength = 0;
	}

	if (!GetIntegerAttribute(
	params.c_str(), "CTSDeltaLength", &mCTSDeltaLength)) {
	mCTSDeltaLength = 0;
	}

	if (!GetIntegerAttribute(
	params.c_str(), "DTSDeltaLength", &mDTSDeltaLength)) {
	mDTSDeltaLength = 0;
	}

	unsigned x;
	if (!GetIntegerAttribute(
	params.c_str(), "randomAccessIndication", &x)) {
	mRandomAccessIndication = false;
	} else {
	CHECK(x == 0 \|\| x == 1);
	mRandomAccessIndication = (x != 0);
	}

	if (!GetIntegerAttribute(
	params.c_str(), "streamStateIndication",
	&mStreamStateIndication)) {
	mStreamStateIndication = 0;
	}

	if (!GetIntegerAttribute(
	params.c_str(), "auxiliaryDataSizeLength",
	&mAuxiliaryDataSizeLength)) {
	mAuxiliaryDataSizeLength = 0;
	}

	mHasAUHeader =
	mSizeLength > 0
	\|\| mIndexLength > 0
	\|\| mIndexDeltaLength > 0
	\|\| mCTSDeltaLength > 0
	\|\| mDTSDeltaLength > 0
	\|\| mRandomAccessIndication
	\|\| mStreamStateIndication > 0;

	int32_t sampleRate, numChannels;
	ASessionDescription::ParseFormatDesc(
	desc.c_str(), &sampleRate, &numChannels);

	mChannelConfig = numChannels;
	CHECK(GetSampleRateIndex(sampleRate, &mSampleRateIndex));
	}
	}

	AMPEG4ElementaryAssembler::~AMPEG4ElementaryAssembler() {
	}

	struct AUHeader {
	unsigned mSize;
	unsigned mSerial;
	};

	bool AMPEG4ElementaryAssembler::initCheck() {
	if(mSizeLength == 0 \|\| mIndexLength == 0 \|\| mIndexDeltaLength == 0) {
	android_errorWriteLog(0x534e4554, "124777537");
	return false;
	}
	return true;
	}

	ARTPAssembler::AssemblyStatus AMPEG4ElementaryAssembler::addPacket(
	const sp<ARTPSource> &source) {
	List<sp<ABuffer> > *queue = source->queue();

	if (queue->empty()) {
	return NOT_ENOUGH_DATA;
	}

	if (mNextExpectedSeqNoValid) {
	List<sp<ABuffer> >::iterator it = queue->begin();
	while (it != queue->end()) {
	if ((uint32_t)(*it)->int32Data() >= mNextExpectedSeqNo) {
	break;
	}

	it = queue->erase(it);
	}

	if (queue->empty()) {
	return NOT_ENOUGH_DATA;
	}
	}

	sp<ABuffer> buffer = *queue->begin();

	if (!mNextExpectedSeqNoValid) {
	mNextExpectedSeqNoValid = true;
	mNextExpectedSeqNo = (uint32_t)buffer->int32Data();
	} else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) {
	ALOGV("Not the sequence number I expected");

	return WRONG_SEQUENCE_NUMBER;
	}

	uint32_t rtpTime;
	CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTime));

	if (mPackets.size() > 0 && rtpTime != mAccessUnitRTPTime) {
	submitAccessUnit();
	}
	mAccessUnitRTPTime = rtpTime;

	if (!mIsGeneric) {
	mPackets.push_back(buffer);
	} else {
	// hexdump(buffer->data(), buffer->size());
	if (buffer->size() < 2) {
	android_errorWriteLog(0x534e4554, "124783982");
	queue->erase(queue->begin());
	return MALFORMED_PACKET;
	}

	unsigned AU_headers_length = U16_AT(buffer->data()); // in bits

	if (buffer->size() < 2 + (AU_headers_length + 7) / 8) {
	android_errorWriteLog(0x534e4554, "124783982");
	queue->erase(queue->begin());
	return MALFORMED_PACKET;
	}

	List<AUHeader> headers;

	ABitReader bits(buffer->data() + 2, buffer->size() - 2);
	unsigned numBitsLeft = AU_headers_length;

	unsigned AU_serial = 0;
	for (;;) {
	if (numBitsLeft < mSizeLength) { break; }

	unsigned AU_size = bits.getBits(mSizeLength);
	numBitsLeft -= mSizeLength;

	size_t n = headers.empty() ? mIndexLength : mIndexDeltaLength;
	if (numBitsLeft < n) { break; }

	unsigned AU_index = bits.getBits(n);
	numBitsLeft -= n;

	if (headers.empty()) {
	AU_serial = AU_index;
	} else {
	AU_serial += 1 + AU_index;
	}

	if (mCTSDeltaLength > 0) {
	if (numBitsLeft < 1) {
	break;
	}
	--numBitsLeft;
	if (bits.getBits(1)) {
	if (numBitsLeft < mCTSDeltaLength) {
	break;
	}
	bits.skipBits(mCTSDeltaLength);
	numBitsLeft -= mCTSDeltaLength;
	}
	}

	if (mDTSDeltaLength > 0) {
	if (numBitsLeft < 1) {
	break;
	}
	--numBitsLeft;
	if (bits.getBits(1)) {
	if (numBitsLeft < mDTSDeltaLength) {
	break;
	}
	bits.skipBits(mDTSDeltaLength);
	numBitsLeft -= mDTSDeltaLength;
	}
	}

	if (mRandomAccessIndication) {
	if (numBitsLeft < 1) {
	break;
	}
	bits.skipBits(1);
	--numBitsLeft;
	}

	if (mStreamStateIndication > 0) {
	if (numBitsLeft < mStreamStateIndication) {
	break;
	}
	bits.skipBits(mStreamStateIndication);
	}

	AUHeader header;
	header.mSize = AU_size;
	header.mSerial = AU_serial;
	headers.push_back(header);
	}

	size_t offset = 2 + (AU_headers_length + 7) / 8;

	if (mAuxiliaryDataSizeLength > 0) {
	ABitReader bits(buffer->data() + offset, buffer->size() - offset);

	unsigned auxSize = bits.getBits(mAuxiliaryDataSizeLength);
	if (buffer->size() < auxSize) {
	ALOGE("b/123940919 auxSize %u", auxSize);
	android_errorWriteLog(0x534e4554, "123940919");
	queue->erase(queue->begin());
	return MALFORMED_PACKET;
	}

	offset += (mAuxiliaryDataSizeLength + auxSize + 7) / 8;
	}

	for (List<AUHeader>::iterator it = headers.begin();
	it != headers.end(); ++it) {
	const AUHeader &header = *it;

	if (buffer->size() < header.mSize) {
	ALOGE("b/123940919 AU_size %u", header.mSize);
	android_errorWriteLog(0x534e4554, "123940919");
	queue->erase(queue->begin());
	return MALFORMED_PACKET;
	}
	if (buffer->size() < offset + header.mSize) {
	android_errorWriteLog(0x534e4554, "124783982");
	queue->erase(queue->begin());
	return MALFORMED_PACKET;
	}

	sp<ABuffer> accessUnit = new ABuffer(header.mSize);
	memcpy(accessUnit->data(), buffer->data() + offset, header.mSize);

	offset += header.mSize;

	CopyTimes(accessUnit, buffer);
	mPackets.push_back(accessUnit);
	}

	if (offset != buffer->size()) {
	ALOGW("potentially malformed packet (offset %zu, size %zu)",
	offset, buffer->size());
	}
	}

	queue->erase(queue->begin());
	++mNextExpectedSeqNo;

	return OK;
	}

	void AMPEG4ElementaryAssembler::submitAccessUnit() {
	CHECK(!mPackets.empty());

	ALOGV("Access unit complete (%zu nal units)", mPackets.size());

	sp<ABuffer> accessUnit;

	if (mIsGeneric) {
	accessUnit = MakeADTSCompoundFromAACFrames(
	OMX_AUDIO_AACObjectLC - 1,
	mSampleRateIndex,
	mChannelConfig,
	mPackets);
	} else {
	accessUnit = MakeCompoundFromPackets(mPackets);
	}

	#if 0
	printf(mAccessUnitDamaged ? "X" : ".");
	fflush(stdout);
	#endif

	if (mAccessUnitDamaged) {
	accessUnit->meta()->setInt32("damaged", true);
	}

	mPackets.clear();
	mAccessUnitDamaged = false;

	sp<AMessage> msg = mNotifyMsg->dup();
	msg->setBuffer("access-unit", accessUnit);
	msg->post();
	}

	ARTPAssembler::AssemblyStatus AMPEG4ElementaryAssembler::assembleMore(
	const sp<ARTPSource> &source) {
	AssemblyStatus status = addPacket(source);
	if (status == MALFORMED_PACKET) {
	ALOGI("access unit is damaged");
	mAccessUnitDamaged = true;
	}
	return status;
	}

	void AMPEG4ElementaryAssembler::packetLost() {
	CHECK(mNextExpectedSeqNoValid);
	ALOGV("packetLost (expected %d)", mNextExpectedSeqNo);

	++mNextExpectedSeqNo;

	mAccessUnitDamaged = true;
	}

	void AMPEG4ElementaryAssembler::onByeReceived() {
	sp<AMessage> msg = mNotifyMsg->dup();
	msg->setInt32("eos", true);
	msg->post();
	}

	} // namespace android