Index: media/remoting/fake_remoting_controller.cc |
diff --git a/media/remoting/fake_remoting_controller.cc b/media/remoting/fake_remoting_controller.cc |
deleted file mode 100644 |
index f1bbdfb0b2bb4e39f696eff023cc4c9c1d2dd25a..0000000000000000000000000000000000000000 |
--- a/media/remoting/fake_remoting_controller.cc |
+++ /dev/null |
@@ -1,191 +0,0 @@ |
-// Copyright 2016 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/remoting/fake_remoting_controller.h" |
- |
-#include "base/bind.h" |
-#include "base/bind_helpers.h" |
-#include "base/callback.h" |
-#include "base/memory/ptr_util.h" |
-#include "base/threading/thread_task_runner_handle.h" |
-#include "media/remoting/remoting_source_impl.h" |
-#include "media/remoting/rpc/proto_utils.h" |
-#include "mojo/public/cpp/bindings/strong_binding.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace media { |
- |
-FakeRemotingDataStreamSender::FakeRemotingDataStreamSender( |
- mojom::RemotingDataStreamSenderRequest request, |
- mojo::ScopedDataPipeConsumerHandle consumer_handle) |
- : binding_(this, std::move(request)), |
- consumer_handle_(std::move(consumer_handle)), |
- consume_data_chunk_count_(0), |
- send_frame_count_(0), |
- cancel_in_flight_count_(0) {} |
- |
-FakeRemotingDataStreamSender::~FakeRemotingDataStreamSender() = default; |
- |
-void FakeRemotingDataStreamSender::ResetHistory() { |
- consume_data_chunk_count_ = 0; |
- send_frame_count_ = 0; |
- cancel_in_flight_count_ = 0; |
- next_frame_data_.resize(0); |
- received_frame_list.clear(); |
-} |
- |
-bool FakeRemotingDataStreamSender::ValidateFrameBuffer(size_t index, |
- size_t size, |
- bool key_frame, |
- int pts_ms) { |
- if (index >= received_frame_list.size()) { |
- VLOG(1) << "There is no such frame"; |
- return false; |
- } |
- |
- const std::vector<uint8_t>& data = received_frame_list[index]; |
- scoped_refptr<::media::DecoderBuffer> media_buffer = |
- remoting::ByteArrayToDecoderBuffer(data.data(), data.size()); |
- |
- // Checks if pts is correct or not |
- if (media_buffer->timestamp().InMilliseconds() != pts_ms) { |
- VLOG(1) << "Pts should be:" << pts_ms << "(" |
- << media_buffer->timestamp().InMilliseconds() << ")"; |
- return false; |
- } |
- |
- // Checks if key frame is set correct or not |
- if (media_buffer->is_key_frame() != key_frame) { |
- VLOG(1) << "Key frame should be:" << key_frame << "(" |
- << media_buffer->is_key_frame() << ")"; |
- return false; |
- } |
- |
- // Checks if frame buffer size is correct or not |
- if (media_buffer->data_size() != size) { |
- VLOG(1) << "Buffer size should be:" << size << "(" |
- << media_buffer->data_size() << ")"; |
- return false; |
- } |
- |
- // Checks if frame buffer is correct or not. |
- bool return_value = true; |
- const uint8_t* buffer = media_buffer->data(); |
- for (size_t i = 0; i < media_buffer->data_size(); ++i) { |
- uint32_t value = static_cast<uint32_t>(i & 0xFF); |
- if (value != static_cast<uint32_t>(buffer[i])) { |
- VLOG(1) << "buffer index: " << i << " should be " |
- << static_cast<uint32_t>(value) << " (" |
- << static_cast<uint32_t>(buffer[i]) << ")"; |
- return_value = false; |
- } |
- } |
- return return_value; |
-} |
- |
-void FakeRemotingDataStreamSender::ConsumeDataChunk( |
- uint32_t offset, |
- uint32_t size, |
- uint32_t total_payload_size) { |
- next_frame_data_.resize(total_payload_size); |
- MojoResult result = mojo::ReadDataRaw(consumer_handle_.get(), |
- next_frame_data_.data() + offset, &size, |
- MOJO_READ_DATA_FLAG_ALL_OR_NONE); |
- CHECK(result == MOJO_RESULT_OK); |
- ++consume_data_chunk_count_; |
-} |
- |
-void FakeRemotingDataStreamSender::SendFrame() { |
- ++send_frame_count_; |
- received_frame_list.push_back(std::move(next_frame_data_)); |
- EXPECT_EQ(send_frame_count_, received_frame_list.size()); |
-} |
- |
-void FakeRemotingDataStreamSender::CancelInFlightData() { |
- ++cancel_in_flight_count_; |
-} |
- |
-FakeRemoter::FakeRemoter(mojom::RemotingSourcePtr source, bool start_will_fail) |
- : source_(std::move(source)), |
- start_will_fail_(start_will_fail), |
- weak_factory_(this) {} |
- |
-FakeRemoter::~FakeRemoter() {} |
- |
-void FakeRemoter::Start() { |
- if (start_will_fail_) { |
- base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&FakeRemoter::StartFailed, weak_factory_.GetWeakPtr())); |
- } else { |
- base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&FakeRemoter::Started, weak_factory_.GetWeakPtr())); |
- } |
-} |
- |
-void FakeRemoter::StartDataStreams( |
- mojo::ScopedDataPipeConsumerHandle audio_pipe, |
- mojo::ScopedDataPipeConsumerHandle video_pipe, |
- mojom::RemotingDataStreamSenderRequest audio_sender_request, |
- mojom::RemotingDataStreamSenderRequest video_sender_request) { |
- if (audio_pipe.is_valid()) { |
- VLOG(2) << "Has audio"; |
- audio_stream_sender_.reset(new FakeRemotingDataStreamSender( |
- std::move(audio_sender_request), std::move(audio_pipe))); |
- } |
- |
- if (video_pipe.is_valid()) { |
- VLOG(2) << "Has video"; |
- video_stream_sender_.reset(new FakeRemotingDataStreamSender( |
- std::move(video_sender_request), std::move(video_pipe))); |
- } |
-} |
- |
-void FakeRemoter::Stop(mojom::RemotingStopReason reason) { |
- base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&FakeRemoter::Stopped, weak_factory_.GetWeakPtr(), reason)); |
-} |
- |
-void FakeRemoter::SendMessageToSink(const std::vector<uint8_t>& message) {} |
- |
-void FakeRemoter::Started() { |
- source_->OnStarted(); |
-} |
- |
-void FakeRemoter::StartFailed() { |
- source_->OnStartFailed(mojom::RemotingStartFailReason::ROUTE_TERMINATED); |
-} |
- |
-void FakeRemoter::Stopped(mojom::RemotingStopReason reason) { |
- source_->OnStopped(reason); |
-} |
- |
-FakeRemoterFactory::FakeRemoterFactory(bool start_will_fail) |
- : start_will_fail_(start_will_fail) {} |
- |
-FakeRemoterFactory::~FakeRemoterFactory() {} |
- |
-void FakeRemoterFactory::Create(mojom::RemotingSourcePtr source, |
- mojom::RemoterRequest request) { |
- mojo::MakeStrongBinding( |
- base::MakeUnique<FakeRemoter>(std::move(source), start_will_fail_), |
- std::move(request)); |
-} |
- |
-scoped_refptr<RemotingSourceImpl> CreateRemotingSourceImpl( |
- bool start_will_fail) { |
- mojom::RemotingSourcePtr remoting_source; |
- mojom::RemotingSourceRequest remoting_source_request(&remoting_source); |
- mojom::RemoterPtr remoter; |
- std::unique_ptr<mojom::RemoterFactory> remoter_factory = |
- base::MakeUnique<FakeRemoterFactory>(start_will_fail); |
- remoter_factory->Create(std::move(remoting_source), |
- mojo::MakeRequest(&remoter)); |
- return new RemotingSourceImpl(std::move(remoting_source_request), |
- std::move(remoter)); |
-} |
- |
-} // namespace media |