Index: media/cast/logging/stats_event_subscriber_unittest.cc |
diff --git a/media/cast/logging/stats_event_subscriber_unittest.cc b/media/cast/logging/stats_event_subscriber_unittest.cc |
index 6416ae68b69afd5b691c5ae2134e43a2751b4be9..7acfddda21d6482b7c5d0cfee66430f7bb3a3577 100644 |
--- a/media/cast/logging/stats_event_subscriber_unittest.cc |
+++ b/media/cast/logging/stats_event_subscriber_unittest.cc |
@@ -2,8 +2,11 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
+#include "media/cast/logging/stats_event_subscriber.h" |
+ |
#include <stddef.h> |
#include <stdint.h> |
+#include <utility> |
#include "base/memory/ref_counted.h" |
#include "base/memory/scoped_ptr.h" |
@@ -13,7 +16,6 @@ |
#include "base/values.h" |
#include "media/cast/cast_environment.h" |
#include "media/cast/logging/logging_defines.h" |
-#include "media/cast/logging/stats_event_subscriber.h" |
#include "media/cast/test/fake_receiver_time_offset_estimator.h" |
#include "media/cast/test/fake_single_thread_task_runner.h" |
#include "testing/gtest/include/gtest/gtest.h" |
@@ -30,11 +32,11 @@ class StatsEventSubscriberTest : public ::testing::Test { |
StatsEventSubscriberTest() |
: sender_clock_(new base::SimpleTestTickClock()), |
task_runner_(new test::FakeSingleThreadTaskRunner(sender_clock_)), |
- cast_environment_(new CastEnvironment( |
- scoped_ptr<base::TickClock>(sender_clock_).Pass(), |
- task_runner_, |
- task_runner_, |
- task_runner_)), |
+ cast_environment_( |
+ new CastEnvironment(scoped_ptr<base::TickClock>(sender_clock_), |
+ task_runner_, |
+ task_runner_, |
+ task_runner_)), |
fake_offset_estimator_( |
base::TimeDelta::FromSeconds(kReceiverOffsetSecs)) { |
receiver_clock_.Advance(base::TimeDelta::FromSeconds(kReceiverOffsetSecs)); |
@@ -85,7 +87,8 @@ TEST_F(StatsEventSubscriberTest, CaptureEncode) { |
capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
capture_begin_event->media_type = VIDEO_EVENT; |
capture_begin_event->rtp_timestamp = rtp_timestamp; |
- cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent( |
+ std::move(capture_begin_event)); |
AdvanceClocks(base::TimeDelta::FromMicroseconds(10)); |
scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); |
@@ -93,7 +96,8 @@ TEST_F(StatsEventSubscriberTest, CaptureEncode) { |
capture_end_event->type = FRAME_CAPTURE_END; |
capture_end_event->media_type = VIDEO_EVENT; |
capture_end_event->rtp_timestamp = rtp_timestamp; |
- cast_environment_->logger()->DispatchFrameEvent(capture_end_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent( |
+ std::move(capture_end_event)); |
if (i % 2 == 0) { |
AdvanceClocks(base::TimeDelta::FromMicroseconds(10)); |
@@ -108,7 +112,7 @@ TEST_F(StatsEventSubscriberTest, CaptureEncode) { |
encode_event->target_bitrate = 5678; |
encode_event->encoder_cpu_utilization = 9.10; |
encode_event->idealized_bitrate_utilization = 11.12; |
- cast_environment_->logger()->DispatchFrameEvent(encode_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(encode_event)); |
} else if (i < extra_frames) { |
dropped_frames++; |
} |
@@ -172,7 +176,7 @@ TEST_F(StatsEventSubscriberTest, Encode) { |
encode_event->target_bitrate = 5678; |
encode_event->encoder_cpu_utilization = 9.10; |
encode_event->idealized_bitrate_utilization = 11.12; |
- cast_environment_->logger()->DispatchFrameEvent(encode_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(encode_event)); |
last_event_time = sender_clock_->NowTicks(); |
AdvanceClocks(base::TimeDelta::FromMicroseconds(35678)); |
@@ -229,7 +233,7 @@ TEST_F(StatsEventSubscriberTest, Decode) { |
decode_event->media_type = VIDEO_EVENT; |
decode_event->rtp_timestamp = rtp_timestamp; |
decode_event->frame_id = frame_id; |
- cast_environment_->logger()->DispatchFrameEvent(decode_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(decode_event)); |
AdvanceClocks(base::TimeDelta::FromMicroseconds(36789)); |
rtp_timestamp += 90; |
@@ -269,7 +273,7 @@ TEST_F(StatsEventSubscriberTest, PlayoutDelay) { |
playout_event->rtp_timestamp = rtp_timestamp; |
playout_event->frame_id = frame_id; |
playout_event->delay_delta = delay; |
- cast_environment_->logger()->DispatchFrameEvent(playout_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(playout_event)); |
AdvanceClocks(base::TimeDelta::FromMicroseconds(37890)); |
rtp_timestamp += 90; |
@@ -299,7 +303,8 @@ TEST_F(StatsEventSubscriberTest, E2ELatency) { |
capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
capture_begin_event->media_type = VIDEO_EVENT; |
capture_begin_event->rtp_timestamp = rtp_timestamp; |
- cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent( |
+ std::move(capture_begin_event)); |
int latency_micros = 100000 + base::RandInt(-5000, 50000); |
base::TimeDelta latency = base::TimeDelta::FromMicroseconds(latency_micros); |
@@ -316,7 +321,7 @@ TEST_F(StatsEventSubscriberTest, E2ELatency) { |
playout_event->rtp_timestamp = rtp_timestamp; |
playout_event->frame_id = frame_id; |
playout_event->delay_delta = delay; |
- cast_environment_->logger()->DispatchFrameEvent(playout_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(playout_event)); |
rtp_timestamp += 90; |
frame_id++; |
@@ -358,7 +363,7 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
encode_event->media_type = VIDEO_EVENT; |
encode_event->rtp_timestamp = rtp_timestamp; |
encode_event->frame_id = 0; |
- cast_environment_->logger()->DispatchFrameEvent(encode_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(encode_event)); |
// Every 2nd packet will be retransmitted once. |
// Every 4th packet will be retransmitted twice. |
@@ -376,7 +381,7 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
send_event->packet_id = i; |
send_event->max_packet_id = num_packets - 1; |
send_event->size = size; |
- cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
num_packets_transmitted++; |
total_queueing_latency += sender_clock_->NowTicks() - sender_encoded_time; |
@@ -407,7 +412,8 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
retransmit_event->packet_id = i; |
retransmit_event->max_packet_id = num_packets - 1; |
retransmit_event->size = size; |
- cast_environment_->logger()->DispatchPacketEvent(retransmit_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent( |
+ std::move(retransmit_event)); |
retransmit_total_size += size; |
num_packets_transmitted++; |
@@ -426,7 +432,8 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
retransmit_event->packet_id = i; |
retransmit_event->max_packet_id = num_packets - 1; |
retransmit_event->size = size; |
- cast_environment_->logger()->DispatchPacketEvent(retransmit_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent( |
+ std::move(retransmit_event)); |
retransmit_total_size += size; |
num_packets_transmitted++; |
@@ -445,7 +452,8 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
retransmit_event->packet_id = i; |
retransmit_event->max_packet_id = num_packets - 1; |
retransmit_event->size = size; |
- cast_environment_->logger()->DispatchPacketEvent(retransmit_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent( |
+ std::move(retransmit_event)); |
scoped_ptr<PacketEvent> reject_event(new PacketEvent()); |
reject_event->timestamp = receiver_clock_.NowTicks(); |
@@ -456,7 +464,7 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
reject_event->packet_id = i; |
reject_event->max_packet_id = num_packets - 1; |
reject_event->size = size; |
- cast_environment_->logger()->DispatchPacketEvent(reject_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent(std::move(reject_event)); |
retransmit_total_size += size; |
num_packets_transmitted++; |
@@ -473,7 +481,7 @@ TEST_F(StatsEventSubscriberTest, Packets) { |
receive_event->packet_id = i; |
receive_event->max_packet_id = num_packets - 1; |
receive_event->size = size; |
- cast_environment_->logger()->DispatchPacketEvent(receive_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent(std::move(receive_event)); |
num_packets_received++; |
} |
@@ -574,7 +582,8 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
capture_begin_event->media_type = VIDEO_EVENT; |
capture_begin_event->rtp_timestamp = rtp_timestamp; |
- cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent( |
+ std::move(capture_begin_event)); |
AdvanceClocks(base::TimeDelta::FromMilliseconds(10)); |
scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); |
@@ -582,7 +591,8 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
capture_end_event->type = FRAME_CAPTURE_END; |
capture_end_event->media_type = VIDEO_EVENT; |
capture_end_event->rtp_timestamp = rtp_timestamp; |
- cast_environment_->logger()->DispatchFrameEvent(capture_end_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent( |
+ std::move(capture_end_event)); |
AdvanceClocks(base::TimeDelta::FromMilliseconds(15)); |
scoped_ptr<FrameEvent> encode_event(new FrameEvent()); |
@@ -596,7 +606,7 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
encode_event->target_bitrate = 5678; |
encode_event->encoder_cpu_utilization = 9.10; |
encode_event->idealized_bitrate_utilization = 11.12; |
- cast_environment_->logger()->DispatchFrameEvent(encode_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(encode_event)); |
} |
// Send 3 packets for the last frame. |
@@ -612,7 +622,7 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
send_event->packet_id = i; |
send_event->max_packet_id = 2; |
send_event->size = 123; |
- cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
} |
// Receive 3 packets for the last frame. |
@@ -629,7 +639,7 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
receive_event->packet_id = i; |
receive_event->max_packet_id = 2; |
receive_event->size = 123; |
- cast_environment_->logger()->DispatchPacketEvent(receive_event.Pass()); |
+ cast_environment_->logger()->DispatchPacketEvent(std::move(receive_event)); |
} |
scoped_ptr<FrameEvent> playout_event(new FrameEvent()); |
@@ -639,7 +649,7 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
playout_event->rtp_timestamp = rtp_timestamp; |
playout_event->frame_id = frame_id; |
playout_event->delay_delta = base::TimeDelta::FromMilliseconds(100); |
- cast_environment_->logger()->DispatchFrameEvent(playout_event.Pass()); |
+ cast_environment_->logger()->DispatchFrameEvent(std::move(playout_event)); |
StatsEventSubscriber::SimpleHistogram* histogram; |
scoped_ptr<base::ListValue> values; |
@@ -647,19 +657,19 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
histogram = subscriber_->GetHistogramForTesting( |
StatsEventSubscriber::CAPTURE_LATENCY_MS_HISTO); |
ASSERT_TRUE(histogram); |
- values = histogram->GetHistogram().Pass(); |
+ values = histogram->GetHistogram(); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "10-14", 10)); |
histogram = subscriber_->GetHistogramForTesting( |
StatsEventSubscriber::ENCODE_TIME_MS_HISTO); |
ASSERT_TRUE(histogram); |
- values = histogram->GetHistogram().Pass(); |
+ values = histogram->GetHistogram(); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "15-19", 10)); |
histogram = subscriber_->GetHistogramForTesting( |
StatsEventSubscriber::QUEUEING_LATENCY_MS_HISTO); |
ASSERT_TRUE(histogram); |
- values = histogram->GetHistogram().Pass(); |
+ values = histogram->GetHistogram(); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "100-119", 1)); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "200-219", 1)); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "300-319", 1)); |
@@ -667,7 +677,7 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
histogram = subscriber_->GetHistogramForTesting( |
StatsEventSubscriber::NETWORK_LATENCY_MS_HISTO); |
ASSERT_TRUE(histogram); |
- values = histogram->GetHistogram().Pass(); |
+ values = histogram->GetHistogram(); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "100-119", 1)); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "200-219", 1)); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "300-319", 1)); |
@@ -675,13 +685,13 @@ TEST_F(StatsEventSubscriberTest, Histograms) { |
histogram = subscriber_->GetHistogramForTesting( |
StatsEventSubscriber::PACKET_LATENCY_MS_HISTO); |
ASSERT_TRUE(histogram); |
- values = histogram->GetHistogram().Pass(); |
+ values = histogram->GetHistogram(); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "400-419", 3)); |
histogram = subscriber_->GetHistogramForTesting( |
StatsEventSubscriber::LATE_FRAME_MS_HISTO); |
ASSERT_TRUE(histogram); |
- values = histogram->GetHistogram().Pass(); |
+ values = histogram->GetHistogram(); |
EXPECT_TRUE(CheckHistogramHasValue(values.get(), "100-119", 1)); |
} |