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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
|
#!/bin/bash
#
# SPDX-FileCopyrightText: 2020 Francis Deslauriers <francis.deslauriers@efficios.com>
#
# SPDX-License-Identifier: LGPL-2.1-only
TEST_DESC="Triggers - rate policy notify"
CURDIR=$(dirname "$0")/
TESTDIR=${CURDIR}/../../../..
# shellcheck source=../../../../utils/utils.sh
source "$TESTDIR/utils/utils.sh"
TESTAPP_PATH="$TESTDIR/utils/testapp"
GEN_UST_EVENTS_TESTAPP_NAME="gen-ust-events"
GEN_UST_EVENTS_TESTAPP_BIN="$TESTAPP_PATH/$GEN_UST_EVENTS_TESTAPP_NAME/$GEN_UST_EVENTS_TESTAPP_NAME"
NOTIFICATION_CLIENT_BIN="$CURDIR/../utils/notification-client"
NUM_TESTS=19
NR_ITER=10
NR_USEC_WAIT=5
function test_rate_policy_every_n()
{
local SESSION_NAME="my_triggered_session"
local TRIGGER_NAME="trigger1"
local END_TRIGGER_NAME="end-trigger1"
local SYNC_AFTER_NOTIF_REGISTER_PATH
SYNC_AFTER_NOTIF_REGISTER_PATH=$(mktemp -u -t test-notif-register.XXXXXX)
diag "Every N rate policy"
# Add a trigger with a notify action with a policy to fire it every 5
# time the condition is met.
lttng_add_trigger_ok \
$TRIGGER_NAME \
--condition event-rule-matches --type=user --name="tp:tptest" \
--action notify \
--rate-policy=every:5
# Add a trigger with a notify action for the tp:end event of the test
# application. This allow us to "delimit" the reception loop for the
# notification client ensuring that all events were hit and passed into
# the notification subsystem.
lttng_add_trigger_ok \
$END_TRIGGER_NAME \
--condition event-rule-matches --type=user --name="tp:end" \
--action notify
for i in $(seq 1 4); do
diag "Iteration $i of 4"
## Phase 1
# Hit the trigger condition 4 time and validate that no (0)
# notification for that condition was received.
$NOTIFICATION_CLIENT_BIN \
--trigger $TRIGGER_NAME \
--sync-after-notif-register "$SYNC_AFTER_NOTIF_REGISTER_PATH" \
--count 0 \
--end-trigger "$END_TRIGGER_NAME" &
notif_client_pid=$!
while [ ! -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}" ]; do
sleep 0.5
done
$GEN_UST_EVENTS_TESTAPP_BIN -i 4 -w $NR_USEC_WAIT --emit-end-event > /dev/null 2>&1
# notification-client will exit once it receives the end-trigger notification.
# Validation of the number of received notification is done by the
# notification client. Here it validate that it received 0 notifications.
wait $notif_client_pid
test "$?" -eq "0"
ok $? "notification client exited successfully"
## Phase 2
# Hit the condition 1 time and validate that a notification is
# received.
rm -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}"
$NOTIFICATION_CLIENT_BIN \
--trigger $TRIGGER_NAME \
--sync-after-notif-register "$SYNC_AFTER_NOTIF_REGISTER_PATH" \
--count 1 \
--end-trigger "$END_TRIGGER_NAME" &
notif_client_pid=$!
while [ ! -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}" ]; do
sleep 0.5
done
# Artificially produce the desired event-rule condition.
$GEN_UST_EVENTS_TESTAPP_BIN -i 1 -w $NR_USEC_WAIT --emit-end-event > /dev/null 2>&1
# notification-client will exit once it receives the end-trigger notification.
# Validation of the number of received notification is done by the
# notification client. Here it validate that it received 1 notifications.
wait $notif_client_pid
test "$?" -eq "0"
ok $? "notification client exited successfully"
rm -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}"
done
# Tearing down.
lttng_remove_trigger_ok $TRIGGER_NAME
lttng_remove_trigger_ok $END_TRIGGER_NAME
rm -f "$SYNC_AFTER_NOTIF_REGISTER_PATH"
}
function test_rate_policy_once_after_n()
{
local SESSION_NAME="my_triggered_session"
local TRIGGER_NAME="trigger1"
local END_TRIGGER_NAME="end-trigger1"
local SYNC_AFTER_NOTIF_REGISTER_PATH
SYNC_AFTER_NOTIF_REGISTER_PATH=$(mktemp -u -t test-notif-register.XXXXXX)
diag "Once after N rate policy"
# Add a trigger with a notify action with a policy to fire it every 5
# time the condition is met.
lttng_add_trigger_ok \
$TRIGGER_NAME \
--condition event-rule-matches --type=user --name="tp:tptest" \
--action notify \
--rate-policy=once-after:5
# Add a trigger with a notify action for the tp:end event of the test
# application. This allow us to "delimit" the reception loop for the
# notification client ensuring that all events were hit and passed into
# the notification subsystem.
lttng_add_trigger_ok \
$END_TRIGGER_NAME \
--condition event-rule-matches --type=user --name="tp:end" \
--action notify
## Phase 1
# Hit the trigger condition 4 time and validate that no (0)
# notification for that condition was received.
$NOTIFICATION_CLIENT_BIN \
--trigger $TRIGGER_NAME \
--sync-after-notif-register "$SYNC_AFTER_NOTIF_REGISTER_PATH" \
--count 0 \
--end-trigger "$END_TRIGGER_NAME" &
notif_client_pid=$!
while [ ! -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}" ]; do
sleep 0.5
done
# Artificially produce the desired event-rule condition.
$GEN_UST_EVENTS_TESTAPP_BIN -i 4 -w $NR_USEC_WAIT --emit-end-event > /dev/null 2>&1
# notification-client will exit once it receives the end-trigger notification.
# Validation of the number of received notification is done by the
# notification client. Here it validate that it received 0 notifications.
wait $notif_client_pid
test "$?" -eq "0"
ok $? "notification client exited successfully"
## Phase 2
# Hit the condition 1 time and validate that a notification is
# received.
rm -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}"
$NOTIFICATION_CLIENT_BIN \
--trigger $TRIGGER_NAME \
--sync-after-notif-register "$SYNC_AFTER_NOTIF_REGISTER_PATH" \
--count 1 \
--end-trigger "$END_TRIGGER_NAME" &
notif_client_pid=$!
while [ ! -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}" ]; do
sleep 0.5
done
# Artificially produce the desired event-rule condition.
$GEN_UST_EVENTS_TESTAPP_BIN -i 1 -w $NR_USEC_WAIT --emit-end-event > /dev/null 2>&1
# notification-client will exit once it receives the end-trigger notification.
# Validation of the number of received notification is done by the
# notification client. Here it validate that it received 1 notifications.
wait $notif_client_pid
test "$?" -eq "0"
ok $? "notification client exited successfully"
## Phase 3
# Hit the condition N time and validate that no (0) notification is
# received.
rm -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}"
$NOTIFICATION_CLIENT_BIN \
--trigger $TRIGGER_NAME \
--sync-after-notif-register "$SYNC_AFTER_NOTIF_REGISTER_PATH" \
--count 0 \
--end-trigger "$END_TRIGGER_NAME" &
notif_client_pid=$!
while [ ! -f "${SYNC_AFTER_NOTIF_REGISTER_PATH}" ]; do
sleep 0.5
done
# Artificially produce the desired event-rule condition.
$GEN_UST_EVENTS_TESTAPP_BIN -i $NR_ITER -w $NR_USEC_WAIT --emit-end-event > /dev/null 2>&1
# notification-client will exit once it receives the end-trigger notification.
# Validation of the number of received notification is done by the
# notification client. Here it validate that it received 0 notifications.
wait $notif_client_pid
test "$?" -eq "0"
ok $? "notification client exited successfully"
# Tearing down.
lttng_remove_trigger_ok $TRIGGER_NAME
lttng_remove_trigger_ok $END_TRIGGER_NAME
rm -f "$SYNC_AFTER_NOTIF_REGISTER_PATH"
}
# MUST set TESTDIR before calling those functions
plan_tests $NUM_TESTS
print_test_banner "$TEST_DESC"
start_lttng_sessiond_notap
test_rate_policy_every_n
test_rate_policy_once_after_n
stop_lttng_sessiond_notap
|
