Index: webrtc/base/buffer.h |
diff --git a/webrtc/base/buffer.h b/webrtc/base/buffer.h |
index f007929a2943f053ffe4bc9a3349c5f708b71c69..05bcfe12406f8b1d449252e6dec9e05e0bd5c5fb 100644 |
--- a/webrtc/base/buffer.h |
+++ b/webrtc/base/buffer.h |
@@ -13,79 +13,113 @@ |
#include <cstring> |
#include <memory> |
+#include <type_traits> |
#include <utility> |
#include "webrtc/base/array_view.h" |
#include "webrtc/base/checks.h" |
-#include "webrtc/base/constructormagic.h" |
namespace rtc { |
namespace internal { |
-// (Internal; please don't use outside this file.) ByteType<T>::t is int if T |
-// is uint8_t, int8_t, or char; otherwise, it's a compilation error. Use like |
-// this: |
-// |
-// template <typename T, typename ByteType<T>::t = 0> |
-// void foo(T* x); |
-// |
-// to let foo<T> be defined only for byte-sized integers. |
-template <typename T> |
-struct ByteType { |
- private: |
- static int F(uint8_t*); |
- static int F(int8_t*); |
- static int F(char*); |
- |
- public: |
- using t = decltype(F(static_cast<T*>(nullptr))); |
+// (Internal; please don't use outside this file.) Determines if elements of |
+// type U are compatible with a BufferT<T>. For most types, we just ignore |
+// top-level const and forbid top-level volatile and require T and U to be |
+// otherwise equal, but all byte-sized integers (notably char, int8_t, and |
+// uint8_t) are compatible with each other. |
+template <typename T, typename U> |
+struct BufferCompat { |
+ static constexpr bool value = |
tommi
2016/04/28 22:49:08
first use of constexpr in webrtc? nice
kwiberg-webrtc
2016/04/29 00:00:19
No, not by a long shot. Here's the winner: https:/
tommi
2016/04/29 07:46:38
w00t!
|
+ !std::is_volatile<U>::value && |
+ ((std::is_integral<T>::value && sizeof(T) == 1) |
+ ? (std::is_integral<U>::value && sizeof(U) == 1) |
+ : (std::is_same<T, typename std::remove_const<U>::type>::value)); |
}; |
} // namespace internal |
// Basic buffer class, can be grown and shrunk dynamically. |
-// Unlike std::string/vector, does not initialize data when expanding capacity. |
-class Buffer { |
+// Unlike std::string/vector, does not initialize data when increasing size. |
+template <typename T> |
+class BufferT { |
+ // We want T's destructor and default constructor to be trivial, i.e. perform |
+ // no action, so that we don't have to touch the memory we allocate and |
+ // deallocate. And we want T to be trivially copyable, so that we can copy T |
+ // instances with std::memcpy. This is precisely the definition of a trivial |
+ // type. |
+ static_assert(std::is_trivial<T>::value, "T must be a trivial type."); |
+ |
+ // This class relies heavily on being able to mutate its data. |
+ static_assert(!std::is_const<T>::value, "T may not be const"); |
+ |
public: |
- Buffer(); // An empty buffer. |
- Buffer(Buffer&& buf); // Move contents from an existing buffer. |
- |
- // Construct a buffer with the specified number of uninitialized bytes. |
- explicit Buffer(size_t size); |
- Buffer(size_t size, size_t capacity); |
- |
- // Construct a buffer and copy the specified number of bytes into it. The |
- // source array may be (const) uint8_t*, int8_t*, or char*. |
- template <typename T, typename internal::ByteType<T>::t = 0> |
- Buffer(const T* data, size_t size) |
- : Buffer(data, size, size) {} |
- |
- template <typename T, typename internal::ByteType<T>::t = 0> |
- Buffer(const T* data, size_t size, size_t capacity) |
- : Buffer(size, capacity) { |
- std::memcpy(data_.get(), data, size); |
+ // An empty BufferT. |
+ BufferT() : size_(0), capacity_(0), data_(nullptr) { |
+ RTC_DCHECK(IsConsistent()); |
} |
- // Construct a buffer from the contents of an array. |
- template <typename T, size_t N, typename internal::ByteType<T>::t = 0> |
- Buffer(const T(&array)[N]) |
- : Buffer(array, N) {} |
+ // Disable copy construction and copy assignment, since copying a buffer is |
+ // expensive enough that we want to force the user to be explicit about it. |
+ BufferT(const BufferT&) = delete; |
+ BufferT& operator=(const BufferT&) = delete; |
- ~Buffer(); |
+ BufferT(BufferT&& buf) |
+ : size_(buf.size()), |
+ capacity_(buf.capacity()), |
+ data_(std::move(buf.data_)) { |
+ RTC_DCHECK(IsConsistent()); |
+ buf.OnMovedFrom(); |
+ } |
+ |
+ // Construct a buffer with the specified number of uninitialized elements. |
+ explicit BufferT(size_t size) : BufferT(size, size) {} |
+ |
+ BufferT(size_t size, size_t capacity) |
+ : size_(size), |
+ capacity_(std::max(size, capacity)), |
+ data_(new T[capacity_]) { |
+ RTC_DCHECK(IsConsistent()); |
+ } |
- // Get a pointer to the data. Just .data() will give you a (const) uint8_t*, |
- // but you may also use .data<int8_t>() and .data<char>(). |
- template <typename T = uint8_t, typename internal::ByteType<T>::t = 0> |
- const T* data() const { |
+ // Construct a buffer and copy the specified number of elements into it. |
+ template <typename U, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ BufferT(const U* data, size_t size) : BufferT(data, size, size) {} |
+ |
+ template <typename U, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ BufferT(U* data, size_t size, size_t capacity) : BufferT(size, capacity) { |
+ static_assert(sizeof(T) == sizeof(U), ""); |
+ std::memcpy(data_.get(), data, size * sizeof(U)); |
+ } |
+ |
+ // Construct a buffer from the contents of an array. |
+ template <typename U, |
+ size_t N, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ BufferT(U (&array)[N]) : BufferT(array, N) {} |
+ |
+ // Get a pointer to the data. Just .data() will give you a (const) T*, but if |
+ // T is a byte-sized integer, you may also use .data<U>() for any other |
+ // byte-sized integer U. |
+ template <typename U = T, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ const U* data() const { |
RTC_DCHECK(IsConsistent()); |
- return reinterpret_cast<T*>(data_.get()); |
+ return reinterpret_cast<U*>(data_.get()); |
} |
- template <typename T = uint8_t, typename internal::ByteType<T>::t = 0> |
- T* data() { |
+ template <typename U = T, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ U* data() { |
RTC_DCHECK(IsConsistent()); |
- return reinterpret_cast<T*>(data_.get()); |
+ return reinterpret_cast<U*>(data_.get()); |
} |
size_t size() const { |
@@ -98,7 +132,7 @@ class Buffer { |
return capacity_; |
} |
- Buffer& operator=(Buffer&& buf) { |
+ BufferT& operator=(BufferT&& buf) { |
RTC_DCHECK(IsConsistent()); |
RTC_DCHECK(buf.IsConsistent()); |
size_ = buf.size_; |
@@ -108,94 +142,110 @@ class Buffer { |
return *this; |
} |
- bool operator==(const Buffer& buf) const { |
+ bool operator==(const BufferT& buf) const { |
+ static_assert(std::is_integral<T>::value, "T must be an integral type"); |
RTC_DCHECK(IsConsistent()); |
- return size_ == buf.size() && memcmp(data_.get(), buf.data(), size_) == 0; |
+ return size_ == buf.size() && |
+ std::memcmp(data_.get(), buf.data(), size_ * sizeof(T)) == 0; |
} |
- bool operator!=(const Buffer& buf) const { return !(*this == buf); } |
+ bool operator!=(const BufferT& buf) const { return !(*this == buf); } |
- uint8_t& operator[](size_t index) { |
+ T& operator[](size_t index) { |
RTC_DCHECK_LT(index, size_); |
return data()[index]; |
} |
- uint8_t operator[](size_t index) const { |
+ T operator[](size_t index) const { |
RTC_DCHECK_LT(index, size_); |
return data()[index]; |
} |
// The SetData functions replace the contents of the buffer. They accept the |
// same input types as the constructors. |
- template <typename T, typename internal::ByteType<T>::t = 0> |
- void SetData(const T* data, size_t size) { |
+ template <typename U, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ void SetData(const U* data, size_t size) { |
RTC_DCHECK(IsConsistent()); |
size_ = 0; |
AppendData(data, size); |
} |
- template <typename T, size_t N, typename internal::ByteType<T>::t = 0> |
- void SetData(const T(&array)[N]) { |
+ template <typename U, |
+ size_t N, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ void SetData(const U (&array)[N]) { |
SetData(array, N); |
} |
- void SetData(const Buffer& buf) { SetData(buf.data(), buf.size()); } |
+ void SetData(const BufferT& buf) { SetData(buf.data(), buf.size()); } |
- // Replace the data in the buffer with at most |max_bytes| of data, using the |
- // function |setter|, which should have the following signature: |
- // size_t setter(ArrayView<T> view) |
+ // Replace the data in the buffer with at most |max_elements| of data, using |
+ // the function |setter|, which should have the following signature: |
+ // size_t setter(ArrayView<U> view) |
// |setter| is given an appropriately typed ArrayView of the area in which to |
// write the data (i.e. starting at the beginning of the buffer) and should |
- // return the number of bytes actually written. This number must be <= |
- // |max_bytes|. |
- template <typename T = uint8_t, typename F, |
- typename internal::ByteType<T>::t = 0> |
- size_t SetData(size_t max_bytes, F&& setter) { |
+ // return the number of elements actually written. This number must be <= |
+ // |max_elements|. |
+ template <typename U = T, |
+ typename F, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ size_t SetData(size_t max_elements, F&& setter) { |
RTC_DCHECK(IsConsistent()); |
size_ = 0; |
- return AppendData<T>(max_bytes, std::forward<F>(setter)); |
+ return AppendData<U>(max_elements, std::forward<F>(setter)); |
} |
- // The AppendData functions adds data to the end of the buffer. They accept |
+ // The AppendData functions add data to the end of the buffer. They accept |
// the same input types as the constructors. |
- template <typename T, typename internal::ByteType<T>::t = 0> |
- void AppendData(const T* data, size_t size) { |
+ template <typename U, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ void AppendData(const U* data, size_t size) { |
RTC_DCHECK(IsConsistent()); |
const size_t new_size = size_ + size; |
EnsureCapacity(new_size); |
- std::memcpy(data_.get() + size_, data, size); |
+ static_assert(sizeof(T) == sizeof(U), ""); |
+ std::memcpy(data_.get() + size_, data, size * sizeof(U)); |
size_ = new_size; |
RTC_DCHECK(IsConsistent()); |
} |
- template <typename T, size_t N, typename internal::ByteType<T>::t = 0> |
- void AppendData(const T(&array)[N]) { |
+ template <typename U, |
+ size_t N, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ void AppendData(const U (&array)[N]) { |
AppendData(array, N); |
} |
- void AppendData(const Buffer& buf) { AppendData(buf.data(), buf.size()); } |
+ void AppendData(const BufferT& buf) { AppendData(buf.data(), buf.size()); } |
- // Append at most |max_bytes| of data to the end of the buffer, using the |
- // function |setter|, which should have the following signature: |
- // size_t setter(ArrayView<T> view) |
+ // Append at most |max_elements| to the end of the buffer, using the function |
+ // |setter|, which should have the following signature: |
+ // size_t setter(ArrayView<U> view) |
// |setter| is given an appropriately typed ArrayView of the area in which to |
// write the data (i.e. starting at the former end of the buffer) and should |
- // return the number of bytes actually written. This number must be <= |
- // |max_bytes|. |
- template <typename T = uint8_t, typename F, |
- typename internal::ByteType<T>::t = 0> |
- size_t AppendData(size_t max_bytes, F&& setter) { |
+ // return the number of elements actually written. This number must be <= |
+ // |max_elements|. |
+ template <typename U = T, |
+ typename F, |
+ typename std::enable_if< |
+ internal::BufferCompat<T, U>::value>::type* = nullptr> |
+ size_t AppendData(size_t max_elements, F&& setter) { |
RTC_DCHECK(IsConsistent()); |
const size_t old_size = size_; |
- SetSize(old_size + max_bytes); |
- T *base_ptr = data<T>() + old_size; |
- size_t written_bytes = |
- setter(rtc::ArrayView<T>(base_ptr, max_bytes)); |
+ SetSize(old_size + max_elements); |
+ U* base_ptr = data<U>() + old_size; |
+ size_t written_elements = setter(rtc::ArrayView<U>(base_ptr, max_elements)); |
- RTC_CHECK_LE(written_bytes, max_bytes); |
- size_ = old_size + written_bytes; |
+ RTC_CHECK_LE(written_elements, max_elements); |
+ size_ = old_size + written_elements; |
RTC_DCHECK(IsConsistent()); |
- return written_bytes; |
+ return written_elements; |
} |
// Sets the size of the buffer. If the new size is smaller than the old, the |
@@ -214,8 +264,8 @@ class Buffer { |
RTC_DCHECK(IsConsistent()); |
if (capacity <= capacity_) |
return; |
- std::unique_ptr<uint8_t[]> new_data(new uint8_t[capacity]); |
- std::memcpy(new_data.get(), data_.get(), size_); |
+ std::unique_ptr<T[]> new_data(new T[capacity]); |
+ std::memcpy(new_data.get(), data_.get(), size_ * sizeof(T)); |
data_ = std::move(new_data); |
capacity_ = capacity; |
RTC_DCHECK(IsConsistent()); |
@@ -229,7 +279,7 @@ class Buffer { |
} |
// Swaps two buffers. Also works for buffers that have been moved from. |
- friend void swap(Buffer& a, Buffer& b) { |
+ friend void swap(BufferT& a, BufferT& b) { |
using std::swap; |
swap(a.size_, b.size_); |
swap(a.capacity_, b.capacity_); |
@@ -262,11 +312,12 @@ class Buffer { |
size_t size_; |
size_t capacity_; |
- std::unique_ptr<uint8_t[]> data_; |
- |
- RTC_DISALLOW_COPY_AND_ASSIGN(Buffer); |
+ std::unique_ptr<T[]> data_; |
}; |
+// By far the most common sort of buffer. |
+using Buffer = BufferT<uint8_t>; |
+ |
} // namespace rtc |
#endif // WEBRTC_BASE_BUFFER_H_ |