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

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

Issue 288103002: [Cast] EncodedAudioFrame+EncodedVideoFrame+reference_time --> EncodedFrame (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase 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 | Annotate | Revision Log
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 initialized_ = rtp_sender_.InitializeAudio(config) &&
24 encryptor_.Initialize(config.rtp.config.aes_key, 24 encryptor_.Initialize(config.rtp.config.aes_key,
25 config.rtp.config.aes_iv_mask); 25 config.rtp.config.aes_iv_mask);
26 } 26 }
27 27
28 TransportAudioSender::~TransportAudioSender() {} 28 TransportAudioSender::~TransportAudioSender() {}
29 29
30 void TransportAudioSender::InsertCodedAudioFrame( 30 void TransportAudioSender::SendFrame(const EncodedFrame& audio_frame) {
31 const EncodedAudioFrame* audio_frame,
32 const base::TimeTicks& recorded_time) {
33 if (!initialized_) { 31 if (!initialized_) {
34 return; 32 return;
35 } 33 }
36 if (encryptor_.initialized()) { 34 if (encryptor_.initialized()) {
37 EncodedAudioFrame encrypted_frame; 35 EncodedFrame encrypted_frame;
38 if (!EncryptAudioFrame(*audio_frame, &encrypted_frame)) { 36 if (!EncryptAudioFrame(audio_frame, &encrypted_frame)) {
37 NOTREACHED();
39 return; 38 return;
40 } 39 }
41 rtp_sender_.IncomingEncodedAudioFrame(&encrypted_frame, recorded_time); 40 rtp_sender_.SendFrame(encrypted_frame);
42 } else { 41 } else {
43 rtp_sender_.IncomingEncodedAudioFrame(audio_frame, recorded_time); 42 rtp_sender_.SendFrame(audio_frame);
44 } 43 }
45 } 44 }
46 45
47 bool TransportAudioSender::EncryptAudioFrame( 46 bool TransportAudioSender::EncryptAudioFrame(
48 const EncodedAudioFrame& audio_frame, 47 const EncodedFrame& audio_frame, EncodedFrame* encrypted_frame) {
49 EncodedAudioFrame* encrypted_frame) {
50 if (!initialized_) { 48 if (!initialized_) {
51 return false; 49 return false;
52 } 50 }
53 if (!encryptor_.Encrypt( 51 if (!encryptor_.Encrypt(
54 audio_frame.frame_id, audio_frame.data, &encrypted_frame->data)) 52 audio_frame.frame_id, audio_frame.data, &encrypted_frame->data))
55 return false; 53 return false;
56 54
57 encrypted_frame->codec = audio_frame.codec; 55 encrypted_frame->dependency = audio_frame.dependency;
58 encrypted_frame->frame_id = audio_frame.frame_id; 56 encrypted_frame->frame_id = audio_frame.frame_id;
57 encrypted_frame->referenced_frame_id = audio_frame.referenced_frame_id;
59 encrypted_frame->rtp_timestamp = audio_frame.rtp_timestamp; 58 encrypted_frame->rtp_timestamp = audio_frame.rtp_timestamp;
59 encrypted_frame->reference_time = audio_frame.reference_time;
60 return true; 60 return true;
61 } 61 }
62 62
63 void TransportAudioSender::ResendPackets( 63 void TransportAudioSender::ResendPackets(
64 const MissingFramesAndPacketsMap& missing_frames_and_packets) { 64 const MissingFramesAndPacketsMap& missing_frames_and_packets) {
65 if (!initialized_) { 65 if (!initialized_) {
66 return; 66 return;
67 } 67 }
68 rtp_sender_.ResendPackets(missing_frames_and_packets); 68 rtp_sender_.ResendPackets(missing_frames_and_packets);
69 } 69 }
70 70
71 } // namespace transport 71 } // namespace transport
72 } // namespace cast 72 } // namespace cast
73 } // namespace media 73 } // namespace media
OLDNEW
« no previous file with comments | « media/cast/transport/transport_audio_sender.h ('k') | media/cast/transport/transport_video_sender.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698