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

Side by Side Diff: media/cast/net/cast_transport_sender_impl.cc

Issue 399743002: Cast: Implement priority packets in PacedSender (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: comments Created 6 years, 5 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
« no previous file with comments | « no previous file | media/cast/net/pacing/paced_sender.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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/net/cast_transport_sender_impl.h" 5 #include "media/cast/net/cast_transport_sender_impl.h"
6 6
7 #include "base/single_thread_task_runner.h" 7 #include "base/single_thread_task_runner.h"
8 #include "media/cast/net/cast_transport_config.h" 8 #include "media/cast/net/cast_transport_config.h"
9 #include "media/cast/net/cast_transport_defines.h" 9 #include "media/cast/net/cast_transport_defines.h"
10 #include "media/cast/net/udp_transport.h" 10 #include "media/cast/net/udp_transport.h"
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after
82 void CastTransportSenderImpl::InitializeAudio( 82 void CastTransportSenderImpl::InitializeAudio(
83 const CastTransportRtpConfig& config) { 83 const CastTransportRtpConfig& config) {
84 LOG_IF(WARNING, config.aes_key.empty() || config.aes_iv_mask.empty()) 84 LOG_IF(WARNING, config.aes_key.empty() || config.aes_iv_mask.empty())
85 << "Unsafe to send audio with encryption DISABLED."; 85 << "Unsafe to send audio with encryption DISABLED.";
86 if (!audio_encryptor_.Initialize(config.aes_key, config.aes_iv_mask)) { 86 if (!audio_encryptor_.Initialize(config.aes_key, config.aes_iv_mask)) {
87 status_callback_.Run(TRANSPORT_AUDIO_UNINITIALIZED); 87 status_callback_.Run(TRANSPORT_AUDIO_UNINITIALIZED);
88 return; 88 return;
89 } 89 }
90 audio_sender_.reset(new RtpSender(clock_, transport_task_runner_, &pacer_)); 90 audio_sender_.reset(new RtpSender(clock_, transport_task_runner_, &pacer_));
91 if (audio_sender_->Initialize(config)) { 91 if (audio_sender_->Initialize(config)) {
92 // Audio packets have a higher priority.
92 pacer_.RegisterAudioSsrc(config.ssrc); 93 pacer_.RegisterAudioSsrc(config.ssrc);
94 pacer_.RegisterPrioritySsrc(config.ssrc);
93 status_callback_.Run(TRANSPORT_AUDIO_INITIALIZED); 95 status_callback_.Run(TRANSPORT_AUDIO_INITIALIZED);
94 } else { 96 } else {
95 audio_sender_.reset(); 97 audio_sender_.reset();
96 status_callback_.Run(TRANSPORT_AUDIO_UNINITIALIZED); 98 status_callback_.Run(TRANSPORT_AUDIO_UNINITIALIZED);
97 } 99 }
98 } 100 }
99 101
100 void CastTransportSenderImpl::InitializeVideo( 102 void CastTransportSenderImpl::InitializeVideo(
101 const CastTransportRtpConfig& config) { 103 const CastTransportRtpConfig& config) {
102 LOG_IF(WARNING, config.aes_key.empty() || config.aes_iv_mask.empty()) 104 LOG_IF(WARNING, config.aes_key.empty() || config.aes_iv_mask.empty())
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
198 void CastTransportSenderImpl::SendRawEvents() { 200 void CastTransportSenderImpl::SendRawEvents() {
199 DCHECK(event_subscriber_.get()); 201 DCHECK(event_subscriber_.get());
200 DCHECK(!raw_events_callback_.is_null()); 202 DCHECK(!raw_events_callback_.is_null());
201 std::vector<PacketEvent> packet_events; 203 std::vector<PacketEvent> packet_events;
202 event_subscriber_->GetPacketEventsAndReset(&packet_events); 204 event_subscriber_->GetPacketEventsAndReset(&packet_events);
203 raw_events_callback_.Run(packet_events); 205 raw_events_callback_.Run(packet_events);
204 } 206 }
205 207
206 } // namespace cast 208 } // namespace cast
207 } // namespace media 209 } // namespace media
OLDNEW
« no previous file with comments | « no previous file | media/cast/net/pacing/paced_sender.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698