Loading media/libstagefright/NuCachedSource2.cpp +18 −10 Original line number Diff line number Diff line Loading @@ -279,6 +279,8 @@ void NuCachedSource2::onMessageReceived(const sp<AMessage> &msg) { void NuCachedSource2::fetchInternal() { LOGV("fetchInternal"); bool reconnect = false; { Mutex::Autolock autoLock(mLock); CHECK(mFinalStatus == OK || mNumRetriesLeft > 0); Loading @@ -286,9 +288,16 @@ void NuCachedSource2::fetchInternal() { if (mFinalStatus != OK) { --mNumRetriesLeft; reconnect = true; } } if (reconnect) { status_t err = mSource->reconnectAtOffset(mCacheOffset + mCache->totalSize()); Mutex::Autolock autoLock(mLock); if (err == ERROR_UNSUPPORTED) { mNumRetriesLeft = 0; return; Loading @@ -299,7 +308,6 @@ void NuCachedSource2::fetchInternal() { return; } } } PageCache::Page *page = mCache->acquirePage(); Loading Loading
media/libstagefright/NuCachedSource2.cpp +18 −10 Original line number Diff line number Diff line Loading @@ -279,6 +279,8 @@ void NuCachedSource2::onMessageReceived(const sp<AMessage> &msg) { void NuCachedSource2::fetchInternal() { LOGV("fetchInternal"); bool reconnect = false; { Mutex::Autolock autoLock(mLock); CHECK(mFinalStatus == OK || mNumRetriesLeft > 0); Loading @@ -286,9 +288,16 @@ void NuCachedSource2::fetchInternal() { if (mFinalStatus != OK) { --mNumRetriesLeft; reconnect = true; } } if (reconnect) { status_t err = mSource->reconnectAtOffset(mCacheOffset + mCache->totalSize()); Mutex::Autolock autoLock(mLock); if (err == ERROR_UNSUPPORTED) { mNumRetriesLeft = 0; return; Loading @@ -299,7 +308,6 @@ void NuCachedSource2::fetchInternal() { return; } } } PageCache::Page *page = mCache->acquirePage(); Loading