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 |