OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // Test application that simulates a cast sender - Data can be either generated | 5 // Test application that simulates a cast sender - Data can be either generated |
6 // or read from a file. | 6 // or read from a file. |
7 | 7 |
8 #include "base/at_exit.h" | 8 #include "base/at_exit.h" |
9 #include "base/file_util.h" | 9 #include "base/file_util.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
(...skipping 330 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
341 video_event_subscriber.get()); | 341 video_event_subscriber.get()); |
342 media::cast::FrameEventMap frame_events; | 342 media::cast::FrameEventMap frame_events; |
343 media::cast::PacketEventMap packet_events; | 343 media::cast::PacketEventMap packet_events; |
344 media::cast::RtpTimestamp first_rtp_timestamp; | 344 media::cast::RtpTimestamp first_rtp_timestamp; |
345 video_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, | 345 video_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, |
346 &first_rtp_timestamp); | 346 &first_rtp_timestamp); |
347 | 347 |
348 VLOG(0) << "Video frame map size: " << frame_events.size(); | 348 VLOG(0) << "Video frame map size: " << frame_events.size(); |
349 VLOG(0) << "Video packet map size: " << packet_events.size(); | 349 VLOG(0) << "Video packet map size: " << packet_events.size(); |
350 | 350 |
351 // "Assign" stream id 0 for the video events. | 351 if (!serializer.SerializeEventsForStream(false, frame_events, packet_events, |
352 if (!serializer.SerializeEventsForStream(0, frame_events, packet_events, | |
353 first_rtp_timestamp)) { | 352 first_rtp_timestamp)) { |
354 VLOG(1) << "Failed to serialize video events."; | 353 VLOG(1) << "Failed to serialize video events."; |
355 return; | 354 return; |
356 } | 355 } |
357 | 356 |
358 int length_so_far = serializer.GetSerializedLength(); | 357 int length_so_far = serializer.GetSerializedLength(); |
359 VLOG(0) << "Video events serialized length: " << length_so_far; | 358 VLOG(0) << "Video events serialized length: " << length_so_far; |
360 | 359 |
361 // Serialize audio events. | 360 // Serialize audio events. |
362 cast_environment->Logging()->RemoveRawEventSubscriber( | 361 cast_environment->Logging()->RemoveRawEventSubscriber( |
363 audio_event_subscriber.get()); | 362 audio_event_subscriber.get()); |
364 audio_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, | 363 audio_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, |
365 &first_rtp_timestamp); | 364 &first_rtp_timestamp); |
366 | 365 |
367 VLOG(0) << "Audio frame map size: " << frame_events.size(); | 366 VLOG(0) << "Audio frame map size: " << frame_events.size(); |
368 VLOG(0) << "Audio packet map size: " << packet_events.size(); | 367 VLOG(0) << "Audio packet map size: " << packet_events.size(); |
369 | 368 |
370 // "Assign" stream id 1 for the audio events. | 369 if (!serializer.SerializeEventsForStream(true, frame_events, packet_events, |
371 if (!serializer.SerializeEventsForStream(1, frame_events, packet_events, | |
372 first_rtp_timestamp)) { | 370 first_rtp_timestamp)) { |
373 VLOG(1) << "Failed to serialize audio events."; | 371 VLOG(1) << "Failed to serialize audio events."; |
374 return; | 372 return; |
375 } | 373 } |
376 | 374 |
377 VLOG(0) << "Audio events serialized length: " | 375 VLOG(0) << "Audio events serialized length: " |
378 << serializer.GetSerializedLength() - length_so_far; | 376 << serializer.GetSerializedLength() - length_so_far; |
379 | 377 |
380 scoped_ptr<std::string> serialized_string = | 378 scoped_ptr<std::string> serialized_string = |
381 serializer.GetSerializedLogAndReset(); | 379 serializer.GetSerializedLogAndReset(); |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
495 | 493 |
496 test_thread.message_loop_proxy()->PostTask( | 494 test_thread.message_loop_proxy()->PostTask( |
497 FROM_HERE, | 495 FROM_HERE, |
498 base::Bind(&media::cast::SendProcess::SendFrame, | 496 base::Bind(&media::cast::SendProcess::SendFrame, |
499 base::Unretained(send_process.get()))); | 497 base::Unretained(send_process.get()))); |
500 | 498 |
501 io_message_loop.Run(); | 499 io_message_loop.Run(); |
502 | 500 |
503 return 0; | 501 return 0; |
504 } | 502 } |
OLD | NEW |