File: test_tracefile_count

package info (click to toggle)
ltt-control 2.14.0-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 21,860 kB
  • sloc: cpp: 192,012; sh: 28,777; ansic: 10,960; python: 7,108; makefile: 3,520; java: 109; xml: 46
file content (192 lines) | stat: -rwxr-xr-x 5,631 bytes parent folder | download
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
#!/bin/bash
#
# SPDX-FileCopyrightText: 2013 Christian Babeux <christian.babeux@efficios.com>
# SPDX-FileCopyrightText: 2020 Jérémie Galarneau <jeremie.galarneau@efficios.com>
#
# SPDX-License-Identifier: LGPL-2.1-only

TEST_DESC="Tracefile count limits"

CURDIR=$(dirname "$0")/
TESTDIR=$CURDIR/../../..
BT2_PLUGINS_DIR="${TESTDIR}/utils/bt2_plugins"

TESTAPP_PATH="$TESTDIR/utils/testapp"
TESTAPP_NAME="gen-ust-events"
TESTAPP_BIN="$TESTAPP_PATH/$TESTAPP_NAME/$TESTAPP_NAME"

NUM_TESTS=74

PAGE_SIZE=$(getconf PAGE_SIZE)
TRACEFILE_SIZE=$PAGE_SIZE

source "$TESTDIR"/utils/utils.sh

if [ ! -x "$TESTAPP_BIN" ]; then
	BAIL_OUT "No UST events binary detected."
fi

function pick_random_cpuid ()
{
	local cpuids
	read -r -a cpuids <<< "$(get_online_cpus)"
	echo "${cpuids[ $RANDOM % ${#cpuids[@]} ]}"
}

function enable_lttng_channel_count_limit ()
{
	sess_name="$1"
	channel_name="$2"
	tracefile_count_limit="$3"

	test_name="Enable channel \`$channel_name\` "
	test_name+="for session \`$sess_name\`: "
	test_name+="$tracefile_count_limit tracefiles"

	"$TESTDIR"/../src/bin/lttng/"$LTTNG_BIN" enable-channel \
	    -u "$channel_name" -s "$sess_name" \
	    --subbuf-size "$PAGE_SIZE" \
	    --tracefile-size "$TRACEFILE_SIZE" \
	    --tracefile-count "$tracefile_count_limit" >/dev/null 2>&1

	ok $? "$test_name"
}

function validate_min_max ()
{
	stats="$1"
	field="$2"
	expected_min="$3"
	expected_max="$4"

	echo $stats | grep -q -E "$field $expected_min $expected_max"
	return $?
}

function get_total_stream_file_size ()
{
	local trace_path="$1"
	local stream_name_pattern="$2"
	local size

	size=$(find "$trace_path" -type f -regex "$stream_name_pattern" -exec du -b -c {} + | tail -n1 | cut -f 1)
	# Set a default is no files were found. This avoids integer comparison errors with an empty value.
	if [ -z "${size}" ]; then
		size=0
	fi
	echo "$size"
}

function get_stream_file_count ()
{
	local trace_path="$1"
	local stream_name_pattern="$2"
	local count

	count=$(find "$trace_path" -type f -regex "$stream_name_pattern" | wc -l)
	echo "$count"
}

function test_tracefile_count_limit ()
{
	local count_limit="$1"

	local channel_name="channel"
	local cpuno=$(pick_random_cpuid)
	local event_name="tp:tptest"
	local expected_size=$((count_limit * TRACEFILE_SIZE))
	local num_iter=100000
	local previous_stream_size=-1
	local session_name
	local stream_pattern=".*${channel_name}_${cpuno}_[0-9]*"
	local stream_size=0
	local trace_path=$(mktemp -d -t "tmp.${FUNCNAME[0]}_trace_path.XXXXXX")

	session_name=$(randstring 16 0)

	diag "Test tracefile count limit : CPU $cpuno, $count_limit tracefiles, expecting a maximum of $expected_size bytes per CPU"

	create_lttng_session_ok "$session_name" "$trace_path"

	enable_lttng_channel_count_limit \
	    "$session_name" "$channel_name" "$count_limit"

	enable_ust_lttng_event_ok \
	    "$session_name" "$event_name" "$channel_name"

	# Run the test app until the total stream size stops changing the
	# expected size is exceeded (error).
	#
	# The `$stream_size` will not stabilize until the trace file count
	# limit is reached. This is guaranteed by the use of start/produce/stop
	# cycles forcing the consumption of buffers, preventing unwanted stall
	# in stream size.
	while [ "$stream_size" -ne "$previous_stream_size" ]; do
		start_lttng_tracing_notap "$session_name"
		if ! taskset -c "$cpuno" "$TESTAPP_BIN" -i "$num_iter" >/dev/null 2>&1 ; then
			diag "Taskset failed for CPU ${cpuno}"
			# This is a case that can happen in the CI cluster which has the CPU
			# affinities of containers changed at runtime when other colocated
			# containers are started or stopped and the cluster manager attempts
			# to rebalance the load across the host's physical resources.
			#
			# When this is the first iteration, skip the remaining tests as
			# most likely all future calls to taskset with this cpu will fail.
			if [[ "${previous_stream_size}" == "-1" ]]; then
				stop_lttng_tracing_notap "${session_name}"
				destroy_lttng_session_ok "${session_name}"
				skip 0 "Taskset failed on first iteration" 5
				rm -rf "${trace_path}"
				return
			fi
		fi
		stop_lttng_tracing_notap "$session_name"

		previous_stream_size="$stream_size"
		stream_size=$(get_total_stream_file_size "$trace_path" "$stream_pattern")
		diag "Completed an iteration: previous size = $previous_stream_size bytes, new size = $stream_size bytes"

		if [ "$stream_size" -gt "$expected_size" ]; then
			diag "Total size for CPU $cpuno exceeds expected size: stream size = $stream_size bytes, expected size = $expected_size"
			break
		fi
	done

	destroy_lttng_session_ok "$session_name"

	[ "$expected_size" -eq "$stream_size" ]
	ok $? "Total stream size of CPU $cpuno is $expected_size"

	[ "$(get_stream_file_count "$trace_path" "$stream_pattern")" -eq "$count_limit" ]
	ok $? "Stream meets the trace file limit of $count_limit"

	stats=$("_run_babeltrace_cmd" --plugin-path "${BT2_PLUGINS_DIR}" convert $trace_path -c filter.lttngtest.event_name -p "names=[\"${event_name}\"]" -c sink.lttngtest.field_stats)

	validate_min_max "$stats" "intfield" "[0-9]+" "$expected_max"
	ok $? "Trace validation - intfield"

	validate_min_max "$stats" "netintfield" "[0-9]+" "$expected_max"
	ok $? "Trace validation - netintfield"

	validate_min_max "$stats" "longfield" "[0-9]+" "$expected_max"
	ok $? "Trace validation - longfield"

	rm -rf "$trace_path"
}

LIMITS=("1" "2" "4" "8" "10" "16" "32" "64")

plan_tests $NUM_TESTS

print_test_banner "$TEST_DESC"

bail_out_if_no_babeltrace

start_lttng_sessiond

for limit in "${LIMITS[@]}";
do
	test_tracefile_count_limit "$limit"
done

stop_lttng_sessiond