OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2015 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 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
46 std::unique_ptr<int64_t[]> temp_deltas; | 46 std::unique_ptr<int64_t[]> temp_deltas; |
47 if (received_ts == nullptr) { | 47 if (received_ts == nullptr) { |
48 temp_deltas.reset(new int64_t[length]); | 48 temp_deltas.reset(new int64_t[length]); |
49 GenerateDeltas(received_seq, length, temp_deltas.get()); | 49 GenerateDeltas(received_seq, length, temp_deltas.get()); |
50 received_ts = temp_deltas.get(); | 50 received_ts = temp_deltas.get(); |
51 } | 51 } |
52 | 52 |
53 expected_seq_.clear(); | 53 expected_seq_.clear(); |
54 expected_deltas_.clear(); | 54 expected_deltas_.clear(); |
55 feedback_.reset(new TransportFeedback()); | 55 feedback_.reset(new TransportFeedback()); |
| 56 feedback_->SetBase(received_seq[0], received_ts[0]); |
| 57 ASSERT_TRUE(feedback_->IsConsistent()); |
56 | 58 |
57 feedback_->SetBase(received_seq[0], received_ts[0]); | |
58 int64_t last_time = feedback_->GetBaseTimeUs(); | 59 int64_t last_time = feedback_->GetBaseTimeUs(); |
59 for (int i = 0; i < length; ++i) { | 60 for (int i = 0; i < length; ++i) { |
60 int64_t time = received_ts[i]; | 61 int64_t time = received_ts[i]; |
61 EXPECT_TRUE(feedback_->AddReceivedPacket(received_seq[i], time)); | 62 EXPECT_TRUE(feedback_->AddReceivedPacket(received_seq[i], time)); |
62 | 63 |
63 if (last_time != -1) { | 64 if (last_time != -1) { |
64 int64_t delta = time - last_time; | 65 int64_t delta = time - last_time; |
65 expected_deltas_.push_back(delta); | 66 expected_deltas_.push_back(delta); |
66 } | 67 } |
67 last_time = time; | 68 last_time = time; |
68 } | 69 } |
| 70 ASSERT_TRUE(feedback_->IsConsistent()); |
69 expected_seq_.insert(expected_seq_.begin(), &received_seq[0], | 71 expected_seq_.insert(expected_seq_.begin(), &received_seq[0], |
70 &received_seq[length]); | 72 &received_seq[length]); |
71 } | 73 } |
72 | 74 |
73 void VerifyPacket() { | 75 void VerifyPacket() { |
| 76 ASSERT_TRUE(feedback_->IsConsistent()); |
74 serialized_ = feedback_->Build(); | 77 serialized_ = feedback_->Build(); |
75 VerifyInternal(); | 78 VerifyInternal(); |
76 feedback_ = TransportFeedback::ParseFrom(serialized_.data(), | 79 feedback_ = TransportFeedback::ParseFrom(serialized_.data(), |
77 serialized_.size()); | 80 serialized_.size()); |
| 81 ASSERT_TRUE(feedback_->IsConsistent()); |
78 ASSERT_NE(nullptr, feedback_.get()); | 82 ASSERT_NE(nullptr, feedback_.get()); |
79 VerifyInternal(); | 83 VerifyInternal(); |
80 } | 84 } |
81 | 85 |
82 static const size_t kAnySize = static_cast<size_t>(0) - 1; | 86 static const size_t kAnySize = static_cast<size_t>(0) - 1; |
83 | 87 |
84 private: | 88 private: |
85 void VerifyInternal() { | 89 void VerifyInternal() { |
86 if (expected_size_ != kAnySize) { | 90 if (expected_size_ != kAnySize) { |
87 // Round up to whole 32-bit words. | 91 // Round up to whole 32-bit words. |
(...skipping 276 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
364 packet.reset(new TransportFeedback()); | 368 packet.reset(new TransportFeedback()); |
365 packet->SetBase(0, 0); | 369 packet->SetBase(0, 0); |
366 EXPECT_TRUE(packet->AddReceivedPacket(0x0, 0)); | 370 EXPECT_TRUE(packet->AddReceivedPacket(0x0, 0)); |
367 EXPECT_FALSE(packet->AddReceivedPacket(0x8000 + 1, 1000)); | 371 EXPECT_FALSE(packet->AddReceivedPacket(0x8000 + 1, 1000)); |
368 | 372 |
369 // Packet status count max 0xFFFF. | 373 // Packet status count max 0xFFFF. |
370 packet.reset(new TransportFeedback()); | 374 packet.reset(new TransportFeedback()); |
371 packet->SetBase(0, 0); | 375 packet->SetBase(0, 0); |
372 EXPECT_TRUE(packet->AddReceivedPacket(0x0, 0)); | 376 EXPECT_TRUE(packet->AddReceivedPacket(0x0, 0)); |
373 EXPECT_TRUE(packet->AddReceivedPacket(0x8000, 1000)); | 377 EXPECT_TRUE(packet->AddReceivedPacket(0x8000, 1000)); |
374 EXPECT_TRUE(packet->AddReceivedPacket(0xFFFF, 2000)); | 378 EXPECT_TRUE(packet->AddReceivedPacket(0xFFFE, 2000)); |
375 EXPECT_FALSE(packet->AddReceivedPacket(0, 3000)); | 379 EXPECT_FALSE(packet->AddReceivedPacket(0xFFFF, 3000)); |
376 | 380 |
377 // Too large delta. | 381 // Too large delta. |
378 packet.reset(new TransportFeedback()); | 382 packet.reset(new TransportFeedback()); |
379 packet->SetBase(0, 0); | 383 packet->SetBase(0, 0); |
380 int64_t kMaxPositiveTimeDelta = std::numeric_limits<int16_t>::max() * | 384 int64_t kMaxPositiveTimeDelta = std::numeric_limits<int16_t>::max() * |
381 TransportFeedback::kDeltaScaleFactor; | 385 TransportFeedback::kDeltaScaleFactor; |
382 EXPECT_FALSE(packet->AddReceivedPacket( | 386 EXPECT_FALSE(packet->AddReceivedPacket( |
383 1, kMaxPositiveTimeDelta + TransportFeedback::kDeltaScaleFactor)); | 387 1, kMaxPositiveTimeDelta + TransportFeedback::kDeltaScaleFactor)); |
384 EXPECT_TRUE(packet->AddReceivedPacket(1, kMaxPositiveTimeDelta)); | 388 EXPECT_TRUE(packet->AddReceivedPacket(1, kMaxPositiveTimeDelta)); |
385 | 389 |
386 // Too large negative delta. | 390 // Too large negative delta. |
387 packet.reset(new TransportFeedback()); | 391 packet.reset(new TransportFeedback()); |
388 packet->SetBase(0, 0); | 392 packet->SetBase(0, 0); |
389 int64_t kMaxNegativeTimeDelta = std::numeric_limits<int16_t>::min() * | 393 int64_t kMaxNegativeTimeDelta = std::numeric_limits<int16_t>::min() * |
390 TransportFeedback::kDeltaScaleFactor; | 394 TransportFeedback::kDeltaScaleFactor; |
391 EXPECT_FALSE(packet->AddReceivedPacket( | 395 EXPECT_FALSE(packet->AddReceivedPacket( |
392 1, kMaxNegativeTimeDelta - TransportFeedback::kDeltaScaleFactor)); | 396 1, kMaxNegativeTimeDelta - TransportFeedback::kDeltaScaleFactor)); |
393 EXPECT_TRUE(packet->AddReceivedPacket(1, kMaxNegativeTimeDelta)); | 397 EXPECT_TRUE(packet->AddReceivedPacket(1, kMaxNegativeTimeDelta)); |
394 | 398 |
395 // Base time at maximum value. | 399 // Base time at maximum value. |
396 int64_t kMaxBaseTime = | 400 int64_t kMaxBaseTime = |
397 static_cast<int64_t>(TransportFeedback::kDeltaScaleFactor) * (1L << 8) * | 401 static_cast<int64_t>(TransportFeedback::kDeltaScaleFactor) * (1L << 8) * |
398 ((1L << 23) - 1); | 402 ((1L << 23) - 1); |
399 packet.reset(new TransportFeedback()); | 403 packet.reset(new TransportFeedback()); |
400 packet->SetBase(0, kMaxBaseTime); | 404 packet->SetBase(0, kMaxBaseTime); |
401 packet->AddReceivedPacket(0, kMaxBaseTime); | 405 EXPECT_TRUE(packet->AddReceivedPacket(0, kMaxBaseTime)); |
402 // Serialize and de-serialize (verify 24bit parsing). | 406 // Serialize and de-serialize (verify 24bit parsing). |
403 rtc::Buffer raw_packet = packet->Build(); | 407 rtc::Buffer raw_packet = packet->Build(); |
404 packet = TransportFeedback::ParseFrom(raw_packet.data(), raw_packet.size()); | 408 packet = TransportFeedback::ParseFrom(raw_packet.data(), raw_packet.size()); |
405 EXPECT_EQ(kMaxBaseTime, packet->GetBaseTimeUs()); | 409 EXPECT_EQ(kMaxBaseTime, packet->GetBaseTimeUs()); |
406 | 410 |
407 // Base time above maximum value. | 411 // Base time above maximum value. |
408 int64_t kTooLargeBaseTime = | 412 int64_t kTooLargeBaseTime = |
409 kMaxBaseTime + (TransportFeedback::kDeltaScaleFactor * (1L << 8)); | 413 kMaxBaseTime + (TransportFeedback::kDeltaScaleFactor * (1L << 8)); |
410 packet.reset(new TransportFeedback()); | 414 packet.reset(new TransportFeedback()); |
411 packet->SetBase(0, kTooLargeBaseTime); | 415 packet->SetBase(0, kTooLargeBaseTime); |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
473 rtc::Buffer serialized_packet = feedback.Build(); | 477 rtc::Buffer serialized_packet = feedback.Build(); |
474 std::unique_ptr<TransportFeedback> deserialized_packet = | 478 std::unique_ptr<TransportFeedback> deserialized_packet = |
475 TransportFeedback::ParseFrom(serialized_packet.data(), | 479 TransportFeedback::ParseFrom(serialized_packet.data(), |
476 serialized_packet.size()); | 480 serialized_packet.size()); |
477 EXPECT_TRUE(deserialized_packet.get() != nullptr); | 481 EXPECT_TRUE(deserialized_packet.get() != nullptr); |
478 } | 482 } |
479 } | 483 } |
480 | 484 |
481 } // namespace | 485 } // namespace |
482 } // namespace webrtc | 486 } // namespace webrtc |
OLD | NEW |