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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
#include "executor.h"
#include <utility>
namespace scripting {
namespace api {
executor_h::executor_h() = default;
executor_h::executor_h(std::shared_ptr<executor::Executor> executor) : m_executor(std::move(executor)) {}
bool executor_h::isValid() const { return m_executor != nullptr; }
const std::shared_ptr<executor::Executor>& executor_h::getExecutor() const { return m_executor; }
//**********HANDLE: executor
ADE_OBJ(l_Executor, executor_h, "executor", "An executor that can be used for scheduling the execution of a function.");
ADE_FUNC(schedule,
l_Executor,
"function() => boolean",
"Takes a function that returns a boolean and schedules that for execution on this executor. If the function "
"returns true it will be run again the. If it returns false it will be removed from the executor.<br>Note: Use "
"this with care since using this without proper care can lead to the function being run in states that are not "
"desired. Consider using async.run.",
"boolean",
"true if function was scheduled, false otherwise.")
{
executor_h* executor = nullptr;
luacpp::LuaFunction func;
if (!ade_get_args(L, "ou", l_Executor.GetPtr(&executor), &func)) {
return ADE_RETURN_FALSE;
}
if (executor == nullptr || !executor->isValid()) {
return ADE_RETURN_FALSE;
}
if (!func.isValid()) {
LuaError(L, "Invalid function handle specified!");
return ADE_RETURN_FALSE;
}
// Post the function onto the executor with a wrapper to convert the Lua value to the proper enum
executor->getExecutor()->post([L, func]() {
const auto ret = func(L);
if (ret.empty()) {
return executor::Executor::CallbackResult::Done;
}
if (!ret[0].is(luacpp::ValueType::BOOLEAN)) {
return executor::Executor::CallbackResult::Done;
}
if (ret[0].getValue<bool>()) {
return executor::Executor::CallbackResult::Reschedule;
}
return executor::Executor::CallbackResult::Done;
});
return ADE_RETURN_TRUE;
}
ADE_FUNC(isValid,
l_Executor,
nullptr,
"Determined if this handle is valid",
"boolean",
"true if valid, false otherwise.")
{
executor_h* executor = nullptr;
if (!ade_get_args(L, "o", l_Executor.GetPtr(&executor))) {
return ADE_RETURN_FALSE;
}
if (executor == nullptr || !executor->isValid()) {
return ADE_RETURN_FALSE;
}
return ADE_RETURN_TRUE;
}
} // namespace api
} // namespace scripting
|
