blob: f1b5fc136fb499ba95c16ec01e9bbbbb44c5348c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// Copyright 2025 Dolphin Emulator Project
// SPDX-License-Identifier: GPL-2.0-or-later
#pragma once
#include <pthread.h>
#include <sys/eventfd.h>
#include "Common/CommonFuncs.h"
#include "Common/Logging/Log.h"
namespace UnixUtil
{
inline int CreateEventFD(unsigned int count, int flags)
{
const int result = eventfd(count, flags);
if (result == -1)
{
ERROR_LOG_FMT(COMMON, "eventfd failed: {}", Common::LastStrerrorString());
std::abort();
}
return result;
}
// Repeatedly call a function that can erroneously produce EINTR.
auto RetryOnEINTR(auto func, auto... args)
{
while (true)
{
const int result = func(args...);
if (result >= 0 || errno != EINTR)
return result;
}
}
// This is a very low-effort wrapper for pthread.
// It allows creating a pthread from any callable (e.g. a lambda).
// The wrapper object must exist for the lifetime of the thread.
template <typename Func>
struct PThreadWrapper
{
Func func;
pthread_t handle{};
explicit PThreadWrapper(Func&& f) : func(std::move(f))
{
if (int result = pthread_create(
&handle, nullptr,
[](void* arg) -> void* {
static_cast<PThreadWrapper*>(arg)->func();
return nullptr;
},
this);
result != 0)
{
ERROR_LOG_FMT(COMMON, "pthread_create: {}", Common::StrerrorString(result));
std::abort();
}
}
};
} // namespace UnixUtil
|
