blob: 4f1af47f8ab03ff42c09df93a525b2b2ebc0b9cd [file] [log] [blame]
// 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.
#include <list>
#include <string>
#include "base/basictypes.h"
#include "base/bind.h"
#include "base/callback.h"
#include "base/callback_helpers.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/thread_checker.h"
#include "cobalt/media/base/callback_holder.h"
#include "cobalt/media/base/decoder_buffer.h"
#include "cobalt/media/base/pipeline_status.h"
#include "cobalt/media/base/video_decoder.h"
#include "cobalt/media/base/video_decoder_config.h"
#include "cobalt/media/base/video_frame.h"
#include "starboard/types.h"
#include "ui/gfx/size.h"
using base::ResetAndReturn;
namespace base {
class SingleThreadTaskRunner;
namespace cobalt {
namespace media {
typedef base::Callback<void(int)> BytesDecodedCB;
class FakeVideoDecoder : public VideoDecoder {
// Constructs an object with a decoding delay of |decoding_delay| frames.
// |bytes_decoded_cb| is called after each decode. The sum of the byte
// count over all calls will be equal to total_bytes_decoded().
FakeVideoDecoder(int decoding_delay, int max_parallel_decoding_requests,
const BytesDecodedCB& bytes_decoded_cb);
~FakeVideoDecoder() OVERRIDE;
// VideoDecoder implementation.
std::string GetDisplayName() const OVERRIDE;
void Initialize(const VideoDecoderConfig& config, bool low_delay,
CdmContext* cdm_context, const InitCB& init_cb,
const OutputCB& output_cb) OVERRIDE;
void Decode(const scoped_refptr<DecoderBuffer>& buffer,
const DecodeCB& decode_cb) OVERRIDE;
void Reset(const base::Closure& closure) OVERRIDE;
int GetMaxDecodeRequests() const OVERRIDE;
// Holds the next init/decode/reset callback from firing.
void HoldNextInit();
void HoldDecode();
void HoldNextReset();
// Satisfies the pending init/decode/reset callback, which must be ready to
// fire when these methods are called.
void SatisfyInit();
void SatisfyDecode();
void SatisfyReset();
// Satisfies single decode request.
void SatisfySingleDecode();
void SimulateError();
// Fail with status DECODER_ERROR_NOT_SUPPORTED when Initialize() is called.
void SimulateFailureToInit();
int total_bytes_decoded() const { return total_bytes_decoded_; }
enum State {
// Callback for updating |total_bytes_decoded_|.
void OnFrameDecoded(int buffer_size, const DecodeCB& decode_cb,
DecodeStatus status);
// Runs |decode_cb| or puts it to |held_decode_callbacks_| depending on
// current value of |hold_decode_|.
void RunOrHoldDecode(const DecodeCB& decode_cb);
// Runs |decode_cb| with a frame from |decoded_frames_|.
void RunDecodeCallback(const DecodeCB& decode_cb);
void DoReset();
base::ThreadChecker thread_checker_;
const size_t decoding_delay_;
const int max_parallel_decoding_requests_;
BytesDecodedCB bytes_decoded_cb_;
State state_;
CallbackHolder<InitCB> init_cb_;
CallbackHolder<base::Closure> reset_cb_;
OutputCB output_cb_;
bool hold_decode_;
std::list<DecodeCB> held_decode_callbacks_;
VideoDecoderConfig current_config_;
std::list<scoped_refptr<VideoFrame> > decoded_frames_;
int total_bytes_decoded_;
bool fail_to_initialize_;
// NOTE: Weak pointers must be invalidated before all other member variables.
base::WeakPtrFactory<FakeVideoDecoder> weak_factory_;
} // namespace media
} // namespace cobalt