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

Commit acc19234 authored by Robert Shih's avatar Robert Shih
Browse files

FLACExtractor: copy protect mWriteBuffer

Bug: 30895578
Change-Id: I4cba36bbe3502678210e5925181683df9726b431
parent 460dcb75
Loading
Loading
Loading
Loading
+19 −16
Original line number Diff line number Diff line
@@ -73,6 +73,10 @@ private:
class FLACParser : public RefBase {

public:
    enum {
        kMaxChannels = 8,
    };

    explicit FLACParser(
        const sp<DataSource> &dataSource,
        // If metadata pointers aren't provided, we don't fill them
@@ -122,7 +126,7 @@ private:
    // media buffers
    size_t mMaxBufferSize;
    MediaBufferGroup *mGroup;
    void (*mCopy)(short *dst, const int *const *src, unsigned nSamples, unsigned nChannels);
    void (*mCopy)(short *dst, const int * src[kMaxChannels], unsigned nSamples, unsigned nChannels);

    // handle to underlying libFLAC parser
    FLAC__StreamDecoder *mDecoder;
@@ -139,7 +143,7 @@ private:
    bool mWriteRequested;
    bool mWriteCompleted;
    FLAC__FrameHeader mWriteHeader;
    const FLAC__int32 * const *mWriteBuffer;
    FLAC__int32 const * mWriteBuffer[kMaxChannels];

    // most recent error reported by libFLAC parser
    FLAC__StreamDecoderErrorStatus mErrorStatus;
@@ -323,7 +327,7 @@ FLAC__StreamDecoderWriteStatus FLACParser::writeCallback(
        mWriteRequested = false;
        // FLAC parser doesn't free or realloc buffer until next frame or finish
        mWriteHeader = frame->header;
        mWriteBuffer = buffer;
        memmove(mWriteBuffer, buffer, sizeof(const FLAC__int32 * const) * getChannels());
        mWriteCompleted = true;
        return FLAC__STREAM_DECODER_WRITE_STATUS_CONTINUE;
    } else {
@@ -382,7 +386,7 @@ void FLACParser::errorCallback(FLAC__StreamDecoderErrorStatus status)

static void copyMono8(
        short *dst,
        const int *const *src,
        const int * src[FLACParser::kMaxChannels],
        unsigned nSamples,
        unsigned /* nChannels */) {
    for (unsigned i = 0; i < nSamples; ++i) {
@@ -392,7 +396,7 @@ static void copyMono8(

static void copyStereo8(
        short *dst,
        const int *const *src,
        const int * src[FLACParser::kMaxChannels],
        unsigned nSamples,
        unsigned /* nChannels */) {
    for (unsigned i = 0; i < nSamples; ++i) {
@@ -401,7 +405,7 @@ static void copyStereo8(
    }
}

static void copyMultiCh8(short *dst, const int *const *src, unsigned nSamples, unsigned nChannels)
static void copyMultiCh8(short *dst, const int * src[FLACParser::kMaxChannels], unsigned nSamples, unsigned nChannels)
{
    for (unsigned i = 0; i < nSamples; ++i) {
        for (unsigned c = 0; c < nChannels; ++c) {
@@ -412,7 +416,7 @@ static void copyMultiCh8(short *dst, const int *const *src, unsigned nSamples, u

static void copyMono16(
        short *dst,
        const int *const *src,
        const int * src[FLACParser::kMaxChannels],
        unsigned nSamples,
        unsigned /* nChannels */) {
    for (unsigned i = 0; i < nSamples; ++i) {
@@ -422,7 +426,7 @@ static void copyMono16(

static void copyStereo16(
        short *dst,
        const int *const *src,
        const int * src[FLACParser::kMaxChannels],
        unsigned nSamples,
        unsigned /* nChannels */) {
    for (unsigned i = 0; i < nSamples; ++i) {
@@ -431,7 +435,7 @@ static void copyStereo16(
    }
}

static void copyMultiCh16(short *dst, const int *const *src, unsigned nSamples, unsigned nChannels)
static void copyMultiCh16(short *dst, const int * src[FLACParser::kMaxChannels], unsigned nSamples, unsigned nChannels)
{
    for (unsigned i = 0; i < nSamples; ++i) {
        for (unsigned c = 0; c < nChannels; ++c) {
@@ -444,7 +448,7 @@ static void copyMultiCh16(short *dst, const int *const *src, unsigned nSamples,

static void copyMono24(
        short *dst,
        const int *const *src,
        const int * src[FLACParser::kMaxChannels],
        unsigned nSamples,
        unsigned /* nChannels */) {
    for (unsigned i = 0; i < nSamples; ++i) {
@@ -454,7 +458,7 @@ static void copyMono24(

static void copyStereo24(
        short *dst,
        const int *const *src,
        const int * src[FLACParser::kMaxChannels],
        unsigned nSamples,
        unsigned /* nChannels */) {
    for (unsigned i = 0; i < nSamples; ++i) {
@@ -463,7 +467,7 @@ static void copyStereo24(
    }
}

static void copyMultiCh24(short *dst, const int *const *src, unsigned nSamples, unsigned nChannels)
static void copyMultiCh24(short *dst, const int * src[FLACParser::kMaxChannels], unsigned nSamples, unsigned nChannels)
{
    for (unsigned i = 0; i < nSamples; ++i) {
        for (unsigned c = 0; c < nChannels; ++c) {
@@ -474,7 +478,7 @@ static void copyMultiCh24(short *dst, const int *const *src, unsigned nSamples,

static void copyTrespass(
        short * /* dst */,
        const int *const * /* src */,
        const int *[FLACParser::kMaxChannels] /* src */,
        unsigned /* nSamples */,
        unsigned /* nChannels */) {
    TRESPASS();
@@ -499,7 +503,6 @@ FLACParser::FLACParser(
      mStreamInfoValid(false),
      mWriteRequested(false),
      mWriteCompleted(false),
      mWriteBuffer(NULL),
      mErrorStatus((FLAC__StreamDecoderErrorStatus) -1)
{
    ALOGV("FLACParser::FLACParser");
@@ -555,7 +558,7 @@ status_t FLACParser::init()
    }
    if (mStreamInfoValid) {
        // check channel count
        if (getChannels() == 0 || getChannels() > 8) {
        if (getChannels() == 0 || getChannels() > kMaxChannels) {
            ALOGE("unsupported channel count %u", getChannels());
            return NO_INIT;
        }
@@ -591,7 +594,7 @@ status_t FLACParser::init()
        static const struct {
            unsigned mChannels;
            unsigned mBitsPerSample;
            void (*mCopy)(short *dst, const int *const *src, unsigned nSamples, unsigned nChannels);
            void (*mCopy)(short *dst, const int * src[kMaxChannels], unsigned nSamples, unsigned nChannels);
        } table[] = {
            { 1,  8, copyMono8    },
            { 2,  8, copyStereo8  },