projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
action executor: use an execution context to validate enqueued action before execution
[lttng-tools.git]
/
src
/
bin
/
lttng-sessiond
/
notification-thread-events.c
diff --git
a/src/bin/lttng-sessiond/notification-thread-events.c
b/src/bin/lttng-sessiond/notification-thread-events.c
index 90fdadd61280bc2452063931ad1c7ca1fc837f8b..5cccc008efbc409fb3797590aaae22bcf6c1c823 100644
(file)
--- a/
src/bin/lttng-sessiond/notification-thread-events.c
+++ b/
src/bin/lttng-sessiond/notification-thread-events.c
@@
-1953,9
+1953,9
@@
int handle_notification_thread_command_session_rotation(
* Ownership of `evaluation` transferred to the action executor
* no matter the result.
*/
* Ownership of `evaluation` transferred to the action executor
* no matter the result.
*/
- executor_status = action_executor_enqueue
(state->executor,
-
trigger, evaluation, &session_creds
,
- client_list);
+ executor_status = action_executor_enqueue
_trigger(
+
state->executor, trigger, evaluation
,
+
&session_creds,
client_list);
evaluation = NULL;
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
evaluation = NULL;
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
@@
-2917,8
+2917,8
@@
int handle_notification_thread_command_register_trigger(
* Ownership of `evaluation` transferred to the action executor
* no matter the result.
*/
* Ownership of `evaluation` transferred to the action executor
* no matter the result.
*/
- executor_status = action_executor_enqueue
(state->executor, trigge
r,
- evaluation, &object_creds, client_list);
+ executor_status = action_executor_enqueue
_trigger(state->executo
r,
+
trigger,
evaluation, &object_creds, client_list);
evaluation = NULL;
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
evaluation = NULL;
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
@@
-4638,7
+4638,7
@@
int dispatch_one_event_notifier_notification(struct notification_thread_state *s
}
client_list = get_client_list_from_condition(state,
lttng_trigger_get_const_condition(element->trigger));
}
client_list = get_client_list_from_condition(state,
lttng_trigger_get_const_condition(element->trigger));
- executor_status = action_executor_enqueue(state->executor,
+ executor_status = action_executor_enqueue
_trigger
(state->executor,
element->trigger, evaluation, NULL, client_list);
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
element->trigger, evaluation, NULL, client_list);
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
@@
-4921,9
+4921,9
@@
int handle_notification_thread_channel_sample(
* Ownership of `evaluation` transferred to the action executor
* no matter the result.
*/
* Ownership of `evaluation` transferred to the action executor
* no matter the result.
*/
- executor_status = action_executor_enqueue
(state->executor,
-
trigger, evaluation, &channel_creds
,
- client_list);
+ executor_status = action_executor_enqueue
_trigger(
+
state->executor, trigger, evaluation
,
+
&channel_creds,
client_list);
evaluation = NULL;
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
evaluation = NULL;
switch (executor_status) {
case ACTION_EXECUTOR_STATUS_OK:
This page took
0.02542 seconds
and
4
git commands to generate.