OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_ | 5 #ifndef MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_ |
6 #define MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_ | 6 #define MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_ |
7 | 7 |
8 #include <list> | 8 #include <list> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 14 matching lines...) Expand all Loading... |
25 namespace base { | 25 namespace base { |
26 class SingleThreadTaskRunner; | 26 class SingleThreadTaskRunner; |
27 } | 27 } |
28 | 28 |
29 namespace media { | 29 namespace media { |
30 | 30 |
31 class FakeVideoDecoder : public VideoDecoder { | 31 class FakeVideoDecoder : public VideoDecoder { |
32 public: | 32 public: |
33 // Constructs an object with a decoding delay of |decoding_delay| frames. | 33 // Constructs an object with a decoding delay of |decoding_delay| frames. |
34 FakeVideoDecoder(int decoding_delay, | 34 FakeVideoDecoder(int decoding_delay, |
| 35 bool supports_get_decode_output, |
35 int max_parallel_decoding_requests); | 36 int max_parallel_decoding_requests); |
36 virtual ~FakeVideoDecoder(); | 37 virtual ~FakeVideoDecoder(); |
37 | 38 |
38 // VideoDecoder implementation. | 39 // VideoDecoder implementation. |
39 virtual void Initialize(const VideoDecoderConfig& config, | 40 virtual void Initialize(const VideoDecoderConfig& config, |
40 bool low_delay, | 41 bool low_delay, |
41 const PipelineStatusCB& status_cb, | 42 const PipelineStatusCB& status_cb) OVERRIDE; |
42 const OutputCB& output_cb) OVERRIDE; | |
43 virtual void Decode(const scoped_refptr<DecoderBuffer>& buffer, | 43 virtual void Decode(const scoped_refptr<DecoderBuffer>& buffer, |
44 const DecodeCB& decode_cb) OVERRIDE; | 44 const DecodeCB& decode_cb) OVERRIDE; |
45 virtual void Reset(const base::Closure& closure) OVERRIDE; | 45 virtual void Reset(const base::Closure& closure) OVERRIDE; |
46 virtual void Stop() OVERRIDE; | 46 virtual void Stop() OVERRIDE; |
| 47 virtual scoped_refptr<VideoFrame> GetDecodeOutput() OVERRIDE; |
47 virtual int GetMaxDecodeRequests() const OVERRIDE; | 48 virtual int GetMaxDecodeRequests() const OVERRIDE; |
48 | 49 |
49 // Holds the next init/decode/reset callback from firing. | 50 // Holds the next init/decode/reset callback from firing. |
50 void HoldNextInit(); | 51 void HoldNextInit(); |
51 void HoldDecode(); | 52 void HoldDecode(); |
52 void HoldNextReset(); | 53 void HoldNextReset(); |
53 | 54 |
54 // Satisfies the pending init/decode/reset callback, which must be ready to | 55 // Satisfies the pending init/decode/reset callback, which must be ready to |
55 // fire when these methods are called. | 56 // fire when these methods are called. |
56 void SatisfyInit(); | 57 void SatisfyInit(); |
(...skipping 11 matching lines...) Expand all Loading... |
68 enum State { | 69 enum State { |
69 STATE_UNINITIALIZED, | 70 STATE_UNINITIALIZED, |
70 STATE_NORMAL, | 71 STATE_NORMAL, |
71 STATE_END_OF_STREAM, | 72 STATE_END_OF_STREAM, |
72 STATE_ERROR, | 73 STATE_ERROR, |
73 }; | 74 }; |
74 | 75 |
75 // Callback for updating |total_bytes_decoded_|. | 76 // Callback for updating |total_bytes_decoded_|. |
76 void OnFrameDecoded(int buffer_size, | 77 void OnFrameDecoded(int buffer_size, |
77 const DecodeCB& decode_cb, | 78 const DecodeCB& decode_cb, |
78 Status status); | 79 Status status, |
| 80 const scoped_refptr<VideoFrame>& video_frame); |
79 | 81 |
80 // Runs |decode_cb| or puts it to |held_decode_callbacks_| depending on | 82 // Runs |decode_cb| or puts it to |held_decode_callbacks_| depending on |
81 // current value of |hold_decode_|. | 83 // current value of |hold_decode_|. |
82 void RunOrHoldDecode(const DecodeCB& decode_cb); | 84 void RunOrHoldDecode(const DecodeCB& decode_cb); |
83 | 85 |
84 // Runs |decode_cb| with a frame from |decoded_frames_|. | 86 // Runs |decode_cb| with a frame from |decoded_frames_|. |
85 void RunDecodeCallback(const DecodeCB& decode_cb); | 87 void RunDecodeCallback(const DecodeCB& decode_cb); |
86 | 88 |
87 void DoReset(); | 89 void DoReset(); |
88 | 90 |
89 base::ThreadChecker thread_checker_; | 91 base::ThreadChecker thread_checker_; |
90 | 92 |
91 const size_t decoding_delay_; | 93 const size_t decoding_delay_; |
| 94 const bool supports_get_decode_output_; |
92 const int max_parallel_decoding_requests_; | 95 const int max_parallel_decoding_requests_; |
93 | 96 |
94 State state_; | 97 State state_; |
95 | 98 |
96 CallbackHolder<PipelineStatusCB> init_cb_; | 99 CallbackHolder<PipelineStatusCB> init_cb_; |
97 CallbackHolder<base::Closure> reset_cb_; | 100 CallbackHolder<base::Closure> reset_cb_; |
98 | 101 |
99 OutputCB output_cb_; | |
100 | |
101 bool hold_decode_; | 102 bool hold_decode_; |
102 std::list<DecodeCB> held_decode_callbacks_; | 103 std::list<DecodeCB> held_decode_callbacks_; |
103 | 104 |
104 VideoDecoderConfig current_config_; | 105 VideoDecoderConfig current_config_; |
105 | 106 |
106 std::list<scoped_refptr<VideoFrame> > decoded_frames_; | 107 std::list<scoped_refptr<VideoFrame> > decoded_frames_; |
107 | 108 |
108 int total_bytes_decoded_; | 109 int total_bytes_decoded_; |
109 | 110 |
110 // NOTE: Weak pointers must be invalidated before all other member variables. | 111 // NOTE: Weak pointers must be invalidated before all other member variables. |
111 base::WeakPtrFactory<FakeVideoDecoder> weak_factory_; | 112 base::WeakPtrFactory<FakeVideoDecoder> weak_factory_; |
112 | 113 |
113 DISALLOW_COPY_AND_ASSIGN(FakeVideoDecoder); | 114 DISALLOW_COPY_AND_ASSIGN(FakeVideoDecoder); |
114 }; | 115 }; |
115 | 116 |
116 } // namespace media | 117 } // namespace media |
117 | 118 |
118 #endif // MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_ | 119 #endif // MEDIA_FILTERS_FAKE_VIDEO_DECODER_H_ |
OLD | NEW |