1
- #include " coro/facade .hpp"
1
+ #include " coro/default_executor .hpp"
2
2
#include < atomic>
3
3
#include < memory>
4
4
5
- static std::atomic<coro::facade *> s_facade = {nullptr };
5
+ static std::atomic<coro::default_executor *> s_facade = {nullptr };
6
6
7
7
#ifdef LIBCORO_FEATURE_NETWORKING
8
- coro::io_scheduler::options coro::facade ::s_io_scheduler_options;
8
+ coro::io_scheduler::options coro::default_executor ::s_io_scheduler_options;
9
9
#else
10
10
coro::thread_pool::options coro::facade::s_thread_pool_options;
11
11
#endif
12
12
13
- coro::facade * coro::facade ::instance ()
13
+ coro::default_executor * coro::default_executor ::instance ()
14
14
{
15
15
auto * result = s_facade.load (std::memory_order::acquire);
16
16
if (!result)
17
17
{
18
- auto ptr = std::make_unique<facade >();
18
+ auto ptr = std::make_unique<default_executor >();
19
19
if (s_facade.compare_exchange_strong (result, ptr.get (), std::memory_order::release, std::memory_order::acquire))
20
20
result = ptr.release ();
21
21
}
22
22
return result;
23
23
}
24
24
25
- coro::facade::facade ()
25
+ coro::default_executor::default_executor ()
26
26
{
27
27
#ifdef LIBCORO_FEATURE_NETWORKING
28
28
m_io_scheduler = io_scheduler::make_shared (s_io_scheduler_options);
@@ -31,7 +31,7 @@ coro::facade::facade()
31
31
#endif
32
32
}
33
33
34
- bool coro::facade ::spawn (coro::task<void >&& task) noexcept
34
+ bool coro::default_executor ::spawn (coro::task<void >&& task) noexcept
35
35
{
36
36
#ifdef LIBCORO_FEATURE_NETWORKING
37
37
return m_io_scheduler->spawn (std::move (task));
@@ -40,7 +40,7 @@ bool coro::facade::spawn(coro::task<void>&& task) noexcept
40
40
#endif
41
41
}
42
42
43
- bool coro::facade ::resume (std::coroutine_handle<> handle)
43
+ bool coro::default_executor ::resume (std::coroutine_handle<> handle)
44
44
{
45
45
#ifdef LIBCORO_FEATURE_NETWORKING
46
46
return m_io_scheduler->resume (handle);
@@ -49,7 +49,7 @@ bool coro::facade::resume(std::coroutine_handle<> handle)
49
49
#endif
50
50
}
51
51
52
- std::size_t coro::facade ::size ()
52
+ std::size_t coro::default_executor ::size ()
53
53
{
54
54
#ifdef LIBCORO_FEATURE_NETWORKING
55
55
return m_io_scheduler->size ();
@@ -58,7 +58,7 @@ std::size_t coro::facade::size()
58
58
#endif
59
59
}
60
60
61
- bool coro::facade ::empty ()
61
+ bool coro::default_executor ::empty ()
62
62
{
63
63
#ifdef LIBCORO_FEATURE_NETWORKING
64
64
return m_io_scheduler->empty ();
@@ -67,7 +67,7 @@ bool coro::facade::empty()
67
67
#endif
68
68
}
69
69
70
- void coro::facade ::shutdown ()
70
+ void coro::default_executor ::shutdown ()
71
71
{
72
72
#ifdef LIBCORO_FEATURE_NETWORKING
73
73
m_io_scheduler->shutdown ();
@@ -77,7 +77,7 @@ void coro::facade::shutdown()
77
77
}
78
78
79
79
#ifdef LIBCORO_FEATURE_NETWORKING
80
- auto coro::facade ::schedule () -> coro::io_scheduler::schedule_operation
80
+ auto coro::default_executor ::schedule () -> coro::io_scheduler::schedule_operation
81
81
{
82
82
return m_io_scheduler->schedule ();
83
83
}
@@ -90,12 +90,12 @@ auto coro::facade::schedule() -> coro::thread_pool::operation
90
90
91
91
#ifdef LIBCORO_FEATURE_NETWORKING
92
92
93
- void coro::facade ::set_io_scheduler_options (io_scheduler::options io_scheduler_options)
93
+ void coro::default_executor ::set_io_scheduler_options (io_scheduler::options io_scheduler_options)
94
94
{
95
95
s_io_scheduler_options = io_scheduler_options;
96
96
}
97
97
98
- std::shared_ptr<coro::io_scheduler> coro::facade ::get_io_scheduler ()
98
+ std::shared_ptr<coro::io_scheduler> coro::default_executor ::get_io_scheduler ()
99
99
{
100
100
return m_io_scheduler;
101
101
}
0 commit comments