Loading media/libstagefright/rtsp/AMPEG4ElementaryAssembler.cpp +8 −0 Original line number Diff line number Diff line Loading @@ -203,6 +203,14 @@ struct AUHeader { 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(); Loading media/libstagefright/rtsp/AMPEG4ElementaryAssembler.h +1 −0 Original line number Diff line number Diff line Loading @@ -36,6 +36,7 @@ struct AMPEG4ElementaryAssembler : public ARTPAssembler { AMPEG4ElementaryAssembler( const sp<AMessage> ¬ify, const AString &desc, const AString ¶ms); virtual bool initCheck(); protected: virtual ~AMPEG4ElementaryAssembler(); Loading media/libstagefright/rtsp/ARTPAssembler.h +1 −0 Original line number Diff line number Diff line Loading @@ -39,6 +39,7 @@ struct ARTPAssembler : public RefBase { void onPacketReceived(const sp<ARTPSource> &source); virtual void onByeReceived() = 0; virtual bool initCheck() { return true; } protected: virtual AssemblyStatus assembleMore(const sp<ARTPSource> &source) = 0; Loading media/libstagefright/rtsp/ARTPSource.cpp +8 −2 Original line number Diff line number Diff line Loading @@ -82,6 +82,10 @@ ARTPSource::ARTPSource( } else { TRESPASS(); } if (mAssembler != NULL && !mAssembler->initCheck()) { mAssembler.clear(); } } static uint32_t AbsDiff(uint32_t seq1, uint32_t seq2) { Loading @@ -89,7 +93,7 @@ static uint32_t AbsDiff(uint32_t seq1, uint32_t seq2) { } void ARTPSource::processRTPPacket(const sp<ABuffer> &buffer) { if (queuePacket(buffer) && mAssembler != NULL) { if (mAssembler != NULL && queuePacket(buffer)) { mAssembler->onPacketReceived(this); } } Loading Loading @@ -171,8 +175,10 @@ bool ARTPSource::queuePacket(const sp<ABuffer> &buffer) { } void ARTPSource::byeReceived() { if (mAssembler != NULL) { mAssembler->onByeReceived(); } } void ARTPSource::addFIR(const sp<ABuffer> &buffer) { if (!mIssueFIRRequests) { Loading Loading
media/libstagefright/rtsp/AMPEG4ElementaryAssembler.cpp +8 −0 Original line number Diff line number Diff line Loading @@ -203,6 +203,14 @@ struct AUHeader { 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(); Loading
media/libstagefright/rtsp/AMPEG4ElementaryAssembler.h +1 −0 Original line number Diff line number Diff line Loading @@ -36,6 +36,7 @@ struct AMPEG4ElementaryAssembler : public ARTPAssembler { AMPEG4ElementaryAssembler( const sp<AMessage> ¬ify, const AString &desc, const AString ¶ms); virtual bool initCheck(); protected: virtual ~AMPEG4ElementaryAssembler(); Loading
media/libstagefright/rtsp/ARTPAssembler.h +1 −0 Original line number Diff line number Diff line Loading @@ -39,6 +39,7 @@ struct ARTPAssembler : public RefBase { void onPacketReceived(const sp<ARTPSource> &source); virtual void onByeReceived() = 0; virtual bool initCheck() { return true; } protected: virtual AssemblyStatus assembleMore(const sp<ARTPSource> &source) = 0; Loading
media/libstagefright/rtsp/ARTPSource.cpp +8 −2 Original line number Diff line number Diff line Loading @@ -82,6 +82,10 @@ ARTPSource::ARTPSource( } else { TRESPASS(); } if (mAssembler != NULL && !mAssembler->initCheck()) { mAssembler.clear(); } } static uint32_t AbsDiff(uint32_t seq1, uint32_t seq2) { Loading @@ -89,7 +93,7 @@ static uint32_t AbsDiff(uint32_t seq1, uint32_t seq2) { } void ARTPSource::processRTPPacket(const sp<ABuffer> &buffer) { if (queuePacket(buffer) && mAssembler != NULL) { if (mAssembler != NULL && queuePacket(buffer)) { mAssembler->onPacketReceived(this); } } Loading Loading @@ -171,8 +175,10 @@ bool ARTPSource::queuePacket(const sp<ABuffer> &buffer) { } void ARTPSource::byeReceived() { if (mAssembler != NULL) { mAssembler->onByeReceived(); } } void ARTPSource::addFIR(const sp<ABuffer> &buffer) { if (!mIssueFIRRequests) { Loading