blob: 821c1586a22b7da92cd732ad1a4ee4e05b037085 [file] [log] [blame]
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +09001#include "builtin.h"
2#include "perf.h"
3
4#include "util/util.h"
5#include "util/cache.h"
6#include "util/symbol.h"
7#include "util/thread.h"
8#include "util/header.h"
9
10#include "util/parse-options.h"
11#include "util/trace-event.h"
12
13#include "util/debug.h"
14#include "util/session.h"
15
16#include <sys/types.h>
17#include <sys/prctl.h>
18#include <semaphore.h>
19#include <pthread.h>
20#include <math.h>
21#include <limits.h>
22
23#include <linux/list.h>
24#include <linux/hash.h>
25
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +090026static struct perf_session *session;
27
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090028/* based on kernel/lockdep.c */
29#define LOCKHASH_BITS 12
30#define LOCKHASH_SIZE (1UL << LOCKHASH_BITS)
31
32static struct list_head lockhash_table[LOCKHASH_SIZE];
33
34#define __lockhashfn(key) hash_long((unsigned long)key, LOCKHASH_BITS)
35#define lockhashentry(key) (lockhash_table + __lockhashfn((key)))
36
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090037struct lock_stat {
Ingo Molnar59f411b2010-01-31 08:27:58 +010038 struct list_head hash_entry;
39 struct rb_node rb; /* used for sorting */
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090040
Ingo Molnar59f411b2010-01-31 08:27:58 +010041 /*
42 * FIXME: raw_field_value() returns unsigned long long,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090043 * so address of lockdep_map should be dealed as 64bit.
Ingo Molnar59f411b2010-01-31 08:27:58 +010044 * Is there more better solution?
45 */
46 void *addr; /* address of lockdep_map, used as ID */
47 char *name; /* for strcpy(), we cannot use const */
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090048
Ingo Molnar59f411b2010-01-31 08:27:58 +010049 unsigned int nr_acquire;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +090050 unsigned int nr_acquired;
Ingo Molnar59f411b2010-01-31 08:27:58 +010051 unsigned int nr_contended;
52 unsigned int nr_release;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090053
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +090054 unsigned int nr_readlock;
55 unsigned int nr_trylock;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090056 /* these times are in nano sec. */
Ingo Molnar59f411b2010-01-31 08:27:58 +010057 u64 wait_time_total;
58 u64 wait_time_min;
59 u64 wait_time_max;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +090060
61 int discard; /* flag of blacklist */
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +090062};
63
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +090064/*
65 * States of lock_seq_stat
66 *
67 * UNINITIALIZED is required for detecting first event of acquire.
68 * As the nature of lock events, there is no guarantee
69 * that the first event for the locks are acquire,
70 * it can be acquired, contended or release.
71 */
72#define SEQ_STATE_UNINITIALIZED 0 /* initial state */
73#define SEQ_STATE_RELEASED 1
74#define SEQ_STATE_ACQUIRING 2
75#define SEQ_STATE_ACQUIRED 3
76#define SEQ_STATE_READ_ACQUIRED 4
77#define SEQ_STATE_CONTENDED 5
78
79/*
80 * MAX_LOCK_DEPTH
81 * Imported from include/linux/sched.h.
82 * Should this be synchronized?
83 */
84#define MAX_LOCK_DEPTH 48
85
86/*
87 * struct lock_seq_stat:
88 * Place to put on state of one lock sequence
89 * 1) acquire -> acquired -> release
90 * 2) acquire -> contended -> acquired -> release
91 * 3) acquire (with read or try) -> release
92 * 4) Are there other patterns?
93 */
94struct lock_seq_stat {
95 struct list_head list;
96 int state;
97 u64 prev_event_time;
98 void *addr;
99
100 int read_count;
101};
102
103struct thread_stat {
104 struct rb_node rb;
105
106 u32 tid;
107 struct list_head seq_list;
108};
109
110static struct rb_root thread_stats;
111
112static struct thread_stat *thread_stat_find(u32 tid)
113{
114 struct rb_node *node;
115 struct thread_stat *st;
116
117 node = thread_stats.rb_node;
118 while (node) {
119 st = container_of(node, struct thread_stat, rb);
120 if (st->tid == tid)
121 return st;
122 else if (tid < st->tid)
123 node = node->rb_left;
124 else
125 node = node->rb_right;
126 }
127
128 return NULL;
129}
130
131static void thread_stat_insert(struct thread_stat *new)
132{
133 struct rb_node **rb = &thread_stats.rb_node;
134 struct rb_node *parent = NULL;
135 struct thread_stat *p;
136
137 while (*rb) {
138 p = container_of(*rb, struct thread_stat, rb);
139 parent = *rb;
140
141 if (new->tid < p->tid)
142 rb = &(*rb)->rb_left;
143 else if (new->tid > p->tid)
144 rb = &(*rb)->rb_right;
145 else
146 BUG_ON("inserting invalid thread_stat\n");
147 }
148
149 rb_link_node(&new->rb, parent, rb);
150 rb_insert_color(&new->rb, &thread_stats);
151}
152
153static struct thread_stat *thread_stat_findnew_after_first(u32 tid)
154{
155 struct thread_stat *st;
156
157 st = thread_stat_find(tid);
158 if (st)
159 return st;
160
161 st = zalloc(sizeof(struct thread_stat));
162 if (!st)
163 die("memory allocation failed\n");
164
165 st->tid = tid;
166 INIT_LIST_HEAD(&st->seq_list);
167
168 thread_stat_insert(st);
169
170 return st;
171}
172
173static struct thread_stat *thread_stat_findnew_first(u32 tid);
174static struct thread_stat *(*thread_stat_findnew)(u32 tid) =
175 thread_stat_findnew_first;
176
177static struct thread_stat *thread_stat_findnew_first(u32 tid)
178{
179 struct thread_stat *st;
180
181 st = zalloc(sizeof(struct thread_stat));
182 if (!st)
183 die("memory allocation failed\n");
184 st->tid = tid;
185 INIT_LIST_HEAD(&st->seq_list);
186
187 rb_link_node(&st->rb, NULL, &thread_stats.rb_node);
188 rb_insert_color(&st->rb, &thread_stats);
189
190 thread_stat_findnew = thread_stat_findnew_after_first;
191 return st;
192}
193
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900194/* build simple key function one is bigger than two */
Ingo Molnar59f411b2010-01-31 08:27:58 +0100195#define SINGLE_KEY(member) \
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900196 static int lock_stat_key_ ## member(struct lock_stat *one, \
197 struct lock_stat *two) \
198 { \
199 return one->member > two->member; \
200 }
201
202SINGLE_KEY(nr_acquired)
203SINGLE_KEY(nr_contended)
204SINGLE_KEY(wait_time_total)
205SINGLE_KEY(wait_time_min)
206SINGLE_KEY(wait_time_max)
207
208struct lock_key {
209 /*
210 * name: the value for specify by user
211 * this should be simpler than raw name of member
212 * e.g. nr_acquired -> acquired, wait_time_total -> wait_total
213 */
Ingo Molnar59f411b2010-01-31 08:27:58 +0100214 const char *name;
215 int (*key)(struct lock_stat*, struct lock_stat*);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900216};
217
Ingo Molnar59f411b2010-01-31 08:27:58 +0100218static const char *sort_key = "acquired";
219
220static int (*compare)(struct lock_stat *, struct lock_stat *);
221
222static struct rb_root result; /* place to store sorted data */
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900223
224#define DEF_KEY_LOCK(name, fn_suffix) \
225 { #name, lock_stat_key_ ## fn_suffix }
226struct lock_key keys[] = {
227 DEF_KEY_LOCK(acquired, nr_acquired),
228 DEF_KEY_LOCK(contended, nr_contended),
229 DEF_KEY_LOCK(wait_total, wait_time_total),
230 DEF_KEY_LOCK(wait_min, wait_time_min),
231 DEF_KEY_LOCK(wait_max, wait_time_max),
232
233 /* extra comparisons much complicated should be here */
234
235 { NULL, NULL }
236};
237
238static void select_key(void)
239{
240 int i;
241
242 for (i = 0; keys[i].name; i++) {
243 if (!strcmp(keys[i].name, sort_key)) {
244 compare = keys[i].key;
245 return;
246 }
247 }
248
249 die("Unknown compare key:%s\n", sort_key);
250}
251
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900252static void insert_to_result(struct lock_stat *st,
Ingo Molnar59f411b2010-01-31 08:27:58 +0100253 int (*bigger)(struct lock_stat *, struct lock_stat *))
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900254{
255 struct rb_node **rb = &result.rb_node;
256 struct rb_node *parent = NULL;
257 struct lock_stat *p;
258
259 while (*rb) {
260 p = container_of(*rb, struct lock_stat, rb);
261 parent = *rb;
262
263 if (bigger(st, p))
264 rb = &(*rb)->rb_left;
265 else
266 rb = &(*rb)->rb_right;
267 }
268
269 rb_link_node(&st->rb, parent, rb);
270 rb_insert_color(&st->rb, &result);
271}
272
273/* returns left most element of result, and erase it */
274static struct lock_stat *pop_from_result(void)
275{
276 struct rb_node *node = result.rb_node;
277
278 if (!node)
279 return NULL;
280
281 while (node->rb_left)
282 node = node->rb_left;
283
284 rb_erase(node, &result);
285 return container_of(node, struct lock_stat, rb);
286}
287
Ingo Molnar59f411b2010-01-31 08:27:58 +0100288static struct lock_stat *lock_stat_findnew(void *addr, const char *name)
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900289{
290 struct list_head *entry = lockhashentry(addr);
291 struct lock_stat *ret, *new;
292
293 list_for_each_entry(ret, entry, hash_entry) {
294 if (ret->addr == addr)
295 return ret;
296 }
297
298 new = zalloc(sizeof(struct lock_stat));
299 if (!new)
300 goto alloc_failed;
301
302 new->addr = addr;
303 new->name = zalloc(sizeof(char) * strlen(name) + 1);
304 if (!new->name)
305 goto alloc_failed;
306 strcpy(new->name, name);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900307
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900308 new->wait_time_min = ULLONG_MAX;
309
310 list_add(&new->hash_entry, entry);
311 return new;
312
313alloc_failed:
314 die("memory allocation failed\n");
315}
316
317static char const *input_name = "perf.data";
318
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900319struct raw_event_sample {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100320 u32 size;
321 char data[0];
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900322};
323
324struct trace_acquire_event {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100325 void *addr;
326 const char *name;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900327 int flag;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900328};
329
330struct trace_acquired_event {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100331 void *addr;
332 const char *name;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900333};
334
335struct trace_contended_event {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100336 void *addr;
337 const char *name;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900338};
339
340struct trace_release_event {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100341 void *addr;
342 const char *name;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900343};
344
345struct trace_lock_handler {
346 void (*acquire_event)(struct trace_acquire_event *,
347 struct event *,
348 int cpu,
349 u64 timestamp,
350 struct thread *thread);
351
352 void (*acquired_event)(struct trace_acquired_event *,
353 struct event *,
354 int cpu,
355 u64 timestamp,
356 struct thread *thread);
357
358 void (*contended_event)(struct trace_contended_event *,
359 struct event *,
360 int cpu,
361 u64 timestamp,
362 struct thread *thread);
363
364 void (*release_event)(struct trace_release_event *,
365 struct event *,
366 int cpu,
367 u64 timestamp,
368 struct thread *thread);
369};
370
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900371static struct lock_seq_stat *get_seq(struct thread_stat *ts, void *addr)
372{
373 struct lock_seq_stat *seq;
374
375 list_for_each_entry(seq, &ts->seq_list, list) {
376 if (seq->addr == addr)
377 return seq;
378 }
379
380 seq = zalloc(sizeof(struct lock_seq_stat));
381 if (!seq)
382 die("Not enough memory\n");
383 seq->state = SEQ_STATE_UNINITIALIZED;
384 seq->addr = addr;
385
386 list_add(&seq->list, &ts->seq_list);
387 return seq;
388}
389
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200390enum broken_state {
391 BROKEN_ACQUIRE,
392 BROKEN_ACQUIRED,
393 BROKEN_CONTENDED,
394 BROKEN_RELEASE,
395 BROKEN_MAX,
396};
397
398static int bad_hist[BROKEN_MAX];
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900399
Frederic Weisbecker84c7a212010-05-05 23:57:25 +0200400enum acquire_flags {
401 TRY_LOCK = 1,
402 READ_LOCK = 2,
403};
404
Ingo Molnar59f411b2010-01-31 08:27:58 +0100405static void
406report_lock_acquire_event(struct trace_acquire_event *acquire_event,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900407 struct event *__event __used,
408 int cpu __used,
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900409 u64 timestamp __used,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900410 struct thread *thread __used)
411{
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900412 struct lock_stat *ls;
413 struct thread_stat *ts;
414 struct lock_seq_stat *seq;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900415
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900416 ls = lock_stat_findnew(acquire_event->addr, acquire_event->name);
417 if (ls->discard)
418 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900419
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900420 ts = thread_stat_findnew(thread->pid);
421 seq = get_seq(ts, acquire_event->addr);
422
423 switch (seq->state) {
424 case SEQ_STATE_UNINITIALIZED:
425 case SEQ_STATE_RELEASED:
426 if (!acquire_event->flag) {
427 seq->state = SEQ_STATE_ACQUIRING;
428 } else {
Frederic Weisbecker84c7a212010-05-05 23:57:25 +0200429 if (acquire_event->flag & TRY_LOCK)
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900430 ls->nr_trylock++;
Frederic Weisbecker84c7a212010-05-05 23:57:25 +0200431 if (acquire_event->flag & READ_LOCK)
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900432 ls->nr_readlock++;
433 seq->state = SEQ_STATE_READ_ACQUIRED;
434 seq->read_count = 1;
435 ls->nr_acquired++;
436 }
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900437 break;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900438 case SEQ_STATE_READ_ACQUIRED:
Frederic Weisbecker84c7a212010-05-05 23:57:25 +0200439 if (acquire_event->flag & READ_LOCK) {
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900440 seq->read_count++;
441 ls->nr_acquired++;
442 goto end;
443 } else {
444 goto broken;
445 }
446 break;
447 case SEQ_STATE_ACQUIRED:
448 case SEQ_STATE_ACQUIRING:
449 case SEQ_STATE_CONTENDED:
450broken:
451 /* broken lock sequence, discard it */
452 ls->discard = 1;
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200453 bad_hist[BROKEN_ACQUIRE]++;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900454 list_del(&seq->list);
455 free(seq);
456 goto end;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900457 break;
458 default:
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900459 BUG_ON("Unknown state of lock sequence found!\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900460 break;
461 }
462
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900463 ls->nr_acquire++;
464 seq->prev_event_time = timestamp;
465end:
466 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900467}
468
Ingo Molnar59f411b2010-01-31 08:27:58 +0100469static void
470report_lock_acquired_event(struct trace_acquired_event *acquired_event,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900471 struct event *__event __used,
472 int cpu __used,
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900473 u64 timestamp __used,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900474 struct thread *thread __used)
475{
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900476 struct lock_stat *ls;
477 struct thread_stat *ts;
478 struct lock_seq_stat *seq;
479 u64 contended_term;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900480
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900481 ls = lock_stat_findnew(acquired_event->addr, acquired_event->name);
482 if (ls->discard)
483 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900484
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900485 ts = thread_stat_findnew(thread->pid);
486 seq = get_seq(ts, acquired_event->addr);
487
488 switch (seq->state) {
489 case SEQ_STATE_UNINITIALIZED:
490 /* orphan event, do nothing */
491 return;
492 case SEQ_STATE_ACQUIRING:
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900493 break;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900494 case SEQ_STATE_CONTENDED:
495 contended_term = timestamp - seq->prev_event_time;
496 ls->wait_time_total += contended_term;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900497 if (contended_term < ls->wait_time_min)
498 ls->wait_time_min = contended_term;
Frederic Weisbecker90c0e5f2010-05-07 02:33:42 +0200499 if (ls->wait_time_max < contended_term)
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900500 ls->wait_time_max = contended_term;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900501 break;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900502 case SEQ_STATE_RELEASED:
503 case SEQ_STATE_ACQUIRED:
504 case SEQ_STATE_READ_ACQUIRED:
505 /* broken lock sequence, discard it */
506 ls->discard = 1;
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200507 bad_hist[BROKEN_ACQUIRED]++;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900508 list_del(&seq->list);
509 free(seq);
510 goto end;
511 break;
512
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900513 default:
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900514 BUG_ON("Unknown state of lock sequence found!\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900515 break;
516 }
517
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900518 seq->state = SEQ_STATE_ACQUIRED;
519 ls->nr_acquired++;
520 seq->prev_event_time = timestamp;
521end:
522 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900523}
524
Ingo Molnar59f411b2010-01-31 08:27:58 +0100525static void
526report_lock_contended_event(struct trace_contended_event *contended_event,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900527 struct event *__event __used,
528 int cpu __used,
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900529 u64 timestamp __used,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900530 struct thread *thread __used)
531{
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900532 struct lock_stat *ls;
533 struct thread_stat *ts;
534 struct lock_seq_stat *seq;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900535
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900536 ls = lock_stat_findnew(contended_event->addr, contended_event->name);
537 if (ls->discard)
538 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900539
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900540 ts = thread_stat_findnew(thread->pid);
541 seq = get_seq(ts, contended_event->addr);
542
543 switch (seq->state) {
544 case SEQ_STATE_UNINITIALIZED:
545 /* orphan event, do nothing */
546 return;
547 case SEQ_STATE_ACQUIRING:
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900548 break;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900549 case SEQ_STATE_RELEASED:
550 case SEQ_STATE_ACQUIRED:
551 case SEQ_STATE_READ_ACQUIRED:
552 case SEQ_STATE_CONTENDED:
553 /* broken lock sequence, discard it */
554 ls->discard = 1;
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200555 bad_hist[BROKEN_CONTENDED]++;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900556 list_del(&seq->list);
557 free(seq);
558 goto end;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900559 break;
560 default:
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900561 BUG_ON("Unknown state of lock sequence found!\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900562 break;
563 }
564
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900565 seq->state = SEQ_STATE_CONTENDED;
566 ls->nr_contended++;
567 seq->prev_event_time = timestamp;
568end:
569 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900570}
571
Ingo Molnar59f411b2010-01-31 08:27:58 +0100572static void
573report_lock_release_event(struct trace_release_event *release_event,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900574 struct event *__event __used,
575 int cpu __used,
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900576 u64 timestamp __used,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900577 struct thread *thread __used)
578{
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900579 struct lock_stat *ls;
580 struct thread_stat *ts;
581 struct lock_seq_stat *seq;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900582
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900583 ls = lock_stat_findnew(release_event->addr, release_event->name);
584 if (ls->discard)
585 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900586
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900587 ts = thread_stat_findnew(thread->pid);
588 seq = get_seq(ts, release_event->addr);
589
590 switch (seq->state) {
591 case SEQ_STATE_UNINITIALIZED:
592 goto end;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900593 break;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900594 case SEQ_STATE_ACQUIRED:
595 break;
596 case SEQ_STATE_READ_ACQUIRED:
597 seq->read_count--;
598 BUG_ON(seq->read_count < 0);
599 if (!seq->read_count) {
600 ls->nr_release++;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900601 goto end;
602 }
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900603 break;
604 case SEQ_STATE_ACQUIRING:
605 case SEQ_STATE_CONTENDED:
606 case SEQ_STATE_RELEASED:
607 /* broken lock sequence, discard it */
608 ls->discard = 1;
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200609 bad_hist[BROKEN_RELEASE]++;
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900610 goto free_seq;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900611 break;
612 default:
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900613 BUG_ON("Unknown state of lock sequence found!\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900614 break;
615 }
616
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900617 ls->nr_release++;
618free_seq:
619 list_del(&seq->list);
620 free(seq);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900621end:
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900622 return;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900623}
624
625/* lock oriented handlers */
626/* TODO: handlers for CPU oriented, thread oriented */
Ingo Molnar59f411b2010-01-31 08:27:58 +0100627static struct trace_lock_handler report_lock_ops = {
628 .acquire_event = report_lock_acquire_event,
629 .acquired_event = report_lock_acquired_event,
630 .contended_event = report_lock_contended_event,
631 .release_event = report_lock_release_event,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900632};
633
634static struct trace_lock_handler *trace_handler;
635
636static void
637process_lock_acquire_event(void *data,
638 struct event *event __used,
639 int cpu __used,
640 u64 timestamp __used,
641 struct thread *thread __used)
642{
643 struct trace_acquire_event acquire_event;
644 u64 tmp; /* this is required for casting... */
645
646 tmp = raw_field_value(event, "lockdep_addr", data);
647 memcpy(&acquire_event.addr, &tmp, sizeof(void *));
648 acquire_event.name = (char *)raw_field_ptr(event, "name", data);
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900649 acquire_event.flag = (int)raw_field_value(event, "flag", data);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900650
Ingo Molnar59f411b2010-01-31 08:27:58 +0100651 if (trace_handler->acquire_event)
652 trace_handler->acquire_event(&acquire_event, event, cpu, timestamp, thread);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900653}
654
655static void
656process_lock_acquired_event(void *data,
657 struct event *event __used,
658 int cpu __used,
659 u64 timestamp __used,
660 struct thread *thread __used)
661{
662 struct trace_acquired_event acquired_event;
663 u64 tmp; /* this is required for casting... */
664
665 tmp = raw_field_value(event, "lockdep_addr", data);
666 memcpy(&acquired_event.addr, &tmp, sizeof(void *));
667 acquired_event.name = (char *)raw_field_ptr(event, "name", data);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900668
Ingo Molnar59f411b2010-01-31 08:27:58 +0100669 if (trace_handler->acquire_event)
670 trace_handler->acquired_event(&acquired_event, event, cpu, timestamp, thread);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900671}
672
673static void
674process_lock_contended_event(void *data,
675 struct event *event __used,
676 int cpu __used,
677 u64 timestamp __used,
678 struct thread *thread __used)
679{
680 struct trace_contended_event contended_event;
681 u64 tmp; /* this is required for casting... */
682
683 tmp = raw_field_value(event, "lockdep_addr", data);
684 memcpy(&contended_event.addr, &tmp, sizeof(void *));
685 contended_event.name = (char *)raw_field_ptr(event, "name", data);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900686
Ingo Molnar59f411b2010-01-31 08:27:58 +0100687 if (trace_handler->acquire_event)
688 trace_handler->contended_event(&contended_event, event, cpu, timestamp, thread);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900689}
690
691static void
692process_lock_release_event(void *data,
693 struct event *event __used,
694 int cpu __used,
695 u64 timestamp __used,
696 struct thread *thread __used)
697{
698 struct trace_release_event release_event;
699 u64 tmp; /* this is required for casting... */
700
701 tmp = raw_field_value(event, "lockdep_addr", data);
702 memcpy(&release_event.addr, &tmp, sizeof(void *));
703 release_event.name = (char *)raw_field_ptr(event, "name", data);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900704
Ingo Molnar59f411b2010-01-31 08:27:58 +0100705 if (trace_handler->acquire_event)
706 trace_handler->release_event(&release_event, event, cpu, timestamp, thread);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900707}
708
709static void
Frederic Weisbeckerc61e52e2010-04-24 00:04:12 +0200710process_raw_event(void *data, int cpu, u64 timestamp, struct thread *thread)
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900711{
712 struct event *event;
713 int type;
714
715 type = trace_parse_common_type(data);
716 event = trace_find_event(type);
717
718 if (!strcmp(event->name, "lock_acquire"))
719 process_lock_acquire_event(data, event, cpu, timestamp, thread);
720 if (!strcmp(event->name, "lock_acquired"))
721 process_lock_acquired_event(data, event, cpu, timestamp, thread);
722 if (!strcmp(event->name, "lock_contended"))
723 process_lock_contended_event(data, event, cpu, timestamp, thread);
724 if (!strcmp(event->name, "lock_release"))
725 process_lock_release_event(data, event, cpu, timestamp, thread);
726}
727
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200728static void print_bad_events(int bad, int total)
729{
730 /* Output for debug, this have to be removed */
731 int i;
732 const char *name[4] =
733 { "acquire", "acquired", "contended", "release" };
734
735 pr_info("\n=== output for debug===\n\n");
Frederic Weisbecker5efe08c2010-05-06 04:55:22 +0200736 pr_info("bad: %d, total: %d\n", bad, total);
737 pr_info("bad rate: %f %%\n", (double)bad / (double)total * 100);
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200738 pr_info("histogram of events caused bad sequence\n");
739 for (i = 0; i < BROKEN_MAX; i++)
740 pr_info(" %10s: %d\n", name[i], bad_hist[i]);
741}
742
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900743/* TODO: various way to print, coloring, nano or milli sec */
744static void print_result(void)
745{
746 struct lock_stat *st;
747 char cut_name[20];
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900748 int bad, total;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900749
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900750 pr_info("%20s ", "Name");
751 pr_info("%10s ", "acquired");
752 pr_info("%10s ", "contended");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900753
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900754 pr_info("%15s ", "total wait (ns)");
755 pr_info("%15s ", "max wait (ns)");
756 pr_info("%15s ", "min wait (ns)");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900757
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900758 pr_info("\n\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900759
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900760 bad = total = 0;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900761 while ((st = pop_from_result())) {
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900762 total++;
763 if (st->discard) {
764 bad++;
765 continue;
766 }
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900767 bzero(cut_name, 20);
768
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900769 if (strlen(st->name) < 16) {
770 /* output raw name */
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900771 pr_info("%20s ", st->name);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900772 } else {
773 strncpy(cut_name, st->name, 16);
774 cut_name[16] = '.';
775 cut_name[17] = '.';
776 cut_name[18] = '.';
777 cut_name[19] = '\0';
778 /* cut off name for saving output style */
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900779 pr_info("%20s ", cut_name);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900780 }
781
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900782 pr_info("%10u ", st->nr_acquired);
783 pr_info("%10u ", st->nr_contended);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900784
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900785 pr_info("%15llu ", st->wait_time_total);
786 pr_info("%15llu ", st->wait_time_max);
787 pr_info("%15llu ", st->wait_time_min == ULLONG_MAX ?
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900788 0 : st->wait_time_min);
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900789 pr_info("\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900790 }
Hitoshi Mitakee4cef1f2010-04-21 21:23:54 +0900791
Frederic Weisbecker10350ec2010-05-05 23:47:28 +0200792 print_bad_events(bad, total);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900793}
794
Arnaldo Carvalho de Melo80354582010-05-17 15:51:10 -0300795static bool info_threads, info_map;
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900796
797static void dump_threads(void)
798{
799 struct thread_stat *st;
800 struct rb_node *node;
801 struct thread *t;
802
803 pr_info("%10s: comm\n", "Thread ID");
804
805 node = rb_first(&thread_stats);
806 while (node) {
807 st = container_of(node, struct thread_stat, rb);
808 t = perf_session__findnew(session, st->tid);
809 pr_info("%10d: %s\n", st->tid, t->comm);
810 node = rb_next(node);
811 };
812}
813
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900814static void dump_map(void)
815{
816 unsigned int i;
817 struct lock_stat *st;
818
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900819 pr_info("Address of instance: name of class\n");
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900820 for (i = 0; i < LOCKHASH_SIZE; i++) {
821 list_for_each_entry(st, &lockhash_table[i], hash_entry) {
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900822 pr_info(" %p: %s\n", st->addr, st->name);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900823 }
824 }
825}
826
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900827static void dump_info(void)
828{
829 if (info_threads)
830 dump_threads();
831 else if (info_map)
832 dump_map();
833 else
834 die("Unknown type of information\n");
835}
836
Frederic Weisbeckerc61e52e2010-04-24 00:04:12 +0200837static int process_sample_event(event_t *self, struct perf_session *s)
838{
839 struct sample_data data;
840 struct thread *thread;
841
842 bzero(&data, sizeof(data));
843 event__parse_sample(self, s->sample_type, &data);
844
845 thread = perf_session__findnew(s, data.tid);
846 if (thread == NULL) {
847 pr_debug("problem processing %d event, skipping it.\n",
848 self->header.type);
849 return -1;
850 }
851
852 process_raw_event(data.raw_data, data.cpu, data.time, thread);
853
854 return 0;
855}
856
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900857static struct perf_event_ops eops = {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100858 .sample = process_sample_event,
859 .comm = event__process_comm,
Frederic Weisbeckerc61e52e2010-04-24 00:04:12 +0200860 .ordered_samples = true,
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900861};
862
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900863static int read_events(void)
864{
Tom Zanussi454c4072010-05-01 01:41:20 -0500865 session = perf_session__new(input_name, O_RDONLY, 0, false);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900866 if (!session)
867 die("Initializing perf session failed\n");
868
869 return perf_session__process_events(session, &eops);
870}
871
872static void sort_result(void)
873{
874 unsigned int i;
875 struct lock_stat *st;
876
877 for (i = 0; i < LOCKHASH_SIZE; i++) {
878 list_for_each_entry(st, &lockhash_table[i], hash_entry) {
879 insert_to_result(st, compare);
880 }
881 }
882}
883
Ingo Molnar59f411b2010-01-31 08:27:58 +0100884static void __cmd_report(void)
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900885{
886 setup_pager();
887 select_key();
888 read_events();
889 sort_result();
890 print_result();
891}
892
Ingo Molnar59f411b2010-01-31 08:27:58 +0100893static const char * const report_usage[] = {
894 "perf lock report [<options>]",
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900895 NULL
896};
897
Ingo Molnar59f411b2010-01-31 08:27:58 +0100898static const struct option report_options[] = {
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900899 OPT_STRING('k', "key", &sort_key, "acquired",
900 "key for sorting"),
901 /* TODO: type */
902 OPT_END()
903};
904
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900905static const char * const info_usage[] = {
906 "perf lock info [<options>]",
907 NULL
908};
909
910static const struct option info_options[] = {
911 OPT_BOOLEAN('t', "threads", &info_threads,
912 "dump thread list in perf.data"),
913 OPT_BOOLEAN('m', "map", &info_map,
914 "map of lock instances (name:address table)"),
915 OPT_END()
916};
917
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900918static const char * const lock_usage[] = {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100919 "perf lock [<options>] {record|trace|report}",
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900920 NULL
921};
922
923static const struct option lock_options[] = {
Ingo Molnar59f411b2010-01-31 08:27:58 +0100924 OPT_STRING('i', "input", &input_name, "file", "input file name"),
Ian Munsiec0555642010-04-13 18:37:33 +1000925 OPT_INCR('v', "verbose", &verbose, "be more verbose (show symbol address, etc)"),
Ingo Molnar59f411b2010-01-31 08:27:58 +0100926 OPT_BOOLEAN('D', "dump-raw-trace", &dump_trace, "dump raw trace in ASCII"),
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900927 OPT_END()
928};
929
930static const char *record_args[] = {
931 "record",
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900932 "-R",
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900933 "-f",
934 "-m", "1024",
935 "-c", "1",
936 "-e", "lock:lock_acquire:r",
937 "-e", "lock:lock_acquired:r",
938 "-e", "lock:lock_contended:r",
939 "-e", "lock:lock_release:r",
940};
941
942static int __cmd_record(int argc, const char **argv)
943{
944 unsigned int rec_argc, i, j;
945 const char **rec_argv;
946
947 rec_argc = ARRAY_SIZE(record_args) + argc - 1;
948 rec_argv = calloc(rec_argc + 1, sizeof(char *));
949
950 for (i = 0; i < ARRAY_SIZE(record_args); i++)
951 rec_argv[i] = strdup(record_args[i]);
952
953 for (j = 1; j < (unsigned int)argc; j++, i++)
954 rec_argv[i] = argv[j];
955
956 BUG_ON(i != rec_argc);
957
958 return cmd_record(i, rec_argv, NULL);
959}
960
961int cmd_lock(int argc, const char **argv, const char *prefix __used)
962{
963 unsigned int i;
964
965 symbol__init();
966 for (i = 0; i < LOCKHASH_SIZE; i++)
967 INIT_LIST_HEAD(lockhash_table + i);
968
969 argc = parse_options(argc, argv, lock_options, lock_usage,
970 PARSE_OPT_STOP_AT_NON_OPTION);
971 if (!argc)
972 usage_with_options(lock_usage, lock_options);
973
974 if (!strncmp(argv[0], "rec", 3)) {
975 return __cmd_record(argc, argv);
Ingo Molnar59f411b2010-01-31 08:27:58 +0100976 } else if (!strncmp(argv[0], "report", 6)) {
977 trace_handler = &report_lock_ops;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900978 if (argc) {
979 argc = parse_options(argc, argv,
Ingo Molnar59f411b2010-01-31 08:27:58 +0100980 report_options, report_usage, 0);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900981 if (argc)
Ingo Molnar59f411b2010-01-31 08:27:58 +0100982 usage_with_options(report_usage, report_options);
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900983 }
Ingo Molnar59f411b2010-01-31 08:27:58 +0100984 __cmd_report();
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900985 } else if (!strcmp(argv[0], "trace")) {
986 /* Aliased to 'perf trace' */
987 return cmd_trace(argc, argv, prefix);
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900988 } else if (!strcmp(argv[0], "info")) {
989 if (argc) {
990 argc = parse_options(argc, argv,
991 info_options, info_usage, 0);
992 if (argc)
993 usage_with_options(info_usage, info_options);
994 }
Ingo Molnar59f411b2010-01-31 08:27:58 +0100995 /* recycling report_lock_ops */
996 trace_handler = &report_lock_ops;
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +0900997 setup_pager();
998 read_events();
Hitoshi Mitake26242d82010-05-03 14:12:00 +0900999 dump_info();
Hitoshi Mitake9b5e3502010-01-30 20:43:33 +09001000 } else {
1001 usage_with_options(lock_usage, lock_options);
1002 }
1003
1004 return 0;
1005}