Merge changes from topic "av_rtp_measure" into sc-dev am: e2a52b0cee (5f20072f) · Commits · e / os / android_frameworks_av

media/libmediaplayerservice/nuplayer/NuPlayer.cpp

+44 −0

Original line number	Diff line number	Diff line
		@@ -2856,10 +2856,43 @@ void NuPlayer::sendIMSRxNotice(const sp<AMessage> &msg) {

		CHECK(msg->findInt32("payload-type", &payloadType));

		int32_t rtpSeq = 0, rtpTime = 0;
		int64_t ntpTime = 0, recvTimeUs = 0;

		Parcel in;
		in.writeInt32(payloadType);

		switch (payloadType) {
		case ARTPSource::RTP_FIRST_PACKET:
		{
		CHECK(msg->findInt32("rtp-time", &rtpTime));
		CHECK(msg->findInt32("rtp-seq-num", &rtpSeq));
		CHECK(msg->findInt64("recv-time-us", &recvTimeUs));
		in.writeInt32(rtpTime);
		in.writeInt32(rtpSeq);
		in.writeInt32(recvTimeUs >> 32);
		in.writeInt32(recvTimeUs & 0xFFFFFFFF);
		break;
		}
		case ARTPSource::RTCP_FIRST_PACKET:
		{
		CHECK(msg->findInt64("recv-time-us", &recvTimeUs));
		in.writeInt32(recvTimeUs >> 32);
		in.writeInt32(recvTimeUs & 0xFFFFFFFF);
		break;
		}
		case ARTPSource::RTCP_SR:
		{
		CHECK(msg->findInt32("rtp-time", &rtpTime));
		CHECK(msg->findInt64("ntp-time", &ntpTime));
		CHECK(msg->findInt64("recv-time-us", &recvTimeUs));
		in.writeInt32(rtpTime);
		in.writeInt32(ntpTime >> 32);
		in.writeInt32(ntpTime & 0xFFFFFFFF);
		in.writeInt32(recvTimeUs >> 32);
		in.writeInt32(recvTimeUs & 0xFFFFFFFF);
		break;
		}
		case ARTPSource::RTCP_TSFB: // RTCP TSFB
		case ARTPSource::RTCP_PSFB: // RTCP PSFB
		case ARTPSource::RTP_AUTODOWN:
		@@ -2882,6 +2915,8 @@ void NuPlayer::sendIMSRxNotice(const sp<AMessage> &msg) {
		int32_t feedbackType, bitrate;
		int32_t highestSeqNum, baseSeqNum, prevExpected;
		int32_t numBufRecv, prevNumBufRecv;
		int32_t latestRtpTime, jbTimeMs, rtpRtcpSrTimeGapMs;
		int64_t recvTimeUs;
		CHECK(msg->findInt32("feedback-type", &feedbackType));
		CHECK(msg->findInt32("bit-rate", &bitrate));
		CHECK(msg->findInt32("highest-seq-num", &highestSeqNum));
		@@ -2889,6 +2924,10 @@ void NuPlayer::sendIMSRxNotice(const sp<AMessage> &msg) {
		CHECK(msg->findInt32("prev-expected", &prevExpected));
		CHECK(msg->findInt32("num-buf-recv", &numBufRecv));
		CHECK(msg->findInt32("prev-num-buf-recv", &prevNumBufRecv));
		CHECK(msg->findInt32("latest-rtp-time", &latestRtpTime));
		CHECK(msg->findInt64("recv-time-us", &recvTimeUs));
		CHECK(msg->findInt32("rtp-jitter-time-ms", &jbTimeMs));
		CHECK(msg->findInt32("rtp-rtcpsr-time-gap-ms", &rtpRtcpSrTimeGapMs));
		in.writeInt32(feedbackType);
		in.writeInt32(bitrate);
		in.writeInt32(highestSeqNum);
		@@ -2896,6 +2935,11 @@ void NuPlayer::sendIMSRxNotice(const sp<AMessage> &msg) {
		in.writeInt32(prevExpected);
		in.writeInt32(numBufRecv);
		in.writeInt32(prevNumBufRecv);
		in.writeInt32(latestRtpTime);
		in.writeInt32(recvTimeUs >> 32);
		in.writeInt32(recvTimeUs & 0xFFFFFFFF);
		in.writeInt32(jbTimeMs);
		in.writeInt32(rtpRtcpSrTimeGapMs);
		break;
		}
		case ARTPSource::RTP_CVO:

media/libmediaplayerservice/nuplayer/RTPSource.cpp

+2 −12

Original line number	Diff line number	Diff line
		@@ -395,23 +395,13 @@ void NuPlayer::RTPSource::onMessageReceived(const sp<AMessage> &msg) {
		CHECK(msg->findInt64("ntp-time", (int64_t *)&ntpTime));

		onTimeUpdate(trackIndex, rtpTime, ntpTime);
		break;
		}

		int32_t firstRTCP;
		if (msg->findInt32("first-rtcp", &firstRTCP)) {
		// There won't be an access unit here, it's just a notification
		// that the data communication worked since we got the first
		// rtcp packet.
		ALOGV("first-rtcp");
		break;
		}

		int32_t IMSRxNotice;
		if (msg->findInt32("rtcp-event", &IMSRxNotice)) {
		int32_t payloadType, feedbackType;
		int32_t payloadType = 0, feedbackType = 0;
		CHECK(msg->findInt32("payload-type", &payloadType));
		CHECK(msg->findInt32("feedback-type", &feedbackType));
		msg->findInt32("feedback-type", &feedbackType);

		sp<AMessage> notify = dupNotify();
		notify->setInt32("what", kWhatIMSRxNotice);

media/libstagefright/rtsp/AAVCAssembler.cpp

+49 −61

Original line number	Diff line number	Diff line
		@@ -44,6 +44,7 @@ AAVCAssembler::AAVCAssembler(const sp<AMessage> &notify)
		mNextExpectedSeqNo(0),
		mAccessUnitDamaged(false),
		mFirstIFrameProvided(false),
		mLastCvo(-1),
		mLastIFrameProvidedAtMs(0),
		mLastRtpTimeJitterDataUs(0),
		mWidth(0),
		@@ -137,7 +138,7 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addNALUnit(
		}
		source->putInterArrivalJitterData(rtpTime, nowTimeUs);

		const int64_t startTimeMs = source->mFirstSysTime / 1000;
		const int64_t startTimeMs = source->mSysAnchorTime / 1000;
		const int64_t nowTimeMs = nowTimeUs / 1000;
		const int32_t staticJitterTimeMs = source->getStaticJitterTimeMs();
		const int32_t baseJitterTimeMs = source->getBaseJitterTimeMs();
		@@ -195,33 +196,38 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addNALUnit(

		if (!isExpired) {
		ALOGV("buffering in jitter buffer.");
		// set an alarm for jitter buffer time expiration.
		// adding 1ms because jitter buffer time is keep changing.
		int64_t expTimeUs = (RtpToMs(std::abs(diffTimeRtp), clockRate) + 1) * 1000;
		source->setJbAlarmTime(nowTimeUs, expTimeUs);
		return NOT_ENOUGH_DATA;
		}

		if (isFirstLineBroken) {
		if (isSecondLineBroken) {
		int64_t totalDiffTimeMs = RtpToMs(diffTimeRtp + jitterTimeRtp, clockRate);
		ALOGE("buffer too late... \t RTP diff from exp =%lld \t MS diff from stamp = %lld\t\t"
		String8 info;
		info.appendFormat("RTP diff from exp =%lld \t MS diff from stamp = %lld\t\t"
		"Seq# %d \t ExpSeq# %d \t"
		"JitterMs %d + (%d + %d * %.3f)",
		(long long)diffTimeRtp, (long long)totalDiffTimeMs,
		buffer->int32Data(), mNextExpectedSeqNo,
		jitterTimeMs, tryJbTimeMs, dynamicJbTimeMs, JITTER_MULTIPLE);
		if (isSecondLineBroken) {
		ALOGE("%s", info.string());
		printNowTimeMs(startTimeMs, nowTimeMs, playedTimeMs);
		printRTPTime(rtpTime, playedTimeRtp, expiredTimeRtp, isExpired);

		mNextExpectedSeqNo = pickProperSeq(queue, firstRTPTime, playedTimeRtp, jitterTimeRtp);
		} else {
		ALOGW("=== WARNING === buffer arrived after %d + %d = %d ms === WARNING === ",
		jitterTimeMs, tryJbTimeMs, jitterTimeMs + tryJbTimeMs);
		ALOGW("%s", info.string());
		}
		}

		if (mNextExpectedSeqNoValid) {
		int32_t size = queue->size();
		mNextExpectedSeqNo = pickStartSeq(queue, firstRTPTime, playedTimeRtp, jitterTimeRtp);
		int32_t cntRemove = deleteUnitUnderSeq(queue, mNextExpectedSeqNo);

		if (cntRemove > 0) {
		int32_t size = queue->size();
		source->noticeAbandonBuffer(cntRemove);
		ALOGW("delete %d of %d buffers", cntRemove, size);
		}
		@@ -441,7 +447,6 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addFragmentedNALUnit(
		uint32_t rtpTimeStartAt;
		CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTimeStartAt));
		uint32_t startSeqNo = buffer->int32Data();
		bool pFrame = nalType == 0x1;

		if (data[1] & 0x40) {
		// Huh? End bit also set on the first buffer.
		@@ -451,8 +456,6 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addFragmentedNALUnit(
		complete = true;
		} else {
		List<sp<ABuffer> >::iterator it = ++queue->begin();
		int32_t connected = 1;
		bool snapped = false;
		while (it != queue->end()) {
		ALOGV("sequence length %zu", totalCount);

		@@ -463,33 +466,26 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addFragmentedNALUnit(

		if ((uint32_t)buffer->int32Data() != expectedSeqNo) {
		ALOGD("sequence not complete, expected seqNo %u, got %u, nalType %u",
		expectedSeqNo, (unsigned)buffer->int32Data(), nalType);
		snapped = true;

		if (!pFrame) {
		return WRONG_SEQUENCE_NUMBER;
		}
		}

		if (!snapped) {
		connected++;
		expectedSeqNo, (uint32_t)buffer->int32Data(), nalType);
		}

		uint32_t rtpTime;
		CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTime));
		if (size < 2
		\|\| data[0] != indicator
		if (size < 2) {
		ALOGV("Ignoring malformed FU buffer.");
		it = queue->erase(it);
		continue;
		}
		if (data[0] != indicator
		\|\| (data[1] & 0x1f) != nalType
		\|\| (data[1] & 0x80)
		\|\| rtpTime != rtpTimeStartAt) {
		ALOGV("Ignoring malformed FU buffer.");

		// Delete the whole start of the FU.

		mNextExpectedSeqNo = expectedSeqNo + 1;
		deleteUnitUnderSeq(queue, mNextExpectedSeqNo);

		return MALFORMED_PACKET;
		// Assembler already have given enough time by jitter buffer
		ALOGD("Seems another frame. Incomplete frame [%d ~ %d) \t %d FUs",
		startSeqNo, expectedSeqNo, (int)queue->distance(queue->begin(), it));
		expectedSeqNo = (uint32_t)buffer->int32Data();
		complete = true;
		break;
		}

		totalSize += size - 2;
		@@ -498,14 +494,6 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addFragmentedNALUnit(
		expectedSeqNo = (uint32_t)buffer->int32Data() + 1;

		if (data[1] & 0x40) {
		if (pFrame && !recycleUnit(startSeqNo, expectedSeqNo,
		connected, totalCount, 0.5f)) {
		mNextExpectedSeqNo = expectedSeqNo;
		deleteUnitUnderSeq(queue, mNextExpectedSeqNo);

		return MALFORMED_PACKET;
		}

		// This is the last fragment.
		complete = true;
		break;
		@@ -557,6 +545,9 @@ ARTPAssembler::AssemblyStatus AAVCAssembler::addFragmentedNALUnit(

		if (cvo >= 0) {
		unit->meta()->setInt32("cvo", cvo);
		mLastCvo = cvo;
		} else if (mLastCvo >= 0) {
		unit->meta()->setInt32("cvo", mLastCvo);
		}
		if (source != nullptr) {
		unit->meta()->setObject("source", source);
		@@ -621,35 +612,32 @@ void AAVCAssembler::submitAccessUnit() {
		msg->post();
		}

		int32_t AAVCAssembler::pickProperSeq(const Queue *queue,
		int32_t AAVCAssembler::pickStartSeq(const Queue *queue,
		uint32_t first, int64_t play, int64_t jit) {
		// pick the first sequence number has the start bit.
		sp<ABuffer> buffer = *(queue->begin());
		int32_t nextSeqNo = buffer->int32Data();
		int32_t firstSeqNo = buffer->int32Data();

		Queue::const_iterator it = queue->begin();
		while (it != queue->end()) {
		int64_t rtpTime = findRTPTime(first, *it);
		// if pkt in time exists, that should be the next pivot
		// This only works for FU-A type & non-start sequence
		unsigned nalType = buffer->data()[0] & 0x1f;
		if (nalType != 28 \|\| buffer->data()[1] & 0x80) {
		return firstSeqNo;
		}

		for (auto it : *queue) {
		const uint8_t *data = it->data();
		int64_t rtpTime = findRTPTime(first, it);
		if (rtpTime + jit >= play) {
		nextSeqNo = (*it)->int32Data();
		break;
		}
		it++;
		if ((data[1] & 0x80)) {
		const int32_t seqNo = it->int32Data();
		ALOGE("finding [HEAD] pkt. \t Seq# (%d ~ )[%d", firstSeqNo, seqNo);
		firstSeqNo = seqNo;
		break;
		}
		return nextSeqNo;
		}

		bool AAVCAssembler::recycleUnit(uint32_t start, uint32_t end, uint32_t connected,
		size_t avail, float goodRatio) {
		float total = end - start;
		float valid = connected;
		float exist = avail;
		bool isRecycle = (valid / total) >= goodRatio;

		ALOGV("checking p-frame losses.. recvBufs %f valid %f diff %f recycle? %d",
		exist, valid, total, isRecycle);

		return isRecycle;
		return firstSeqNo;
		}

		int32_t AAVCAssembler::deleteUnitUnderSeq(Queue *queue, uint32_t seq) {

media/libstagefright/rtsp/AAVCAssembler.h

+3 −3

Original line number	Diff line number	Diff line
		@@ -22,6 +22,7 @@

		#include <utils/List.h>
		#include <utils/RefBase.h>
		#include <utils/String8.h>

		namespace android {

		@@ -47,6 +48,7 @@ private:
		uint32_t mNextExpectedSeqNo;
		bool mAccessUnitDamaged;
		bool mFirstIFrameProvided;
		int32_t mLastCvo;
		uint64_t mLastIFrameProvidedAtMs;
		int64_t mLastRtpTimeJitterDataUs;
		int32_t mWidth;
		@@ -64,9 +66,7 @@ private:

		void submitAccessUnit();

		int32_t pickProperSeq(const Queue *q, uint32_t first, int64_t play, int64_t jit);
		bool recycleUnit(uint32_t start, uint32_t end, uint32_t connected,
		size_t avail, float goodRatio);
		int32_t pickStartSeq(const Queue *q, uint32_t first, int64_t play, int64_t jit);
		int32_t deleteUnitUnderSeq(Queue *q, uint32_t seq);

		DISALLOW_EVIL_CONSTRUCTORS(AAVCAssembler);

media/libstagefright/rtsp/AHEVCAssembler.cpp

+49 −60

Original line number	Diff line number	Diff line
		@@ -51,6 +51,7 @@ AHEVCAssembler::AHEVCAssembler(const sp<AMessage> &notify)
		mNextExpectedSeqNo(0),
		mAccessUnitDamaged(false),
		mFirstIFrameProvided(false),
		mLastCvo(-1),
		mLastIFrameProvidedAtMs(0),
		mLastRtpTimeJitterDataUs(0),
		mWidth(0),
		@@ -147,7 +148,7 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addNALUnit(
		}
		source->putInterArrivalJitterData(rtpTime, nowTimeUs);

		const int64_t startTimeMs = source->mFirstSysTime / 1000;
		const int64_t startTimeMs = source->mSysAnchorTime / 1000;
		const int64_t nowTimeMs = nowTimeUs / 1000;
		const int32_t staticJitterTimeMs = source->getStaticJitterTimeMs();
		const int32_t baseJitterTimeMs = source->getBaseJitterTimeMs();
		@@ -205,33 +206,38 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addNALUnit(

		if (!isExpired) {
		ALOGV("buffering in jitter buffer.");
		// set an alarm for jitter buffer time expiration.
		// adding 1ms because jitter buffer time is keep changing.
		int64_t expTimeUs = (RtpToMs(std::abs(diffTimeRtp), clockRate) + 1) * 1000;
		source->setJbAlarmTime(nowTimeUs, expTimeUs);
		return NOT_ENOUGH_DATA;
		}

		if (isFirstLineBroken) {
		if (isSecondLineBroken) {
		int64_t totalDiffTimeMs = RtpToMs(diffTimeRtp + jitterTimeRtp, clockRate);
		ALOGE("buffer too late... \t RTP diff from exp =%lld \t MS diff from stamp = %lld\t\t"
		String8 info;
		info.appendFormat("RTP diff from exp =%lld \t MS diff from stamp = %lld\t\t"
		"Seq# %d \t ExpSeq# %d \t"
		"JitterMs %d + (%d + %d * %.3f)",
		(long long)diffTimeRtp, (long long)totalDiffTimeMs,
		buffer->int32Data(), mNextExpectedSeqNo,
		jitterTimeMs, tryJbTimeMs, dynamicJbTimeMs, JITTER_MULTIPLE);
		if (isSecondLineBroken) {
		ALOGE("%s", info.string());
		printNowTimeMs(startTimeMs, nowTimeMs, playedTimeMs);
		printRTPTime(rtpTime, playedTimeRtp, expiredTimeRtp, isExpired);

		mNextExpectedSeqNo = pickProperSeq(queue, firstRTPTime, playedTimeRtp, jitterTimeRtp);
		} else {
		ALOGW("=== WARNING === buffer arrived after %d + %d = %d ms === WARNING === ",
		jitterTimeMs, tryJbTimeMs, jitterTimeMs + tryJbTimeMs);
		ALOGW("%s", info.string());
		}
		}

		if (mNextExpectedSeqNoValid) {
		int32_t size = queue->size();
		mNextExpectedSeqNo = pickStartSeq(queue, firstRTPTime, playedTimeRtp, jitterTimeRtp);
		int32_t cntRemove = deleteUnitUnderSeq(queue, mNextExpectedSeqNo);

		if (cntRemove > 0) {
		int32_t size = queue->size();
		source->noticeAbandonBuffer(cntRemove);
		ALOGW("delete %d of %d buffers", cntRemove, size);
		}
		@@ -466,7 +472,6 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addFragmentedNALUnit(
		uint32_t rtpTimeStartAt;
		CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTimeStartAt));
		uint32_t startSeqNo = buffer->int32Data();
		bool pFrame = (nalType < 0x10);

		if (data[2] & 0x40) {
		// Huh? End bit also set on the first buffer.
		@@ -476,8 +481,6 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addFragmentedNALUnit(
		complete = true;
		} else {
		List<sp<ABuffer> >::iterator it = ++queue->begin();
		int32_t connected = 1;
		bool snapped = false;
		while (it != queue->end()) {
		ALOGV("sequence length %zu", totalCount);

		@@ -488,33 +491,26 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addFragmentedNALUnit(

		if ((uint32_t)buffer->int32Data() != expectedSeqNo) {
		ALOGV("sequence not complete, expected seqNo %u, got %u, nalType %u",
		expectedSeqNo, (uint32_t)buffer->int32Data(), nalType);
		snapped = true;

		if (!pFrame) {
		return WRONG_SEQUENCE_NUMBER;
		}
		}

		if (!snapped) {
		connected++;
		expectedSeqNo, (unsigned)buffer->int32Data(), nalType);
		}

		uint32_t rtpTime;
		CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTime));
		if (size < 3
		\|\| ((data[0] >> 1) & H265_NALU_MASK) != indicator
		if (size < 3) {
		ALOGV("Ignoring malformed FU buffer.");
		it = queue->erase(it);
		continue;
		}
		if (((data[0] >> 1) & H265_NALU_MASK) != indicator
		\|\| (data[2] & H265_NALU_MASK) != nalType
		\|\| (data[2] & 0x80)
		\|\| rtpTime != rtpTimeStartAt) {
		ALOGV("Ignoring malformed FU buffer.");

		// Delete the whole start of the FU.

		mNextExpectedSeqNo = expectedSeqNo + 1;
		deleteUnitUnderSeq(queue, mNextExpectedSeqNo);

		return MALFORMED_PACKET;
		// Assembler already have given enough time by jitter buffer
		ALOGD("Seems another frame. Incomplete frame [%d ~ %d) \t %d FUs",
		startSeqNo, expectedSeqNo, (int)queue->distance(queue->begin(), it));
		expectedSeqNo = (uint32_t)buffer->int32Data();
		complete = true;
		break;
		}

		totalSize += size - 3;
		@@ -523,13 +519,6 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addFragmentedNALUnit(
		expectedSeqNo = (uint32_t)buffer->int32Data() + 1;

		if (data[2] & 0x40) {
		if (pFrame && !recycleUnit(startSeqNo, expectedSeqNo,
		connected, totalCount, 0.5f)) {
		mNextExpectedSeqNo = expectedSeqNo;
		deleteUnitUnderSeq(queue, mNextExpectedSeqNo);

		return MALFORMED_PACKET;
		}
		// This is the last fragment.
		complete = true;
		break;
		@@ -579,6 +568,9 @@ ARTPAssembler::AssemblyStatus AHEVCAssembler::addFragmentedNALUnit(

		if (cvo >= 0) {
		unit->meta()->setInt32("cvo", cvo);
		mLastCvo = cvo;
		} else if (mLastCvo >= 0) {
		unit->meta()->setInt32("cvo", mLastCvo);
		}

		addSingleNALUnit(unit);
		@@ -635,35 +627,32 @@ void AHEVCAssembler::submitAccessUnit() {
		msg->post();
		}

		int32_t AHEVCAssembler::pickProperSeq(const Queue *queue,
		int32_t AHEVCAssembler::pickStartSeq(const Queue *queue,
		uint32_t first, int64_t play, int64_t jit) {
		// pick the first sequence number has the start bit.
		sp<ABuffer> buffer = *(queue->begin());
		int32_t nextSeqNo = buffer->int32Data();
		int32_t firstSeqNo = buffer->int32Data();

		Queue::const_iterator it = queue->begin();
		while (it != queue->end()) {
		int64_t rtpTime = findRTPTime(first, *it);
		// if pkt in time exists, that should be the next pivot
		// This only works for FU-A type & non-start sequence
		unsigned nalType = buffer->data()[0] & 0x1f;
		if (nalType != 28 \|\| buffer->data()[2] & 0x80) {
		return firstSeqNo;
		}

		for (auto it : *queue) {
		const uint8_t *data = it->data();
		int64_t rtpTime = findRTPTime(first, it);
		if (rtpTime + jit >= play) {
		nextSeqNo = (*it)->int32Data();
		break;
		}
		it++;
		if ((data[2] & 0x80)) {
		const int32_t seqNo = it->int32Data();
		ALOGE("finding [HEAD] pkt. \t Seq# (%d ~ )[%d", firstSeqNo, seqNo);
		firstSeqNo = seqNo;
		break;
		}
		return nextSeqNo;
		}

		bool AHEVCAssembler::recycleUnit(uint32_t start, uint32_t end, uint32_t connected,
		size_t avail, float goodRatio) {
		float total = end - start;
		float valid = connected;
		float exist = avail;
		bool isRecycle = (valid / total) >= goodRatio;

		ALOGV("checking p-frame losses.. recvBufs %f valid %f diff %f recycle? %d",
		exist, valid, total, isRecycle);

		return isRecycle;
		return firstSeqNo;
		}

		int32_t AHEVCAssembler::deleteUnitUnderSeq(Queue *queue, uint32_t seq) {