Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(145)

Unified Diff: media/cast/test/cast_benchmarks.cc

Issue 1878883003: Refactor: simplify interface of SenderRtcpSession and CastTransport. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Addressed comments. Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: media/cast/test/cast_benchmarks.cc
diff --git a/media/cast/test/cast_benchmarks.cc b/media/cast/test/cast_benchmarks.cc
index a578788421cc310a689307a0fa7055b4977f7100..0e11521fcbe4e39132589aaded61750c1b6b4295 100644
--- a/media/cast/test/cast_benchmarks.cc
+++ b/media/cast/test/cast_benchmarks.cc
@@ -33,6 +33,7 @@
#include "base/bind_helpers.h"
#include "base/command_line.h"
#include "base/debug/profiler.h"
+#include "base/memory/ptr_util.h"
#include "base/memory/weak_ptr.h"
#include "base/run_loop.h"
#include "base/stl_util.h"
@@ -94,20 +95,18 @@ class CastTransportWrapper : public CastTransport {
encoded_audio_bytes_ = encoded_audio_bytes;
}
- void InitializeAudio(const CastTransportRtpConfig& config,
- const RtcpCastMessageCallback& cast_message_cb,
- const RtcpRttCallback& rtt_cb,
- const RtcpPliCallback& key_frame_cb) final {
+ void InitializeAudio(
+ const CastTransportRtpConfig& config,
+ std::unique_ptr<SenderRtcpObserver> rtcp_observer) final {
audio_ssrc_ = config.ssrc;
- transport_->InitializeAudio(config, cast_message_cb, rtt_cb, key_frame_cb);
+ transport_->InitializeAudio(config, std::move(rtcp_observer));
}
- void InitializeVideo(const CastTransportRtpConfig& config,
- const RtcpCastMessageCallback& cast_message_cb,
- const RtcpRttCallback& rtt_cb,
- const RtcpPliCallback& key_frame_cb) final {
+ void InitializeVideo(
+ const CastTransportRtpConfig& config,
+ std::unique_ptr<SenderRtcpObserver> rtcp_observer) final {
video_ssrc_ = config.ssrc;
- transport_->InitializeVideo(config, cast_message_cb, rtt_cb, key_frame_cb);
+ transport_->InitializeVideo(config, std::move(rtcp_observer));
}
void InsertFrame(uint32_t ssrc, const EncodedFrame& frame) final {
@@ -175,7 +174,7 @@ class CastTransportWrapper : public CastTransport {
void SetOptions(const base::DictionaryValue& options) final {}
private:
- scoped_ptr<CastTransport> transport_;
+ std::unique_ptr<CastTransport> transport_;
uint32_t audio_ssrc_, video_ssrc_;
uint64_t* encoded_video_bytes_;
uint64_t* encoded_audio_bytes_;
@@ -217,12 +216,12 @@ class RunOneBenchmark {
task_runner_receiver_(
new test::SkewedSingleThreadTaskRunner(task_runner_)),
cast_environment_sender_(new CastEnvironment(
- scoped_ptr<base::TickClock>(testing_clock_sender_),
+ std::unique_ptr<base::TickClock>(testing_clock_sender_),
task_runner_sender_,
task_runner_sender_,
task_runner_sender_)),
cast_environment_receiver_(new CastEnvironment(
- scoped_ptr<base::TickClock>(testing_clock_receiver_),
+ std::unique_ptr<base::TickClock>(testing_clock_receiver_),
task_runner_receiver_,
task_runner_receiver_,
task_runner_receiver_)),
@@ -275,7 +274,7 @@ class RunOneBenchmark {
void Create(const MeasuringPoint& p);
- void ReceivePacket(scoped_ptr<Packet> packet) {
+ void ReceivePacket(std::unique_ptr<Packet> packet) {
cast_receiver_->ReceivePacket(std::move(packet));
}
@@ -313,7 +312,7 @@ class RunOneBenchmark {
&RunOneBenchmark::BasicPlayerGotVideoFrame, base::Unretained(this)));
}
- void BasicPlayerGotAudioFrame(scoped_ptr<AudioBus> audio_bus,
+ void BasicPlayerGotAudioFrame(std::unique_ptr<AudioBus> audio_bus,
const base::TimeTicks& playout_time,
bool is_continuous) {
audio_ticks_.push_back(
@@ -329,8 +328,8 @@ class RunOneBenchmark {
&RunOneBenchmark::BasicPlayerGotAudioFrame, base::Unretained(this)));
}
- scoped_ptr<test::PacketPipe> CreateSimplePipe(const MeasuringPoint& p) {
- scoped_ptr<test::PacketPipe> pipe = test::NewBuffer(65536, p.bitrate);
+ std::unique_ptr<test::PacketPipe> CreateSimplePipe(const MeasuringPoint& p) {
+ std::unique_ptr<test::PacketPipe> pipe = test::NewBuffer(65536, p.bitrate);
pipe->AppendToPipe(test::NewRandomDrop(p.percent_packet_drop / 100.0));
pipe->AppendToPipe(test::NewConstantDelay(p.latency / 1000.0));
return pipe;
@@ -434,12 +433,12 @@ class RunOneBenchmark {
LoopBackTransport* receiver_to_sender_; // Owned by CastTransportImpl.
LoopBackTransport* sender_to_receiver_; // Owned by CastTransportImpl.
CastTransportWrapper transport_sender_;
- scoped_ptr<CastTransport> transport_receiver_;
+ std::unique_ptr<CastTransport> transport_receiver_;
uint64_t video_bytes_encoded_;
uint64_t audio_bytes_encoded_;
- scoped_ptr<CastReceiver> cast_receiver_;
- scoped_ptr<CastSender> cast_sender_;
+ std::unique_ptr<CastReceiver> cast_receiver_;
+ std::unique_ptr<CastSender> cast_sender_;
int frames_sent_;
base::TimeDelta frame_duration_;
@@ -461,9 +460,9 @@ class TransportClient : public CastTransport::Client {
EXPECT_TRUE(result);
};
void OnLoggingEventsReceived(
- scoped_ptr<std::vector<FrameEvent>> frame_events,
- scoped_ptr<std::vector<PacketEvent>> packet_events) final{};
- void ProcessRtpPacket(scoped_ptr<Packet> packet) final {
+ std::unique_ptr<std::vector<FrameEvent>> frame_events,
+ std::unique_ptr<std::vector<PacketEvent>> packet_events) final{};
+ void ProcessRtpPacket(std::unique_ptr<Packet> packet) final {
if (run_one_benchmark_)
run_one_benchmark_->ReceivePacket(std::move(packet));
};
@@ -481,15 +480,15 @@ void RunOneBenchmark::Create(const MeasuringPoint& p) {
transport_sender_.Init(
new CastTransportImpl(
testing_clock_sender_, base::TimeDelta::FromSeconds(1),
- make_scoped_ptr(new TransportClient(nullptr)),
- make_scoped_ptr(sender_to_receiver_), task_runner_sender_),
+ base::WrapUnique(new TransportClient(nullptr)),
+ base::WrapUnique(sender_to_receiver_), task_runner_sender_),
&video_bytes_encoded_, &audio_bytes_encoded_);
receiver_to_sender_ = new LoopBackTransport(cast_environment_receiver_);
transport_receiver_.reset(new CastTransportImpl(
testing_clock_receiver_, base::TimeDelta::FromSeconds(1),
- make_scoped_ptr(new TransportClient(this)),
- make_scoped_ptr(receiver_to_sender_), task_runner_receiver_));
+ base::WrapUnique(new TransportClient(this)),
+ base::WrapUnique(receiver_to_sender_), task_runner_receiver_));
cast_receiver_ =
CastReceiver::Create(cast_environment_receiver_, audio_receiver_config_,
« media/cast/net/rtcp/sender_rtcp_session.h ('K') | « media/cast/sender/video_sender_unittest.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698