Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(337)

Unified Diff: media/base/android/media_decoder_job.h

Issue 2283493003: Delete browser MSE implementation. (Closed)
Patch Set: Actually delete MSP. Cleanse references. Remove AudioTrack usage. Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: media/base/android/media_decoder_job.h
diff --git a/media/base/android/media_decoder_job.h b/media/base/android/media_decoder_job.h
deleted file mode 100644
index 3313e5e053c393c7427a66652bec5acbaad34eb8..0000000000000000000000000000000000000000
--- a/media/base/android/media_decoder_job.h
+++ /dev/null
@@ -1,367 +0,0 @@
-// Copyright 2013 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#ifndef MEDIA_BASE_ANDROID_MEDIA_DECODER_JOB_H_
-#define MEDIA_BASE_ANDROID_MEDIA_DECODER_JOB_H_
-
-#include <stddef.h>
-#include <memory>
-
-#include "base/callback.h"
-#include "base/macros.h"
-#include "base/memory/weak_ptr.h"
-#include "base/time/time.h"
-#include "media/base/android/demuxer_stream_player_params.h"
-#include "media/base/android/media_codec_bridge.h"
-#include "ui/gl/android/scoped_java_surface.h"
-
-namespace base {
-class SingleThreadTaskRunner;
-}
-
-namespace media {
-
-class MediaDrmBridge;
-
-// Class for managing all the decoding tasks. Each decoding task will be posted
-// onto the same thread. The thread will be stopped once Stop() is called.
-// Data is stored in 2 chunks. When new data arrives, it is always stored in
-// an inactive chunk. And when the current active chunk becomes empty, a new
-// data request will be sent to the renderer.
-class MediaDecoderJob {
- public:
- // Return value when Decode() is called.
- enum MediaDecoderJobStatus {
- STATUS_SUCCESS,
- STATUS_KEY_FRAME_REQUIRED,
- STATUS_FAILURE,
- };
-
- struct Deleter {
- inline void operator()(MediaDecoderJob* ptr) const { ptr->Release(); }
- };
-
- // Callback when a decoder job finishes its work. Args: whether decode
- // finished successfully, a flag whether the frame is late for statistics,
- // cacurrent presentation time, max presentation time.
- // If the current presentation time is equal to kNoTimestamp, the decoder
- // job skipped rendering of the decoded output and the callback target should
- // ignore the timestamps provided. The late frame flag has no meaning in this
- // case.
- typedef base::Callback<void(MediaCodecStatus, bool, base::TimeDelta,
- base::TimeDelta)> DecoderCallback;
-
- virtual ~MediaDecoderJob();
-
- // Called by MediaSourcePlayer when more data for this object has arrived.
- void OnDataReceived(const DemuxerData& data);
-
- // Prefetch so we know the decoder job has data when we call Decode().
- // |prefetch_cb| - Run when prefetching has completed.
- void Prefetch(const base::Closure& prefetch_cb);
-
- // Called by MediaSourcePlayer to decode some data.
- // |callback| - Run when decode operation has completed.
- //
- // Returns STATUS_SUCCESS on success, or STATUS_FAILURE on failure, or
- // STATUS_KEY_FRAME_REQUIRED if a browser seek is required. |callback| is
- // ignored and will not be called for the latter 2 cases.
- MediaDecoderJobStatus Decode(base::TimeTicks start_time_ticks,
- base::TimeDelta start_presentation_timestamp,
- const DecoderCallback& callback);
-
- // Called to stop the last Decode() early.
- // If the decoder is in the process of decoding the next frame, then
- // this method will just allow the decode to complete as normal. If
- // this object is waiting for a data request to complete, then this method
- // will wait for the data to arrive and then call the |callback|
- // passed to Decode() with a status of MEDIA_CODEC_ABORT. This ensures that
- // the |callback| passed to Decode() is always called and the status
- // reflects whether data was actually decoded or the decode terminated early.
- void StopDecode();
-
- // Flushes the decoder and abandons all the data that is being decoded.
- virtual void Flush();
-
- // Enters prerolling state. The job must not currently be decoding.
- void BeginPrerolling(base::TimeDelta preroll_timestamp);
-
- // Releases all the decoder resources as the current tab is going background.
- virtual void ReleaseDecoderResources();
-
- // Sets the demuxer configs.
- virtual void SetDemuxerConfigs(const DemuxerConfigs& configs) = 0;
-
- // Returns whether the decoder has finished decoding all the data.
- bool OutputEOSReached() const;
-
- // Returns true if the audio/video stream is available, implemented by child
- // classes.
- virtual bool HasStream() const = 0;
-
- void SetDrmBridge(MediaDrmBridge* drm_bridge);
-
- bool is_decoding() const { return !decode_cb_.is_null(); }
-
- bool is_content_encrypted() const { return is_content_encrypted_; }
-
- bool prerolling() const { return prerolling_; }
-
- protected:
- // Creates a new MediaDecoderJob instance.
- // |decoder_task_runner| - Thread on which the decoder task will run.
- // |request_data_cb| - Callback to request more data for the decoder.
- // |config_changed_cb| - Callback to inform the caller that
- // demuxer config has changed.
- MediaDecoderJob(
- const scoped_refptr<base::SingleThreadTaskRunner>& decoder_task_runner,
- const base::Closure& request_data_cb,
- const base::Closure& config_changed_cb);
-
- // Release the output buffer at index |output_buffer_index| and render it if
- // |render_output| is true. Upon completion, |callback| will be called.
- // |is_late_frame| can be passed with the |callback| if the implementation
- // does not calculate it itself.
- virtual void ReleaseOutputBuffer(
- int output_buffer_index,
- size_t offset,
- size_t size,
- bool render_output,
- bool is_late_frame,
- base::TimeDelta current_presentation_timestamp,
- MediaCodecStatus status,
- const DecoderCallback& callback) = 0;
-
- // Returns true if the "time to render" needs to be computed for frames in
- // this decoder job.
- virtual bool ComputeTimeToRender() const = 0;
-
- // Gets MediaCrypto object from |drm_bridge_|.
- jobject GetMediaCrypto();
-
- // Releases the |media_codec_bridge_|.
- void ReleaseMediaCodecBridge();
-
- // Sets the current frame to a previously cached key frame. Returns true if
- // a key frame is found, or false otherwise.
- // TODO(qinmin): add UMA to study the cache hit ratio for key frames.
- bool SetCurrentFrameToPreviouslyCachedKeyFrame();
-
- MediaDrmBridge* drm_bridge() { return drm_bridge_; }
-
- void set_is_content_encrypted(bool is_content_encrypted) {
- is_content_encrypted_ = is_content_encrypted;
- }
-
- bool need_to_reconfig_decoder_job_;
-
- std::unique_ptr<MediaCodecBridge> media_codec_bridge_;
-
- private:
- friend class MediaSourcePlayerTest;
-
- // Causes this instance to be deleted on the thread it is bound to.
- void Release();
-
- // Queues an access unit into |media_codec_bridge_|'s input buffer.
- MediaCodecStatus QueueInputBuffer(const AccessUnit& unit);
-
- // Returns true if this object has data to decode.
- bool HasData() const;
-
- // Initiates a request for more data.
- // |done_cb| is called when more data is available in |received_data_|.
- void RequestData(const base::Closure& done_cb);
-
- // Posts a task to start decoding the current access unit in |received_data_|.
- void DecodeCurrentAccessUnit(
- base::TimeTicks start_time_ticks,
- base::TimeDelta start_presentation_timestamp);
-
- // Helper function to decode data on |decoder_task_runner_|. |unit| contains
- // the data to be decoded. |start_time_ticks| and
- // |start_presentation_timestamp| represent the system time and the
- // presentation timestamp when the first frame is rendered. We use these
- // information to estimate when the current frame should be rendered.
- // If |needs_flush| is true, codec needs to be flushed at the beginning of
- // this call.
- // It is possible that |stop_decode_pending_| or |release_resources_pending_|
- // becomes true while DecodeInternal() is called. However, they should have
- // no impact on DecodeInternal(). They will be handled after DecoderInternal()
- // finishes and OnDecodeCompleted() is posted on the UI thread.
- void DecodeInternal(const AccessUnit& unit,
- base::TimeTicks start_time_ticks,
- base::TimeDelta start_presentation_timestamp,
- bool needs_flush,
- const DecoderCallback& callback);
-
- // Called on the UI thread to indicate that one decode cycle has completed.
- // Completes any pending job destruction or any pending decode stop. If
- // destruction was not pending, passes its arguments to |decode_cb_|.
- void OnDecodeCompleted(MediaCodecStatus status,
- bool is_late_frame,
- base::TimeDelta current_presentation_timestamp,
- base::TimeDelta max_presentation_timestamp);
-
- // Helper function to get the current access unit that is being decoded.
- const AccessUnit& CurrentAccessUnit() const;
-
- // Helper function to get the current data chunk index that is being decoded.
- size_t CurrentReceivedDataChunkIndex() const;
-
- // Check whether a chunk has no remaining access units to decode. If
- // |is_active_chunk| is true, this function returns whether decoder has
- // consumed all data in |received_data_[current_demuxer_data_index_]|.
- // Otherwise, it returns whether decoder has consumed all data in the inactive
- // chunk.
- bool NoAccessUnitsRemainingInChunk(bool is_active_chunk) const;
-
- // Requests new data for the current chunk if it runs out of data.
- void RequestCurrentChunkIfEmpty();
-
- // Initializes |received_data_| and |access_unit_index_|.
- void InitializeReceivedData();
-
- // Called when the decoder is completely drained and is ready to be released.
- void OnDecoderDrained();
-
- // Creates |media_codec_bridge_| for decoding purpose.
- // Returns STATUS_SUCCESS on success, or STATUS_FAILURE on failure, or
- // STATUS_KEY_FRAME_REQUIRED if a browser seek is required.
- MediaDecoderJobStatus CreateMediaCodecBridge();
-
- // Implemented by the child class to create |media_codec_bridge_| for a
- // particular stream.
- // Returns STATUS_SUCCESS on success, or STATUS_FAILURE on failure, or
- // STATUS_KEY_FRAME_REQUIRED if a browser seek is required.
- virtual MediaDecoderJobStatus CreateMediaCodecBridgeInternal() = 0;
-
- // Returns true if the |configs| doesn't match the current demuxer configs
- // the decoder job has.
- virtual bool AreDemuxerConfigsChanged(
- const DemuxerConfigs& configs) const = 0;
-
- // Returns true if |media_codec_bridge_| needs to be reconfigured for the
- // new DemuxerConfigs, or false otherwise.
- virtual bool IsCodecReconfigureNeeded(const DemuxerConfigs& configs) const;
-
- // Signals to decoder job that decoder has updated output format. Decoder job
- // may need to do internal reconfiguration in order to correctly interpret
- // incoming buffers. Returns true if this internal configuration succeeded.
- virtual bool OnOutputFormatChanged();
-
- // Update the output format from the decoder, returns true if the output
- // format changes, or false otherwise.
- virtual bool UpdateOutputFormat();
-
- // Return the index to |received_data_| that is not currently being decoded.
- size_t inactive_demuxer_data_index() const {
- return 1 - current_demuxer_data_index_;
- }
-
- // The UI message loop where callbacks should be dispatched.
- scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner_;
-
- // The task runner that decoder job runs on.
- scoped_refptr<base::SingleThreadTaskRunner> decoder_task_runner_;
-
- // Whether the decoder needs to be flushed.
- bool needs_flush_;
-
- // Whether input EOS is encountered.
- // TODO(wolenetz/qinmin): Protect with a lock. See http://crbug.com/320043.
- bool input_eos_encountered_;
-
- // Whether output EOS is encountered.
- bool output_eos_encountered_;
-
- // Tracks whether DecodeInternal() should skip decoding if the first access
- // unit is EOS or empty, and report |MEDIA_CODEC_OUTPUT_END_OF_STREAM|. This
- // is to work around some decoders that could crash otherwise. See
- // http://b/11696552.
- bool skip_eos_enqueue_;
-
- // The timestamp the decoder needs to preroll to. If an access unit's
- // timestamp is smaller than |preroll_timestamp_|, don't render it.
- // TODO(qinmin): Comparing access unit's timestamp with |preroll_timestamp_|
- // is not very accurate.
- base::TimeDelta preroll_timestamp_;
-
- // Indicates prerolling state. If true, this job has not yet decoded output
- // that it will render, since the most recent of job construction or
- // BeginPrerolling(). If false, |preroll_timestamp_| has been reached.
- // TODO(qinmin): Comparing access unit's timestamp with |preroll_timestamp_|
- // is not very accurate.
- bool prerolling_;
-
- // Callback used to request more data.
- base::Closure request_data_cb_;
-
- // Callback to notify the caller config has changed.
- base::Closure config_changed_cb_;
-
- // Callback to run when new data has been received.
- base::Closure data_received_cb_;
-
- // Callback to run when the current Decode() operation completes.
- DecoderCallback decode_cb_;
-
- // Data received over IPC from last RequestData() operation.
- // We keep 2 chunks at the same time to reduce the IPC latency between chunks.
- // If data inside the current chunk are all decoded, we will request a new
- // chunk from the demuxer and swap the current chunk with the other one.
- // New data will always be stored in the other chunk since the current
- // one may be still in use.
- DemuxerData received_data_[2];
-
- // Index to the current data chunk that is being decoded.
- size_t current_demuxer_data_index_;
-
- // Index to the access unit inside each data chunk that is being decoded.
- size_t access_unit_index_[2];
-
- // The index of input buffer that can be used by QueueInputBuffer().
- // If the index is uninitialized or invalid, it must be -1.
- int input_buf_index_;
-
- // Indicates whether content is encrypted.
- bool is_content_encrypted_;
-
- // Indicates the decoder job should stop after decoding the current access
- // unit.
- bool stop_decode_pending_;
-
- // Indicates that this object should be destroyed once the current
- // Decode() has completed. This gets set when Release() gets called
- // while there is a decode in progress.
- bool destroy_pending_;
-
- // Indicates whether the decoder is in the middle of requesting new data.
- bool is_requesting_demuxer_data_;
-
- // Indicates whether the incoming data should be ignored.
- bool is_incoming_data_invalid_;
-
- // Indicates that |media_codec_bridge_| should be released once the current
- // Decode() has completed. This gets set when ReleaseDecoderResources() gets
- // called while there is a decode in progress.
- bool release_resources_pending_;
-
- // Pointer to a DRM object that will be used for encrypted streams.
- MediaDrmBridge* drm_bridge_;
-
- // Indicates whether |media_codec_bridge_| is in the middle of being drained
- // due to a config change.
- bool drain_decoder_;
-
- // This access unit is passed to the decoder during config changes to drain
- // the decoder.
- AccessUnit eos_unit_;
-
- DISALLOW_IMPLICIT_CONSTRUCTORS(MediaDecoderJob);
-};
-
-} // namespace media
-
-#endif // MEDIA_BASE_ANDROID_MEDIA_DECODER_JOB_H_

Powered by Google App Engine
This is Rietveld 408576698