| 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 |