1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
// 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_FILTERS_FAKE_VIDEO_DECODER_H_
#define MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_
#include <stddef.h>
#include <list>
#include "base/bind.h"
#include "base/callback.h"
#include "base/callback_helpers.h"
#include "base/macros.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/thread_checker.h"
#include "media/base/callback_holder.h"
#include "media/base/decoder_buffer.h"
#include "media/base/pipeline_status.h"
#include "media/base/video_decoder.h"
#include "media/base/video_decoder_config.h"
#include "media/base/video_frame.h"
#include "ui/gfx/geometry/size.h"
using base::ResetAndReturn;
namespace base {
class SingleThreadTaskRunner;
}
namespace media {
typedef base::Callback<void(int)> BytesDecodedCB;
class FakeVideoDecoder : public VideoDecoder {
public:
// 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_; }
private:
enum State {
STATE_UNINITIALIZED,
STATE_NORMAL,
STATE_END_OF_STREAM,
STATE_ERROR,
};
// Callback for updating |total_bytes_decoded_|.
void OnFrameDecoded(int buffer_size,
const DecodeCB& decode_cb,
Status 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_;
DISALLOW_COPY_AND_ASSIGN(FakeVideoDecoder);
};
} // namespace media
#endif // MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_
|