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

Side by Side Diff: media/cast/logging/encoding_event_subscriber_unittest.cc

Issue 1544313002: Convert Pass()→std::move() in //media (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 12 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 unified diff | Download patch
« no previous file with comments | « media/cast/cast_environment.cc ('k') | media/cast/logging/log_event_dispatcher.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
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
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
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
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
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
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
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
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
OLDNEW
« no previous file with comments | « media/cast/cast_environment.cc ('k') | media/cast/logging/log_event_dispatcher.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698