RELAND: Media Remoting end to end integration tests.

media/test/mock_media_source.cc

+// Copyright (c) 2017 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 "media/test/mock_media_source.h"
+
+#include "base/threading/thread_task_runner_handle.h"
+#include "media/base/test_data_util.h"
+#include "media/base/timestamp_constants.h"
+
+namespace media {
+
+constexpr char kSourceId[] = "SourceId";
+const size_t kAppendWholeFile = std::numeric_limits<size_t>::max();
+
+MockMediaSource::MockMediaSource(const std::string& filename,
+                                 const std::string& mimetype,
+                                 size_t initial_append_size)
+    : current_position_(0),
+      initial_append_size_(initial_append_size),
+      mimetype_(mimetype),
+      chunk_demuxer_(new ChunkDemuxer(
+          base::Bind(&MockMediaSource::DemuxerOpened, base::Unretained(this)),
+          base::Bind(&MockMediaSource::OnEncryptedMediaInitData,
+                     base::Unretained(this)),
+          &media_log_)),
+      owned_chunk_demuxer_(chunk_demuxer_) {
+  file_data_ = ReadTestDataFile(filename);
+
+  if (initial_append_size_ == kAppendWholeFile)
+    initial_append_size_ = file_data_->data_size();
+
+  DCHECK_GT(initial_append_size_, 0u);
+  DCHECK_LE(initial_append_size_, file_data_->data_size());
+}
+
+MockMediaSource::~MockMediaSource() {}
+
+std::unique_ptr<Demuxer> MockMediaSource::GetDemuxer() {
+  return std::move(owned_chunk_demuxer_);
+}
+
+void MockMediaSource::set_encrypted_media_init_data_cb(

[DaleCurtis, 2017/04/20 21:40:25]

hacker_style() must be inline so keep this in the .h

[xjz, 2017/04/20 22:07:45]

Done.

+    const Demuxer::EncryptedMediaInitDataCB& encrypted_media_init_data_cb) {
+  encrypted_media_init_data_cb_ = encrypted_media_init_data_cb;
+}
+
+void MockMediaSource::set_demuxer_failure_cb(

[DaleCurtis, 2017/04/20 21:40:25]

Ditto.

[xjz, 2017/04/20 22:07:45]

Done.

+    const PipelineStatusCB& demuxer_failure_cb) {
+  demuxer_failure_cb_ = demuxer_failure_cb;
+}
+
+void MockMediaSource::Seek(base::TimeDelta seek_time,
+                           size_t new_position,
+                           size_t seek_append_size) {
+  chunk_demuxer_->StartWaitingForSeek(seek_time);
+
+  chunk_demuxer_->ResetParserState(kSourceId, base::TimeDelta(),
+                                   kInfiniteDuration, &last_timestamp_offset_);
+
+  DCHECK_LT(new_position, file_data_->data_size());
+  current_position_ = new_position;
+
+  AppendData(seek_append_size);
+}
+
+void MockMediaSource::Seek(base::TimeDelta seek_time) {
+  chunk_demuxer_->StartWaitingForSeek(seek_time);
+}
+
+void MockMediaSource::AppendData(size_t size) {
+  DCHECK(chunk_demuxer_);
+  DCHECK_LT(current_position_, file_data_->data_size());
+  DCHECK_LE(current_position_ + size, file_data_->data_size());
+
+  ASSERT_TRUE(chunk_demuxer_->AppendData(
+      kSourceId, file_data_->data() + current_position_, size,
+      base::TimeDelta(), kInfiniteDuration, &last_timestamp_offset_));
+  current_position_ += size;
+}
+
+bool MockMediaSource::AppendAtTime(base::TimeDelta timestamp_offset,
+                                   const uint8_t* pData,
+                                   int size) {
+  CHECK(!chunk_demuxer_->IsParsingMediaSegment(kSourceId));
+  bool success =
+      chunk_demuxer_->AppendData(kSourceId, pData, size, base::TimeDelta(),
+                                 kInfiniteDuration, &timestamp_offset);
+  last_timestamp_offset_ = timestamp_offset;
+  return success;
+}
+
+void MockMediaSource::AppendAtTimeWithWindow(
+    base::TimeDelta timestamp_offset,
+    base::TimeDelta append_window_start,
+    base::TimeDelta append_window_end,
+    const uint8_t* pData,
+    int size) {
+  CHECK(!chunk_demuxer_->IsParsingMediaSegment(kSourceId));
+  ASSERT_TRUE(chunk_demuxer_->AppendData(kSourceId, pData, size,
+                                         append_window_start, append_window_end,
+                                         &timestamp_offset));
+  last_timestamp_offset_ = timestamp_offset;
+}
+
+void MockMediaSource::SetMemoryLimits(size_t limit_bytes) {
+  chunk_demuxer_->SetMemoryLimitsForTest(DemuxerStream::AUDIO, limit_bytes);
+  chunk_demuxer_->SetMemoryLimitsForTest(DemuxerStream::VIDEO, limit_bytes);
+}
+
+void MockMediaSource::EvictCodedFrames(base::TimeDelta currentMediaTime,
+                                       size_t newDataSize) {
+  chunk_demuxer_->EvictCodedFrames(kSourceId, currentMediaTime, newDataSize);
+}
+
+void MockMediaSource::RemoveRange(base::TimeDelta start, base::TimeDelta end) {
+  chunk_demuxer_->Remove(kSourceId, start, end);
+}
+
+void MockMediaSource::EndOfStream() {
+  chunk_demuxer_->MarkEndOfStream(PIPELINE_OK);
+}
+
+void MockMediaSource::Shutdown() {
+  if (!chunk_demuxer_)
+    return;
+  chunk_demuxer_->ResetParserState(kSourceId, base::TimeDelta(),
+                                   kInfiniteDuration, &last_timestamp_offset_);
+  chunk_demuxer_->Shutdown();
+  chunk_demuxer_ = NULL;
+}
+
+void MockMediaSource::DemuxerOpened() {
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE,
+      base::Bind(&MockMediaSource::DemuxerOpenedTask, base::Unretained(this)));
+}
+
+void MockMediaSource::DemuxerOpenedTask() {
+  ChunkDemuxer::Status status = AddId();
+  if (status != ChunkDemuxer::kOk) {
+    CHECK(!demuxer_failure_cb_.is_null());
+    demuxer_failure_cb_.Run(DEMUXER_ERROR_COULD_NOT_OPEN);
+    return;
+  }
+  chunk_demuxer_->SetTracksWatcher(
+      kSourceId, base::Bind(&MockMediaSource::InitSegmentReceived,
+                            base::Unretained(this)));
+
+  AppendData(initial_append_size_);
+}
+
+ChunkDemuxer::Status MockMediaSource::AddId() {
+  // This code assumes that |mimetype_| is one of the following forms.
+  // 1. audio/mpeg
+  // 2. video/webm;codec="vorbis,vp8".
+  size_t semicolon = mimetype_.find(";");
+  std::string type = mimetype_;
+  std::string codecs_param = "";
+  if (semicolon != std::string::npos) {
+    type = mimetype_.substr(0, semicolon);
+    size_t codecs_param_start = mimetype_.find("codecs=\"", semicolon);
+
+    CHECK_NE(codecs_param_start, std::string::npos);
+
+    codecs_param_start += 8;  // Skip over the codecs=".
+
+    size_t codecs_param_end = mimetype_.find("\"", codecs_param_start);
+
+    CHECK_NE(codecs_param_end, std::string::npos);
+
+    codecs_param = mimetype_.substr(codecs_param_start,
+                                    codecs_param_end - codecs_param_start);
+  }
+
+  return chunk_demuxer_->AddId(kSourceId, type, codecs_param);
+}
+
+void MockMediaSource::OnEncryptedMediaInitData(
+    EmeInitDataType init_data_type,
+    const std::vector<uint8_t>& init_data) {
+  DCHECK(!init_data.empty());
+  CHECK(!encrypted_media_init_data_cb_.is_null());
+  encrypted_media_init_data_cb_.Run(init_data_type, init_data);
+}
+
+base::TimeDelta MockMediaSource::last_timestamp_offset() const {
+  return last_timestamp_offset_;
+}
+
+void MockMediaSource::InitSegmentReceived(std::unique_ptr<MediaTracks> tracks) {
+  CHECK(tracks.get());
+  EXPECT_GT(tracks->tracks().size(), 0u);
+  CHECK(chunk_demuxer_);
+  // Verify that track ids are unique.
+  std::set<MediaTrack::Id> track_ids;
+  for (const auto& track : tracks->tracks()) {
+    EXPECT_EQ(track_ids.end(), track_ids.find(track->id()));
+    track_ids.insert(track->id());
+  }
+  InitSegmentReceivedMock(tracks);
+}
+
+}  // namespace media