| OLD | NEW |
| 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 #include <algorithm> | 10 #include <algorithm> |
| (...skipping 513 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 524 if (!sequence_number_to_retransmit_) { | 524 if (!sequence_number_to_retransmit_) { |
| 525 sequence_number_to_retransmit_ = | 525 sequence_number_to_retransmit_ = |
| 526 rtc::Optional<uint16_t>(header.sequenceNumber); | 526 rtc::Optional<uint16_t>(header.sequenceNumber); |
| 527 | 527 |
| 528 // Don't ask for retransmission straight away, may be deduped in pacer. | 528 // Don't ask for retransmission straight away, may be deduped in pacer. |
| 529 } else if (header.sequenceNumber == *sequence_number_to_retransmit_) { | 529 } else if (header.sequenceNumber == *sequence_number_to_retransmit_) { |
| 530 observation_complete_.Set(); | 530 observation_complete_.Set(); |
| 531 } else { | 531 } else { |
| 532 // Send a NACK as often as necessary until retransmission is received. | 532 // Send a NACK as often as necessary until retransmission is received. |
| 533 rtcp::Nack nack; | 533 rtcp::Nack nack; |
| 534 nack.From(local_ssrc_); | 534 nack.SetSenderSsrc(local_ssrc_); |
| 535 nack.To(remote_ssrc_); | 535 nack.SetMediaSsrc(remote_ssrc_); |
| 536 uint16_t nack_list[] = {*sequence_number_to_retransmit_}; | 536 uint16_t nack_list[] = {*sequence_number_to_retransmit_}; |
| 537 nack.WithList(nack_list, 1); | 537 nack.SetPacketIds(nack_list, 1); |
| 538 rtc::Buffer buffer = nack.Build(); | 538 rtc::Buffer buffer = nack.Build(); |
| 539 | 539 |
| 540 EXPECT_TRUE(receive_transport_->SendRtcp(buffer.data(), buffer.size())); | 540 EXPECT_TRUE(receive_transport_->SendRtcp(buffer.data(), buffer.size())); |
| 541 } | 541 } |
| 542 | 542 |
| 543 return SEND_PACKET; | 543 return SEND_PACKET; |
| 544 } | 544 } |
| 545 | 545 |
| 546 void ModifyAudioConfigs( | 546 void ModifyAudioConfigs( |
| 547 AudioSendStream::Config* send_config, | 547 AudioSendStream::Config* send_config, |
| (...skipping 3196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3744 private: | 3744 private: |
| 3745 bool video_observed_; | 3745 bool video_observed_; |
| 3746 bool audio_observed_; | 3746 bool audio_observed_; |
| 3747 SequenceNumberUnwrapper unwrapper_; | 3747 SequenceNumberUnwrapper unwrapper_; |
| 3748 std::set<int64_t> received_packet_ids_; | 3748 std::set<int64_t> received_packet_ids_; |
| 3749 } test; | 3749 } test; |
| 3750 | 3750 |
| 3751 RunBaseTest(&test); | 3751 RunBaseTest(&test); |
| 3752 } | 3752 } |
| 3753 } // namespace webrtc | 3753 } // namespace webrtc |
| OLD | NEW |