Merge "Merge "Replace data source with data reader" into rvc-dev am:...

import android.annotation.Nullable;

import android.annotation.StringDef;

import android.media.MediaCodec.CryptoInfo;

import android.net.Uri;

import android.text.TextUtils;

import android.util.Pair;

import android.util.SparseArray;

import com.google.android.exoplayer2.extractor.ts.TsExtractor;

import com.google.android.exoplayer2.extractor.wav.WavExtractor;

import com.google.android.exoplayer2.upstream.DataReader;

import com.google.android.exoplayer2.upstream.DataSource;

import com.google.android.exoplayer2.upstream.DataSpec;

import com.google.android.exoplayer2.upstream.TransferListener;

import com.google.android.exoplayer2.util.ParsableByteArray;

import com.google.android.exoplayer2.util.Util;

import com.google.android.exoplayer2.video.ColorInfo;

    private final OutputConsumer mOutputConsumer;

    private final String[] mParserNamesPool;

    private final PositionHolder mPositionHolder;

    private final InputReadingDataSource mDataSource;

    private final InputReadingDataReader mExoDataReader;

    private final DataReaderAdapter mScratchDataReaderAdapter;

    private final ParsableByteArrayAdapter mScratchParsableByteArrayAdapter;

    private String mParserName;

            // clearBuffers() method, or similar.

            mExtractorInput =

                    new DefaultExtractorInput(

                            mDataSource,

                            mExoDataReader,

                            seekableInputReader.getPosition(),

                            seekableInputReader.getLength());

        }

        mDataSource.mInputReader = seekableInputReader;

        mExoDataReader.mInputReader = seekableInputReader;

        // TODO: Apply parameters when creating extractor instances.

        if (mExtractor == null) {

        mParserNamesPool = parserNamesPool;

        mParserName = sniff ? PARSER_NAME_UNKNOWN : parserNamesPool[0];

        mPositionHolder = new PositionHolder();

        mDataSource = new InputReadingDataSource();

        mExoDataReader = new InputReadingDataReader();

        removePendingSeek();

        mScratchDataReaderAdapter = new DataReaderAdapter();

        mScratchParsableByteArrayAdapter = new ParsableByteArrayAdapter();

    // Private classes.

    private static final class InputReadingDataSource implements DataSource {

    private static final class InputReadingDataReader implements DataReader {

        public InputReader mInputReader;

        @Override

        public void addTransferListener(TransferListener transferListener) {

            // Do nothing.

        }

        @Override

        public long open(DataSpec dataSpec) {

            throw new UnsupportedOperationException();

        }

        @Override

        public int read(byte[] buffer, int offset, int readLength) throws IOException {

            return mInputReader.read(buffer, offset, readLength);

        }

        @Override

        public Uri getUri() {

            return null;

        }

        @Override

        public Map<String, List<String>> getResponseHeaders() {

            return null;

        }

        @Override

        public void close() {

            throw new UnsupportedOperationException();

        }

    }

    private final class ExtractorOutputAdapter implements ExtractorOutput {