diff options
author | Dave Burke <daveburke@google.com> | 2011-10-17 18:35:11 -0700 |
---|---|---|
committer | Android (Google) Code Review <android-gerrit@google.com> | 2011-10-17 18:35:11 -0700 |
commit | a038c14efdaa118e2d8c5b42584cb0bb5f3b2ec7 (patch) | |
tree | 5623607148e6570ce1b553df6688556cf3374c4d /media | |
parent | 0cc79c66329b9ffa7d7bdfafa5d245a11fd3660d (diff) | |
parent | 95c4d6034dc356f70c6293ea53d4858415b2d020 (diff) | |
download | frameworks_av-a038c14efdaa118e2d8c5b42584cb0bb5f3b2ec7.zip frameworks_av-a038c14efdaa118e2d8c5b42584cb0bb5f3b2ec7.tar.gz frameworks_av-a038c14efdaa118e2d8c5b42584cb0bb5f3b2ec7.tar.bz2 |
Merge "Don't hold onto the lock while reconnecting to the server" into ics-mr0
Diffstat (limited to 'media')
-rw-r--r-- | media/libstagefright/NuCachedSource2.cpp | 28 |
1 files changed, 18 insertions, 10 deletions
diff --git a/media/libstagefright/NuCachedSource2.cpp b/media/libstagefright/NuCachedSource2.cpp index 4f183f5..1e1de04 100644 --- a/media/libstagefright/NuCachedSource2.cpp +++ b/media/libstagefright/NuCachedSource2.cpp @@ -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); @@ -286,18 +288,24 @@ void NuCachedSource2::fetchInternal() { if (mFinalStatus != OK) { --mNumRetriesLeft; - status_t err = - mSource->reconnectAtOffset(mCacheOffset + mCache->totalSize()); + reconnect = true; + } + } - if (err == ERROR_UNSUPPORTED) { - mNumRetriesLeft = 0; - return; - } else if (err != OK) { - LOGI("The attempt to reconnect failed, %d retries remaining", - mNumRetriesLeft); + if (reconnect) { + status_t err = + mSource->reconnectAtOffset(mCacheOffset + mCache->totalSize()); - return; - } + Mutex::Autolock autoLock(mLock); + + if (err == ERROR_UNSUPPORTED) { + mNumRetriesLeft = 0; + return; + } else if (err != OK) { + LOGI("The attempt to reconnect failed, %d retries remaining", + mNumRetriesLeft); + + return; } } |