| 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 <queue> | 8 #include <queue> |
| 9 | 9 |
| 10 #include "base/at_exit.h" | 10 #include "base/at_exit.h" |
| (...skipping 757 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 768 CHECK(end_result) << "Cast sender uninitialized"; | 768 CHECK(end_result) << "Cast sender uninitialized"; |
| 769 } | 769 } |
| 770 | 770 |
| 771 net::IPEndPoint CreateUDPAddress(std::string ip_str, int port) { | 771 net::IPEndPoint CreateUDPAddress(std::string ip_str, int port) { |
| 772 net::IPAddressNumber ip_number; | 772 net::IPAddressNumber ip_number; |
| 773 CHECK(net::ParseIPLiteralToNumber(ip_str, &ip_number)); | 773 CHECK(net::ParseIPLiteralToNumber(ip_str, &ip_number)); |
| 774 return net::IPEndPoint(ip_number, port); | 774 return net::IPEndPoint(ip_number, port); |
| 775 } | 775 } |
| 776 | 776 |
| 777 void DumpLoggingData(const media::cast::proto::LogMetadata& log_metadata, | 777 void DumpLoggingData(const media::cast::proto::LogMetadata& log_metadata, |
| 778 const media::cast::FrameEventMap& frame_events, | 778 const media::cast::FrameEventList& frame_events, |
| 779 const media::cast::PacketEventMap& packet_events, | 779 const media::cast::PacketEventList& packet_events, |
| 780 base::ScopedFILE log_file) { | 780 base::ScopedFILE log_file) { |
| 781 VLOG(0) << "Frame map size: " << frame_events.size(); | 781 VLOG(0) << "Frame map size: " << frame_events.size(); |
| 782 VLOG(0) << "Packet map size: " << packet_events.size(); | 782 VLOG(0) << "Packet map size: " << packet_events.size(); |
| 783 | 783 |
| 784 scoped_ptr<char[]> event_log(new char[kMaxSerializedLogBytes]); | 784 scoped_ptr<char[]> event_log(new char[kMaxSerializedLogBytes]); |
| 785 int event_log_bytes; | 785 int event_log_bytes; |
| 786 if (!media::cast::SerializeEvents(log_metadata, | 786 if (!media::cast::SerializeEvents(log_metadata, |
| 787 frame_events, | 787 frame_events, |
| 788 packet_events, | 788 packet_events, |
| 789 true, | 789 true, |
| (...skipping 17 matching lines...) Expand all Loading... |
| 807 scoped_ptr<media::cast::EncodingEventSubscriber> audio_event_subscriber, | 807 scoped_ptr<media::cast::EncodingEventSubscriber> audio_event_subscriber, |
| 808 base::ScopedFILE video_log_file, | 808 base::ScopedFILE video_log_file, |
| 809 base::ScopedFILE audio_log_file) { | 809 base::ScopedFILE audio_log_file) { |
| 810 cast_environment->Logging()->RemoveRawEventSubscriber( | 810 cast_environment->Logging()->RemoveRawEventSubscriber( |
| 811 video_event_subscriber.get()); | 811 video_event_subscriber.get()); |
| 812 cast_environment->Logging()->RemoveRawEventSubscriber( | 812 cast_environment->Logging()->RemoveRawEventSubscriber( |
| 813 audio_event_subscriber.get()); | 813 audio_event_subscriber.get()); |
| 814 | 814 |
| 815 VLOG(0) << "Dumping logging data for video stream."; | 815 VLOG(0) << "Dumping logging data for video stream."; |
| 816 media::cast::proto::LogMetadata log_metadata; | 816 media::cast::proto::LogMetadata log_metadata; |
| 817 media::cast::FrameEventMap frame_events; | 817 media::cast::FrameEventList frame_events; |
| 818 media::cast::PacketEventMap packet_events; | 818 media::cast::PacketEventList packet_events; |
| 819 video_event_subscriber->GetEventsAndReset( | 819 video_event_subscriber->GetEventsAndReset( |
| 820 &log_metadata, &frame_events, &packet_events); | 820 &log_metadata, &frame_events, &packet_events); |
| 821 | 821 |
| 822 DumpLoggingData(log_metadata, | 822 DumpLoggingData(log_metadata, |
| 823 frame_events, | 823 frame_events, |
| 824 packet_events, | 824 packet_events, |
| 825 video_log_file.Pass()); | 825 video_log_file.Pass()); |
| 826 | 826 |
| 827 VLOG(0) << "Dumping logging data for audio stream."; | 827 VLOG(0) << "Dumping logging data for audio stream."; |
| 828 audio_event_subscriber->GetEventsAndReset( | 828 audio_event_subscriber->GetEventsAndReset( |
| (...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 962 base::Passed(&video_event_subscriber), | 962 base::Passed(&video_event_subscriber), |
| 963 base::Passed(&audio_event_subscriber), | 963 base::Passed(&audio_event_subscriber), |
| 964 base::Passed(&video_log_file), | 964 base::Passed(&video_log_file), |
| 965 base::Passed(&audio_log_file)), | 965 base::Passed(&audio_log_file)), |
| 966 base::TimeDelta::FromSeconds(logging_duration_seconds)); | 966 base::TimeDelta::FromSeconds(logging_duration_seconds)); |
| 967 send_process->Start(cast_sender->audio_frame_input(), | 967 send_process->Start(cast_sender->audio_frame_input(), |
| 968 cast_sender->video_frame_input()); | 968 cast_sender->video_frame_input()); |
| 969 io_message_loop.Run(); | 969 io_message_loop.Run(); |
| 970 return 0; | 970 return 0; |
| 971 } | 971 } |
| OLD | NEW |