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

Side by Side Diff: media/cast/transport/transport_audio_sender.cc

Issue 268983002: Revert of Cast: Fix two video freezing problems (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 7 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 unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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/transport/transport_audio_sender.h" 5 #include "media/cast/transport/transport_audio_sender.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/logging.h" 8 #include "base/logging.h"
9 #include "base/message_loop/message_loop.h" 9 #include "base/message_loop/message_loop.h"
10 #include "media/cast/transport/rtp_sender/rtp_sender.h" 10 #include "media/cast/transport/rtp_sender/rtp_sender.h"
11 11
12 namespace media { 12 namespace media {
13 namespace cast { 13 namespace cast {
14 namespace transport { 14 namespace transport {
15 15
16 TransportAudioSender::TransportAudioSender( 16 TransportAudioSender::TransportAudioSender(
17 const CastTransportAudioConfig& config, 17 const CastTransportAudioConfig& config,
18 base::TickClock* clock, 18 base::TickClock* clock,
19 const scoped_refptr<base::SingleThreadTaskRunner>& transport_task_runner, 19 const scoped_refptr<base::SingleThreadTaskRunner>& transport_task_runner,
20 PacedSender* const paced_packet_sender) 20 PacedSender* const paced_packet_sender)
21 : rtp_sender_(clock, transport_task_runner, paced_packet_sender), 21 : rtp_sender_(clock, transport_task_runner, paced_packet_sender),
22 encryptor_() { 22 encryptor_() {
23 initialized_ = rtp_sender_.InitializeAudio(config) && 23 rtp_sender_.InitializeAudio(config);
24 encryptor_.Initialize(config.rtp.config.aes_key, 24 initialized_ =
25 config.rtp.config.aes_iv_mask); 25 encryptor_.Initialize(config.base.aes_key, config.base.aes_iv_mask);
26 } 26 }
27 27
28 TransportAudioSender::~TransportAudioSender() {} 28 TransportAudioSender::~TransportAudioSender() {}
29 29
30 void TransportAudioSender::InsertCodedAudioFrame( 30 void TransportAudioSender::InsertCodedAudioFrame(
31 const EncodedAudioFrame* audio_frame, 31 const EncodedAudioFrame* audio_frame,
32 const base::TimeTicks& recorded_time) { 32 const base::TimeTicks& recorded_time) {
33 if (!initialized_) {
34 return;
35 }
36 if (encryptor_.initialized()) { 33 if (encryptor_.initialized()) {
37 EncodedAudioFrame encrypted_frame; 34 EncodedAudioFrame encrypted_frame;
38 if (!EncryptAudioFrame(*audio_frame, &encrypted_frame)) { 35 if (!EncryptAudioFrame(*audio_frame, &encrypted_frame)) {
39 return; 36 return;
40 } 37 }
41 rtp_sender_.IncomingEncodedAudioFrame(&encrypted_frame, recorded_time); 38 rtp_sender_.IncomingEncodedAudioFrame(&encrypted_frame, recorded_time);
42 } else { 39 } else {
43 rtp_sender_.IncomingEncodedAudioFrame(audio_frame, recorded_time); 40 rtp_sender_.IncomingEncodedAudioFrame(audio_frame, recorded_time);
44 } 41 }
45 } 42 }
46 43
47 bool TransportAudioSender::EncryptAudioFrame( 44 bool TransportAudioSender::EncryptAudioFrame(
48 const EncodedAudioFrame& audio_frame, 45 const EncodedAudioFrame& audio_frame,
49 EncodedAudioFrame* encrypted_frame) { 46 EncodedAudioFrame* encrypted_frame) {
50 if (!initialized_) {
51 return false;
52 }
53 if (!encryptor_.Encrypt( 47 if (!encryptor_.Encrypt(
54 audio_frame.frame_id, audio_frame.data, &encrypted_frame->data)) 48 audio_frame.frame_id, audio_frame.data, &encrypted_frame->data))
55 return false; 49 return false;
56 50
57 encrypted_frame->codec = audio_frame.codec; 51 encrypted_frame->codec = audio_frame.codec;
58 encrypted_frame->frame_id = audio_frame.frame_id; 52 encrypted_frame->frame_id = audio_frame.frame_id;
59 encrypted_frame->rtp_timestamp = audio_frame.rtp_timestamp; 53 encrypted_frame->rtp_timestamp = audio_frame.rtp_timestamp;
60 return true; 54 return true;
61 } 55 }
62 56
63 void TransportAudioSender::ResendPackets( 57 void TransportAudioSender::ResendPackets(
64 const MissingFramesAndPacketsMap& missing_frames_and_packets) { 58 const MissingFramesAndPacketsMap& missing_frames_and_packets) {
65 if (!initialized_) {
66 return;
67 }
68 rtp_sender_.ResendPackets(missing_frames_and_packets); 59 rtp_sender_.ResendPackets(missing_frames_and_packets);
69 } 60 }
70 61
71 void TransportAudioSender::SubscribeAudioRtpStatsCallback( 62 void TransportAudioSender::SubscribeAudioRtpStatsCallback(
72 const CastTransportRtpStatistics& callback) { 63 const CastTransportRtpStatistics& callback) {
73 rtp_sender_.SubscribeRtpStatsCallback(callback); 64 rtp_sender_.SubscribeRtpStatsCallback(callback);
74 } 65 }
75 66
76 } // namespace transport 67 } // namespace transport
77 } // namespace cast 68 } // namespace cast
78 } // namespace media 69 } // namespace media
OLDNEW
« no previous file with comments | « media/cast/transport/transport/udp_transport.cc ('k') | media/cast/transport/transport_video_sender.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698