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 #include "media/cast/video_receiver/video_receiver.h" | 5 #include "media/cast/video_receiver/video_receiver.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
11 #include "base/message_loop/message_loop.h" | 11 #include "base/message_loop/message_loop.h" |
12 #include "crypto/encryptor.h" | 12 #include "crypto/encryptor.h" |
13 #include "crypto/symmetric_key.h" | 13 #include "crypto/symmetric_key.h" |
14 #include "media/cast/cast_defines.h" | 14 #include "media/cast/cast_defines.h" |
15 #include "media/cast/framer/framer.h" | 15 #include "media/cast/framer/framer.h" |
| 16 #include "media/cast/rtcp/rtcp_sender.h" |
16 #include "media/cast/video_receiver/video_decoder.h" | 17 #include "media/cast/video_receiver/video_decoder.h" |
17 | 18 |
18 namespace media { | 19 namespace media { |
19 namespace cast { | 20 namespace cast { |
20 | 21 |
21 const int64 kMinSchedulingDelayMs = 1; | 22 const int64 kMinSchedulingDelayMs = 1; |
22 | 23 |
23 static const int64 kMinTimeBetweenOffsetUpdatesMs = 2000; | 24 static const int64 kMinTimeBetweenOffsetUpdatesMs = 2000; |
24 static const int kTimeOffsetFilter = 8; | 25 static const int kTimeOffsetFilter = 8; |
25 static const int64_t kMinProcessIntervalMs = 5; | 26 static const int64_t kMinProcessIntervalMs = 5; |
(...skipping 410 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
436 // Send a cast feedback message. Actual message created in the framer (cast | 437 // Send a cast feedback message. Actual message created in the framer (cast |
437 // message builder). | 438 // message builder). |
438 void VideoReceiver::CastFeedback(const RtcpCastMessage& cast_message) { | 439 void VideoReceiver::CastFeedback(const RtcpCastMessage& cast_message) { |
439 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 440 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
440 | 441 |
441 RtcpReceiverLogMessage receiver_log; | 442 RtcpReceiverLogMessage receiver_log; |
442 VideoRtcpRawMap video_logs = | 443 VideoRtcpRawMap video_logs = |
443 cast_environment_->Logging()->GetVideoRtcpRawData(); | 444 cast_environment_->Logging()->GetVideoRtcpRawData(); |
444 | 445 |
445 while (!video_logs.empty()) { | 446 while (!video_logs.empty()) { |
| 447 // TODO(hclam): Avoid calling begin() within a loop. |
446 VideoRtcpRawMap::iterator it = video_logs.begin(); | 448 VideoRtcpRawMap::iterator it = video_logs.begin(); |
447 uint32 rtp_timestamp = it->first; | 449 uint32 rtp_timestamp = it->first; |
448 std::pair<VideoRtcpRawMap::iterator, VideoRtcpRawMap::iterator> | 450 std::pair<VideoRtcpRawMap::iterator, VideoRtcpRawMap::iterator> |
449 frame_range = video_logs.equal_range(rtp_timestamp); | 451 frame_range = video_logs.equal_range(rtp_timestamp); |
450 | 452 |
451 RtcpReceiverFrameLogMessage frame_log(rtp_timestamp); | 453 RtcpReceiverFrameLogMessage frame_log(rtp_timestamp); |
452 | 454 |
453 VideoRtcpRawMap::const_iterator event_it = frame_range.first; | 455 VideoRtcpRawMap::const_iterator event_it = frame_range.first; |
454 for (; event_it != frame_range.second; ++event_it) { | 456 for (; event_it != frame_range.second; ++event_it) { |
| 457 if (!RtcpSender::IsReceiverEvent(event_it->second.type)) |
| 458 continue; |
455 RtcpReceiverEventLogMessage event_log_message; | 459 RtcpReceiverEventLogMessage event_log_message; |
456 event_log_message.type = event_it->second.type; | 460 event_log_message.type = event_it->second.type; |
457 event_log_message.event_timestamp = event_it->second.timestamp; | 461 event_log_message.event_timestamp = event_it->second.timestamp; |
458 event_log_message.delay_delta = event_it->second.delay_delta; | 462 event_log_message.delay_delta = event_it->second.delay_delta; |
459 event_log_message.packet_id = event_it->second.packet_id; | 463 event_log_message.packet_id = event_it->second.packet_id; |
460 frame_log.event_log_messages_.push_back(event_log_message); | 464 frame_log.event_log_messages_.push_back(event_log_message); |
461 } | 465 } |
462 receiver_log.push_back(frame_log); | 466 receiver_log.push_back(frame_log); |
463 video_logs.erase(rtp_timestamp); | 467 video_logs.erase(rtp_timestamp); |
464 } | 468 } |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
507 } | 511 } |
508 | 512 |
509 void VideoReceiver::SendNextRtcpReport() { | 513 void VideoReceiver::SendNextRtcpReport() { |
510 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 514 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
511 rtcp_->SendRtcpFromRtpReceiver(NULL, NULL); | 515 rtcp_->SendRtcpFromRtpReceiver(NULL, NULL); |
512 ScheduleNextRtcpReport(); | 516 ScheduleNextRtcpReport(); |
513 } | 517 } |
514 | 518 |
515 } // namespace cast | 519 } // namespace cast |
516 } // namespace media | 520 } // namespace media |
OLD | NEW |