diff options
| author | 2012-12-06 18:37:24 -0800 | |
|---|---|---|
| committer | 2012-12-06 18:37:24 -0800 | |
| commit | 3ed2736c10efb2f18062591e308036837d9725a4 (patch) | |
| tree | 4449607d96267c7ce65091459afc7d389d33aac2 /libs/gui/ConsumerBase.cpp | |
| parent | 98cbec81be1d39223e33abde9ac35e43b62918bf (diff) | |
| parent | b21a4e3b5f7f07ed160ca6e1809313e2a8e2a6a4 (diff) | |
am b21a4e3b: ConsumerBase: free buffers outside the lock
* commit 'b21a4e3b5f7f07ed160ca6e1809313e2a8e2a6a4':
  ConsumerBase: free buffers outside the lock
Diffstat (limited to 'libs/gui/ConsumerBase.cpp')
| -rw-r--r-- | libs/gui/ConsumerBase.cpp | 34 | 
1 files changed, 24 insertions, 10 deletions
| diff --git a/libs/gui/ConsumerBase.cpp b/libs/gui/ConsumerBase.cpp index 624d7e0156..cfc0293189 100644 --- a/libs/gui/ConsumerBase.cpp +++ b/libs/gui/ConsumerBase.cpp @@ -109,21 +109,35 @@ void ConsumerBase::onFrameAvailable() {  }  void ConsumerBase::onBuffersReleased() { -    Mutex::Autolock lock(mMutex); +    sp<GraphicBuffer> bufRefs[BufferQueue::NUM_BUFFER_SLOTS]; + +    { // Scope for the lock +        Mutex::Autolock lock(mMutex); + +        CB_LOGV("onBuffersReleased"); -    CB_LOGV("onBuffersReleased"); +        if (mAbandoned) { +            // Nothing to do if we're already abandoned. +            return; +        } + +        uint32_t mask = 0; +        mBufferQueue->getReleasedBuffers(&mask); +        for (int i = 0; i < BufferQueue::NUM_BUFFER_SLOTS; i++) { +            if (mask & (1 << i)) { +                // Grab a local reference to the buffers so that they don't +                // get freed while the lock is held. +                bufRefs[i] = mSlots[i].mGraphicBuffer; -    if (mAbandoned) { -        // Nothing to do if we're already abandoned. -        return; +                freeBufferLocked(i); +            } +        }      } -    uint32_t mask = 0; -    mBufferQueue->getReleasedBuffers(&mask); +    // Clear the local buffer references.  This would happen automatically +    // when the array gets dtor'd, but I'm doing it explicitly for clarity.      for (int i = 0; i < BufferQueue::NUM_BUFFER_SLOTS; i++) { -        if (mask & (1 << i)) { -            freeBufferLocked(i); -        } +        bufRefs[i].clear();      }  } |