Compare commits

..

2 commits

Author SHA1 Message Date
f3836545d9 fix license
All checks were successful
eden-license / license-header (pull_request) Successful in 24s
2025-09-27 01:07:49 +02:00
106e1a98bd [service] unstub process winding 2025-09-27 01:07:49 +02:00
3 changed files with 97 additions and 26 deletions

View file

@ -32,6 +32,7 @@ add_library(
atomic_ops.h
bit_cast.h
bit_field.h
bit_set.h
bit_util.h
bounded_threadsafe_queue.h
cityhash.cpp

86
src/common/bit_set.h Normal file
View file

@ -0,0 +1,86 @@
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
// SPDX-License-Identifier: GPL-2.0-or-later
#pragma once
#include <array>
#include <bit>
#include "common/alignment.h"
#include "common/bit_util.h"
#include "common/common_types.h"
namespace Common {
namespace impl {
template <typename Storage, size_t N>
class BitSet {
public:
constexpr BitSet() = default;
constexpr void SetBit(size_t i) {
this->words[i / FlagsPerWord] |= GetBitMask(i % FlagsPerWord);
}
constexpr void ClearBit(size_t i) {
this->words[i / FlagsPerWord] &= ~GetBitMask(i % FlagsPerWord);
}
constexpr size_t CountLeadingZero() const {
for (size_t i = 0; i < NumWords; i++) {
if (this->words[i]) {
return FlagsPerWord * i + CountLeadingZeroImpl(this->words[i]);
}
}
return FlagsPerWord * NumWords;
}
constexpr size_t GetNextSet(size_t n) const {
for (size_t i = (n + 1) / FlagsPerWord; i < NumWords; i++) {
Storage word = this->words[i];
if (!IsAligned(n + 1, FlagsPerWord)) {
word &= GetBitMask(n % FlagsPerWord) - 1;
}
if (word) {
return FlagsPerWord * i + CountLeadingZeroImpl(word);
}
}
return FlagsPerWord * NumWords;
}
private:
static_assert(std::is_unsigned_v<Storage>);
static_assert(sizeof(Storage) <= sizeof(u64));
static constexpr size_t FlagsPerWord = BitSize<Storage>();
static constexpr size_t NumWords = AlignUp(N, FlagsPerWord) / FlagsPerWord;
static constexpr auto CountLeadingZeroImpl(Storage word) {
return std::countl_zero(static_cast<unsigned long long>(word)) -
(BitSize<unsigned long long>() - FlagsPerWord);
}
static constexpr Storage GetBitMask(size_t bit) {
return Storage(1) << (FlagsPerWord - 1 - bit);
}
std::array<Storage, NumWords> words{};
};
} // namespace impl
template <size_t N>
using BitSet8 = impl::BitSet<u8, N>;
template <size_t N>
using BitSet16 = impl::BitSet<u16, N>;
template <size_t N>
using BitSet32 = impl::BitSet<u32, N>;
template <size_t N>
using BitSet64 = impl::BitSet<u64, N>;
} // namespace Common

View file

@ -1,6 +1,3 @@
// SPDX-FileCopyrightText: Copyright 2025 Eden Emulator Project
// SPDX-License-Identifier: GPL-3.0-or-later
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
// SPDX-License-Identifier: GPL-2.0-or-later
@ -8,12 +5,10 @@
#include <array>
#include <bit>
#include <bitset>
#include <concepts>
#include <cstddef>
#include "common/alignment.h"
#include "common/assert.h"
#include "common/bit_set.h"
#include "common/common_types.h"
#include "common/concepts.h"
@ -164,7 +159,7 @@ public:
}
if (m_queues[priority].PushBack(core, member)) {
m_available_priorities[core].set(std::size_t(priority));
m_available_priorities[core].SetBit(priority);
}
}
@ -177,7 +172,7 @@ public:
}
if (m_queues[priority].PushFront(core, member)) {
m_available_priorities[core].set(std::size_t(priority));
m_available_priorities[core].SetBit(priority);
}
}
@ -190,19 +185,14 @@ public:
}
if (m_queues[priority].Remove(core, member)) {
m_available_priorities[core].reset(std::size_t(priority));
m_available_priorities[core].ClearBit(priority);
}
}
constexpr Member* GetFront(s32 core) const {
ASSERT(IsValidCore(core));
const s32 priority = s32([](auto const& e) {
for (size_t i = 0; i < e.size(); ++i)
if (e[i])
return i;
return e.size();
}(m_available_priorities[core]));
const s32 priority = static_cast<s32>(m_available_priorities[core].CountLeadingZero());
if (priority <= LowestPriority) {
return m_queues[priority].GetFront(core);
} else {
@ -221,22 +211,16 @@ public:
}
}
template<size_t N>
constexpr size_t GetNextSet(std::bitset<N> const& bit, size_t n) const {
for (size_t i = n + 1; i < bit.size(); i++)
if (bit[i])
return i;
return bit.size();
}
constexpr Member* GetNext(s32 core, const Member* member) const {
ASSERT(IsValidCore(core));
Member* next = member->GetPriorityQueueEntry(core).GetNext();
if (next == nullptr) {
s32 priority = s32(GetNextSet(m_available_priorities[core], member->GetPriority()));
if (priority <= LowestPriority)
const s32 priority = static_cast<s32>(
m_available_priorities[core].GetNextSet(member->GetPriority()));
if (priority <= LowestPriority) {
next = m_queues[priority].GetFront(core);
}
}
return next;
}
@ -266,7 +250,7 @@ public:
private:
std::array<KPerCoreQueue, NumPriority> m_queues{};
std::array<std::bitset<NumPriority>, NumCores> m_available_priorities{};
std::array<Common::BitSet64<NumPriority>, NumCores> m_available_priorities{};
};
private: