blob: 473ffdcf0218edb87c3f71bfd52c6c2885eaf74d [file] [edit]
/*
* Copyright (C) 2016-2021 Apple Inc. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
* EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
* PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
* OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#pragma once
#include <bit>
#include <limits>
#include <wtf/Assertions.h>
#include <wtf/FastMalloc.h>
#include <wtf/HashFunctions.h>
#include <wtf/HashTraits.h>
#include <wtf/MallocSpan.h>
#include <wtf/Noncopyable.h>
#include <wtf/StdLibExtras.h>
namespace WTF {
DECLARE_ALLOCATOR_WITH_HEAP_IDENTIFIER(SmallSet);
// Functionally, this class is very similar to Variant<Vector<T, SmallArraySize>, HashSet<T>>
// It is optimized primarily for space, but is also quite fast
// Its main limitation is that it has no way to remove elements once they have been added to it
// It uses HashTraits to determine its empty value.
// Use it whenever you need to store an unbounded but probably small number of unsigned integers or pointers.
template<typename T, typename Hash = PtrHashBase<T, false /* isSmartPtr */>, typename Traits = HashTraits<T>, unsigned SmallArraySize = 8>
class SmallSet {
WTF_DEPRECATED_MAKE_FAST_ALLOCATED(SmallSet);
WTF_MAKE_NONCOPYABLE(SmallSet);
static_assert(std::is_trivially_destructible<T>::value, "We currently don't support non-trivially destructible types.");
static_assert(std::has_single_bit(SmallArraySize), "Inline size must be a power of two.");
static_assert(sizeof(T*) <= SmallArraySize * sizeof(T), "This class has not been tested for m_inline.buffer larger than m_inline.smallStorage");
public:
SmallSet()
: m_inline()
{
initialize();
}
// We take care to have SmallSet have partial move semantics allowable through
// memcpy. It's partial move semantics because our destructor should not be called
// on the SmallPtrObject in the old memory we were moved from (otherwise, we might free m_buffer twice)
// unless that old memory is reset to be isSmall(). See move constructor below.
// To maintain these semantics, we determine if we're small by checking our size
// and not our m_buffer pointer. And when we're small, we don't do operations on
// m_buffer, instead, we perform operations on m_smallStorage directly. The reason we want
// these semantics is that it's beneficial to have a Vector that contains SmallSet
// (or an object with SmallSet as a field) be allowed to use memcpy for its move operation.
SmallSet(SmallSet&& other)
{
memcpySpan(asMutableByteSpan(*this), asByteSpan(other));
other.initialize();
}
SmallSet& operator=(SmallSet&& other)
{
this->~SmallSet();
new (this) SmallSet(WTF::move(other));
return *this;
}
~SmallSet()
{
if (!isSmall())
SmallSetMalloc::free(m_inline.buffer);
}
class iterator {
WTF_DEPRECATED_MAKE_FAST_ALLOCATED(iterator);
public:
iterator() = default;
iterator(unsigned index, std::span<T> buffer)
: m_index(index)
, m_buffer(buffer)
{ }
iterator& operator++()
{
++m_index;
ASSERT(m_index <= m_buffer.size());
while (m_index < m_buffer.size() && isEmptyBucket(m_buffer[m_index]))
++m_index;
return *this;
}
T& operator*() { return m_buffer[m_index]; }
T operator*() const { return m_buffer[m_index]; }
bool operator==(const iterator& other) const { ASSERT(m_buffer.data() == other.m_buffer.data()); return m_index == other.m_index; }
private:
template<typename U, typename H, typename TR, unsigned S> friend class WTF::SmallSet;
unsigned m_index;
std::span<T> m_buffer;
};
struct AddResult {
iterator entry;
bool isNewEntry;
};
inline AddResult add(T value) LIFETIME_BOUND
{
ASSERT(isValidEntry(value));
if (isSmall()) {
for (unsigned i = 0; i < m_size; i++) {
if (equal(m_inline.smallStorage[i], value))
return { iterator { i, std::span { m_inline.smallStorage } }, false };
}
if (m_size < SmallArraySize) {
m_inline.smallStorage[m_size] = value;
++m_size;
return { iterator { m_size - 1, std::span { m_inline.smallStorage } }, true };
}
grow(std::max(64u, SmallArraySize * 2));
// Fall through. We're no longer small :(
}
// If we're more than 3/4ths full we grow.
if (m_size * 4 >= m_capacity * 3) [[unlikely]] {
grow(m_capacity * 2);
ASSERT(std::has_single_bit(m_capacity));
}
T* bucket = this->bucket(value);
if (!equal(*bucket, value)) {
*bucket = value;
++m_size;
return { iterator { static_cast<unsigned>(bucket - m_inline.buffer), unsafeMakeSpan(m_inline.buffer, m_capacity) }, true };
}
return { iterator { static_cast<unsigned>(bucket - m_inline.buffer), unsafeMakeSpan(m_inline.buffer, m_capacity) }, false };
}
inline bool contains(T value) const
{
ASSERT(isValidEntry(value));
if (isSmall()) {
// We only need to search up to m_size because we store things linearly inside m_smallStorage.
for (unsigned i = 0; i < m_size; i++) {
if (m_inline.smallStorage[i] == value)
return true;
}
return false;
}
T* bucket = this->bucket(value);
return equal(*bucket, value);
}
iterator begin() const LIFETIME_BOUND
{
iterator it;
it.m_index = std::numeric_limits<unsigned>::max();
it.m_buffer = spanConstCast<T>(buffer());
++it;
return it;
}
iterator end() const LIFETIME_BOUND
{
iterator it;
it.m_index = m_capacity;
it.m_buffer = spanConstCast<T>(buffer());
return it;
}
inline unsigned size() const { return m_size; }
inline bool isEmpty() const { return !size(); }
unsigned memoryUse() const
{
unsigned memory = sizeof(SmallSet);
if (!isSmall())
memory += m_capacity * sizeof(T);
return memory;
}
private:
static bool isEmptyBucket(const T& value)
{
return isHashTraitsEmptyValue<Traits>(value);
}
bool equal(const T left, const T right) const
{
if constexpr (Hash::safeToCompareToEmptyOrDeleted)
return Hash::equal(left, right);
if (isValidEntry(left) && isValidEntry(right))
return Hash::equal(left, right);
return left == right;
}
bool isValidEntry(const T& value) const
{
return !isEmptyBucket(value);
}
inline bool isSmall() const
{
return m_capacity == SmallArraySize;
}
inline void initialize()
{
m_size = 0;
m_capacity = SmallArraySize;
initializeBuckets(std::span { m_inline.smallStorage });
ASSERT(isSmall());
}
static void initializeBuckets(std::span<T> span)
{
if constexpr (Traits::emptyValueIsZero)
memsetSpan(span, 0);
else {
for (auto& entry : span)
entry = Traits::emptyValue();
}
}
inline void grow(unsigned size)
{
size_t allocationSize = sizeof(T) * size;
auto oldBuffer = buffer();
unsigned oldCapacity = m_capacity;
auto newBuffer = MallocSpan<T, SmallSetMalloc>::malloc(allocationSize);
initializeBuckets(newBuffer.mutableSpan());
m_capacity = size;
for (unsigned i = 0; i < oldCapacity; i++) {
if (isValidEntry(oldBuffer[i])) {
T* ptr = bucketInBuffer(newBuffer.mutableSpan(), static_cast<T>(oldBuffer[i]));
*ptr = oldBuffer[i];
}
}
if (oldCapacity != SmallArraySize)
SmallSetMalloc::free(oldBuffer.data());
m_inline.buffer = newBuffer.leakSpan().data();
}
inline T* bucket(T target) const
{
ASSERT(!isSmall());
return bucketInBuffer(unsafeMakeSpan(m_inline.buffer, m_capacity), target);
}
inline T* bucketInBuffer(std::span<T> buffer, T target) const
{
ASSERT(std::has_single_bit(m_capacity));
unsigned bucket = Hash::hash(target) & (m_capacity - 1);
unsigned index = 0;
while (true) {
T* ptr = buffer.subspan(bucket).data();
if (!isValidEntry(*ptr))
return ptr;
if (equal(*ptr, target))
return ptr;
++index;
bucket = (bucket + index) & (m_capacity - 1);
}
}
std::span<T> buffer() { return isSmall() ? std::span<T> { m_inline.smallStorage } : unsafeMakeSpan(m_inline.buffer, m_capacity); }
std::span<const T> buffer() const { return isSmall() ? std::span<const T> { m_inline.smallStorage } : unsafeMakeSpan(m_inline.buffer, m_capacity); }
unsigned m_size;
unsigned m_capacity;
union U {
T* buffer;
std::array<T, SmallArraySize> smallStorage;
U() { };
} m_inline;
};
} // namespace WTF
using WTF::SmallSet;