Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(63)

Side by Side Diff: media/cast/test/sender.cc

Issue 241833002: Cast: Limit number of events/packets in EncodingEventSubscriber protos. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fix merge Created 6 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « media/cast/logging/serialize_deserialize_test.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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 }
OLDNEW
« no previous file with comments | « media/cast/logging/serialize_deserialize_test.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698