forked from suyu/suyu
Compare commits
5 commits
Author | SHA1 | Date | |
---|---|---|---|
b579338d2f | |||
7d0b6e781d | |||
eed403ea0c | |||
22b5180b82 | |||
767fed4c4c |
12 changed files with 2183 additions and 197 deletions
5
.gitmodules
vendored
5
.gitmodules
vendored
|
@ -1,4 +1,6 @@
|
||||||
# SPDX-FileCopyrightText: 2014 Citra Emulator Project
|
# SPDX-FileCopyrightText: 2014 Citra Emulator Project
|
||||||
|
# SPDX-FileCopyrightText: 2024 suyu Emulator Project
|
||||||
|
# SPDX-FileCopyrightText: 2024 Torzu Emulator Project
|
||||||
# SPDX-License-Identifier: GPL-2.0-or-later
|
# SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
[submodule "enet"]
|
[submodule "enet"]
|
||||||
|
@ -67,3 +69,6 @@
|
||||||
[submodule "Vulkan-Utility-Libraries"]
|
[submodule "Vulkan-Utility-Libraries"]
|
||||||
path = externals/Vulkan-Utility-Libraries
|
path = externals/Vulkan-Utility-Libraries
|
||||||
url = https://github.com/KhronosGroup/Vulkan-Utility-Libraries.git
|
url = https://github.com/KhronosGroup/Vulkan-Utility-Libraries.git
|
||||||
|
[submodule "externals/boost-headers"]
|
||||||
|
path = externals/boost-headers
|
||||||
|
url = https://github.com/boostorg/headers.git
|
||||||
|
|
|
@ -1,5 +1,6 @@
|
||||||
# SPDX-FileCopyrightText: 2018 yuzu Emulator Project
|
# SPDX-FileCopyrightText: 2018 yuzu Emulator Project
|
||||||
# SPDX-FileCopyrightText: 2024 suyu Emulator Project
|
# SPDX-FileCopyrightText: 2024 suyu Emulator Project
|
||||||
|
# SPDX-FileCopyrightText: 2024 Torzu Emulator Project
|
||||||
# SPDX-License-Identifier: GPL-2.0-or-later
|
# SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
cmake_minimum_required(VERSION 3.22)
|
cmake_minimum_required(VERSION 3.22)
|
||||||
|
@ -276,20 +277,8 @@ if (ARCHITECTURE_arm64 AND (ANDROID OR ${CMAKE_SYSTEM_NAME} STREQUAL "Linux"))
|
||||||
add_definitions(-DHAS_NCE=1)
|
add_definitions(-DHAS_NCE=1)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
# Configure C++ standard
|
set(CMAKE_CXX_STANDARD 20)
|
||||||
# ===========================
|
set(CMAKE_CXX_STANDARD_REQUIRED ON)
|
||||||
|
|
||||||
# boost asio's concept usage doesn't play nicely with some compilers yet.
|
|
||||||
add_definitions(-DBOOST_ASIO_DISABLE_CONCEPTS)
|
|
||||||
if (MSVC)
|
|
||||||
add_compile_options($<$<COMPILE_LANGUAGE:CXX>:/std:c++20>)
|
|
||||||
|
|
||||||
# boost still makes use of deprecated result_of.
|
|
||||||
add_definitions(-D_HAS_DEPRECATED_RESULT_OF)
|
|
||||||
else()
|
|
||||||
set(CMAKE_CXX_STANDARD 20)
|
|
||||||
set(CMAKE_CXX_STANDARD_REQUIRED ON)
|
|
||||||
endif()
|
|
||||||
|
|
||||||
# Output binaries to bin/
|
# Output binaries to bin/
|
||||||
set(CMAKE_RUNTIME_OUTPUT_DIRECTORY ${PROJECT_BINARY_DIR}/bin)
|
set(CMAKE_RUNTIME_OUTPUT_DIRECTORY ${PROJECT_BINARY_DIR}/bin)
|
||||||
|
@ -298,7 +287,6 @@ set(CMAKE_RUNTIME_OUTPUT_DIRECTORY ${PROJECT_BINARY_DIR}/bin)
|
||||||
# =======================================================================
|
# =======================================================================
|
||||||
|
|
||||||
# Enforce the search mode of non-required packages for better and shorter failure messages
|
# Enforce the search mode of non-required packages for better and shorter failure messages
|
||||||
find_package(Boost 1.79.0 REQUIRED context)
|
|
||||||
find_package(enet 1.3 MODULE)
|
find_package(enet 1.3 MODULE)
|
||||||
find_package(fmt 9 REQUIRED)
|
find_package(fmt 9 REQUIRED)
|
||||||
find_package(LLVM 17.0.2 MODULE COMPONENTS Demangle)
|
find_package(LLVM 17.0.2 MODULE COMPONENTS Demangle)
|
||||||
|
@ -356,11 +344,6 @@ if (SUYU_TESTS)
|
||||||
find_package(Catch2 3.0.1 REQUIRED)
|
find_package(Catch2 3.0.1 REQUIRED)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
# boost:asio has functions that require AcceptEx et al
|
|
||||||
if (MINGW)
|
|
||||||
find_library(MSWSOCK_LIBRARY mswsock REQUIRED)
|
|
||||||
endif()
|
|
||||||
|
|
||||||
if(ENABLE_OPENSSL)
|
if(ENABLE_OPENSSL)
|
||||||
find_package(OpenSSL 1.1.1 REQUIRED)
|
find_package(OpenSSL 1.1.1 REQUIRED)
|
||||||
endif()
|
endif()
|
||||||
|
@ -687,8 +670,6 @@ function(create_target_directory_groups target_name)
|
||||||
endforeach()
|
endforeach()
|
||||||
endfunction()
|
endfunction()
|
||||||
|
|
||||||
# Prevent boost from linking against libs when building
|
|
||||||
target_link_libraries(Boost::headers INTERFACE Boost::disable_autolinking)
|
|
||||||
# Adjustments for MSVC + Ninja
|
# Adjustments for MSVC + Ninja
|
||||||
if (MSVC AND CMAKE_GENERATOR STREQUAL "Ninja")
|
if (MSVC AND CMAKE_GENERATOR STREQUAL "Ninja")
|
||||||
add_compile_options(
|
add_compile_options(
|
||||||
|
|
|
@ -6,5 +6,5 @@ SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
Please check out the
|
Please check out the
|
||||||
|
|
||||||
* [Contributors's guide](https://git.suyu.dev/suyu/suyu/wiki/Contributing).
|
* [Contributors's guide](https://gitlab.com/suyu-emu/suyu/-/wikis/Contributing).
|
||||||
* [Merge request guidelines](https://git.suyu.dev/suyu/suyu/wiki/Typical-Git-Workflow#once-your-pull-request-is-ready-to-be-merged)
|
* [Merge request guidelines](https://gitlab.com/suyu-emu/suyu/-/wikis/Merge-requests)
|
||||||
|
|
21
MIGRATION.md
21
MIGRATION.md
|
@ -1,21 +0,0 @@
|
||||||
# Migrating from yuzu
|
|
||||||
|
|
||||||
When coming from yuzu, the migration is as easy as renaming some directories.
|
|
||||||
|
|
||||||
## Windows
|
|
||||||
|
|
||||||
Use the run dialog to go to `%APPDATA%` or manually go to `C:\Users\{USERNAME}\AppData\Roaming` (you may have to enable hidden files) and simply rename the `yuzu` directories and simply rename those to `suyu`.
|
|
||||||
|
|
||||||
## Unix (macOS/Linux)
|
|
||||||
Similarly, you can simply rename the folders `~/.local/share/yuzu` and `~/.config/yuzu` to `suyu`, either via a file manager or with the following commands:
|
|
||||||
```sh
|
|
||||||
$ mv ~/.local/share/yuzu ~/.local/share/suyu
|
|
||||||
$ mv ~/.config/yuzu ~/.config/suyu
|
|
||||||
```
|
|
||||||
There is also `~/.cache/yuzu`, which you can safely delete. Suyu will build a fresh cache in its own directory.
|
|
||||||
|
|
||||||
### Linux
|
|
||||||
Depending on your setup, you may want to substitute those base paths for `$XDG_DATA_HOME` and `$XDG_CONFIG_HOME` respectively.
|
|
||||||
|
|
||||||
## Android
|
|
||||||
TBD
|
|
21
README.md
21
README.md
|
@ -9,7 +9,7 @@ SPDX-License-Identifier: GPL-3.0-or-later
|
||||||
We're in need of developers. Please join our chat below if you want to contribute!
|
We're in need of developers. Please join our chat below if you want to contribute!
|
||||||
This repo was based on Yuzu EA 4176 but the code is being rewritten from the ground up for legal and performance reasons.
|
This repo was based on Yuzu EA 4176 but the code is being rewritten from the ground up for legal and performance reasons.
|
||||||
|
|
||||||
Support the original suyu developer team [here](https://discord.gg/79B6wqFPnc).
|
Support the original suyu developer team [here](https://discord.gg/ajz5hdrZ)
|
||||||
|
|
||||||
<hr />
|
<hr />
|
||||||
|
|
||||||
|
@ -23,7 +23,7 @@ Support the original suyu developer team [here](https://discord.gg/79B6wqFPnc).
|
||||||
|
|
||||||
<h4 align="center"><b>suyu</b> was the continuation of the world's most popular, open-source Nintendo Switch emulator, yuzu, but is now something more.
|
<h4 align="center"><b>suyu</b> was the continuation of the world's most popular, open-source Nintendo Switch emulator, yuzu, but is now something more.
|
||||||
<br>
|
<br>
|
||||||
It is written in C++ with portability in mind, and we actively provide builds for Windows, Linux, Android and iOS potentially coming soon.
|
It is written in C++ (C# possibly required soon) with portability in mind, we actively work on builds for Windows, Linux, Android and hopefully IOS, along with a WIP custom OS called suyuOS (https://git.suyu.dev/suyu/suyu-os) .
|
||||||
|
|
||||||
</h4>
|
</h4>
|
||||||
|
|
||||||
|
@ -41,10 +41,6 @@ It is written in C++ with portability in mind, and we actively provide builds fo
|
||||||
## Hardware Requirements
|
## Hardware Requirements
|
||||||
[Click here to see the Hardware Requirements](https://git.suyu.dev/suyu/suyu/wiki/Hardware-Requirements)
|
[Click here to see the Hardware Requirements](https://git.suyu.dev/suyu/suyu/wiki/Hardware-Requirements)
|
||||||
|
|
||||||
## Migrating from yuzu
|
|
||||||
|
|
||||||
See [MIGRATION.md](MIGRATION.md).
|
|
||||||
|
|
||||||
## Status
|
## Status
|
||||||
|
|
||||||
We currently have builds over at the [Releases](https://git.suyu.dev/suyu/suyu/releases) page.
|
We currently have builds over at the [Releases](https://git.suyu.dev/suyu/suyu/releases) page.
|
||||||
|
@ -55,10 +51,10 @@ We currently have builds over at the [Releases](https://git.suyu.dev/suyu/suyu/r
|
||||||
|
|
||||||
This project is completely free and open source, and anyone can contribute to help improve suyu.
|
This project is completely free and open source, and anyone can contribute to help improve suyu.
|
||||||
|
|
||||||
Most of the development happens on the Git. For development discussion, please join us in our [Chat](https://chat.suyu.dev) or contact a developer.
|
Most of the development happens on GitLab. For development discussion, please join us in our [Chat](https://chat.suyu.dev).
|
||||||
|
|
||||||
If you want to contribute, please take a look at the [Contributor's Guide](https://git.suyu.dev/suyu/suyu/wiki/Contributing) and [Developer Information](https://git.suyu.dev/suyu/suyu/wiki/Developer-Information).
|
If you want to contribute, please take a look at the [Contributor's Guide](https://git.suyu.dev/suyu/suyu/wiki/Contributing) and [Developer Information](https://git.suyu.dev/suyu/suyu/wiki/Developer-Information).
|
||||||
You can also contact any of the developers on the Chat to learn more about the current state of suyu.
|
You can also contact any of the developers on Discord to learn more about the current state of suyu.
|
||||||
|
|
||||||
## Downloads
|
## Downloads
|
||||||
|
|
||||||
|
@ -66,12 +62,13 @@ You can also contact any of the developers on the Chat to learn more about the c
|
||||||
* __Linux__: [Releases](https://git.suyu.dev/suyu/suyu/releases)
|
* __Linux__: [Releases](https://git.suyu.dev/suyu/suyu/releases)
|
||||||
* __macOS__: [Releases](https://git.suyu.dev/suyu/suyu/releases)
|
* __macOS__: [Releases](https://git.suyu.dev/suyu/suyu/releases)
|
||||||
* __Android__: [Releases](https://git.suyu.dev/suyu/suyu/releases)
|
* __Android__: [Releases](https://git.suyu.dev/suyu/suyu/releases)
|
||||||
###### We currently do not provide builds for iOS, however if you would like, you could try the experimental [Sudachi](https://github.com/emuPlace/Sudachi/releases)/[Folium](https://github.com/jarrodnorwell/Folium/releases).
|
* __For IOS users, we recommend Sudachi__: [Releases](https://github.com/emuPlace/Sudachi/releases)
|
||||||
|
|
||||||
If you want daily builds then [Click here](https://git.suyu.dev/suyu/suyu/actions).
|
If you want daily builds then [Click here](https://git.suyu.dev/suyu/suyu/actions)
|
||||||
If you don't know how to download the daily builds then [Click here](https://git.suyu.dev/suyu/suyu/raw/branch/dev/img/daily-builds.png)
|
If you don't know how to download the daily builds then [Click here](https://git.suyu.dev/suyu/suyu/raw/branch/dev/img/daily-builds.png)
|
||||||
|
Right now we only have daily builds for Linux and Android.
|
||||||
|
|
||||||
We have official builds [here.](https://git.suyu.dev/suyu/suyu/releases)<br>If any website or person is claiming to have a build for suyu, take that with a grain of salt.
|
We have official builds [here.](https://git.suyu.dev/suyu/suyu/releases) If any website or person is claiming to have a build for suyu, take that with a grain of salt.
|
||||||
|
|
||||||
## Building
|
## Building
|
||||||
|
|
||||||
|
@ -84,7 +81,7 @@ We have official builds [here.](https://git.suyu.dev/suyu/suyu/releases)<br>If a
|
||||||
|
|
||||||
## Support
|
## Support
|
||||||
|
|
||||||
If you have any questions, don't hesitate to ask us in our [chat](https://chat.suyu.dev), make an issue or contact a developer. We don't bite!
|
If you have any questions, don't hesitate to ask us in our [chat](https://chat.suyu.dev). We don't bite!
|
||||||
|
|
||||||
|
|
||||||
## License
|
## License
|
||||||
|
|
5
externals/CMakeLists.txt
vendored
5
externals/CMakeLists.txt
vendored
|
@ -1,4 +1,6 @@
|
||||||
# SPDX-FileCopyrightText: 2016 Citra Emulator Project
|
# SPDX-FileCopyrightText: 2016 Citra Emulator Project
|
||||||
|
# SPDX-FileCopyrightText: 2024 suyu Emulator Project
|
||||||
|
# SPDX-FileCopyrightText: 2024 Torzu Emulator Project
|
||||||
# SPDX-License-Identifier: GPL-2.0-or-later
|
# SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
# Dynarmic has cmake_minimum_required(3.12) and we may want to override
|
# Dynarmic has cmake_minimum_required(3.12) and we may want to override
|
||||||
|
@ -160,6 +162,9 @@ if (SUYU_USE_EXTERNAL_VULKAN_UTILITY_LIBRARIES)
|
||||||
add_subdirectory(Vulkan-Utility-Libraries)
|
add_subdirectory(Vulkan-Utility-Libraries)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
|
# Boost headers
|
||||||
|
add_subdirectory(boost-headers)
|
||||||
|
|
||||||
# TZDB (Time Zone Database)
|
# TZDB (Time Zone Database)
|
||||||
add_subdirectory(nx_tzdb)
|
add_subdirectory(nx_tzdb)
|
||||||
|
|
||||||
|
|
1
externals/boost-headers
vendored
Submodule
1
externals/boost-headers
vendored
Submodule
|
@ -0,0 +1 @@
|
||||||
|
Subproject commit 0456900fadde4b07c84760eadea4ccc9f948fe28
|
|
@ -1,5 +1,6 @@
|
||||||
# SPDX-FileCopyrightText: 2018 yuzu Emulator Project
|
# SPDX-FileCopyrightText: 2018 yuzu Emulator Project
|
||||||
# SPDX-FileCopyrightText: 2024 suyu Emulator Project
|
# SPDX-FileCopyrightText: 2024 suyu Emulator Project
|
||||||
|
# SPDX-FileCopyrightText: 2024 Torzu Emulator Project
|
||||||
# SPDX-License-Identifier: GPL-2.0-or-later
|
# SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
if (DEFINED ENV{AZURECIREPO})
|
if (DEFINED ENV{AZURECIREPO})
|
||||||
|
@ -262,7 +263,7 @@ if (CMAKE_CXX_COMPILER_ID STREQUAL "Clang")
|
||||||
)
|
)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
target_link_libraries(common PUBLIC Boost::context Boost::headers fmt::fmt microprofile stb::headers Threads::Threads)
|
target_link_libraries(common PUBLIC Boost::headers fmt::fmt microprofile stb::headers Threads::Threads)
|
||||||
target_link_libraries(common PRIVATE lz4::lz4 zstd::zstd LLVM::Demangle)
|
target_link_libraries(common PRIVATE lz4::lz4 zstd::zstd LLVM::Demangle)
|
||||||
|
|
||||||
if (ANDROID)
|
if (ANDROID)
|
||||||
|
|
|
@ -1,91 +1,52 @@
|
||||||
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
|
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
|
||||||
|
// SPDX-FileCopyrightText: Copyright 2024 suyu Emulator Project
|
||||||
|
// SPDX-FileCopyrightText: Copyright 2024 Torzu Emulator Project
|
||||||
// SPDX-License-Identifier: GPL-2.0-or-later
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
#include <mutex>
|
#include <mutex>
|
||||||
|
|
||||||
#include "common/assert.h"
|
#include "common/assert.h"
|
||||||
#include "common/fiber.h"
|
#include "common/fiber.h"
|
||||||
#include "common/virtual_buffer.h"
|
#define MINICORO_IMPL
|
||||||
|
#include "common/minicoro.h"
|
||||||
#include <boost/context/detail/fcontext.hpp>
|
|
||||||
|
|
||||||
namespace Common {
|
namespace Common {
|
||||||
|
|
||||||
constexpr std::size_t default_stack_size = 512 * 1024;
|
|
||||||
|
|
||||||
struct Fiber::FiberImpl {
|
struct Fiber::FiberImpl {
|
||||||
FiberImpl() : stack{default_stack_size}, rewind_stack{default_stack_size} {}
|
FiberImpl() {}
|
||||||
|
|
||||||
VirtualBuffer<u8> stack;
|
|
||||||
VirtualBuffer<u8> rewind_stack;
|
|
||||||
|
|
||||||
std::mutex guard;
|
std::mutex guard;
|
||||||
std::function<void()> entry_point;
|
|
||||||
std::function<void()> rewind_point;
|
|
||||||
std::shared_ptr<Fiber> previous_fiber;
|
|
||||||
bool is_thread_fiber{};
|
|
||||||
bool released{};
|
bool released{};
|
||||||
|
bool is_thread_fiber{};
|
||||||
|
Fiber* next_fiber{};
|
||||||
|
Fiber** next_fiber_ptr;
|
||||||
|
std::function<void()> entry_point;
|
||||||
|
|
||||||
u8* stack_limit{};
|
mco_coro* context;
|
||||||
u8* rewind_stack_limit{};
|
|
||||||
boost::context::detail::fcontext_t context{};
|
|
||||||
boost::context::detail::fcontext_t rewind_context{};
|
|
||||||
};
|
};
|
||||||
|
|
||||||
void Fiber::SetRewindPoint(std::function<void()>&& rewind_func) {
|
Fiber::Fiber() : impl{std::make_unique<FiberImpl>()} {
|
||||||
impl->rewind_point = std::move(rewind_func);
|
impl->is_thread_fiber = true;
|
||||||
}
|
|
||||||
|
|
||||||
void Fiber::Start(boost::context::detail::transfer_t& transfer) {
|
|
||||||
ASSERT(impl->previous_fiber != nullptr);
|
|
||||||
impl->previous_fiber->impl->context = transfer.fctx;
|
|
||||||
impl->previous_fiber->impl->guard.unlock();
|
|
||||||
impl->previous_fiber.reset();
|
|
||||||
impl->entry_point();
|
|
||||||
UNREACHABLE();
|
|
||||||
}
|
|
||||||
|
|
||||||
void Fiber::OnRewind([[maybe_unused]] boost::context::detail::transfer_t& transfer) {
|
|
||||||
ASSERT(impl->context != nullptr);
|
|
||||||
impl->context = impl->rewind_context;
|
|
||||||
impl->rewind_context = nullptr;
|
|
||||||
u8* tmp = impl->stack_limit;
|
|
||||||
impl->stack_limit = impl->rewind_stack_limit;
|
|
||||||
impl->rewind_stack_limit = tmp;
|
|
||||||
impl->rewind_point();
|
|
||||||
UNREACHABLE();
|
|
||||||
}
|
|
||||||
|
|
||||||
void Fiber::FiberStartFunc(boost::context::detail::transfer_t transfer) {
|
|
||||||
auto* fiber = static_cast<Fiber*>(transfer.data);
|
|
||||||
fiber->Start(transfer);
|
|
||||||
}
|
|
||||||
|
|
||||||
void Fiber::RewindStartFunc(boost::context::detail::transfer_t transfer) {
|
|
||||||
auto* fiber = static_cast<Fiber*>(transfer.data);
|
|
||||||
fiber->OnRewind(transfer);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Fiber::Fiber(std::function<void()>&& entry_point_func) : impl{std::make_unique<FiberImpl>()} {
|
Fiber::Fiber(std::function<void()>&& entry_point_func) : impl{std::make_unique<FiberImpl>()} {
|
||||||
impl->entry_point = std::move(entry_point_func);
|
impl->entry_point = std::move(entry_point_func);
|
||||||
impl->stack_limit = impl->stack.data();
|
auto desc = mco_desc_init(
|
||||||
impl->rewind_stack_limit = impl->rewind_stack.data();
|
[](mco_coro* coro) { reinterpret_cast<Fiber*>(coro->user_data)->impl->entry_point(); }, 0);
|
||||||
u8* stack_base = impl->stack_limit + default_stack_size;
|
desc.user_data = this;
|
||||||
impl->context =
|
mco_result res = mco_create(&impl->context, &desc);
|
||||||
boost::context::detail::make_fcontext(stack_base, impl->stack.size(), FiberStartFunc);
|
ASSERT(res == MCO_SUCCESS);
|
||||||
}
|
}
|
||||||
|
|
||||||
Fiber::Fiber() : impl{std::make_unique<FiberImpl>()} {}
|
|
||||||
|
|
||||||
Fiber::~Fiber() {
|
Fiber::~Fiber() {
|
||||||
if (impl->released) {
|
if (impl->released) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
// Make sure the Fiber is not being used
|
DestroyPre();
|
||||||
const bool locked = impl->guard.try_lock();
|
if (impl->is_thread_fiber) {
|
||||||
ASSERT_MSG(locked, "Destroying a fiber that's still running");
|
DestroyThreadFiber();
|
||||||
if (locked) {
|
} else {
|
||||||
impl->guard.unlock();
|
DestroyWorkFiber();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -94,42 +55,66 @@ void Fiber::Exit() {
|
||||||
if (!impl->is_thread_fiber) {
|
if (!impl->is_thread_fiber) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
impl->guard.unlock();
|
DestroyPre();
|
||||||
|
DestroyThreadFiber();
|
||||||
|
}
|
||||||
|
|
||||||
|
void Fiber::DestroyPre() {
|
||||||
|
// Make sure the Fiber is not being used
|
||||||
|
const bool locked = impl->guard.try_lock();
|
||||||
|
ASSERT_MSG(locked, "Destroying a fiber that's still running");
|
||||||
|
if (locked) {
|
||||||
|
impl->guard.unlock();
|
||||||
|
}
|
||||||
impl->released = true;
|
impl->released = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
void Fiber::Rewind() {
|
void Fiber::DestroyWorkFiber() {
|
||||||
ASSERT(impl->rewind_point);
|
mco_result res = mco_destroy(impl->context);
|
||||||
ASSERT(impl->rewind_context == nullptr);
|
ASSERT(res == MCO_SUCCESS);
|
||||||
u8* stack_base = impl->rewind_stack_limit + default_stack_size;
|
}
|
||||||
impl->rewind_context =
|
|
||||||
boost::context::detail::make_fcontext(stack_base, impl->stack.size(), RewindStartFunc);
|
void Fiber::DestroyThreadFiber() {
|
||||||
boost::context::detail::jump_fcontext(impl->rewind_context, this);
|
if (*impl->next_fiber_ptr) {
|
||||||
|
*impl->next_fiber_ptr = nullptr;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void Fiber::YieldTo(std::weak_ptr<Fiber> weak_from, Fiber& to) {
|
void Fiber::YieldTo(std::weak_ptr<Fiber> weak_from, Fiber& to) {
|
||||||
to.impl->guard.lock();
|
|
||||||
to.impl->previous_fiber = weak_from.lock();
|
|
||||||
|
|
||||||
auto transfer = boost::context::detail::jump_fcontext(to.impl->context, &to);
|
|
||||||
|
|
||||||
// "from" might no longer be valid if the thread was killed
|
|
||||||
if (auto from = weak_from.lock()) {
|
if (auto from = weak_from.lock()) {
|
||||||
if (from->impl->previous_fiber == nullptr) {
|
if (!from->impl->is_thread_fiber) {
|
||||||
ASSERT_MSG(false, "previous_fiber is nullptr!");
|
// Set next fiber
|
||||||
return;
|
from->impl->next_fiber = &to;
|
||||||
|
// Yield from thread
|
||||||
|
if (!from->impl->released) {
|
||||||
|
from->impl->guard.unlock();
|
||||||
|
mco_yield(from->impl->context);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
from->impl->guard.lock();
|
||||||
|
// Keep running next fiber until they've ran out
|
||||||
|
auto& next_fiber_ptr = from->impl->next_fiber_ptr;
|
||||||
|
next_fiber_ptr = &from->impl->next_fiber;
|
||||||
|
*next_fiber_ptr = &to;
|
||||||
|
for ([[maybe_unused]] unsigned round = 0; *next_fiber_ptr; round++) {
|
||||||
|
auto next = *next_fiber_ptr;
|
||||||
|
*next_fiber_ptr = nullptr;
|
||||||
|
next_fiber_ptr = &next->impl->next_fiber;
|
||||||
|
// Stop if new thread is thread fiber
|
||||||
|
if (next->impl->is_thread_fiber)
|
||||||
|
break;
|
||||||
|
// Resume new thread
|
||||||
|
next->impl->guard.lock();
|
||||||
|
mco_result res = mco_resume(next->impl->context);
|
||||||
|
ASSERT(res == MCO_SUCCESS);
|
||||||
|
}
|
||||||
|
from->impl->guard.unlock();
|
||||||
}
|
}
|
||||||
from->impl->previous_fiber->impl->context = transfer.fctx;
|
|
||||||
from->impl->previous_fiber->impl->guard.unlock();
|
|
||||||
from->impl->previous_fiber.reset();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
std::shared_ptr<Fiber> Fiber::ThreadToFiber() {
|
std::shared_ptr<Fiber> Fiber::ThreadToFiber() {
|
||||||
std::shared_ptr<Fiber> fiber = std::shared_ptr<Fiber>{new Fiber()};
|
return std::shared_ptr<Fiber>{new Fiber()};
|
||||||
fiber->impl->guard.lock();
|
|
||||||
fiber->impl->is_thread_fiber = true;
|
|
||||||
return fiber;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
} // namespace Common
|
} // namespace Common
|
|
@ -1,4 +1,6 @@
|
||||||
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
|
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
|
||||||
|
// SPDX-FileCopyrightText: Copyright 2024 suyu Emulator Project
|
||||||
|
// SPDX-FileCopyrightText: Copyright 2024 Torzu Emulator Project
|
||||||
// SPDX-License-Identifier: GPL-2.0-or-later
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
|
@ -6,9 +8,7 @@
|
||||||
#include <functional>
|
#include <functional>
|
||||||
#include <memory>
|
#include <memory>
|
||||||
|
|
||||||
namespace boost::context::detail {
|
#include "common/minicoro.h"
|
||||||
struct transfer_t;
|
|
||||||
}
|
|
||||||
|
|
||||||
namespace Common {
|
namespace Common {
|
||||||
|
|
||||||
|
@ -38,28 +38,21 @@ public:
|
||||||
Fiber(Fiber&&) = default;
|
Fiber(Fiber&&) = default;
|
||||||
Fiber& operator=(Fiber&&) = default;
|
Fiber& operator=(Fiber&&) = default;
|
||||||
|
|
||||||
/// Yields control from Fiber 'from' to Fiber 'to'
|
|
||||||
/// Fiber 'from' must be the currently running fiber.
|
|
||||||
static void YieldTo(std::weak_ptr<Fiber> weak_from, Fiber& to);
|
static void YieldTo(std::weak_ptr<Fiber> weak_from, Fiber& to);
|
||||||
[[nodiscard]] static std::shared_ptr<Fiber> ThreadToFiber();
|
[[nodiscard]] static std::shared_ptr<Fiber> ThreadToFiber();
|
||||||
|
|
||||||
void SetRewindPoint(std::function<void()>&& rewind_func);
|
|
||||||
|
|
||||||
void Rewind();
|
|
||||||
|
|
||||||
/// Only call from main thread's fiber
|
/// Only call from main thread's fiber
|
||||||
void Exit();
|
void Exit();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
Fiber();
|
Fiber();
|
||||||
|
|
||||||
void OnRewind(boost::context::detail::transfer_t& transfer);
|
void DestroyPre();
|
||||||
void Start(boost::context::detail::transfer_t& transfer);
|
void DestroyWorkFiber();
|
||||||
static void FiberStartFunc(boost::context::detail::transfer_t transfer);
|
void DestroyThreadFiber();
|
||||||
static void RewindStartFunc(boost::context::detail::transfer_t transfer);
|
|
||||||
|
|
||||||
struct FiberImpl;
|
struct FiberImpl;
|
||||||
std::unique_ptr<FiberImpl> impl;
|
std::unique_ptr<FiberImpl> impl;
|
||||||
};
|
};
|
||||||
|
|
||||||
} // namespace Common
|
} // namespace Common
|
2077
src/common/minicoro.h
Normal file
2077
src/common/minicoro.h
Normal file
File diff suppressed because it is too large
Load diff
|
@ -1,4 +1,5 @@
|
||||||
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
|
// SPDX-FileCopyrightText: Copyright 2020 yuzu Emulator Project
|
||||||
|
// SPDX-FileCopyrightText: Copyright 2024 Torzu Emulator Project
|
||||||
// SPDX-License-Identifier: GPL-2.0-or-later
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
||||||
|
|
||||||
#include <atomic>
|
#include <atomic>
|
||||||
|
@ -271,43 +272,4 @@ TEST_CASE("Fibers::StartRace", "[common]") {
|
||||||
REQUIRE(test_control.value3 == 1);
|
REQUIRE(test_control.value3 == 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
class TestControl4;
|
|
||||||
|
|
||||||
class TestControl4 {
|
|
||||||
public:
|
|
||||||
TestControl4() {
|
|
||||||
fiber1 = std::make_shared<Fiber>([this] { DoWork(); });
|
|
||||||
goal_reached = false;
|
|
||||||
rewinded = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
void Execute() {
|
|
||||||
thread_fiber = Fiber::ThreadToFiber();
|
|
||||||
Fiber::YieldTo(thread_fiber, *fiber1);
|
|
||||||
thread_fiber->Exit();
|
|
||||||
}
|
|
||||||
|
|
||||||
void DoWork() {
|
|
||||||
fiber1->SetRewindPoint([this] { DoWork(); });
|
|
||||||
if (rewinded) {
|
|
||||||
goal_reached = true;
|
|
||||||
Fiber::YieldTo(fiber1, *thread_fiber);
|
|
||||||
}
|
|
||||||
rewinded = true;
|
|
||||||
fiber1->Rewind();
|
|
||||||
}
|
|
||||||
|
|
||||||
std::shared_ptr<Common::Fiber> fiber1;
|
|
||||||
std::shared_ptr<Common::Fiber> thread_fiber;
|
|
||||||
bool goal_reached;
|
|
||||||
bool rewinded;
|
|
||||||
};
|
|
||||||
|
|
||||||
TEST_CASE("Fibers::Rewind", "[common]") {
|
|
||||||
TestControl4 test_control{};
|
|
||||||
test_control.Execute();
|
|
||||||
REQUIRE(test_control.goal_reached);
|
|
||||||
REQUIRE(test_control.rewinded);
|
|
||||||
}
|
|
||||||
|
|
||||||
} // namespace Common
|
} // namespace Common
|
||||||
|
|
Loading…
Reference in a new issue