| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/cast/logging/encoding_event_subscriber.h" |
| 6 |
| 5 #include <stdint.h> | 7 #include <stdint.h> |
| 8 #include <utility> |
| 6 | 9 |
| 7 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
| 8 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
| 9 #include "base/test/simple_test_tick_clock.h" | 12 #include "base/test/simple_test_tick_clock.h" |
| 10 #include "base/time/tick_clock.h" | 13 #include "base/time/tick_clock.h" |
| 11 #include "media/cast/cast_environment.h" | 14 #include "media/cast/cast_environment.h" |
| 12 #include "media/cast/logging/encoding_event_subscriber.h" | |
| 13 #include "media/cast/logging/logging_defines.h" | 15 #include "media/cast/logging/logging_defines.h" |
| 14 #include "media/cast/test/fake_single_thread_task_runner.h" | 16 #include "media/cast/test/fake_single_thread_task_runner.h" |
| 15 #include "testing/gtest/include/gtest/gtest.h" | 17 #include "testing/gtest/include/gtest/gtest.h" |
| 16 | 18 |
| 17 using media::cast::proto::AggregatedFrameEvent; | 19 using media::cast::proto::AggregatedFrameEvent; |
| 18 using media::cast::proto::AggregatedPacketEvent; | 20 using media::cast::proto::AggregatedPacketEvent; |
| 19 using media::cast::proto::BasePacketEvent; | 21 using media::cast::proto::BasePacketEvent; |
| 20 using media::cast::proto::LogMetadata; | 22 using media::cast::proto::LogMetadata; |
| 21 | 23 |
| 22 namespace { | 24 namespace { |
| 23 | 25 |
| 24 int64_t InMilliseconds(base::TimeTicks event_time) { | 26 int64_t InMilliseconds(base::TimeTicks event_time) { |
| 25 return (event_time - base::TimeTicks()).InMilliseconds(); | 27 return (event_time - base::TimeTicks()).InMilliseconds(); |
| 26 } | 28 } |
| 27 | 29 |
| 28 } | 30 } |
| 29 | 31 |
| 30 namespace media { | 32 namespace media { |
| 31 namespace cast { | 33 namespace cast { |
| 32 | 34 |
| 33 class EncodingEventSubscriberTest : public ::testing::Test { | 35 class EncodingEventSubscriberTest : public ::testing::Test { |
| 34 protected: | 36 protected: |
| 35 EncodingEventSubscriberTest() | 37 EncodingEventSubscriberTest() |
| 36 : testing_clock_(new base::SimpleTestTickClock()), | 38 : testing_clock_(new base::SimpleTestTickClock()), |
| 37 task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)), | 39 task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)), |
| 38 cast_environment_(new CastEnvironment( | 40 cast_environment_( |
| 39 scoped_ptr<base::TickClock>(testing_clock_).Pass(), | 41 new CastEnvironment(scoped_ptr<base::TickClock>(testing_clock_), |
| 40 task_runner_, | 42 task_runner_, |
| 41 task_runner_, | 43 task_runner_, |
| 42 task_runner_)), | 44 task_runner_)), |
| 43 first_rtp_timestamp_(0) {} | 45 first_rtp_timestamp_(0) {} |
| 44 | 46 |
| 45 void Init(EventMediaType event_media_type) { | 47 void Init(EventMediaType event_media_type) { |
| 46 DCHECK(!event_subscriber_); | 48 DCHECK(!event_subscriber_); |
| 47 event_subscriber_.reset(new EncodingEventSubscriber(event_media_type, 10)); | 49 event_subscriber_.reset(new EncodingEventSubscriber(event_media_type, 10)); |
| 48 cast_environment_->logger()->Subscribe(event_subscriber_.get()); | 50 cast_environment_->logger()->Subscribe(event_subscriber_.get()); |
| 49 } | 51 } |
| 50 | 52 |
| 51 ~EncodingEventSubscriberTest() override { | 53 ~EncodingEventSubscriberTest() override { |
| 52 if (event_subscriber_) | 54 if (event_subscriber_) |
| (...skipping 23 matching lines...) Expand all Loading... |
| 76 | 78 |
| 77 // Entry with RTP timestamp 0 should get dropped. | 79 // Entry with RTP timestamp 0 should get dropped. |
| 78 int width = 320; | 80 int width = 320; |
| 79 int height = 180; | 81 int height = 180; |
| 80 for (int i = 0; i < 11; i++) { | 82 for (int i = 0; i < 11; i++) { |
| 81 scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); | 83 scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); |
| 82 capture_begin_event->timestamp = now; | 84 capture_begin_event->timestamp = now; |
| 83 capture_begin_event->type = FRAME_CAPTURE_BEGIN; | 85 capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
| 84 capture_begin_event->media_type = VIDEO_EVENT; | 86 capture_begin_event->media_type = VIDEO_EVENT; |
| 85 capture_begin_event->rtp_timestamp = i * 100; | 87 capture_begin_event->rtp_timestamp = i * 100; |
| 86 cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); | 88 cast_environment_->logger()->DispatchFrameEvent( |
| 89 std::move(capture_begin_event)); |
| 87 | 90 |
| 88 scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); | 91 scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); |
| 89 capture_end_event->timestamp = now; | 92 capture_end_event->timestamp = now; |
| 90 capture_end_event->type = FRAME_CAPTURE_END; | 93 capture_end_event->type = FRAME_CAPTURE_END; |
| 91 capture_end_event->media_type = VIDEO_EVENT; | 94 capture_end_event->media_type = VIDEO_EVENT; |
| 92 capture_end_event->rtp_timestamp = i * 100; | 95 capture_end_event->rtp_timestamp = i * 100; |
| 93 capture_end_event->width = width; | 96 capture_end_event->width = width; |
| 94 capture_end_event->height = height; | 97 capture_end_event->height = height; |
| 95 cast_environment_->logger()->DispatchFrameEvent(capture_end_event.Pass()); | 98 cast_environment_->logger()->DispatchFrameEvent( |
| 99 std::move(capture_end_event)); |
| 96 | 100 |
| 97 scoped_ptr<FrameEvent> decoded_event(new FrameEvent()); | 101 scoped_ptr<FrameEvent> decoded_event(new FrameEvent()); |
| 98 decoded_event->timestamp = now; | 102 decoded_event->timestamp = now; |
| 99 decoded_event->type = FRAME_DECODED; | 103 decoded_event->type = FRAME_DECODED; |
| 100 decoded_event->media_type = VIDEO_EVENT; | 104 decoded_event->media_type = VIDEO_EVENT; |
| 101 decoded_event->rtp_timestamp = i * 100; | 105 decoded_event->rtp_timestamp = i * 100; |
| 102 decoded_event->frame_id = 0; | 106 decoded_event->frame_id = 0; |
| 103 cast_environment_->logger()->DispatchFrameEvent(decoded_event.Pass()); | 107 cast_environment_->logger()->DispatchFrameEvent(std::move(decoded_event)); |
| 104 | 108 |
| 105 width += 160; | 109 width += 160; |
| 106 height += 90; | 110 height += 90; |
| 107 } | 111 } |
| 108 | 112 |
| 109 GetEventsAndReset(); | 113 GetEventsAndReset(); |
| 110 | 114 |
| 111 ASSERT_EQ(10u, frame_events_.size()); | 115 ASSERT_EQ(10u, frame_events_.size()); |
| 112 EXPECT_EQ(100u, frame_events_.front()->relative_rtp_timestamp()); | 116 EXPECT_EQ(100u, frame_events_.front()->relative_rtp_timestamp()); |
| 113 EXPECT_EQ(1000u, frame_events_.back()->relative_rtp_timestamp()); | 117 EXPECT_EQ(1000u, frame_events_.back()->relative_rtp_timestamp()); |
| (...skipping 16 matching lines...) Expand all Loading... |
| 130 for (int i = 0; i < 11; i++) { | 134 for (int i = 0; i < 11; i++) { |
| 131 scoped_ptr<PacketEvent> receive_event(new PacketEvent()); | 135 scoped_ptr<PacketEvent> receive_event(new PacketEvent()); |
| 132 receive_event->timestamp = now; | 136 receive_event->timestamp = now; |
| 133 receive_event->type = PACKET_RECEIVED; | 137 receive_event->type = PACKET_RECEIVED; |
| 134 receive_event->media_type = AUDIO_EVENT; | 138 receive_event->media_type = AUDIO_EVENT; |
| 135 receive_event->rtp_timestamp = i * 100; | 139 receive_event->rtp_timestamp = i * 100; |
| 136 receive_event->frame_id = 0; | 140 receive_event->frame_id = 0; |
| 137 receive_event->packet_id = i; | 141 receive_event->packet_id = i; |
| 138 receive_event->max_packet_id = 10; | 142 receive_event->max_packet_id = 10; |
| 139 receive_event->size = 123; | 143 receive_event->size = 123; |
| 140 cast_environment_->logger()->DispatchPacketEvent(receive_event.Pass()); | 144 cast_environment_->logger()->DispatchPacketEvent(std::move(receive_event)); |
| 141 } | 145 } |
| 142 | 146 |
| 143 GetEventsAndReset(); | 147 GetEventsAndReset(); |
| 144 | 148 |
| 145 ASSERT_EQ(10u, packet_events_.size()); | 149 ASSERT_EQ(10u, packet_events_.size()); |
| 146 EXPECT_EQ(100u, packet_events_.front()->relative_rtp_timestamp()); | 150 EXPECT_EQ(100u, packet_events_.front()->relative_rtp_timestamp()); |
| 147 EXPECT_EQ(1000u, packet_events_.back()->relative_rtp_timestamp()); | 151 EXPECT_EQ(1000u, packet_events_.back()->relative_rtp_timestamp()); |
| 148 } | 152 } |
| 149 | 153 |
| 150 TEST_F(EncodingEventSubscriberTest, EventFiltering) { | 154 TEST_F(EncodingEventSubscriberTest, EventFiltering) { |
| 151 Init(VIDEO_EVENT); | 155 Init(VIDEO_EVENT); |
| 152 | 156 |
| 153 base::TimeTicks now(testing_clock_->NowTicks()); | 157 base::TimeTicks now(testing_clock_->NowTicks()); |
| 154 RtpTimestamp rtp_timestamp = 100; | 158 RtpTimestamp rtp_timestamp = 100; |
| 155 scoped_ptr<FrameEvent> video_event(new FrameEvent()); | 159 scoped_ptr<FrameEvent> video_event(new FrameEvent()); |
| 156 video_event->timestamp = now; | 160 video_event->timestamp = now; |
| 157 video_event->type = FRAME_DECODED; | 161 video_event->type = FRAME_DECODED; |
| 158 video_event->media_type = VIDEO_EVENT; | 162 video_event->media_type = VIDEO_EVENT; |
| 159 video_event->rtp_timestamp = rtp_timestamp; | 163 video_event->rtp_timestamp = rtp_timestamp; |
| 160 video_event->frame_id = 0; | 164 video_event->frame_id = 0; |
| 161 cast_environment_->logger()->DispatchFrameEvent(video_event.Pass()); | 165 cast_environment_->logger()->DispatchFrameEvent(std::move(video_event)); |
| 162 | 166 |
| 163 // This is an AUDIO_EVENT and shouldn't be processed by the subscriber. | 167 // This is an AUDIO_EVENT and shouldn't be processed by the subscriber. |
| 164 scoped_ptr<FrameEvent> audio_event(new FrameEvent()); | 168 scoped_ptr<FrameEvent> audio_event(new FrameEvent()); |
| 165 audio_event->timestamp = now; | 169 audio_event->timestamp = now; |
| 166 audio_event->type = FRAME_DECODED; | 170 audio_event->type = FRAME_DECODED; |
| 167 audio_event->media_type = AUDIO_EVENT; | 171 audio_event->media_type = AUDIO_EVENT; |
| 168 audio_event->rtp_timestamp = rtp_timestamp; | 172 audio_event->rtp_timestamp = rtp_timestamp; |
| 169 audio_event->frame_id = 0; | 173 audio_event->frame_id = 0; |
| 170 cast_environment_->logger()->DispatchFrameEvent(audio_event.Pass()); | 174 cast_environment_->logger()->DispatchFrameEvent(std::move(audio_event)); |
| 171 | 175 |
| 172 GetEventsAndReset(); | 176 GetEventsAndReset(); |
| 173 | 177 |
| 174 ASSERT_EQ(1u, frame_events_.size()); | 178 ASSERT_EQ(1u, frame_events_.size()); |
| 175 FrameEventList::iterator it = frame_events_.begin(); | 179 FrameEventList::iterator it = frame_events_.begin(); |
| 176 | 180 |
| 177 linked_ptr<AggregatedFrameEvent> frame_event = *it; | 181 linked_ptr<AggregatedFrameEvent> frame_event = *it; |
| 178 | 182 |
| 179 ASSERT_EQ(1, frame_event->event_type_size()); | 183 ASSERT_EQ(1, frame_event->event_type_size()); |
| 180 EXPECT_EQ(media::cast::proto::FRAME_DECODED, | 184 EXPECT_EQ(media::cast::proto::FRAME_DECODED, |
| 181 frame_event->event_type(0)); | 185 frame_event->event_type(0)); |
| 182 | 186 |
| 183 GetEventsAndReset(); | 187 GetEventsAndReset(); |
| 184 | 188 |
| 185 EXPECT_TRUE(packet_events_.empty()); | 189 EXPECT_TRUE(packet_events_.empty()); |
| 186 } | 190 } |
| 187 | 191 |
| 188 TEST_F(EncodingEventSubscriberTest, FrameEvent) { | 192 TEST_F(EncodingEventSubscriberTest, FrameEvent) { |
| 189 Init(VIDEO_EVENT); | 193 Init(VIDEO_EVENT); |
| 190 base::TimeTicks now(testing_clock_->NowTicks()); | 194 base::TimeTicks now(testing_clock_->NowTicks()); |
| 191 RtpTimestamp rtp_timestamp = 100; | 195 RtpTimestamp rtp_timestamp = 100; |
| 192 scoped_ptr<FrameEvent> decode_event(new FrameEvent()); | 196 scoped_ptr<FrameEvent> decode_event(new FrameEvent()); |
| 193 decode_event->timestamp = now; | 197 decode_event->timestamp = now; |
| 194 decode_event->type = FRAME_DECODED; | 198 decode_event->type = FRAME_DECODED; |
| 195 decode_event->media_type = VIDEO_EVENT; | 199 decode_event->media_type = VIDEO_EVENT; |
| 196 decode_event->rtp_timestamp = rtp_timestamp; | 200 decode_event->rtp_timestamp = rtp_timestamp; |
| 197 decode_event->frame_id = 0; | 201 decode_event->frame_id = 0; |
| 198 cast_environment_->logger()->DispatchFrameEvent(decode_event.Pass()); | 202 cast_environment_->logger()->DispatchFrameEvent(std::move(decode_event)); |
| 199 | 203 |
| 200 GetEventsAndReset(); | 204 GetEventsAndReset(); |
| 201 | 205 |
| 202 ASSERT_EQ(1u, frame_events_.size()); | 206 ASSERT_EQ(1u, frame_events_.size()); |
| 203 | 207 |
| 204 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; | 208 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
| 205 FrameEventList::iterator it = frame_events_.begin(); | 209 FrameEventList::iterator it = frame_events_.begin(); |
| 206 | 210 |
| 207 linked_ptr<AggregatedFrameEvent> event = *it; | 211 linked_ptr<AggregatedFrameEvent> event = *it; |
| 208 | 212 |
| (...skipping 16 matching lines...) Expand all Loading... |
| 225 base::TimeTicks now(testing_clock_->NowTicks()); | 229 base::TimeTicks now(testing_clock_->NowTicks()); |
| 226 RtpTimestamp rtp_timestamp = 100; | 230 RtpTimestamp rtp_timestamp = 100; |
| 227 int delay_ms = 100; | 231 int delay_ms = 100; |
| 228 scoped_ptr<FrameEvent> playout_event(new FrameEvent()); | 232 scoped_ptr<FrameEvent> playout_event(new FrameEvent()); |
| 229 playout_event->timestamp = now; | 233 playout_event->timestamp = now; |
| 230 playout_event->type = FRAME_PLAYOUT; | 234 playout_event->type = FRAME_PLAYOUT; |
| 231 playout_event->media_type = AUDIO_EVENT; | 235 playout_event->media_type = AUDIO_EVENT; |
| 232 playout_event->rtp_timestamp = rtp_timestamp; | 236 playout_event->rtp_timestamp = rtp_timestamp; |
| 233 playout_event->frame_id = 0; | 237 playout_event->frame_id = 0; |
| 234 playout_event->delay_delta = base::TimeDelta::FromMilliseconds(delay_ms); | 238 playout_event->delay_delta = base::TimeDelta::FromMilliseconds(delay_ms); |
| 235 cast_environment_->logger()->DispatchFrameEvent(playout_event.Pass()); | 239 cast_environment_->logger()->DispatchFrameEvent(std::move(playout_event)); |
| 236 | 240 |
| 237 GetEventsAndReset(); | 241 GetEventsAndReset(); |
| 238 | 242 |
| 239 ASSERT_EQ(1u, frame_events_.size()); | 243 ASSERT_EQ(1u, frame_events_.size()); |
| 240 | 244 |
| 241 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; | 245 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
| 242 FrameEventList::iterator it = frame_events_.begin(); | 246 FrameEventList::iterator it = frame_events_.begin(); |
| 243 | 247 |
| 244 linked_ptr<AggregatedFrameEvent> event = *it; | 248 linked_ptr<AggregatedFrameEvent> event = *it; |
| 245 | 249 |
| (...skipping 22 matching lines...) Expand all Loading... |
| 268 encode_event->timestamp = now; | 272 encode_event->timestamp = now; |
| 269 encode_event->type = FRAME_ENCODED; | 273 encode_event->type = FRAME_ENCODED; |
| 270 encode_event->media_type = VIDEO_EVENT; | 274 encode_event->media_type = VIDEO_EVENT; |
| 271 encode_event->rtp_timestamp = rtp_timestamp; | 275 encode_event->rtp_timestamp = rtp_timestamp; |
| 272 encode_event->frame_id = 0; | 276 encode_event->frame_id = 0; |
| 273 encode_event->size = size; | 277 encode_event->size = size; |
| 274 encode_event->key_frame = key_frame; | 278 encode_event->key_frame = key_frame; |
| 275 encode_event->target_bitrate = target_bitrate; | 279 encode_event->target_bitrate = target_bitrate; |
| 276 encode_event->encoder_cpu_utilization = encoder_cpu_utilization; | 280 encode_event->encoder_cpu_utilization = encoder_cpu_utilization; |
| 277 encode_event->idealized_bitrate_utilization = idealized_bitrate_utilization; | 281 encode_event->idealized_bitrate_utilization = idealized_bitrate_utilization; |
| 278 cast_environment_->logger()->DispatchFrameEvent(encode_event.Pass()); | 282 cast_environment_->logger()->DispatchFrameEvent(std::move(encode_event)); |
| 279 | 283 |
| 280 GetEventsAndReset(); | 284 GetEventsAndReset(); |
| 281 | 285 |
| 282 ASSERT_EQ(1u, frame_events_.size()); | 286 ASSERT_EQ(1u, frame_events_.size()); |
| 283 | 287 |
| 284 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; | 288 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
| 285 FrameEventList::iterator it = frame_events_.begin(); | 289 FrameEventList::iterator it = frame_events_.begin(); |
| 286 | 290 |
| 287 linked_ptr<AggregatedFrameEvent> event = *it; | 291 linked_ptr<AggregatedFrameEvent> event = *it; |
| 288 | 292 |
| (...skipping 18 matching lines...) Expand all Loading... |
| 307 RtpTimestamp rtp_timestamp1 = 100; | 311 RtpTimestamp rtp_timestamp1 = 100; |
| 308 RtpTimestamp rtp_timestamp2 = 200; | 312 RtpTimestamp rtp_timestamp2 = 200; |
| 309 base::TimeTicks now1(testing_clock_->NowTicks()); | 313 base::TimeTicks now1(testing_clock_->NowTicks()); |
| 310 scoped_ptr<FrameEvent> playout_event(new FrameEvent()); | 314 scoped_ptr<FrameEvent> playout_event(new FrameEvent()); |
| 311 playout_event->timestamp = now1; | 315 playout_event->timestamp = now1; |
| 312 playout_event->type = FRAME_PLAYOUT; | 316 playout_event->type = FRAME_PLAYOUT; |
| 313 playout_event->media_type = AUDIO_EVENT; | 317 playout_event->media_type = AUDIO_EVENT; |
| 314 playout_event->rtp_timestamp = rtp_timestamp1; | 318 playout_event->rtp_timestamp = rtp_timestamp1; |
| 315 playout_event->frame_id = 0; | 319 playout_event->frame_id = 0; |
| 316 playout_event->delay_delta = base::TimeDelta::FromMilliseconds(100); | 320 playout_event->delay_delta = base::TimeDelta::FromMilliseconds(100); |
| 317 cast_environment_->logger()->DispatchFrameEvent(playout_event.Pass()); | 321 cast_environment_->logger()->DispatchFrameEvent(std::move(playout_event)); |
| 318 | 322 |
| 319 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); | 323 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); |
| 320 base::TimeTicks now2(testing_clock_->NowTicks()); | 324 base::TimeTicks now2(testing_clock_->NowTicks()); |
| 321 scoped_ptr<FrameEvent> encode_event(new FrameEvent()); | 325 scoped_ptr<FrameEvent> encode_event(new FrameEvent()); |
| 322 encode_event->timestamp = now2; | 326 encode_event->timestamp = now2; |
| 323 encode_event->type = FRAME_ENCODED; | 327 encode_event->type = FRAME_ENCODED; |
| 324 encode_event->media_type = AUDIO_EVENT; | 328 encode_event->media_type = AUDIO_EVENT; |
| 325 encode_event->rtp_timestamp = rtp_timestamp2; | 329 encode_event->rtp_timestamp = rtp_timestamp2; |
| 326 encode_event->frame_id = 0; | 330 encode_event->frame_id = 0; |
| 327 encode_event->size = 123; | 331 encode_event->size = 123; |
| 328 encode_event->encoder_cpu_utilization = 0.44; | 332 encode_event->encoder_cpu_utilization = 0.44; |
| 329 encode_event->idealized_bitrate_utilization = 0.55; | 333 encode_event->idealized_bitrate_utilization = 0.55; |
| 330 cast_environment_->logger()->DispatchFrameEvent(encode_event.Pass()); | 334 cast_environment_->logger()->DispatchFrameEvent(std::move(encode_event)); |
| 331 | 335 |
| 332 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); | 336 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); |
| 333 base::TimeTicks now3(testing_clock_->NowTicks()); | 337 base::TimeTicks now3(testing_clock_->NowTicks()); |
| 334 scoped_ptr<FrameEvent> decode_event(new FrameEvent()); | 338 scoped_ptr<FrameEvent> decode_event(new FrameEvent()); |
| 335 decode_event->timestamp = now3; | 339 decode_event->timestamp = now3; |
| 336 decode_event->type = FRAME_DECODED; | 340 decode_event->type = FRAME_DECODED; |
| 337 decode_event->media_type = AUDIO_EVENT; | 341 decode_event->media_type = AUDIO_EVENT; |
| 338 decode_event->rtp_timestamp = rtp_timestamp1; | 342 decode_event->rtp_timestamp = rtp_timestamp1; |
| 339 decode_event->frame_id = 0; | 343 decode_event->frame_id = 0; |
| 340 cast_environment_->logger()->DispatchFrameEvent(decode_event.Pass()); | 344 cast_environment_->logger()->DispatchFrameEvent(std::move(decode_event)); |
| 341 | 345 |
| 342 GetEventsAndReset(); | 346 GetEventsAndReset(); |
| 343 | 347 |
| 344 ASSERT_EQ(2u, frame_events_.size()); | 348 ASSERT_EQ(2u, frame_events_.size()); |
| 345 | 349 |
| 346 RtpTimestamp relative_rtp_timestamp = rtp_timestamp1 - first_rtp_timestamp_; | 350 RtpTimestamp relative_rtp_timestamp = rtp_timestamp1 - first_rtp_timestamp_; |
| 347 FrameEventList::iterator it = frame_events_.begin(); | 351 FrameEventList::iterator it = frame_events_.begin(); |
| 348 | 352 |
| 349 linked_ptr<AggregatedFrameEvent> event = *it; | 353 linked_ptr<AggregatedFrameEvent> event = *it; |
| 350 | 354 |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 386 int size = 100; | 390 int size = 100; |
| 387 scoped_ptr<PacketEvent> receive_event(new PacketEvent()); | 391 scoped_ptr<PacketEvent> receive_event(new PacketEvent()); |
| 388 receive_event->timestamp = now; | 392 receive_event->timestamp = now; |
| 389 receive_event->type = PACKET_RECEIVED; | 393 receive_event->type = PACKET_RECEIVED; |
| 390 receive_event->media_type = AUDIO_EVENT; | 394 receive_event->media_type = AUDIO_EVENT; |
| 391 receive_event->rtp_timestamp = rtp_timestamp; | 395 receive_event->rtp_timestamp = rtp_timestamp; |
| 392 receive_event->frame_id = 0; | 396 receive_event->frame_id = 0; |
| 393 receive_event->packet_id = packet_id; | 397 receive_event->packet_id = packet_id; |
| 394 receive_event->max_packet_id = 10; | 398 receive_event->max_packet_id = 10; |
| 395 receive_event->size = size; | 399 receive_event->size = size; |
| 396 cast_environment_->logger()->DispatchPacketEvent(receive_event.Pass()); | 400 cast_environment_->logger()->DispatchPacketEvent(std::move(receive_event)); |
| 397 | 401 |
| 398 GetEventsAndReset(); | 402 GetEventsAndReset(); |
| 399 | 403 |
| 400 ASSERT_EQ(1u, packet_events_.size()); | 404 ASSERT_EQ(1u, packet_events_.size()); |
| 401 | 405 |
| 402 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; | 406 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
| 403 PacketEventList::iterator it = packet_events_.begin(); | 407 PacketEventList::iterator it = packet_events_.begin(); |
| 404 | 408 |
| 405 linked_ptr<AggregatedPacketEvent> event = *it; | 409 linked_ptr<AggregatedPacketEvent> event = *it; |
| 406 | 410 |
| (...skipping 21 matching lines...) Expand all Loading... |
| 428 int size = 100; | 432 int size = 100; |
| 429 scoped_ptr<PacketEvent> send_event(new PacketEvent()); | 433 scoped_ptr<PacketEvent> send_event(new PacketEvent()); |
| 430 send_event->timestamp = now1; | 434 send_event->timestamp = now1; |
| 431 send_event->type = PACKET_SENT_TO_NETWORK; | 435 send_event->type = PACKET_SENT_TO_NETWORK; |
| 432 send_event->media_type = VIDEO_EVENT; | 436 send_event->media_type = VIDEO_EVENT; |
| 433 send_event->rtp_timestamp = rtp_timestamp; | 437 send_event->rtp_timestamp = rtp_timestamp; |
| 434 send_event->frame_id = 0; | 438 send_event->frame_id = 0; |
| 435 send_event->packet_id = packet_id; | 439 send_event->packet_id = packet_id; |
| 436 send_event->max_packet_id = 10; | 440 send_event->max_packet_id = 10; |
| 437 send_event->size = size; | 441 send_event->size = size; |
| 438 cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); | 442 cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
| 439 | 443 |
| 440 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); | 444 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); |
| 441 base::TimeTicks now2(testing_clock_->NowTicks()); | 445 base::TimeTicks now2(testing_clock_->NowTicks()); |
| 442 scoped_ptr<PacketEvent> retransmit_event(new PacketEvent()); | 446 scoped_ptr<PacketEvent> retransmit_event(new PacketEvent()); |
| 443 retransmit_event->timestamp = now2; | 447 retransmit_event->timestamp = now2; |
| 444 retransmit_event->type = PACKET_RETRANSMITTED; | 448 retransmit_event->type = PACKET_RETRANSMITTED; |
| 445 retransmit_event->media_type = VIDEO_EVENT; | 449 retransmit_event->media_type = VIDEO_EVENT; |
| 446 retransmit_event->rtp_timestamp = rtp_timestamp; | 450 retransmit_event->rtp_timestamp = rtp_timestamp; |
| 447 retransmit_event->frame_id = 0; | 451 retransmit_event->frame_id = 0; |
| 448 retransmit_event->packet_id = packet_id; | 452 retransmit_event->packet_id = packet_id; |
| 449 retransmit_event->max_packet_id = 10; | 453 retransmit_event->max_packet_id = 10; |
| 450 retransmit_event->size = size; | 454 retransmit_event->size = size; |
| 451 cast_environment_->logger()->DispatchPacketEvent(retransmit_event.Pass()); | 455 cast_environment_->logger()->DispatchPacketEvent(std::move(retransmit_event)); |
| 452 | 456 |
| 453 GetEventsAndReset(); | 457 GetEventsAndReset(); |
| 454 | 458 |
| 455 ASSERT_EQ(1u, packet_events_.size()); | 459 ASSERT_EQ(1u, packet_events_.size()); |
| 456 | 460 |
| 457 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; | 461 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
| 458 PacketEventList::iterator it = packet_events_.begin(); | 462 PacketEventList::iterator it = packet_events_.begin(); |
| 459 | 463 |
| 460 linked_ptr<AggregatedPacketEvent> event = *it; | 464 linked_ptr<AggregatedPacketEvent> event = *it; |
| 461 | 465 |
| (...skipping 21 matching lines...) Expand all Loading... |
| 483 int size = 100; | 487 int size = 100; |
| 484 scoped_ptr<PacketEvent> send_event(new PacketEvent()); | 488 scoped_ptr<PacketEvent> send_event(new PacketEvent()); |
| 485 send_event->timestamp = now1; | 489 send_event->timestamp = now1; |
| 486 send_event->type = PACKET_SENT_TO_NETWORK; | 490 send_event->type = PACKET_SENT_TO_NETWORK; |
| 487 send_event->media_type = VIDEO_EVENT; | 491 send_event->media_type = VIDEO_EVENT; |
| 488 send_event->rtp_timestamp = rtp_timestamp; | 492 send_event->rtp_timestamp = rtp_timestamp; |
| 489 send_event->frame_id = 0; | 493 send_event->frame_id = 0; |
| 490 send_event->packet_id = packet_id_1; | 494 send_event->packet_id = packet_id_1; |
| 491 send_event->max_packet_id = 10; | 495 send_event->max_packet_id = 10; |
| 492 send_event->size = size; | 496 send_event->size = size; |
| 493 cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); | 497 cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
| 494 | 498 |
| 495 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); | 499 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); |
| 496 base::TimeTicks now2(testing_clock_->NowTicks()); | 500 base::TimeTicks now2(testing_clock_->NowTicks()); |
| 497 scoped_ptr<PacketEvent> retransmit_event(new PacketEvent()); | 501 scoped_ptr<PacketEvent> retransmit_event(new PacketEvent()); |
| 498 retransmit_event->timestamp = now2; | 502 retransmit_event->timestamp = now2; |
| 499 retransmit_event->type = PACKET_RETRANSMITTED; | 503 retransmit_event->type = PACKET_RETRANSMITTED; |
| 500 retransmit_event->media_type = VIDEO_EVENT; | 504 retransmit_event->media_type = VIDEO_EVENT; |
| 501 retransmit_event->rtp_timestamp = rtp_timestamp; | 505 retransmit_event->rtp_timestamp = rtp_timestamp; |
| 502 retransmit_event->frame_id = 0; | 506 retransmit_event->frame_id = 0; |
| 503 retransmit_event->packet_id = packet_id_2; | 507 retransmit_event->packet_id = packet_id_2; |
| 504 retransmit_event->max_packet_id = 10; | 508 retransmit_event->max_packet_id = 10; |
| 505 retransmit_event->size = size; | 509 retransmit_event->size = size; |
| 506 cast_environment_->logger()->DispatchPacketEvent(retransmit_event.Pass()); | 510 cast_environment_->logger()->DispatchPacketEvent(std::move(retransmit_event)); |
| 507 | 511 |
| 508 GetEventsAndReset(); | 512 GetEventsAndReset(); |
| 509 | 513 |
| 510 ASSERT_EQ(1u, packet_events_.size()); | 514 ASSERT_EQ(1u, packet_events_.size()); |
| 511 | 515 |
| 512 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; | 516 RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
| 513 PacketEventList::iterator it = packet_events_.begin(); | 517 PacketEventList::iterator it = packet_events_.begin(); |
| 514 | 518 |
| 515 linked_ptr<AggregatedPacketEvent> event = *it; | 519 linked_ptr<AggregatedPacketEvent> event = *it; |
| 516 | 520 |
| (...skipping 27 matching lines...) Expand all Loading... |
| 544 int size = 100; | 548 int size = 100; |
| 545 scoped_ptr<PacketEvent> send_event(new PacketEvent()); | 549 scoped_ptr<PacketEvent> send_event(new PacketEvent()); |
| 546 send_event->timestamp = now1; | 550 send_event->timestamp = now1; |
| 547 send_event->type = PACKET_SENT_TO_NETWORK; | 551 send_event->type = PACKET_SENT_TO_NETWORK; |
| 548 send_event->media_type = VIDEO_EVENT; | 552 send_event->media_type = VIDEO_EVENT; |
| 549 send_event->rtp_timestamp = rtp_timestamp_1; | 553 send_event->rtp_timestamp = rtp_timestamp_1; |
| 550 send_event->frame_id = 0; | 554 send_event->frame_id = 0; |
| 551 send_event->packet_id = packet_id_1; | 555 send_event->packet_id = packet_id_1; |
| 552 send_event->max_packet_id = 10; | 556 send_event->max_packet_id = 10; |
| 553 send_event->size = size; | 557 send_event->size = size; |
| 554 cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); | 558 cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
| 555 | 559 |
| 556 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); | 560 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(20)); |
| 557 base::TimeTicks now2(testing_clock_->NowTicks()); | 561 base::TimeTicks now2(testing_clock_->NowTicks()); |
| 558 scoped_ptr<PacketEvent> retransmit_event(new PacketEvent()); | 562 scoped_ptr<PacketEvent> retransmit_event(new PacketEvent()); |
| 559 retransmit_event->timestamp = now2; | 563 retransmit_event->timestamp = now2; |
| 560 retransmit_event->type = PACKET_RETRANSMITTED; | 564 retransmit_event->type = PACKET_RETRANSMITTED; |
| 561 retransmit_event->media_type = VIDEO_EVENT; | 565 retransmit_event->media_type = VIDEO_EVENT; |
| 562 retransmit_event->rtp_timestamp = rtp_timestamp_2; | 566 retransmit_event->rtp_timestamp = rtp_timestamp_2; |
| 563 retransmit_event->frame_id = 0; | 567 retransmit_event->frame_id = 0; |
| 564 retransmit_event->packet_id = packet_id_2; | 568 retransmit_event->packet_id = packet_id_2; |
| 565 retransmit_event->max_packet_id = 10; | 569 retransmit_event->max_packet_id = 10; |
| 566 retransmit_event->size = size; | 570 retransmit_event->size = size; |
| 567 cast_environment_->logger()->DispatchPacketEvent(retransmit_event.Pass()); | 571 cast_environment_->logger()->DispatchPacketEvent(std::move(retransmit_event)); |
| 568 | 572 |
| 569 GetEventsAndReset(); | 573 GetEventsAndReset(); |
| 570 | 574 |
| 571 ASSERT_EQ(2u, packet_events_.size()); | 575 ASSERT_EQ(2u, packet_events_.size()); |
| 572 | 576 |
| 573 RtpTimestamp relative_rtp_timestamp = rtp_timestamp_1 - first_rtp_timestamp_; | 577 RtpTimestamp relative_rtp_timestamp = rtp_timestamp_1 - first_rtp_timestamp_; |
| 574 PacketEventList::iterator it = packet_events_.begin(); | 578 PacketEventList::iterator it = packet_events_.begin(); |
| 575 | 579 |
| 576 linked_ptr<AggregatedPacketEvent> event = *it; | 580 linked_ptr<AggregatedPacketEvent> event = *it; |
| 577 | 581 |
| (...skipping 28 matching lines...) Expand all Loading... |
| 606 TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) { | 610 TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) { |
| 607 Init(VIDEO_EVENT); | 611 Init(VIDEO_EVENT); |
| 608 RtpTimestamp rtp_timestamp = 12345; | 612 RtpTimestamp rtp_timestamp = 12345; |
| 609 base::TimeTicks now(testing_clock_->NowTicks()); | 613 base::TimeTicks now(testing_clock_->NowTicks()); |
| 610 | 614 |
| 611 scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); | 615 scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); |
| 612 capture_begin_event->timestamp = now; | 616 capture_begin_event->timestamp = now; |
| 613 capture_begin_event->type = FRAME_CAPTURE_BEGIN; | 617 capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
| 614 capture_begin_event->media_type = VIDEO_EVENT; | 618 capture_begin_event->media_type = VIDEO_EVENT; |
| 615 capture_begin_event->rtp_timestamp = rtp_timestamp; | 619 capture_begin_event->rtp_timestamp = rtp_timestamp; |
| 616 cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); | 620 cast_environment_->logger()->DispatchFrameEvent( |
| 621 std::move(capture_begin_event)); |
| 617 | 622 |
| 618 scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); | 623 scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); |
| 619 capture_end_event->timestamp = now; | 624 capture_end_event->timestamp = now; |
| 620 capture_end_event->type = FRAME_CAPTURE_END; | 625 capture_end_event->type = FRAME_CAPTURE_END; |
| 621 capture_end_event->media_type = VIDEO_EVENT; | 626 capture_end_event->media_type = VIDEO_EVENT; |
| 622 capture_end_event->rtp_timestamp = rtp_timestamp + 30; | 627 capture_end_event->rtp_timestamp = rtp_timestamp + 30; |
| 623 capture_end_event->width = 1280; | 628 capture_end_event->width = 1280; |
| 624 capture_end_event->height = 720; | 629 capture_end_event->height = 720; |
| 625 cast_environment_->logger()->DispatchFrameEvent(capture_end_event.Pass()); | 630 cast_environment_->logger()->DispatchFrameEvent(std::move(capture_end_event)); |
| 626 | 631 |
| 627 GetEventsAndReset(); | 632 GetEventsAndReset(); |
| 628 | 633 |
| 629 EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_); | 634 EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_); |
| 630 FrameEventList::iterator it = frame_events_.begin(); | 635 FrameEventList::iterator it = frame_events_.begin(); |
| 631 ASSERT_NE(frame_events_.end(), it); | 636 ASSERT_NE(frame_events_.end(), it); |
| 632 EXPECT_EQ(0u, (*it)->relative_rtp_timestamp()); | 637 EXPECT_EQ(0u, (*it)->relative_rtp_timestamp()); |
| 633 | 638 |
| 634 ++it; | 639 ++it; |
| 635 ASSERT_NE(frame_events_.end(), it); | 640 ASSERT_NE(frame_events_.end(), it); |
| 636 EXPECT_EQ(30u, (*it)->relative_rtp_timestamp()); | 641 EXPECT_EQ(30u, (*it)->relative_rtp_timestamp()); |
| 637 EXPECT_EQ(1280, (*it)->width()); | 642 EXPECT_EQ(1280, (*it)->width()); |
| 638 EXPECT_EQ(720, (*it)->height()); | 643 EXPECT_EQ(720, (*it)->height()); |
| 639 | 644 |
| 640 rtp_timestamp = 67890; | 645 rtp_timestamp = 67890; |
| 641 | 646 |
| 642 capture_begin_event.reset(new FrameEvent()); | 647 capture_begin_event.reset(new FrameEvent()); |
| 643 capture_begin_event->timestamp = now; | 648 capture_begin_event->timestamp = now; |
| 644 capture_begin_event->type = FRAME_CAPTURE_BEGIN; | 649 capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
| 645 capture_begin_event->media_type = VIDEO_EVENT; | 650 capture_begin_event->media_type = VIDEO_EVENT; |
| 646 capture_begin_event->rtp_timestamp = rtp_timestamp; | 651 capture_begin_event->rtp_timestamp = rtp_timestamp; |
| 647 cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); | 652 cast_environment_->logger()->DispatchFrameEvent( |
| 653 std::move(capture_begin_event)); |
| 648 | 654 |
| 649 GetEventsAndReset(); | 655 GetEventsAndReset(); |
| 650 | 656 |
| 651 EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_); | 657 EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_); |
| 652 } | 658 } |
| 653 | 659 |
| 654 TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) { | 660 TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) { |
| 655 Init(VIDEO_EVENT); | 661 Init(VIDEO_EVENT); |
| 656 RtpTimestamp rtp_timestamp = 0xffffffff - 20; | 662 RtpTimestamp rtp_timestamp = 0xffffffff - 20; |
| 657 base::TimeTicks now(testing_clock_->NowTicks()); | 663 base::TimeTicks now(testing_clock_->NowTicks()); |
| 658 | 664 |
| 659 scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); | 665 scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); |
| 660 capture_begin_event->timestamp = now; | 666 capture_begin_event->timestamp = now; |
| 661 capture_begin_event->type = FRAME_CAPTURE_BEGIN; | 667 capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
| 662 capture_begin_event->media_type = VIDEO_EVENT; | 668 capture_begin_event->media_type = VIDEO_EVENT; |
| 663 capture_begin_event->rtp_timestamp = rtp_timestamp; | 669 capture_begin_event->rtp_timestamp = rtp_timestamp; |
| 664 cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); | 670 cast_environment_->logger()->DispatchFrameEvent( |
| 671 std::move(capture_begin_event)); |
| 665 | 672 |
| 666 // RtpTimestamp has now wrapped around. | 673 // RtpTimestamp has now wrapped around. |
| 667 scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); | 674 scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); |
| 668 capture_end_event->timestamp = now; | 675 capture_end_event->timestamp = now; |
| 669 capture_end_event->type = FRAME_CAPTURE_END; | 676 capture_end_event->type = FRAME_CAPTURE_END; |
| 670 capture_end_event->media_type = VIDEO_EVENT; | 677 capture_end_event->media_type = VIDEO_EVENT; |
| 671 capture_end_event->rtp_timestamp = rtp_timestamp + 30; | 678 capture_end_event->rtp_timestamp = rtp_timestamp + 30; |
| 672 capture_end_event->width = 1280; | 679 capture_end_event->width = 1280; |
| 673 capture_end_event->height = 720; | 680 capture_end_event->height = 720; |
| 674 cast_environment_->logger()->DispatchFrameEvent(capture_end_event.Pass()); | 681 cast_environment_->logger()->DispatchFrameEvent(std::move(capture_end_event)); |
| 675 | 682 |
| 676 GetEventsAndReset(); | 683 GetEventsAndReset(); |
| 677 | 684 |
| 678 FrameEventList::iterator it = frame_events_.begin(); | 685 FrameEventList::iterator it = frame_events_.begin(); |
| 679 ASSERT_NE(frame_events_.end(), it); | 686 ASSERT_NE(frame_events_.end(), it); |
| 680 EXPECT_EQ(0u, (*it)->relative_rtp_timestamp()); | 687 EXPECT_EQ(0u, (*it)->relative_rtp_timestamp()); |
| 681 | 688 |
| 682 ++it; | 689 ++it; |
| 683 ASSERT_NE(frame_events_.end(), it); | 690 ASSERT_NE(frame_events_.end(), it); |
| 684 EXPECT_EQ(30u, (*it)->relative_rtp_timestamp()); | 691 EXPECT_EQ(30u, (*it)->relative_rtp_timestamp()); |
| 685 EXPECT_EQ(1280, (*it)->width()); | 692 EXPECT_EQ(1280, (*it)->width()); |
| 686 EXPECT_EQ(720, (*it)->height()); | 693 EXPECT_EQ(720, (*it)->height()); |
| 687 } | 694 } |
| 688 | 695 |
| 689 TEST_F(EncodingEventSubscriberTest, MaxEventsPerProto) { | 696 TEST_F(EncodingEventSubscriberTest, MaxEventsPerProto) { |
| 690 Init(VIDEO_EVENT); | 697 Init(VIDEO_EVENT); |
| 691 RtpTimestamp rtp_timestamp = 100; | 698 RtpTimestamp rtp_timestamp = 100; |
| 692 for (int i = 0; i < kMaxEventsPerProto + 1; i++) { | 699 for (int i = 0; i < kMaxEventsPerProto + 1; i++) { |
| 693 scoped_ptr<FrameEvent> ack_event(new FrameEvent()); | 700 scoped_ptr<FrameEvent> ack_event(new FrameEvent()); |
| 694 ack_event->timestamp = testing_clock_->NowTicks(); | 701 ack_event->timestamp = testing_clock_->NowTicks(); |
| 695 ack_event->type = FRAME_ACK_RECEIVED; | 702 ack_event->type = FRAME_ACK_RECEIVED; |
| 696 ack_event->media_type = VIDEO_EVENT; | 703 ack_event->media_type = VIDEO_EVENT; |
| 697 ack_event->rtp_timestamp = rtp_timestamp; | 704 ack_event->rtp_timestamp = rtp_timestamp; |
| 698 ack_event->frame_id = 0; | 705 ack_event->frame_id = 0; |
| 699 cast_environment_->logger()->DispatchFrameEvent(ack_event.Pass()); | 706 cast_environment_->logger()->DispatchFrameEvent(std::move(ack_event)); |
| 700 | 707 |
| 701 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(30)); | 708 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(30)); |
| 702 } | 709 } |
| 703 | 710 |
| 704 GetEventsAndReset(); | 711 GetEventsAndReset(); |
| 705 | 712 |
| 706 ASSERT_EQ(2u, frame_events_.size()); | 713 ASSERT_EQ(2u, frame_events_.size()); |
| 707 FrameEventList::iterator frame_it = frame_events_.begin(); | 714 FrameEventList::iterator frame_it = frame_events_.begin(); |
| 708 ASSERT_TRUE(frame_it != frame_events_.end()); | 715 ASSERT_TRUE(frame_it != frame_events_.end()); |
| 709 | 716 |
| 710 linked_ptr<AggregatedFrameEvent> frame_event = *frame_it; | 717 linked_ptr<AggregatedFrameEvent> frame_event = *frame_it; |
| 711 | 718 |
| 712 EXPECT_EQ(kMaxEventsPerProto, frame_event->event_type_size()); | 719 EXPECT_EQ(kMaxEventsPerProto, frame_event->event_type_size()); |
| 713 | 720 |
| 714 for (int i = 0; i < kMaxPacketsPerFrame + 1; i++) { | 721 for (int i = 0; i < kMaxPacketsPerFrame + 1; i++) { |
| 715 scoped_ptr<PacketEvent> send_event(new PacketEvent()); | 722 scoped_ptr<PacketEvent> send_event(new PacketEvent()); |
| 716 send_event->timestamp = testing_clock_->NowTicks(); | 723 send_event->timestamp = testing_clock_->NowTicks(); |
| 717 send_event->type = PACKET_SENT_TO_NETWORK; | 724 send_event->type = PACKET_SENT_TO_NETWORK; |
| 718 send_event->media_type = VIDEO_EVENT; | 725 send_event->media_type = VIDEO_EVENT; |
| 719 send_event->rtp_timestamp = rtp_timestamp; | 726 send_event->rtp_timestamp = rtp_timestamp; |
| 720 send_event->frame_id = 0; | 727 send_event->frame_id = 0; |
| 721 send_event->packet_id = i; | 728 send_event->packet_id = i; |
| 722 send_event->max_packet_id = kMaxPacketsPerFrame; | 729 send_event->max_packet_id = kMaxPacketsPerFrame; |
| 723 send_event->size = 123; | 730 send_event->size = 123; |
| 724 cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); | 731 cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
| 725 | 732 |
| 726 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(30)); | 733 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(30)); |
| 727 } | 734 } |
| 728 | 735 |
| 729 GetEventsAndReset(); | 736 GetEventsAndReset(); |
| 730 | 737 |
| 731 EXPECT_EQ(2u, packet_events_.size()); | 738 EXPECT_EQ(2u, packet_events_.size()); |
| 732 | 739 |
| 733 PacketEventList::iterator packet_it = packet_events_.begin(); | 740 PacketEventList::iterator packet_it = packet_events_.begin(); |
| 734 ASSERT_TRUE(packet_it != packet_events_.end()); | 741 ASSERT_TRUE(packet_it != packet_events_.end()); |
| (...skipping 10 matching lines...) Expand all Loading... |
| 745 for (int j = 0; j < kMaxEventsPerProto + 1; j++) { | 752 for (int j = 0; j < kMaxEventsPerProto + 1; j++) { |
| 746 scoped_ptr<PacketEvent> send_event(new PacketEvent()); | 753 scoped_ptr<PacketEvent> send_event(new PacketEvent()); |
| 747 send_event->timestamp = testing_clock_->NowTicks(); | 754 send_event->timestamp = testing_clock_->NowTicks(); |
| 748 send_event->type = PACKET_SENT_TO_NETWORK; | 755 send_event->type = PACKET_SENT_TO_NETWORK; |
| 749 send_event->media_type = VIDEO_EVENT; | 756 send_event->media_type = VIDEO_EVENT; |
| 750 send_event->rtp_timestamp = rtp_timestamp; | 757 send_event->rtp_timestamp = rtp_timestamp; |
| 751 send_event->frame_id = 0; | 758 send_event->frame_id = 0; |
| 752 send_event->packet_id = 0; | 759 send_event->packet_id = 0; |
| 753 send_event->max_packet_id = 0; | 760 send_event->max_packet_id = 0; |
| 754 send_event->size = 123; | 761 send_event->size = 123; |
| 755 cast_environment_->logger()->DispatchPacketEvent(send_event.Pass()); | 762 cast_environment_->logger()->DispatchPacketEvent(std::move(send_event)); |
| 756 | 763 |
| 757 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(30)); | 764 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(30)); |
| 758 } | 765 } |
| 759 | 766 |
| 760 GetEventsAndReset(); | 767 GetEventsAndReset(); |
| 761 | 768 |
| 762 EXPECT_EQ(2u, packet_events_.size()); | 769 EXPECT_EQ(2u, packet_events_.size()); |
| 763 packet_it = packet_events_.begin(); | 770 packet_it = packet_events_.begin(); |
| 764 ASSERT_TRUE(packet_it != packet_events_.end()); | 771 ASSERT_TRUE(packet_it != packet_events_.end()); |
| 765 | 772 |
| 766 packet_event = *packet_it; | 773 packet_event = *packet_it; |
| 767 | 774 |
| 768 EXPECT_EQ(kMaxEventsPerProto, | 775 EXPECT_EQ(kMaxEventsPerProto, |
| 769 packet_event->base_packet_event(0).event_type_size()); | 776 packet_event->base_packet_event(0).event_type_size()); |
| 770 | 777 |
| 771 ++packet_it; | 778 ++packet_it; |
| 772 packet_event = *packet_it; | 779 packet_event = *packet_it; |
| 773 EXPECT_EQ(1, packet_event->base_packet_event(0).event_type_size()); | 780 EXPECT_EQ(1, packet_event->base_packet_event(0).event_type_size()); |
| 774 } | 781 } |
| 775 | 782 |
| 776 } // namespace cast | 783 } // namespace cast |
| 777 } // namespace media | 784 } // namespace media |
| OLD | NEW |