Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit c9880beb authored by Andreas Huber's avatar Andreas Huber Committed by Android Git Automerger
Browse files

am dcf872dc: am c34c8c3f: Merge "Only send the playback complete notification... 

am dcf872dc: am c34c8c3f: Merge "Only send the playback complete notification if a) an error occurred on any track or b) all tracks have finished playing. The previous behaviour was to send the notification as soon as the first track finished playing." into gingerbrea

Merge commit 'dcf872dc'

* commit 'dcf872dc':
  Only send the playback complete notification if a) an error occurred on any track or b) all tracks have finished playing. The previous behaviour was to send the notification as soon as the first track finished playing.
parents 3038f47d dcf872dc

media/libstagefright/AwesomePlayer.cpp

+33 −19
Original line number Diff line number Diff line
@@ -371,9 +371,6 @@ void AwesomePlayer::reset_l() { 
    }

    mAudioSource.clear();



    if (mTimeSource != mAudioPlayer) {

        delete mTimeSource;

    }

    mTimeSource = NULL;



    delete mAudioPlayer;
@@ -494,22 +491,35 @@ void AwesomePlayer::onStreamDone() { 
    }

    mStreamDoneEventPending = false;



    if (mStreamDoneStatus == ERROR_END_OF_STREAM && (mFlags & LOOPING)) {

    if (mStreamDoneStatus != ERROR_END_OF_STREAM) {

        LOGV("MEDIA_ERROR %d", mStreamDoneStatus);



        notifyListener_l(

                MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, mStreamDoneStatus);



        pause_l();



        mFlags |= AT_EOS;

        return;

    }



    const bool allDone =

        (mVideoSource == NULL || (mFlags & VIDEO_AT_EOS))

            && (mAudioSource == NULL || (mFlags & AUDIO_AT_EOS));



    if (!allDone) {

        return;

    }



    if (mFlags & LOOPING) {

        seekTo_l(0);



        if (mVideoSource != NULL) {

            postVideoEvent_l();

        }

    } else {

        if (mStreamDoneStatus == ERROR_END_OF_STREAM) {

        LOGV("MEDIA_PLAYBACK_COMPLETE");

        notifyListener_l(MEDIA_PLAYBACK_COMPLETE);

        } else {

            LOGV("MEDIA_ERROR %d", mStreamDoneStatus);



            notifyListener_l(

                    MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, mStreamDoneStatus);

        }



        pause_l();
@@ -563,7 +573,6 @@ status_t AwesomePlayer::play_l() { 
                    return err;

                }



                delete mTimeSource;

                mTimeSource = mAudioPlayer;



                deferredAudioSeek = true;
@@ -579,7 +588,7 @@ status_t AwesomePlayer::play_l() { 
    }



    if (mTimeSource == NULL && mAudioPlayer == NULL) {

        mTimeSource = new SystemTimeSource;

        mTimeSource = &mSystemTimeSource;

    }



    if (mVideoSource != NULL) {
@@ -744,7 +753,7 @@ status_t AwesomePlayer::seekTo_l(int64_t timeUs) { 
    mSeeking = true;

    mSeekNotificationSent = false;

    mSeekTimeUs = timeUs;

    mFlags &= ~AT_EOS;

    mFlags &= ~(AT_EOS | AUDIO_AT_EOS | VIDEO_AT_EOS);



    seekAudioIfNecessary_l();
@@ -924,6 +933,7 @@ void AwesomePlayer::onVideoEvent() { 
                    continue;

                }



                mFlags |= VIDEO_AT_EOS;

                postStreamDoneEvent_l(err);

                return;

            }
@@ -968,19 +978,21 @@ void AwesomePlayer::onVideoEvent() { 
        mSeekNotificationSent = false;

    }



    TimeSource *ts = (mFlags & AUDIO_AT_EOS) ? &mSystemTimeSource : mTimeSource;



    if (mFlags & FIRST_FRAME) {

        mFlags &= ~FIRST_FRAME;



        mTimeSourceDeltaUs = mTimeSource->getRealTimeUs() - timeUs;

        mTimeSourceDeltaUs = ts->getRealTimeUs() - timeUs;

    }



    int64_t realTimeUs, mediaTimeUs;

    if (mAudioPlayer != NULL

    if (!(mFlags & AUDIO_AT_EOS) && mAudioPlayer != NULL

        && mAudioPlayer->getMediaTimeMapping(&realTimeUs, &mediaTimeUs)) {

        mTimeSourceDeltaUs = realTimeUs - mediaTimeUs;

    }



    int64_t nowUs = mTimeSource->getRealTimeUs() - mTimeSourceDeltaUs;

    int64_t nowUs = ts->getRealTimeUs() - mTimeSourceDeltaUs;



    int64_t latenessUs = nowUs - timeUs;
@@ -1081,6 +1093,8 @@ void AwesomePlayer::onCheckAudioStatus() { 
    status_t finalStatus;

    if (mWatchForAudioEOS && mAudioPlayer->reachedEOS(&finalStatus)) {

        mWatchForAudioEOS = false;

        mFlags |= AUDIO_AT_EOS;

        mFlags |= FIRST_FRAME;

        postStreamDoneEvent_l(finalStatus);

    }

media/libstagefright/include/AwesomePlayer.h

+4 −1
Original line number Diff line number Diff line
@@ -24,6 +24,7 @@ 
#include <media/MediaPlayerInterface.h>

#include <media/stagefright/DataSource.h>

#include <media/stagefright/OMXClient.h>

#include <media/stagefright/TimeSource.h>

#include <utils/threads.h>



namespace android {
@@ -33,7 +34,6 @@ struct DataSource; 
struct MediaBuffer;

struct MediaExtractor;

struct MediaSource;

struct TimeSource;

struct NuCachedSource2;



struct ALooper;
@@ -102,6 +102,8 @@ private: 
        AT_EOS              = 32,

        PREPARE_CANCELLED   = 64,

        CACHE_UNDERRUN      = 128,

        AUDIO_AT_EOS        = 256,

        VIDEO_AT_EOS        = 512,

    };



    mutable Mutex mLock;
@@ -115,6 +117,7 @@ private: 
    sp<ISurface> mISurface;

    sp<MediaPlayerBase::AudioSink> mAudioSink;



    SystemTimeSource mSystemTimeSource;

    TimeSource *mTimeSource;



    String8 mUri;