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
|
// Copyright 2015 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 "chromecast/media/cma/base/demuxer_stream_for_test.h"
#include "base/threading/thread.h"
#include "media/base/media_util.h"
namespace chromecast {
namespace media {
DemuxerStreamForTest::DemuxerStreamForTest(int total_frames,
int cycle_count,
int delayed_frame_count,
const std::list<int>& config_idx)
: total_frame_count_(total_frames),
cycle_count_(cycle_count),
delayed_frame_count_(delayed_frame_count),
config_idx_(config_idx),
frame_count_(0),
has_pending_read_(false) {
DCHECK_LE(delayed_frame_count, cycle_count);
}
DemuxerStreamForTest::~DemuxerStreamForTest() {
}
void DemuxerStreamForTest::Read(const ReadCB& read_cb) {
has_pending_read_ = true;
if (!config_idx_.empty() && config_idx_.front() == frame_count_) {
config_idx_.pop_front();
has_pending_read_ = false;
read_cb.Run(kConfigChanged, scoped_refptr<::media::DecoderBuffer>());
return;
}
if ((frame_count_ % cycle_count_) < delayed_frame_count_) {
base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
FROM_HERE,
base::Bind(
&DemuxerStreamForTest::DoRead, base::Unretained(this), read_cb),
base::TimeDelta::FromMilliseconds(20));
return;
}
DoRead(read_cb);
}
::media::AudioDecoderConfig DemuxerStreamForTest::audio_decoder_config() {
NOTREACHED() << "DemuxerStreamForTest is a video DemuxerStream";
return ::media::AudioDecoderConfig();
}
::media::VideoDecoderConfig DemuxerStreamForTest::video_decoder_config() {
gfx::Size coded_size(640, 480);
gfx::Rect visible_rect(640, 480);
gfx::Size natural_size(640, 480);
return ::media::VideoDecoderConfig(::media::kCodecH264,
::media::VIDEO_CODEC_PROFILE_UNKNOWN,
::media::PIXEL_FORMAT_YV12,
::media::COLOR_SPACE_UNSPECIFIED,
coded_size,
visible_rect,
natural_size,
::media::EmptyExtraData(),
::media::Unencrypted());
}
::media::DemuxerStream::Type DemuxerStreamForTest::type() const {
return VIDEO;
}
bool DemuxerStreamForTest::SupportsConfigChanges() {
return true;
}
::media::VideoRotation DemuxerStreamForTest::video_rotation() {
return ::media::VIDEO_ROTATION_0;
}
void DemuxerStreamForTest::DoRead(const ReadCB& read_cb) {
has_pending_read_ = false;
if (total_frame_count_ != -1 && frame_count_ >= total_frame_count_) {
// End of stream
read_cb.Run(kOk, ::media::DecoderBuffer::CreateEOSBuffer());
return;
}
scoped_refptr<::media::DecoderBuffer> buffer(new ::media::DecoderBuffer(16));
buffer->set_timestamp(frame_count_ * base::TimeDelta::FromMilliseconds(
kDemuxerStreamForTestFrameDuration));
frame_count_++;
read_cb.Run(kOk, buffer);
}
} // namespace media
} // namespace chromecast
|
