Index: media/cast/test/sender.cc |
diff --git a/media/cast/test/sender.cc b/media/cast/test/sender.cc |
index 2ab957c9777e5639f8815414b640809cd99bcd7b..b5fcc1342f25f0497d682cdf29903d53cf0f6f14 100644 |
--- a/media/cast/test/sender.cc |
+++ b/media/cast/test/sender.cc |
@@ -317,6 +317,24 @@ 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"; |
@@ -421,14 +439,6 @@ int main(int argc, char** argv) { |
config.audio_rtp_config = audio_config.rtp_config; |
config.video_rtp_config = video_config.rtp_config; |
- scoped_ptr<media::cast::transport::CastTransportSender> transport_sender( |
- media::cast::transport::CastTransportSender::CreateCastTransportSender( |
- NULL, |
- clock.get(), |
- config, |
- base::Bind(&UpdateCastTransportStatus), |
- io_message_loop.message_loop_proxy())); |
- |
// Enable main and send side threads only. Enable raw event logging. |
// Running transport on the main thread. |
media::cast::CastLoggingConfig logging_config; |
@@ -444,6 +454,17 @@ int main(int argc, char** argv) { |
io_message_loop.message_loop_proxy(), |
logging_config)); |
+ scoped_ptr<media::cast::transport::CastTransportSender> transport_sender( |
+ media::cast::transport::CastTransportSender::CreateCastTransportSender( |
+ NULL, |
+ cast_environment->Clock(), |
+ config, |
+ logging_config, |
+ base::Bind(&UpdateCastTransportStatus), |
+ base::Bind(&LogRawEvents, cast_environment), |
+ base::TimeDelta::FromSeconds(1), |
+ io_message_loop.message_loop_proxy())); |
+ |
scoped_ptr<media::cast::CastSender> cast_sender( |
media::cast::CastSender::CreateCastSender( |
cast_environment, |
@@ -463,7 +484,6 @@ int main(int argc, char** argv) { |
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; |