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/base_paths.h" | 9 #include "base/base_paths.h" |
10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
(...skipping 428 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
439 CHECK(end_result) << "Cast sender uninitialized"; | 439 CHECK(end_result) << "Cast sender uninitialized"; |
440 } | 440 } |
441 | 441 |
442 net::IPEndPoint CreateUDPAddress(std::string ip_str, int port) { | 442 net::IPEndPoint CreateUDPAddress(std::string ip_str, int port) { |
443 net::IPAddressNumber ip_number; | 443 net::IPAddressNumber ip_number; |
444 CHECK(net::ParseIPLiteralToNumber(ip_str, &ip_number)); | 444 CHECK(net::ParseIPLiteralToNumber(ip_str, &ip_number)); |
445 return net::IPEndPoint(ip_number, port); | 445 return net::IPEndPoint(ip_number, port); |
446 } | 446 } |
447 | 447 |
448 void DumpLoggingData(const media::cast::proto::LogMetadata& log_metadata, | 448 void DumpLoggingData(const media::cast::proto::LogMetadata& log_metadata, |
449 const media::cast::FrameEventMap& frame_events, | 449 const media::cast::FrameEventList& frame_events, |
450 const media::cast::PacketEventMap& packet_events, | 450 const media::cast::PacketEventList& packet_events, |
451 base::ScopedFILE log_file) { | 451 base::ScopedFILE log_file) { |
452 VLOG(0) << "Frame map size: " << frame_events.size(); | 452 VLOG(0) << "Frame map size: " << frame_events.size(); |
453 VLOG(0) << "Packet map size: " << packet_events.size(); | 453 VLOG(0) << "Packet map size: " << packet_events.size(); |
454 | 454 |
455 scoped_ptr<char[]> event_log(new char[kMaxSerializedLogBytes]); | 455 scoped_ptr<char[]> event_log(new char[kMaxSerializedLogBytes]); |
456 int event_log_bytes; | 456 int event_log_bytes; |
457 if (!media::cast::SerializeEvents(log_metadata, | 457 if (!media::cast::SerializeEvents(log_metadata, |
458 frame_events, | 458 frame_events, |
459 packet_events, | 459 packet_events, |
460 true, | 460 true, |
(...skipping 17 matching lines...) Expand all Loading... |
478 scoped_ptr<media::cast::EncodingEventSubscriber> audio_event_subscriber, | 478 scoped_ptr<media::cast::EncodingEventSubscriber> audio_event_subscriber, |
479 base::ScopedFILE video_log_file, | 479 base::ScopedFILE video_log_file, |
480 base::ScopedFILE audio_log_file) { | 480 base::ScopedFILE audio_log_file) { |
481 cast_environment->Logging()->RemoveRawEventSubscriber( | 481 cast_environment->Logging()->RemoveRawEventSubscriber( |
482 video_event_subscriber.get()); | 482 video_event_subscriber.get()); |
483 cast_environment->Logging()->RemoveRawEventSubscriber( | 483 cast_environment->Logging()->RemoveRawEventSubscriber( |
484 audio_event_subscriber.get()); | 484 audio_event_subscriber.get()); |
485 | 485 |
486 VLOG(0) << "Dumping logging data for video stream."; | 486 VLOG(0) << "Dumping logging data for video stream."; |
487 media::cast::proto::LogMetadata log_metadata; | 487 media::cast::proto::LogMetadata log_metadata; |
488 media::cast::FrameEventMap frame_events; | 488 media::cast::FrameEventList frame_events; |
489 media::cast::PacketEventMap packet_events; | 489 media::cast::PacketEventList packet_events; |
490 video_event_subscriber->GetEventsAndReset( | 490 video_event_subscriber->GetEventsAndReset( |
491 &log_metadata, &frame_events, &packet_events); | 491 &log_metadata, &frame_events, &packet_events); |
492 | 492 |
493 DumpLoggingData(log_metadata, | 493 DumpLoggingData(log_metadata, |
494 frame_events, | 494 frame_events, |
495 packet_events, | 495 packet_events, |
496 video_log_file.Pass()); | 496 video_log_file.Pass()); |
497 | 497 |
498 VLOG(0) << "Dumping logging data for audio stream."; | 498 VLOG(0) << "Dumping logging data for audio stream."; |
499 audio_event_subscriber->GetEventsAndReset( | 499 audio_event_subscriber->GetEventsAndReset( |
(...skipping 144 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
644 | 644 |
645 test_thread.message_loop_proxy()->PostTask( | 645 test_thread.message_loop_proxy()->PostTask( |
646 FROM_HERE, | 646 FROM_HERE, |
647 base::Bind(&media::cast::SendProcess::SendNextFrame, | 647 base::Bind(&media::cast::SendProcess::SendNextFrame, |
648 base::Unretained(send_process.get()))); | 648 base::Unretained(send_process.get()))); |
649 | 649 |
650 io_message_loop.Run(); | 650 io_message_loop.Run(); |
651 | 651 |
652 return 0; | 652 return 0; |
653 } | 653 } |
OLD | NEW |