Index/src / ex / execution_context.cpp

src/ex/execution_context.cpp

91.4% Lines (64/70) 100.0% Functions (7/7)
[ ] prev/next file n p prev/next uncovered line
Line TLA Hits Source Code
1 //
2 // Copyright (c) 2025 Vinnie Falco (vinnie.falco@gmail.com)
3 //
4 // Distributed under the Boost Software License, Version 1.0. (See accompanying
5 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6 //
7 // Official repository: https://github.com/cppalliance/capy
8 //
9
10 #include <boost/capy/ex/execution_context.hpp>
11 #include <boost/capy/ex/recycling_memory_resource.hpp>
12 #include <boost/capy/detail/except.hpp>
13
14 namespace boost {
15 namespace capy {
16
17 2865x execution_context::
18 2865x execution_context()
19 2865x : frame_alloc_(get_recycling_memory_resource())
20 {
21 2865x }
22
23 2865x execution_context::
24 ~execution_context()
25 {
26 2865x shutdown();
27 2865x destroy();
28 2865x }
29
30 void
31 2928x execution_context::
32 shutdown() noexcept
33 {
34 2928x if(shutdown_)
35 63x return;
36 2865x shutdown_ = true;
37
38 2865x service* p = head_;
39 2902x while(p)
40 {
41 37x p->shutdown();
42 37x p = p->next_;
43 }
44 }
45
46 void
47 2928x execution_context::
48 destroy() noexcept
49 {
50 2928x service* p = head_;
51 2928x head_ = nullptr;
52 2965x while(p)
53 {
54 37x service* next = p->next_;
55 37x delete p;
56 37x p = next;
57 }
58 2928x }
59
60 execution_context::service*
61 117x execution_context::
62 find_impl(detail::type_index ti) const noexcept
63 {
64 117x auto p = head_;
65 124x while(p)
66 {
67 43x if(p->t0_ == ti || p->t1_ == ti)
68 36x break;
69 7x p = p->next_;
70 }
71 117x return p;
72 }
73
74 execution_context::service&
75 44x execution_context::
76 use_service_impl(factory& f)
77 {
78 44x std::unique_lock<std::mutex> lock(mutex_);
79
80 44x if(auto* p = find_impl(f.t0))
81 14x return *p;
82
83 30x lock.unlock();
84
85 // Create the service outside lock, enabling nested calls
86 30x service* sp = f.create(*this);
87 30x sp->t0_ = f.t0;
88 30x sp->t1_ = f.t1;
89
90 30x lock.lock();
91
92 30x if(auto* p = find_impl(f.t0))
93 {
94 ✗ delete sp;
95 ✗ return *p;
96 }
97
98 30x sp->next_ = head_;
99 30x head_ = sp;
100
101 30x return *sp;
102 44x }
103
104 execution_context::service&
105 10x execution_context::
106 make_service_impl(factory& f)
107 {
108 {
109 10x std::lock_guard<std::mutex> lock(mutex_);
110 10x if(find_impl(f.t0))
111 2x detail::throw_invalid_argument();
112 8x if(f.t0 != f.t1 && find_impl(f.t1))
113 1x detail::throw_invalid_argument();
114 10x }
115
116 // Unlocked to allow nested service creation from constructor
117 7x service* p = f.create(*this);
118
119 7x std::lock_guard<std::mutex> lock(mutex_);
120 7x if(find_impl(f.t0))
121 {
122 ✗ delete p;
123 ✗ detail::throw_invalid_argument();
124 }
125
126 7x p->t0_ = f.t0;
127 7x if(f.t0 != f.t1)
128 {
129 1x if(find_impl(f.t1))
130 {
131 ✗ delete p;
132 ✗ detail::throw_invalid_argument();
133 }
134 1x p->t1_ = f.t1;
135 }
136 else
137 {
138 6x p->t1_ = f.t0;
139 }
140
141 7x p->next_ = head_;
142 7x head_ = p;
143
144 7x return *p;
145 7x }
146
147 } // namespace capy
148 } // namespace boost
149