Cast: IPC from browser to renderer to send packet events from transport to cast library.

media/cast/test/sender.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 // Test application that simulates a cast sender - Data can be either generated
 // or read from a file.
 
 #include "base/at_exit.h"
 #include "base/file_util.h"
 #include "base/logging.h"
@@ skipping 299 matching lines @@
   base::WeakPtrFactory<SendProcess> weak_factory_;
 };
 
 }  // namespace cast
 }  // namespace media
 
 namespace {
 void UpdateCastTransportStatus(
     media::cast::transport::CastTransportStatus status) {}
 
+void LogRawEvents(
+    const scoped_refptr<media::cast::CastEnvironment>& cast_environment,
+    const std::vector<media::cast::PacketEvent>& packet_events) {
+  VLOG(1) << "Got packet events from transport, size: " << packet_events.size();
+  for (std::vector<media::cast::PacketEvent>::const_iterator it =
+           packet_events.begin();
+       it != packet_events.end();
+       ++it) {
+    cast_environment->Logging()->InsertPacketEvent(it->timestamp,
+                                                   it->type,
+                                                   it->rtp_timestamp,
+                                                   it->frame_id,
+                                                   it->packet_id,
+                                                   it->max_packet_id,
+                                                   it->size);
+  }
+}
+
 void InitializationResult(media::cast::CastInitializationStatus result) {
   CHECK_EQ(result, media::cast::STATUS_INITIALIZED);
   VLOG(1) << "Cast Sender initialized";
 }
 
 net::IPEndPoint CreateUDPAddress(std::string ip_str, int port) {
   net::IPAddressNumber ip_number;
   CHECK(net::ParseIPLiteralToNumber(ip_str, &ip_number));
   return net::IPEndPoint(ip_number, port);
 }
@@ skipping 73 matching lines @@
   media::cast::GetPort(&remote_port);
 
   std::string remote_ip_address =
       media::cast::GetIpAddress("Enter receiver IP.");
 
   media::cast::AudioSenderConfig audio_config =
       media::cast::GetAudioSenderConfig();
   media::cast::VideoSenderConfig video_config =
       media::cast::GetVideoSenderConfig();
 
+  // Enable main and send side threads only. Enable raw event logging.
+  // Running transport on the main thread.
+  media::cast::CastLoggingConfig logging_config;
+  logging_config.enable_raw_data_collection = true;
+
   // Setting up transport config.
   media::cast::transport::CastTransportAudioConfig transport_audio_config;
   media::cast::transport::CastTransportVideoConfig transport_video_config;
   net::IPEndPoint remote_endpoint =
       CreateUDPAddress(remote_ip_address, remote_port);
   net::IPEndPoint local_endpoint = CreateUDPAddress("0.0.0.0", 0);
   transport_audio_config.base.ssrc = audio_config.sender_ssrc;
   transport_audio_config.base.rtp_config = audio_config.rtp_config;
   transport_video_config.base.ssrc = video_config.sender_ssrc;
   transport_video_config.base.rtp_config = video_config.rtp_config;
 
-  scoped_ptr<media::cast::transport::CastTransportSender> transport_sender =
-      media::cast::transport::CastTransportSender::Create(
-          NULL,  // net log.
-          clock.get(),
-          local_endpoint,
-          remote_endpoint,
-          base::Bind(&UpdateCastTransportStatus),
-          io_message_loop.message_loop_proxy());
-
-  transport_sender->InitializeAudio(transport_audio_config);
-  transport_sender->InitializeVideo(transport_video_config);
-
   // Enable main and send side threads only. Enable raw event and stats logging.
   // Running transport on the main thread.
   scoped_refptr<media::cast::CastEnvironment> cast_environment(
       new media::cast::CastEnvironment(
           clock.Pass(),
           io_message_loop.message_loop_proxy(),
           audio_thread.message_loop_proxy(),
           NULL,
           video_thread.message_loop_proxy(),
           NULL,
           io_message_loop.message_loop_proxy(),
           media::cast::GetLoggingConfigWithRawEventsAndStatsEnabled()));
 
+  scoped_ptr<media::cast::transport::CastTransportSender> transport_sender =
+      media::cast::transport::CastTransportSender::Create(
+          NULL,  // net log.
+          clock.get(),
+          local_endpoint,
+          remote_endpoint,
+          logging_config,
+          base::Bind(&UpdateCastTransportStatus),
+          base::Bind(&LogRawEvents, cast_environment),
+          base::TimeDelta::FromSeconds(1),
+          io_message_loop.message_loop_proxy());
+
+  transport_sender->InitializeAudio(transport_audio_config);
+  transport_sender->InitializeVideo(transport_video_config);
+
   scoped_ptr<media::cast::CastSender> cast_sender(
       media::cast::CastSender::CreateCastSender(
           cast_environment,
           &audio_config,
           &video_config,
           NULL,  // gpu_factories.
           base::Bind(&InitializationResult),
           transport_sender.get()));
 
   transport_sender->SetPacketReceiver(cast_sender->packet_receiver());
 
   media::cast::FrameInput* frame_input = cast_sender->frame_input();
   scoped_ptr<media::cast::SendProcess> send_process(
       new media::cast::SendProcess(test_thread.message_loop_proxy(),
                                    cast_environment->Clock(),
                                    video_config,
                                    frame_input));
 
   // Set up event subscribers.
-  // TODO(imcheng): Set up separate subscribers for audio / video / other.
   int logging_duration = media::cast::GetLoggingDuration();
   scoped_ptr<media::cast::EncodingEventSubscriber> video_event_subscriber;
   scoped_ptr<media::cast::EncodingEventSubscriber> audio_event_subscriber;
   if (logging_duration > 0) {
     std::string log_file_name(media::cast::GetLogFileDestination());
     video_event_subscriber.reset(new media::cast::EncodingEventSubscriber(
         media::cast::VIDEO_EVENT, 10000));
     audio_event_subscriber.reset(new media::cast::EncodingEventSubscriber(
         media::cast::AUDIO_EVENT, 10000));
     cast_environment->Logging()->AddRawEventSubscriber(
@@ skipping 18 matching lines @@
 
   test_thread.message_loop_proxy()->PostTask(
       FROM_HERE,
       base::Bind(&media::cast::SendProcess::SendFrame,
                  base::Unretained(send_process.get())));
 
   io_message_loop.Run();
 
   return 0;
 }