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

Side by Side Diff: webrtc/call/call.cc

Issue 2981513002: Wire up RTP keep-alive in ortc api. (Closed)
Patch Set: deps, again Created 3 years, 4 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
« no previous file with comments | « webrtc/call/call.h ('k') | webrtc/call/call_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source 5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
(...skipping 194 matching lines...) Expand 10 before | Expand all | Expand 10 after
205 void SignalChannelNetworkState(MediaType media, NetworkState state) override; 205 void SignalChannelNetworkState(MediaType media, NetworkState state) override;
206 206
207 void OnTransportOverheadChanged(MediaType media, 207 void OnTransportOverheadChanged(MediaType media,
208 int transport_overhead_per_packet) override; 208 int transport_overhead_per_packet) override;
209 209
210 void OnNetworkRouteChanged(const std::string& transport_name, 210 void OnNetworkRouteChanged(const std::string& transport_name,
211 const rtc::NetworkRoute& network_route) override; 211 const rtc::NetworkRoute& network_route) override;
212 212
213 void OnSentPacket(const rtc::SentPacket& sent_packet) override; 213 void OnSentPacket(const rtc::SentPacket& sent_packet) override;
214 214
215
216 // Implements BitrateObserver. 215 // Implements BitrateObserver.
217 void OnNetworkChanged(uint32_t bitrate_bps, 216 void OnNetworkChanged(uint32_t bitrate_bps,
218 uint8_t fraction_loss, 217 uint8_t fraction_loss,
219 int64_t rtt_ms, 218 int64_t rtt_ms,
220 int64_t probing_interval_ms) override; 219 int64_t probing_interval_ms) override;
221 220
222 // Implements BitrateAllocator::LimitObserver. 221 // Implements BitrateAllocator::LimitObserver.
223 void OnAllocationLimitsChanged(uint32_t min_send_bitrate_bps, 222 void OnAllocationLimitsChanged(uint32_t min_send_bitrate_bps,
224 uint32_t max_padding_bitrate_bps) override; 223 uint32_t max_padding_bitrate_bps) override;
225 224
(...skipping 501 matching lines...) Expand 10 before | Expand all | Expand 10 after
727 } 726 }
728 727
729 // TODO(mflodman): Base the start bitrate on a current bandwidth estimate, if 728 // TODO(mflodman): Base the start bitrate on a current bandwidth estimate, if
730 // the call has already started. 729 // the call has already started.
731 // Copy ssrcs from |config| since |config| is moved. 730 // Copy ssrcs from |config| since |config| is moved.
732 std::vector<uint32_t> ssrcs = config.rtp.ssrcs; 731 std::vector<uint32_t> ssrcs = config.rtp.ssrcs;
733 VideoSendStream* send_stream = new VideoSendStream( 732 VideoSendStream* send_stream = new VideoSendStream(
734 num_cpu_cores_, module_process_thread_.get(), &worker_queue_, 733 num_cpu_cores_, module_process_thread_.get(), &worker_queue_,
735 call_stats_.get(), transport_send_.get(), bitrate_allocator_.get(), 734 call_stats_.get(), transport_send_.get(), bitrate_allocator_.get(),
736 video_send_delay_stats_.get(), event_log_, std::move(config), 735 video_send_delay_stats_.get(), event_log_, std::move(config),
737 std::move(encoder_config), suspended_video_send_ssrcs_, 736 std::move(encoder_config), suspended_video_send_ssrcs_);
738 config_.keepalive_config);
739 737
740 { 738 {
741 WriteLockScoped write_lock(*send_crit_); 739 WriteLockScoped write_lock(*send_crit_);
742 for (uint32_t ssrc : ssrcs) { 740 for (uint32_t ssrc : ssrcs) {
743 RTC_DCHECK(video_send_ssrcs_.find(ssrc) == video_send_ssrcs_.end()); 741 RTC_DCHECK(video_send_ssrcs_.find(ssrc) == video_send_ssrcs_.end());
744 video_send_ssrcs_[ssrc] = send_stream; 742 video_send_ssrcs_[ssrc] = send_stream;
745 } 743 }
746 video_send_streams_.insert(send_stream); 744 video_send_streams_.insert(send_stream);
747 } 745 }
748 send_stream->SignalNetworkState(video_network_state_); 746 send_stream->SignalNetworkState(video_network_state_);
(...skipping 668 matching lines...) Expand 10 before | Expand all | Expand 10 after
1417 (use_send_side_bwe && header.extension.hasTransportSequenceNumber)) { 1415 (use_send_side_bwe && header.extension.hasTransportSequenceNumber)) {
1418 receive_side_cc_.OnReceivedPacket( 1416 receive_side_cc_.OnReceivedPacket(
1419 packet.arrival_time_ms(), packet.payload_size() + packet.padding_size(), 1417 packet.arrival_time_ms(), packet.payload_size() + packet.padding_size(),
1420 header); 1418 header);
1421 } 1419 }
1422 } 1420 }
1423 1421
1424 } // namespace internal 1422 } // namespace internal
1425 1423
1426 } // namespace webrtc 1424 } // namespace webrtc
OLDNEW
« no previous file with comments | « webrtc/call/call.h ('k') | webrtc/call/call_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698