torzu-backup/torzu
1
1
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity

clang-formated new fiber.cpp and minicoro.h

Browse source
This commit is contained in:
darktux 2024-04-05 01:58:30 +02:00
parent b07b266b87
commit f2592ff593
2 changed files with 1242 additions and 1199 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/common/fiber.cpp
View file

@ -16,11 +16,11 @@ struct Fiber::FiberImpl {
std::mutex guard;
bool released{};
bool is_thread_fiber{};
Fiber *next_fiber{};
Fiber **next_fiber_ptr;
Fiber* next_fiber{};
Fiber** next_fiber_ptr;
std::function<void()> entry_point;
mco_coro *context;
mco_coro* context;
};
Fiber::Fiber() : impl{std::make_unique<FiberImpl>()} {
@ -29,9 +29,8 @@ Fiber::Fiber() : 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);
auto desc = mco_desc_init([] (mco_coro *coro) {
reinterpret_cast<Fiber*>(coro->user_data)->impl->entry_point();
}, 0);
auto desc = mco_desc_init(
[](mco_coro* coro) { reinterpret_cast<Fiber*>(coro->user_data)->impl->entry_point(); }, 0);
desc.user_data = this;
mco_result res = mco_create(&impl->context, &desc);
ASSERT(res == MCO_SUCCESS);

2430
src/common/minicoro.h
View file

File diff suppressed because it is too large Load diff