| OLD | NEW |
| 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/file_util.h" | 9 #include "base/file_util.h" |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 330 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 341 video_event_subscriber.get()); | 341 video_event_subscriber.get()); |
| 342 media::cast::FrameEventMap frame_events; | 342 media::cast::FrameEventMap frame_events; |
| 343 media::cast::PacketEventMap packet_events; | 343 media::cast::PacketEventMap packet_events; |
| 344 media::cast::RtpTimestamp first_rtp_timestamp; | 344 media::cast::RtpTimestamp first_rtp_timestamp; |
| 345 video_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, | 345 video_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, |
| 346 &first_rtp_timestamp); | 346 &first_rtp_timestamp); |
| 347 | 347 |
| 348 VLOG(0) << "Video frame map size: " << frame_events.size(); | 348 VLOG(0) << "Video frame map size: " << frame_events.size(); |
| 349 VLOG(0) << "Video packet map size: " << packet_events.size(); | 349 VLOG(0) << "Video packet map size: " << packet_events.size(); |
| 350 | 350 |
| 351 // "Assign" stream id 0 for the video events. | 351 if (!serializer.SerializeEventsForStream(false, frame_events, packet_events, |
| 352 if (!serializer.SerializeEventsForStream(0, frame_events, packet_events, | |
| 353 first_rtp_timestamp)) { | 352 first_rtp_timestamp)) { |
| 354 VLOG(1) << "Failed to serialize video events."; | 353 VLOG(1) << "Failed to serialize video events."; |
| 355 return; | 354 return; |
| 356 } | 355 } |
| 357 | 356 |
| 358 int length_so_far = serializer.GetSerializedLength(); | 357 int length_so_far = serializer.GetSerializedLength(); |
| 359 VLOG(0) << "Video events serialized length: " << length_so_far; | 358 VLOG(0) << "Video events serialized length: " << length_so_far; |
| 360 | 359 |
| 361 // Serialize audio events. | 360 // Serialize audio events. |
| 362 cast_environment->Logging()->RemoveRawEventSubscriber( | 361 cast_environment->Logging()->RemoveRawEventSubscriber( |
| 363 audio_event_subscriber.get()); | 362 audio_event_subscriber.get()); |
| 364 audio_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, | 363 audio_event_subscriber->GetEventsAndReset(&frame_events, &packet_events, |
| 365 &first_rtp_timestamp); | 364 &first_rtp_timestamp); |
| 366 | 365 |
| 367 VLOG(0) << "Audio frame map size: " << frame_events.size(); | 366 VLOG(0) << "Audio frame map size: " << frame_events.size(); |
| 368 VLOG(0) << "Audio packet map size: " << packet_events.size(); | 367 VLOG(0) << "Audio packet map size: " << packet_events.size(); |
| 369 | 368 |
| 370 // "Assign" stream id 1 for the audio events. | 369 if (!serializer.SerializeEventsForStream(true, frame_events, packet_events, |
| 371 if (!serializer.SerializeEventsForStream(1, frame_events, packet_events, | |
| 372 first_rtp_timestamp)) { | 370 first_rtp_timestamp)) { |
| 373 VLOG(1) << "Failed to serialize audio events."; | 371 VLOG(1) << "Failed to serialize audio events."; |
| 374 return; | 372 return; |
| 375 } | 373 } |
| 376 | 374 |
| 377 VLOG(0) << "Audio events serialized length: " | 375 VLOG(0) << "Audio events serialized length: " |
| 378 << serializer.GetSerializedLength() - length_so_far; | 376 << serializer.GetSerializedLength() - length_so_far; |
| 379 | 377 |
| 380 scoped_ptr<std::string> serialized_string = | 378 scoped_ptr<std::string> serialized_string = |
| 381 serializer.GetSerializedLogAndReset(); | 379 serializer.GetSerializedLogAndReset(); |
| (...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 495 | 493 |
| 496 test_thread.message_loop_proxy()->PostTask( | 494 test_thread.message_loop_proxy()->PostTask( |
| 497 FROM_HERE, | 495 FROM_HERE, |
| 498 base::Bind(&media::cast::SendProcess::SendFrame, | 496 base::Bind(&media::cast::SendProcess::SendFrame, |
| 499 base::Unretained(send_process.get()))); | 497 base::Unretained(send_process.get()))); |
| 500 | 498 |
| 501 io_message_loop.Run(); | 499 io_message_loop.Run(); |
| 502 | 500 |
| 503 return 0; | 501 return 0; |
| 504 } | 502 } |
| OLD | NEW |