1 // SPDX-License-Identifier: GPL-2.0 2 #include "util/debug.h" 3 #include "util/map.h" 4 #include "util/symbol.h" 5 #include "util/sort.h" 6 #include "util/evsel.h" 7 #include "util/event.h" 8 #include "util/evlist.h" 9 #include "util/machine.h" 10 #include "util/parse-events.h" 11 #include "tests/tests.h" 12 #include "tests/hists_common.h" 13 #include <linux/kernel.h> 14 15 struct sample { 16 u32 pid; 17 u64 ip; 18 struct thread *thread; 19 struct map *map; 20 struct symbol *sym; 21 int socket; 22 }; 23 24 /* For the numbers, see hists_common.c */ 25 static struct sample fake_samples[] = { 26 /* perf [kernel] schedule() */ 27 { .pid = FAKE_PID_PERF1, .ip = FAKE_IP_KERNEL_SCHEDULE, .socket = 0 }, 28 /* perf [perf] main() */ 29 { .pid = FAKE_PID_PERF1, .ip = FAKE_IP_PERF_MAIN, .socket = 0 }, 30 /* perf [libc] malloc() */ 31 { .pid = FAKE_PID_PERF1, .ip = FAKE_IP_LIBC_MALLOC, .socket = 0 }, 32 /* perf [perf] main() */ 33 { .pid = FAKE_PID_PERF2, .ip = FAKE_IP_PERF_MAIN, .socket = 0 }, /* will be merged */ 34 /* perf [perf] cmd_record() */ 35 { .pid = FAKE_PID_PERF2, .ip = FAKE_IP_PERF_CMD_RECORD, .socket = 1 }, 36 /* perf [kernel] page_fault() */ 37 { .pid = FAKE_PID_PERF2, .ip = FAKE_IP_KERNEL_PAGE_FAULT, .socket = 1 }, 38 /* bash [bash] main() */ 39 { .pid = FAKE_PID_BASH, .ip = FAKE_IP_BASH_MAIN, .socket = 2 }, 40 /* bash [bash] xmalloc() */ 41 { .pid = FAKE_PID_BASH, .ip = FAKE_IP_BASH_XMALLOC, .socket = 2 }, 42 /* bash [libc] malloc() */ 43 { .pid = FAKE_PID_BASH, .ip = FAKE_IP_LIBC_MALLOC, .socket = 3 }, 44 /* bash [kernel] page_fault() */ 45 { .pid = FAKE_PID_BASH, .ip = FAKE_IP_KERNEL_PAGE_FAULT, .socket = 3 }, 46 }; 47 48 static int add_hist_entries(struct evlist *evlist, 49 struct machine *machine) 50 { 51 struct evsel *evsel; 52 struct addr_location al; 53 struct perf_sample sample = { .period = 100, }; 54 size_t i; 55 56 /* 57 * each evsel will have 10 samples but the 4th sample 58 * (perf [perf] main) will be collapsed to an existing entry 59 * so total 9 entries will be in the tree. 60 */ 61 evlist__for_each_entry(evlist, evsel) { 62 for (i = 0; i < ARRAY_SIZE(fake_samples); i++) { 63 struct hist_entry_iter iter = { 64 .evsel = evsel, 65 .sample = &sample, 66 .ops = &hist_iter_normal, 67 .hide_unresolved = false, 68 }; 69 struct hists *hists = evsel__hists(evsel); 70 71 /* make sure it has no filter at first */ 72 hists->thread_filter = NULL; 73 hists->dso_filter = NULL; 74 hists->symbol_filter_str = NULL; 75 76 sample.cpumode = PERF_RECORD_MISC_USER; 77 sample.pid = fake_samples[i].pid; 78 sample.tid = fake_samples[i].pid; 79 sample.ip = fake_samples[i].ip; 80 81 if (machine__resolve(machine, &al, &sample) < 0) 82 goto out; 83 84 al.socket = fake_samples[i].socket; 85 if (hist_entry_iter__add(&iter, &al, 86 sysctl_perf_event_max_stack, NULL) < 0) { 87 addr_location__put(&al); 88 goto out; 89 } 90 91 fake_samples[i].thread = al.thread; 92 fake_samples[i].map = al.map; 93 fake_samples[i].sym = al.sym; 94 } 95 } 96 97 return 0; 98 99 out: 100 pr_debug("Not enough memory for adding a hist entry\n"); 101 return TEST_FAIL; 102 } 103 104 int test__hists_filter(struct test *test __maybe_unused, int subtest __maybe_unused) 105 { 106 int err = TEST_FAIL; 107 struct machines machines; 108 struct machine *machine; 109 struct evsel *evsel; 110 struct evlist *evlist = evlist__new(); 111 112 TEST_ASSERT_VAL("No memory", evlist); 113 114 err = parse_events(evlist, "cpu-clock", NULL); 115 if (err) 116 goto out; 117 err = parse_events(evlist, "task-clock", NULL); 118 if (err) 119 goto out; 120 err = TEST_FAIL; 121 122 /* default sort order (comm,dso,sym) will be used */ 123 if (setup_sorting(NULL) < 0) 124 goto out; 125 126 machines__init(&machines); 127 128 /* setup threads/dso/map/symbols also */ 129 machine = setup_fake_machine(&machines); 130 if (!machine) 131 goto out; 132 133 if (verbose > 1) 134 machine__fprintf(machine, stderr); 135 136 /* process sample events */ 137 err = add_hist_entries(evlist, machine); 138 if (err < 0) 139 goto out; 140 141 evlist__for_each_entry(evlist, evsel) { 142 struct hists *hists = evsel__hists(evsel); 143 144 hists__collapse_resort(hists, NULL); 145 perf_evsel__output_resort(evsel, NULL); 146 147 if (verbose > 2) { 148 pr_info("Normal histogram\n"); 149 print_hists_out(hists); 150 } 151 152 TEST_ASSERT_VAL("Invalid nr samples", 153 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 10); 154 TEST_ASSERT_VAL("Invalid nr hist entries", 155 hists->nr_entries == 9); 156 TEST_ASSERT_VAL("Invalid total period", 157 hists->stats.total_period == 1000); 158 TEST_ASSERT_VAL("Unmatched nr samples", 159 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 160 hists->stats.nr_non_filtered_samples); 161 TEST_ASSERT_VAL("Unmatched nr hist entries", 162 hists->nr_entries == hists->nr_non_filtered_entries); 163 TEST_ASSERT_VAL("Unmatched total period", 164 hists->stats.total_period == 165 hists->stats.total_non_filtered_period); 166 167 /* now applying thread filter for 'bash' */ 168 hists->thread_filter = fake_samples[9].thread; 169 hists__filter_by_thread(hists); 170 171 if (verbose > 2) { 172 pr_info("Histogram for thread filter\n"); 173 print_hists_out(hists); 174 } 175 176 /* normal stats should be invariant */ 177 TEST_ASSERT_VAL("Invalid nr samples", 178 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 10); 179 TEST_ASSERT_VAL("Invalid nr hist entries", 180 hists->nr_entries == 9); 181 TEST_ASSERT_VAL("Invalid total period", 182 hists->stats.total_period == 1000); 183 184 /* but filter stats are changed */ 185 TEST_ASSERT_VAL("Unmatched nr samples for thread filter", 186 hists->stats.nr_non_filtered_samples == 4); 187 TEST_ASSERT_VAL("Unmatched nr hist entries for thread filter", 188 hists->nr_non_filtered_entries == 4); 189 TEST_ASSERT_VAL("Unmatched total period for thread filter", 190 hists->stats.total_non_filtered_period == 400); 191 192 /* remove thread filter first */ 193 hists->thread_filter = NULL; 194 hists__filter_by_thread(hists); 195 196 /* now applying dso filter for 'kernel' */ 197 hists->dso_filter = fake_samples[0].map->dso; 198 hists__filter_by_dso(hists); 199 200 if (verbose > 2) { 201 pr_info("Histogram for dso filter\n"); 202 print_hists_out(hists); 203 } 204 205 /* normal stats should be invariant */ 206 TEST_ASSERT_VAL("Invalid nr samples", 207 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 10); 208 TEST_ASSERT_VAL("Invalid nr hist entries", 209 hists->nr_entries == 9); 210 TEST_ASSERT_VAL("Invalid total period", 211 hists->stats.total_period == 1000); 212 213 /* but filter stats are changed */ 214 TEST_ASSERT_VAL("Unmatched nr samples for dso filter", 215 hists->stats.nr_non_filtered_samples == 3); 216 TEST_ASSERT_VAL("Unmatched nr hist entries for dso filter", 217 hists->nr_non_filtered_entries == 3); 218 TEST_ASSERT_VAL("Unmatched total period for dso filter", 219 hists->stats.total_non_filtered_period == 300); 220 221 /* remove dso filter first */ 222 hists->dso_filter = NULL; 223 hists__filter_by_dso(hists); 224 225 /* 226 * now applying symbol filter for 'main'. Also note that 227 * there's 3 samples that have 'main' symbol but the 4th 228 * entry of fake_samples was collapsed already so it won't 229 * be counted as a separate entry but the sample count and 230 * total period will be remained. 231 */ 232 hists->symbol_filter_str = "main"; 233 hists__filter_by_symbol(hists); 234 235 if (verbose > 2) { 236 pr_info("Histogram for symbol filter\n"); 237 print_hists_out(hists); 238 } 239 240 /* normal stats should be invariant */ 241 TEST_ASSERT_VAL("Invalid nr samples", 242 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 10); 243 TEST_ASSERT_VAL("Invalid nr hist entries", 244 hists->nr_entries == 9); 245 TEST_ASSERT_VAL("Invalid total period", 246 hists->stats.total_period == 1000); 247 248 /* but filter stats are changed */ 249 TEST_ASSERT_VAL("Unmatched nr samples for symbol filter", 250 hists->stats.nr_non_filtered_samples == 3); 251 TEST_ASSERT_VAL("Unmatched nr hist entries for symbol filter", 252 hists->nr_non_filtered_entries == 2); 253 TEST_ASSERT_VAL("Unmatched total period for symbol filter", 254 hists->stats.total_non_filtered_period == 300); 255 256 /* remove symbol filter first */ 257 hists->symbol_filter_str = NULL; 258 hists__filter_by_symbol(hists); 259 260 /* now applying socket filters */ 261 hists->socket_filter = 2; 262 hists__filter_by_socket(hists); 263 264 if (verbose > 2) { 265 pr_info("Histogram for socket filters\n"); 266 print_hists_out(hists); 267 } 268 269 /* normal stats should be invariant */ 270 TEST_ASSERT_VAL("Invalid nr samples", 271 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 10); 272 TEST_ASSERT_VAL("Invalid nr hist entries", 273 hists->nr_entries == 9); 274 TEST_ASSERT_VAL("Invalid total period", 275 hists->stats.total_period == 1000); 276 277 /* but filter stats are changed */ 278 TEST_ASSERT_VAL("Unmatched nr samples for socket filter", 279 hists->stats.nr_non_filtered_samples == 2); 280 TEST_ASSERT_VAL("Unmatched nr hist entries for socket filter", 281 hists->nr_non_filtered_entries == 2); 282 TEST_ASSERT_VAL("Unmatched total period for socket filter", 283 hists->stats.total_non_filtered_period == 200); 284 285 /* remove socket filter first */ 286 hists->socket_filter = -1; 287 hists__filter_by_socket(hists); 288 289 /* now applying all filters at once. */ 290 hists->thread_filter = fake_samples[1].thread; 291 hists->dso_filter = fake_samples[1].map->dso; 292 hists__filter_by_thread(hists); 293 hists__filter_by_dso(hists); 294 295 if (verbose > 2) { 296 pr_info("Histogram for all filters\n"); 297 print_hists_out(hists); 298 } 299 300 /* normal stats should be invariant */ 301 TEST_ASSERT_VAL("Invalid nr samples", 302 hists->stats.nr_events[PERF_RECORD_SAMPLE] == 10); 303 TEST_ASSERT_VAL("Invalid nr hist entries", 304 hists->nr_entries == 9); 305 TEST_ASSERT_VAL("Invalid total period", 306 hists->stats.total_period == 1000); 307 308 /* but filter stats are changed */ 309 TEST_ASSERT_VAL("Unmatched nr samples for all filter", 310 hists->stats.nr_non_filtered_samples == 2); 311 TEST_ASSERT_VAL("Unmatched nr hist entries for all filter", 312 hists->nr_non_filtered_entries == 1); 313 TEST_ASSERT_VAL("Unmatched total period for all filter", 314 hists->stats.total_non_filtered_period == 200); 315 } 316 317 318 err = TEST_OK; 319 320 out: 321 /* tear down everything */ 322 evlist__delete(evlist); 323 reset_output_field(); 324 machines__exit(&machines); 325 326 return err; 327 } 328