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

Unified Diff: media/cast/test/sender.cc

Issue 178073004: Cast: IPC from browser to renderer to send packet events from transport to cast library. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Change to DVLOG(1) Created 6 years, 10 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 side-by-side diff with in-line comments
Download patch
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;

Powered by Google App Engine
This is Rietveld 408576698