14
14
#include " orc-rt/ExecutorAddress.h"
15
15
#include " orc-rt/SPSAllocAction.h"
16
16
17
- #include " SimplePackedSerializationTestUtils .h"
17
+ #include " AllocActionTestUtils .h"
18
18
#include " gtest/gtest.h"
19
19
20
20
using namespace orc_rt ;
@@ -77,11 +77,14 @@ TEST(AllocActionTest, RunFinalizationActionsComplete) {
77
77
78
78
std::vector<AllocActionPair> InitialActions;
79
79
80
- auto MakeArgBuffer = [&]() { return makeExecutorAddrBuffer (&Val); };
81
- InitialActions.push_back ({{increment_sps_allocaction, MakeArgBuffer ()},
82
- {decrement_sps_allocaction, MakeArgBuffer ()}});
83
- InitialActions.push_back ({{increment_sps_allocaction, MakeArgBuffer ()},
84
- {decrement_sps_allocaction, MakeArgBuffer ()}});
80
+ auto MakeAAOnVal = [&](AllocActionFn Fn) {
81
+ return *MakeAllocAction<SPSExecutorAddr>::from (Fn,
82
+ ExecutorAddr::fromPtr (&Val));
83
+ };
84
+ InitialActions.push_back ({MakeAAOnVal (increment_sps_allocaction),
85
+ MakeAAOnVal (decrement_sps_allocaction)});
86
+ InitialActions.push_back ({MakeAAOnVal (increment_sps_allocaction),
87
+ MakeAAOnVal (decrement_sps_allocaction)});
85
88
86
89
auto DeallocActions = cantFail (runFinalizeActions (std::move (InitialActions)));
87
90
@@ -102,11 +105,14 @@ TEST(AllocActionTest, RunFinalizeActionsFail) {
102
105
103
106
std::vector<AllocActionPair> InitialActions;
104
107
105
- auto MakeArgBuffer = [&]() { return makeExecutorAddrBuffer (&Val); };
106
- InitialActions.push_back ({{increment_sps_allocaction, MakeArgBuffer ()},
107
- {decrement_sps_allocaction, MakeArgBuffer ()}});
108
- InitialActions.push_back ({{fail_sps_allocaction, MakeArgBuffer ()},
109
- {decrement_sps_allocaction, MakeArgBuffer ()}});
108
+ auto MakeAAOnVal = [&](AllocActionFn Fn) {
109
+ return *MakeAllocAction<SPSExecutorAddr>::from (Fn,
110
+ ExecutorAddr::fromPtr (&Val));
111
+ };
112
+ InitialActions.push_back ({MakeAAOnVal (increment_sps_allocaction),
113
+ MakeAAOnVal (decrement_sps_allocaction)});
114
+ InitialActions.push_back ({*MakeAllocAction<>::from (fail_sps_allocaction),
115
+ MakeAAOnVal (decrement_sps_allocaction)});
110
116
111
117
auto DeallocActions = runFinalizeActions (std::move (InitialActions));
112
118
@@ -126,11 +132,14 @@ TEST(AllocActionTest, RunFinalizeActionsNullFinalize) {
126
132
127
133
std::vector<AllocActionPair> InitialActions;
128
134
129
- auto MakeArgBuffer = [&]() { return makeExecutorAddrBuffer (&Val); };
130
- InitialActions.push_back ({{increment_sps_allocaction, MakeArgBuffer ()},
131
- {decrement_sps_allocaction, MakeArgBuffer ()}});
132
- InitialActions.push_back ({{nullptr , WrapperFunctionBuffer ()},
133
- {decrement_sps_allocaction, MakeArgBuffer ()}});
135
+ auto MakeAAOnVal = [&](AllocActionFn Fn) {
136
+ return *MakeAllocAction<SPSExecutorAddr>::from (Fn,
137
+ ExecutorAddr::fromPtr (&Val));
138
+ };
139
+ InitialActions.push_back ({MakeAAOnVal (increment_sps_allocaction),
140
+ MakeAAOnVal (decrement_sps_allocaction)});
141
+ InitialActions.push_back ({*MakeAllocAction<>::from (nullptr ),
142
+ MakeAAOnVal (decrement_sps_allocaction)});
134
143
135
144
auto DeallocActions = cantFail (runFinalizeActions (std::move (InitialActions)));
136
145
@@ -148,11 +157,14 @@ TEST(AllocActionTest, RunFinalizeActionsNullDealloc) {
148
157
149
158
std::vector<AllocActionPair> InitialActions;
150
159
151
- auto MakeArgBuffer = [&]() { return makeExecutorAddrBuffer (&Val); };
152
- InitialActions.push_back ({{increment_sps_allocaction, MakeArgBuffer ()},
153
- {decrement_sps_allocaction, MakeArgBuffer ()}});
154
- InitialActions.push_back ({{increment_sps_allocaction, MakeArgBuffer ()},
155
- {nullptr , WrapperFunctionBuffer ()}});
160
+ auto MakeAAOnVal = [&](AllocActionFn Fn) {
161
+ return *MakeAllocAction<SPSExecutorAddr>::from (Fn,
162
+ ExecutorAddr::fromPtr (&Val));
163
+ };
164
+ InitialActions.push_back ({MakeAAOnVal (increment_sps_allocaction),
165
+ MakeAAOnVal (decrement_sps_allocaction)});
166
+ InitialActions.push_back ({MakeAAOnVal (increment_sps_allocaction),
167
+ *MakeAllocAction<>::from (nullptr )});
156
168
157
169
auto DeallocActions = cantFail (runFinalizeActions (std::move (InitialActions)));
158
170
0 commit comments