| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 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 158 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 169 ssrc_(0), | 169 ssrc_(0), |
| 170 remote_ssrc_(0), | 170 remote_ssrc_(0), |
| 171 receive_statistics_(receive_statistics), | 171 receive_statistics_(receive_statistics), |
| 172 | 172 |
| 173 sequence_number_fir_(0), | 173 sequence_number_fir_(0), |
| 174 | 174 |
| 175 remb_bitrate_(0), | 175 remb_bitrate_(0), |
| 176 | 176 |
| 177 tmmbr_send_bps_(0), | 177 tmmbr_send_bps_(0), |
| 178 packet_oh_send_(0), | 178 packet_oh_send_(0), |
| 179 max_payload_length_(IP_PACKET_SIZE - 28), // IPv4 + UDP by default. | 179 max_packet_size_(IP_PACKET_SIZE - 28), // IPv4 + UDP by default. |
| 180 | 180 |
| 181 app_sub_type_(0), | 181 app_sub_type_(0), |
| 182 app_name_(0), | 182 app_name_(0), |
| 183 app_data_(nullptr), | 183 app_data_(nullptr), |
| 184 app_length_(0), | 184 app_length_(0), |
| 185 | 185 |
| 186 xr_send_receiver_reference_time_enabled_(false), | 186 xr_send_receiver_reference_time_enabled_(false), |
| 187 packet_type_counter_observer_(packet_type_counter_observer) { | 187 packet_type_counter_observer_(packet_type_counter_observer) { |
| 188 RTC_DCHECK(transport_ != nullptr); | 188 RTC_DCHECK(transport_ != nullptr); |
| 189 | 189 |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 276 | 276 |
| 277 void RTCPSender::SetTMMBRStatus(bool enable) { | 277 void RTCPSender::SetTMMBRStatus(bool enable) { |
| 278 rtc::CritScope lock(&critical_section_rtcp_sender_); | 278 rtc::CritScope lock(&critical_section_rtcp_sender_); |
| 279 if (enable) { | 279 if (enable) { |
| 280 SetFlag(RTCPPacketType::kRtcpTmmbr, false); | 280 SetFlag(RTCPPacketType::kRtcpTmmbr, false); |
| 281 } else { | 281 } else { |
| 282 ConsumeFlag(RTCPPacketType::kRtcpTmmbr, true); | 282 ConsumeFlag(RTCPPacketType::kRtcpTmmbr, true); |
| 283 } | 283 } |
| 284 } | 284 } |
| 285 | 285 |
| 286 void RTCPSender::SetMaxPayloadLength(size_t max_payload_length) { | 286 void RTCPSender::SetMaxRtpPacketSize(size_t max_packet_size) { |
| 287 max_payload_length_ = max_payload_length; | 287 max_packet_size_ = max_packet_size; |
| 288 } | 288 } |
| 289 | 289 |
| 290 void RTCPSender::SetTimestampOffset(uint32_t timestamp_offset) { | 290 void RTCPSender::SetTimestampOffset(uint32_t timestamp_offset) { |
| 291 rtc::CritScope lock(&critical_section_rtcp_sender_); | 291 rtc::CritScope lock(&critical_section_rtcp_sender_); |
| 292 timestamp_offset_ = timestamp_offset; | 292 timestamp_offset_ = timestamp_offset; |
| 293 } | 293 } |
| 294 | 294 |
| 295 void RTCPSender::SetLastRtpTime(uint32_t rtp_timestamp, | 295 void RTCPSender::SetLastRtpTime(uint32_t rtp_timestamp, |
| 296 int64_t capture_time_ms) { | 296 int64_t capture_time_ms) { |
| 297 rtc::CritScope lock(&critical_section_rtcp_sender_); | 297 rtc::CritScope lock(&critical_section_rtcp_sender_); |
| (...skipping 523 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 821 } | 821 } |
| 822 | 822 |
| 823 if (packet_type_counter_observer_ != nullptr) { | 823 if (packet_type_counter_observer_ != nullptr) { |
| 824 packet_type_counter_observer_->RtcpPacketTypesCounterUpdated( | 824 packet_type_counter_observer_->RtcpPacketTypesCounterUpdated( |
| 825 remote_ssrc_, packet_type_counter_); | 825 remote_ssrc_, packet_type_counter_); |
| 826 } | 826 } |
| 827 | 827 |
| 828 RTC_DCHECK(AllVolatileFlagsConsumed()); | 828 RTC_DCHECK(AllVolatileFlagsConsumed()); |
| 829 } | 829 } |
| 830 | 830 |
| 831 size_t bytes_sent = container.SendPackets(max_payload_length_); | 831 size_t bytes_sent = container.SendPackets(max_packet_size_); |
| 832 return bytes_sent == 0 ? -1 : 0; | 832 return bytes_sent == 0 ? -1 : 0; |
| 833 } | 833 } |
| 834 | 834 |
| 835 void RTCPSender::PrepareReport(const FeedbackState& feedback_state) { | 835 void RTCPSender::PrepareReport(const FeedbackState& feedback_state) { |
| 836 bool generate_report; | 836 bool generate_report; |
| 837 if (IsFlagPresent(kRtcpSr) || IsFlagPresent(kRtcpRr)) { | 837 if (IsFlagPresent(kRtcpSr) || IsFlagPresent(kRtcpRr)) { |
| 838 // Report type already explicitly set, don't automatically populate. | 838 // Report type already explicitly set, don't automatically populate. |
| 839 generate_report = true; | 839 generate_report = true; |
| 840 RTC_DCHECK(ConsumeFlag(kRtcpReport) == false); | 840 RTC_DCHECK(ConsumeFlag(kRtcpReport) == false); |
| 841 } else { | 841 } else { |
| (...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1042 } | 1042 } |
| 1043 | 1043 |
| 1044 Transport* const transport_; | 1044 Transport* const transport_; |
| 1045 RtcEventLog* const event_log_; | 1045 RtcEventLog* const event_log_; |
| 1046 bool send_failure_; | 1046 bool send_failure_; |
| 1047 // TODO(terelius): We would like to | 1047 // TODO(terelius): We would like to |
| 1048 // RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(Sender); | 1048 // RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(Sender); |
| 1049 // but we can't because of an incorrect warning (C4822) in MVS 2013. | 1049 // but we can't because of an incorrect warning (C4822) in MVS 2013. |
| 1050 } sender(transport_, event_log_); | 1050 } sender(transport_, event_log_); |
| 1051 | 1051 |
| 1052 RTC_DCHECK_LE(max_payload_length_, IP_PACKET_SIZE); | 1052 RTC_DCHECK_LE(max_packet_size_, IP_PACKET_SIZE); |
| 1053 uint8_t buffer[IP_PACKET_SIZE]; | 1053 uint8_t buffer[IP_PACKET_SIZE]; |
| 1054 return packet.BuildExternalBuffer(buffer, max_payload_length_, &sender) && | 1054 return packet.BuildExternalBuffer(buffer, max_packet_size_, &sender) && |
| 1055 !sender.send_failure_; | 1055 !sender.send_failure_; |
| 1056 } | 1056 } |
| 1057 | 1057 |
| 1058 } // namespace webrtc | 1058 } // namespace webrtc |
| OLD | NEW |