/* * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. * * Use of this source code is governed by a BSD-style license * that can be found in the LICENSE file in the root of the source * tree. An additional intellectual property rights grant can be found * in the file PATENTS. All contributing project authors may * be found in the AUTHORS file in the root of the source tree. */ #ifndef RTC_BASE_NUMERICS_SEQUENCE_NUMBER_UTIL_H_ #define RTC_BASE_NUMERICS_SEQUENCE_NUMBER_UTIL_H_ #include #include #include #include "absl/types/optional.h" #include "rtc_base/checks.h" #include "rtc_base/numerics/mod_ops.h" namespace webrtc { // Test if the sequence number |a| is ahead or at sequence number |b|. // // If |M| is an even number and the two sequence numbers are at max distance // from each other, then the sequence number with the highest value is // considered to be ahead. template inline typename std::enable_if<(M > 0), bool>::type AheadOrAt(T a, T b) { static_assert(std::is_unsigned::value, "Type must be an unsigned integer."); const T maxDist = M / 2; if (!(M & 1) && MinDiff(a, b) == maxDist) return b < a; return ForwardDiff(b, a) <= maxDist; } template inline typename std::enable_if<(M == 0), bool>::type AheadOrAt(T a, T b) { static_assert(std::is_unsigned::value, "Type must be an unsigned integer."); const T maxDist = std::numeric_limits::max() / 2 + T(1); if (a - b == maxDist) return b < a; return ForwardDiff(b, a) < maxDist; } template inline bool AheadOrAt(T a, T b) { return AheadOrAt(a, b); } // Test if the sequence number |a| is ahead of sequence number |b|. // // If |M| is an even number and the two sequence numbers are at max distance // from each other, then the sequence number with the highest value is // considered to be ahead. template inline bool AheadOf(T a, T b) { static_assert(std::is_unsigned::value, "Type must be an unsigned integer."); return a != b && AheadOrAt(a, b); } // Comparator used to compare sequence numbers in a continuous fashion. // // WARNING! If used to sort sequence numbers of length M then the interval // covered by the sequence numbers may not be larger than floor(M/2). template struct AscendingSeqNumComp { bool operator()(T a, T b) const { return AheadOf(a, b); } }; // Comparator used to compare sequence numbers in a continuous fashion. // // WARNING! If used to sort sequence numbers of length M then the interval // covered by the sequence numbers may not be larger than floor(M/2). template struct DescendingSeqNumComp { bool operator()(T a, T b) const { return AheadOf(b, a); } }; // A sequence number unwrapper where the first unwrapped value equals the // first value being unwrapped. template class SeqNumUnwrapper { static_assert( std::is_unsigned::value && std::numeric_limits::max() < std::numeric_limits::max(), "Type unwrapped must be an unsigned integer smaller than int64_t."); public: int64_t Unwrap(T value) { if (!last_value_) { last_unwrapped_ = {value}; } else { last_unwrapped_ += ForwardDiff(*last_value_, value); if (!AheadOrAt(value, *last_value_)) { constexpr int64_t kBackwardAdjustment = M == 0 ? int64_t{std::numeric_limits::max()} + 1 : M; last_unwrapped_ -= kBackwardAdjustment; } } last_value_ = value; return last_unwrapped_; } private: int64_t last_unwrapped_ = 0; absl::optional last_value_; }; } // namespace webrtc #endif // RTC_BASE_NUMERICS_SEQUENCE_NUMBER_UTIL_H_