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

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: 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
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 "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
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
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
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 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698