Merge "Implement server side playback timestamps with 64 bit accuracy" into nyc-dev

    virtual size_t  framesReady() const = 0;  // see description at AudioFlinger.h

    // Return the total number of frames that have been obtained and released

    virtual size_t  framesReleased() const { return 0; }

    virtual int64_t  framesReleased() const { return 0; }

    // Invoked by buffer consumer when a new timestamp is available.

    // Default implementation ignores the timestamp.

    virtual void    onTimestamp(const AudioTimestamp& timestamp) { }

    virtual void    onTimestamp(const ExtendedTimestamp& timestamp) { }

};

}   // namespace android

    // NBAIO_Sink interface

    //virtual size_t framesRead() const;

    virtual size_t framesOverrun();

    virtual size_t overruns() { (void) framesOverrun(); return mOverruns; }

    virtual int64_t framesOverrun();

    virtual int64_t overruns() { (void) framesOverrun(); return mOverruns; }

    // This is an over-estimate, and could dupe the caller into making a blocking read()

    // FIXME Use an audio HAL API to query the buffer filling status when it's available.

private:

    audio_stream_in * const mStream;

    size_t              mStreamBufferSizeBytes; // as reported by get_buffer_size()

    size_t              mFramesOverrun;

    size_t              mOverruns;

    int64_t             mFramesOverrun;

    int64_t             mOverruns;

};

}   // namespace android

    virtual ssize_t write(const void *buffer, size_t count);

    virtual status_t getTimestamp(AudioTimestamp& timestamp);

    virtual status_t getTimestamp(ExtendedTimestamp &timestamp);

    // NBAIO_Sink end

namespace android {

typedef SingleStateQueue<AudioTimestamp> AudioTimestampSingleStateQueue;

typedef SingleStateQueue<ExtendedTimestamp> ExtendedTimestampSingleStateQueue;

// MonoPipe is similar to Pipe except:

//  - supports only a single reader, called MonoPipeReader

    // NBAIO_Sink interface

    //virtual size_t framesWritten() const;

    //virtual size_t framesUnderrun() const;

    //virtual size_t underruns() const;

    //virtual int64_t framesWritten() const;

    //virtual int64_t framesUnderrun() const;

    //virtual int64_t underruns() const;

    virtual ssize_t availableToWrite() const;

    virtual ssize_t write(const void *buffer, size_t count);

            bool    isShutdown();

            // Return NO_ERROR if there is a timestamp available

            status_t getTimestamp(AudioTimestamp& timestamp);

            status_t getTimestamp(ExtendedTimestamp &timestamp);

private:

    const size_t    mReqFrames;     // as requested in constructor, unrounded

    bool            mIsShutdown;    // whether shutdown(true) was called, no barriers are needed

    AudioTimestampSingleStateQueue::Shared      mTimestampShared;

    AudioTimestampSingleStateQueue::Mutator     mTimestampMutator;

    AudioTimestampSingleStateQueue::Observer    mTimestampObserver;

    ExtendedTimestampSingleStateQueue::Shared      mTimestampShared;

    ExtendedTimestampSingleStateQueue::Mutator     mTimestampMutator;

    ExtendedTimestampSingleStateQueue::Observer    mTimestampObserver;

};

}   // namespace android

    virtual ssize_t read(void *buffer, size_t count);

    virtual void    onTimestamp(const AudioTimestamp& timestamp);

    virtual void    onTimestamp(const ExtendedTimestamp &timestamp);

    // NBAIO_Source end