Loading media/libstagefright/TimedEventQueue.cpp +6 −5 Original line number Diff line number Diff line Loading @@ -127,6 +127,7 @@ TimedEventQueue::event_id TimedEventQueue::postTimedEvent( QueueItem item; item.event = event; item.realtime_us = realtime_us; item.has_wakelock = false; if (it == mQueue.begin()) { mQueueHeadChangedCondition.signal(); Loading @@ -134,7 +135,7 @@ TimedEventQueue::event_id TimedEventQueue::postTimedEvent( if (realtime_us > ALooper::GetNowUs() + kWakelockMinDelay) { acquireWakeLock_l(); event->setWakeLock(); item.has_wakelock = true; } mQueue.insert(it, item); Loading Loading @@ -190,7 +191,7 @@ void TimedEventQueue::cancelEvents( ALOGV("cancelling event %d", (*it).event->eventID()); (*it).event->setEventID(0); if ((*it).event->hasWakeLock()) { if ((*it).has_wakelock) { releaseWakeLock_l(); } it = mQueue.erase(it); Loading Loading @@ -288,9 +289,6 @@ void TimedEventQueue::threadEntry() { if (event != NULL) { // Fire event with the lock NOT held. event->fire(this, now_us); if (event->hasWakeLock()) { releaseWakeLock_l(); } } } } Loading @@ -302,6 +300,9 @@ sp<TimedEventQueue::Event> TimedEventQueue::removeEventFromQueue_l( if ((*it).event->eventID() == id) { sp<Event> event = (*it).event; event->setEventID(0); if ((*it).has_wakelock) { releaseWakeLock_l(); } mQueue.erase(it); return event; } Loading media/libstagefright/include/TimedEventQueue.h +2 −10 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ struct TimedEventQueue { struct Event : public RefBase { Event() : mEventID(0), mHasWakeLock(false) { : mEventID(0) { } virtual ~Event() {} Loading @@ -42,14 +42,6 @@ struct TimedEventQueue { return mEventID; } void setWakeLock() { mHasWakeLock = true; } bool hasWakeLock() { return mHasWakeLock; } protected: virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0; Loading @@ -57,7 +49,6 @@ struct TimedEventQueue { friend class TimedEventQueue; event_id mEventID; bool mHasWakeLock; void setEventID(event_id id) { mEventID = id; Loading Loading @@ -127,6 +118,7 @@ private: struct QueueItem { sp<Event> event; int64_t realtime_us; bool has_wakelock; }; struct StopEvent : public TimedEventQueue::Event { Loading Loading
media/libstagefright/TimedEventQueue.cpp +6 −5 Original line number Diff line number Diff line Loading @@ -127,6 +127,7 @@ TimedEventQueue::event_id TimedEventQueue::postTimedEvent( QueueItem item; item.event = event; item.realtime_us = realtime_us; item.has_wakelock = false; if (it == mQueue.begin()) { mQueueHeadChangedCondition.signal(); Loading @@ -134,7 +135,7 @@ TimedEventQueue::event_id TimedEventQueue::postTimedEvent( if (realtime_us > ALooper::GetNowUs() + kWakelockMinDelay) { acquireWakeLock_l(); event->setWakeLock(); item.has_wakelock = true; } mQueue.insert(it, item); Loading Loading @@ -190,7 +191,7 @@ void TimedEventQueue::cancelEvents( ALOGV("cancelling event %d", (*it).event->eventID()); (*it).event->setEventID(0); if ((*it).event->hasWakeLock()) { if ((*it).has_wakelock) { releaseWakeLock_l(); } it = mQueue.erase(it); Loading Loading @@ -288,9 +289,6 @@ void TimedEventQueue::threadEntry() { if (event != NULL) { // Fire event with the lock NOT held. event->fire(this, now_us); if (event->hasWakeLock()) { releaseWakeLock_l(); } } } } Loading @@ -302,6 +300,9 @@ sp<TimedEventQueue::Event> TimedEventQueue::removeEventFromQueue_l( if ((*it).event->eventID() == id) { sp<Event> event = (*it).event; event->setEventID(0); if ((*it).has_wakelock) { releaseWakeLock_l(); } mQueue.erase(it); return event; } Loading
media/libstagefright/include/TimedEventQueue.h +2 −10 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ struct TimedEventQueue { struct Event : public RefBase { Event() : mEventID(0), mHasWakeLock(false) { : mEventID(0) { } virtual ~Event() {} Loading @@ -42,14 +42,6 @@ struct TimedEventQueue { return mEventID; } void setWakeLock() { mHasWakeLock = true; } bool hasWakeLock() { return mHasWakeLock; } protected: virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0; Loading @@ -57,7 +49,6 @@ struct TimedEventQueue { friend class TimedEventQueue; event_id mEventID; bool mHasWakeLock; void setEventID(event_id id) { mEventID = id; Loading Loading @@ -127,6 +118,7 @@ private: struct QueueItem { sp<Event> event; int64_t realtime_us; bool has_wakelock; }; struct StopEvent : public TimedEventQueue::Event { Loading