perf evlist: Don't die if sample_{id_all|type} is invalid
[linux-2.6.git] / tools / perf / builtin-timechart.c
1 /*
2  * builtin-timechart.c - make an svg timechart of system activity
3  *
4  * (C) Copyright 2009 Intel Corporation
5  *
6  * Authors:
7  *     Arjan van de Ven <arjan@linux.intel.com>
8  *
9  * This program is free software; you can redistribute it and/or
10  * modify it under the terms of the GNU General Public License
11  * as published by the Free Software Foundation; version 2
12  * of the License.
13  */
14
15 #include "builtin.h"
16
17 #include "util/util.h"
18
19 #include "util/color.h"
20 #include <linux/list.h>
21 #include "util/cache.h"
22 #include <linux/rbtree.h>
23 #include "util/symbol.h"
24 #include "util/callchain.h"
25 #include "util/strlist.h"
26
27 #include "perf.h"
28 #include "util/header.h"
29 #include "util/parse-options.h"
30 #include "util/parse-events.h"
31 #include "util/event.h"
32 #include "util/session.h"
33 #include "util/svghelper.h"
34
35 #define SUPPORT_OLD_POWER_EVENTS 1
36 #define PWR_EVENT_EXIT -1
37
38
39 static char             const *input_name = "perf.data";
40 static char             const *output_name = "output.svg";
41
42 static unsigned int     numcpus;
43 static u64              min_freq;       /* Lowest CPU frequency seen */
44 static u64              max_freq;       /* Highest CPU frequency seen */
45 static u64              turbo_frequency;
46
47 static u64              first_time, last_time;
48
49 static bool             power_only;
50
51
52 struct per_pid;
53 struct per_pidcomm;
54
55 struct cpu_sample;
56 struct power_event;
57 struct wake_event;
58
59 struct sample_wrapper;
60
61 /*
62  * Datastructure layout:
63  * We keep an list of "pid"s, matching the kernels notion of a task struct.
64  * Each "pid" entry, has a list of "comm"s.
65  *      this is because we want to track different programs different, while
66  *      exec will reuse the original pid (by design).
67  * Each comm has a list of samples that will be used to draw
68  * final graph.
69  */
70
71 struct per_pid {
72         struct per_pid *next;
73
74         int             pid;
75         int             ppid;
76
77         u64             start_time;
78         u64             end_time;
79         u64             total_time;
80         int             display;
81
82         struct per_pidcomm *all;
83         struct per_pidcomm *current;
84 };
85
86
87 struct per_pidcomm {
88         struct per_pidcomm *next;
89
90         u64             start_time;
91         u64             end_time;
92         u64             total_time;
93
94         int             Y;
95         int             display;
96
97         long            state;
98         u64             state_since;
99
100         char            *comm;
101
102         struct cpu_sample *samples;
103 };
104
105 struct sample_wrapper {
106         struct sample_wrapper *next;
107
108         u64             timestamp;
109         unsigned char   data[0];
110 };
111
112 #define TYPE_NONE       0
113 #define TYPE_RUNNING    1
114 #define TYPE_WAITING    2
115 #define TYPE_BLOCKED    3
116
117 struct cpu_sample {
118         struct cpu_sample *next;
119
120         u64 start_time;
121         u64 end_time;
122         int type;
123         int cpu;
124 };
125
126 static struct per_pid *all_data;
127
128 #define CSTATE 1
129 #define PSTATE 2
130
131 struct power_event {
132         struct power_event *next;
133         int type;
134         int state;
135         u64 start_time;
136         u64 end_time;
137         int cpu;
138 };
139
140 struct wake_event {
141         struct wake_event *next;
142         int waker;
143         int wakee;
144         u64 time;
145 };
146
147 static struct power_event    *power_events;
148 static struct wake_event     *wake_events;
149
150 struct process_filter;
151 struct process_filter {
152         char                    *name;
153         int                     pid;
154         struct process_filter   *next;
155 };
156
157 static struct process_filter *process_filter;
158
159
160 static struct per_pid *find_create_pid(int pid)
161 {
162         struct per_pid *cursor = all_data;
163
164         while (cursor) {
165                 if (cursor->pid == pid)
166                         return cursor;
167                 cursor = cursor->next;
168         }
169         cursor = malloc(sizeof(struct per_pid));
170         assert(cursor != NULL);
171         memset(cursor, 0, sizeof(struct per_pid));
172         cursor->pid = pid;
173         cursor->next = all_data;
174         all_data = cursor;
175         return cursor;
176 }
177
178 static void pid_set_comm(int pid, char *comm)
179 {
180         struct per_pid *p;
181         struct per_pidcomm *c;
182         p = find_create_pid(pid);
183         c = p->all;
184         while (c) {
185                 if (c->comm && strcmp(c->comm, comm) == 0) {
186                         p->current = c;
187                         return;
188                 }
189                 if (!c->comm) {
190                         c->comm = strdup(comm);
191                         p->current = c;
192                         return;
193                 }
194                 c = c->next;
195         }
196         c = malloc(sizeof(struct per_pidcomm));
197         assert(c != NULL);
198         memset(c, 0, sizeof(struct per_pidcomm));
199         c->comm = strdup(comm);
200         p->current = c;
201         c->next = p->all;
202         p->all = c;
203 }
204
205 static void pid_fork(int pid, int ppid, u64 timestamp)
206 {
207         struct per_pid *p, *pp;
208         p = find_create_pid(pid);
209         pp = find_create_pid(ppid);
210         p->ppid = ppid;
211         if (pp->current && pp->current->comm && !p->current)
212                 pid_set_comm(pid, pp->current->comm);
213
214         p->start_time = timestamp;
215         if (p->current) {
216                 p->current->start_time = timestamp;
217                 p->current->state_since = timestamp;
218         }
219 }
220
221 static void pid_exit(int pid, u64 timestamp)
222 {
223         struct per_pid *p;
224         p = find_create_pid(pid);
225         p->end_time = timestamp;
226         if (p->current)
227                 p->current->end_time = timestamp;
228 }
229
230 static void
231 pid_put_sample(int pid, int type, unsigned int cpu, u64 start, u64 end)
232 {
233         struct per_pid *p;
234         struct per_pidcomm *c;
235         struct cpu_sample *sample;
236
237         p = find_create_pid(pid);
238         c = p->current;
239         if (!c) {
240                 c = malloc(sizeof(struct per_pidcomm));
241                 assert(c != NULL);
242                 memset(c, 0, sizeof(struct per_pidcomm));
243                 p->current = c;
244                 c->next = p->all;
245                 p->all = c;
246         }
247
248         sample = malloc(sizeof(struct cpu_sample));
249         assert(sample != NULL);
250         memset(sample, 0, sizeof(struct cpu_sample));
251         sample->start_time = start;
252         sample->end_time = end;
253         sample->type = type;
254         sample->next = c->samples;
255         sample->cpu = cpu;
256         c->samples = sample;
257
258         if (sample->type == TYPE_RUNNING && end > start && start > 0) {
259                 c->total_time += (end-start);
260                 p->total_time += (end-start);
261         }
262
263         if (c->start_time == 0 || c->start_time > start)
264                 c->start_time = start;
265         if (p->start_time == 0 || p->start_time > start)
266                 p->start_time = start;
267 }
268
269 #define MAX_CPUS 4096
270
271 static u64 cpus_cstate_start_times[MAX_CPUS];
272 static int cpus_cstate_state[MAX_CPUS];
273 static u64 cpus_pstate_start_times[MAX_CPUS];
274 static u64 cpus_pstate_state[MAX_CPUS];
275
276 static int process_comm_event(union perf_event *event,
277                               struct perf_sample *sample __used,
278                               struct perf_session *session __used)
279 {
280         pid_set_comm(event->comm.tid, event->comm.comm);
281         return 0;
282 }
283
284 static int process_fork_event(union perf_event *event,
285                               struct perf_sample *sample __used,
286                               struct perf_session *session __used)
287 {
288         pid_fork(event->fork.pid, event->fork.ppid, event->fork.time);
289         return 0;
290 }
291
292 static int process_exit_event(union perf_event *event,
293                               struct perf_sample *sample __used,
294                               struct perf_session *session __used)
295 {
296         pid_exit(event->fork.pid, event->fork.time);
297         return 0;
298 }
299
300 struct trace_entry {
301         unsigned short          type;
302         unsigned char           flags;
303         unsigned char           preempt_count;
304         int                     pid;
305         int                     lock_depth;
306 };
307
308 #ifdef SUPPORT_OLD_POWER_EVENTS
309 static int use_old_power_events;
310 struct power_entry_old {
311         struct trace_entry te;
312         u64     type;
313         u64     value;
314         u64     cpu_id;
315 };
316 #endif
317
318 struct power_processor_entry {
319         struct trace_entry te;
320         u32     state;
321         u32     cpu_id;
322 };
323
324 #define TASK_COMM_LEN 16
325 struct wakeup_entry {
326         struct trace_entry te;
327         char comm[TASK_COMM_LEN];
328         int   pid;
329         int   prio;
330         int   success;
331 };
332
333 /*
334  * trace_flag_type is an enumeration that holds different
335  * states when a trace occurs. These are:
336  *  IRQS_OFF            - interrupts were disabled
337  *  IRQS_NOSUPPORT      - arch does not support irqs_disabled_flags
338  *  NEED_RESCED         - reschedule is requested
339  *  HARDIRQ             - inside an interrupt handler
340  *  SOFTIRQ             - inside a softirq handler
341  */
342 enum trace_flag_type {
343         TRACE_FLAG_IRQS_OFF             = 0x01,
344         TRACE_FLAG_IRQS_NOSUPPORT       = 0x02,
345         TRACE_FLAG_NEED_RESCHED         = 0x04,
346         TRACE_FLAG_HARDIRQ              = 0x08,
347         TRACE_FLAG_SOFTIRQ              = 0x10,
348 };
349
350
351
352 struct sched_switch {
353         struct trace_entry te;
354         char prev_comm[TASK_COMM_LEN];
355         int  prev_pid;
356         int  prev_prio;
357         long prev_state; /* Arjan weeps. */
358         char next_comm[TASK_COMM_LEN];
359         int  next_pid;
360         int  next_prio;
361 };
362
363 static void c_state_start(int cpu, u64 timestamp, int state)
364 {
365         cpus_cstate_start_times[cpu] = timestamp;
366         cpus_cstate_state[cpu] = state;
367 }
368
369 static void c_state_end(int cpu, u64 timestamp)
370 {
371         struct power_event *pwr;
372         pwr = malloc(sizeof(struct power_event));
373         if (!pwr)
374                 return;
375         memset(pwr, 0, sizeof(struct power_event));
376
377         pwr->state = cpus_cstate_state[cpu];
378         pwr->start_time = cpus_cstate_start_times[cpu];
379         pwr->end_time = timestamp;
380         pwr->cpu = cpu;
381         pwr->type = CSTATE;
382         pwr->next = power_events;
383
384         power_events = pwr;
385 }
386
387 static void p_state_change(int cpu, u64 timestamp, u64 new_freq)
388 {
389         struct power_event *pwr;
390         pwr = malloc(sizeof(struct power_event));
391
392         if (new_freq > 8000000) /* detect invalid data */
393                 return;
394
395         if (!pwr)
396                 return;
397         memset(pwr, 0, sizeof(struct power_event));
398
399         pwr->state = cpus_pstate_state[cpu];
400         pwr->start_time = cpus_pstate_start_times[cpu];
401         pwr->end_time = timestamp;
402         pwr->cpu = cpu;
403         pwr->type = PSTATE;
404         pwr->next = power_events;
405
406         if (!pwr->start_time)
407                 pwr->start_time = first_time;
408
409         power_events = pwr;
410
411         cpus_pstate_state[cpu] = new_freq;
412         cpus_pstate_start_times[cpu] = timestamp;
413
414         if ((u64)new_freq > max_freq)
415                 max_freq = new_freq;
416
417         if (new_freq < min_freq || min_freq == 0)
418                 min_freq = new_freq;
419
420         if (new_freq == max_freq - 1000)
421                         turbo_frequency = max_freq;
422 }
423
424 static void
425 sched_wakeup(int cpu, u64 timestamp, int pid, struct trace_entry *te)
426 {
427         struct wake_event *we;
428         struct per_pid *p;
429         struct wakeup_entry *wake = (void *)te;
430
431         we = malloc(sizeof(struct wake_event));
432         if (!we)
433                 return;
434
435         memset(we, 0, sizeof(struct wake_event));
436         we->time = timestamp;
437         we->waker = pid;
438
439         if ((te->flags & TRACE_FLAG_HARDIRQ) || (te->flags & TRACE_FLAG_SOFTIRQ))
440                 we->waker = -1;
441
442         we->wakee = wake->pid;
443         we->next = wake_events;
444         wake_events = we;
445         p = find_create_pid(we->wakee);
446
447         if (p && p->current && p->current->state == TYPE_NONE) {
448                 p->current->state_since = timestamp;
449                 p->current->state = TYPE_WAITING;
450         }
451         if (p && p->current && p->current->state == TYPE_BLOCKED) {
452                 pid_put_sample(p->pid, p->current->state, cpu, p->current->state_since, timestamp);
453                 p->current->state_since = timestamp;
454                 p->current->state = TYPE_WAITING;
455         }
456 }
457
458 static void sched_switch(int cpu, u64 timestamp, struct trace_entry *te)
459 {
460         struct per_pid *p = NULL, *prev_p;
461         struct sched_switch *sw = (void *)te;
462
463
464         prev_p = find_create_pid(sw->prev_pid);
465
466         p = find_create_pid(sw->next_pid);
467
468         if (prev_p->current && prev_p->current->state != TYPE_NONE)
469                 pid_put_sample(sw->prev_pid, TYPE_RUNNING, cpu, prev_p->current->state_since, timestamp);
470         if (p && p->current) {
471                 if (p->current->state != TYPE_NONE)
472                         pid_put_sample(sw->next_pid, p->current->state, cpu, p->current->state_since, timestamp);
473
474                 p->current->state_since = timestamp;
475                 p->current->state = TYPE_RUNNING;
476         }
477
478         if (prev_p->current) {
479                 prev_p->current->state = TYPE_NONE;
480                 prev_p->current->state_since = timestamp;
481                 if (sw->prev_state & 2)
482                         prev_p->current->state = TYPE_BLOCKED;
483                 if (sw->prev_state == 0)
484                         prev_p->current->state = TYPE_WAITING;
485         }
486 }
487
488
489 static int process_sample_event(union perf_event *event __used,
490                                 struct perf_sample *sample,
491                                 struct perf_evsel *evsel __used,
492                                 struct perf_session *session)
493 {
494         struct trace_entry *te;
495
496         if (session->sample_type & PERF_SAMPLE_TIME) {
497                 if (!first_time || first_time > sample->time)
498                         first_time = sample->time;
499                 if (last_time < sample->time)
500                         last_time = sample->time;
501         }
502
503         te = (void *)sample->raw_data;
504         if (session->sample_type & PERF_SAMPLE_RAW && sample->raw_size > 0) {
505                 char *event_str;
506 #ifdef SUPPORT_OLD_POWER_EVENTS
507                 struct power_entry_old *peo;
508                 peo = (void *)te;
509 #endif
510                 /*
511                  * FIXME: use evsel, its already mapped from id to perf_evsel,
512                  * remove perf_header__find_event infrastructure bits.
513                  * Mapping all these "power:cpu_idle" strings to the tracepoint
514                  * ID and then just comparing against evsel->attr.config.
515                  *
516                  * e.g.:
517                  *
518                  * if (evsel->attr.config == power_cpu_idle_id)
519                  */
520                 event_str = perf_header__find_event(te->type);
521
522                 if (!event_str)
523                         return 0;
524
525                 if (sample->cpu > numcpus)
526                         numcpus = sample->cpu;
527
528                 if (strcmp(event_str, "power:cpu_idle") == 0) {
529                         struct power_processor_entry *ppe = (void *)te;
530                         if (ppe->state == (u32)PWR_EVENT_EXIT)
531                                 c_state_end(ppe->cpu_id, sample->time);
532                         else
533                                 c_state_start(ppe->cpu_id, sample->time,
534                                               ppe->state);
535                 }
536                 else if (strcmp(event_str, "power:cpu_frequency") == 0) {
537                         struct power_processor_entry *ppe = (void *)te;
538                         p_state_change(ppe->cpu_id, sample->time, ppe->state);
539                 }
540
541                 else if (strcmp(event_str, "sched:sched_wakeup") == 0)
542                         sched_wakeup(sample->cpu, sample->time, sample->pid, te);
543
544                 else if (strcmp(event_str, "sched:sched_switch") == 0)
545                         sched_switch(sample->cpu, sample->time, te);
546
547 #ifdef SUPPORT_OLD_POWER_EVENTS
548                 if (use_old_power_events) {
549                         if (strcmp(event_str, "power:power_start") == 0)
550                                 c_state_start(peo->cpu_id, sample->time,
551                                               peo->value);
552
553                         else if (strcmp(event_str, "power:power_end") == 0)
554                                 c_state_end(sample->cpu, sample->time);
555
556                         else if (strcmp(event_str,
557                                         "power:power_frequency") == 0)
558                                 p_state_change(peo->cpu_id, sample->time,
559                                                peo->value);
560                 }
561 #endif
562         }
563         return 0;
564 }
565
566 /*
567  * After the last sample we need to wrap up the current C/P state
568  * and close out each CPU for these.
569  */
570 static void end_sample_processing(void)
571 {
572         u64 cpu;
573         struct power_event *pwr;
574
575         for (cpu = 0; cpu <= numcpus; cpu++) {
576                 pwr = malloc(sizeof(struct power_event));
577                 if (!pwr)
578                         return;
579                 memset(pwr, 0, sizeof(struct power_event));
580
581                 /* C state */
582 #if 0
583                 pwr->state = cpus_cstate_state[cpu];
584                 pwr->start_time = cpus_cstate_start_times[cpu];
585                 pwr->end_time = last_time;
586                 pwr->cpu = cpu;
587                 pwr->type = CSTATE;
588                 pwr->next = power_events;
589
590                 power_events = pwr;
591 #endif
592                 /* P state */
593
594                 pwr = malloc(sizeof(struct power_event));
595                 if (!pwr)
596                         return;
597                 memset(pwr, 0, sizeof(struct power_event));
598
599                 pwr->state = cpus_pstate_state[cpu];
600                 pwr->start_time = cpus_pstate_start_times[cpu];
601                 pwr->end_time = last_time;
602                 pwr->cpu = cpu;
603                 pwr->type = PSTATE;
604                 pwr->next = power_events;
605
606                 if (!pwr->start_time)
607                         pwr->start_time = first_time;
608                 if (!pwr->state)
609                         pwr->state = min_freq;
610                 power_events = pwr;
611         }
612 }
613
614 /*
615  * Sort the pid datastructure
616  */
617 static void sort_pids(void)
618 {
619         struct per_pid *new_list, *p, *cursor, *prev;
620         /* sort by ppid first, then by pid, lowest to highest */
621
622         new_list = NULL;
623
624         while (all_data) {
625                 p = all_data;
626                 all_data = p->next;
627                 p->next = NULL;
628
629                 if (new_list == NULL) {
630                         new_list = p;
631                         p->next = NULL;
632                         continue;
633                 }
634                 prev = NULL;
635                 cursor = new_list;
636                 while (cursor) {
637                         if (cursor->ppid > p->ppid ||
638                                 (cursor->ppid == p->ppid && cursor->pid > p->pid)) {
639                                 /* must insert before */
640                                 if (prev) {
641                                         p->next = prev->next;
642                                         prev->next = p;
643                                         cursor = NULL;
644                                         continue;
645                                 } else {
646                                         p->next = new_list;
647                                         new_list = p;
648                                         cursor = NULL;
649                                         continue;
650                                 }
651                         }
652
653                         prev = cursor;
654                         cursor = cursor->next;
655                         if (!cursor)
656                                 prev->next = p;
657                 }
658         }
659         all_data = new_list;
660 }
661
662
663 static void draw_c_p_states(void)
664 {
665         struct power_event *pwr;
666         pwr = power_events;
667
668         /*
669          * two pass drawing so that the P state bars are on top of the C state blocks
670          */
671         while (pwr) {
672                 if (pwr->type == CSTATE)
673                         svg_cstate(pwr->cpu, pwr->start_time, pwr->end_time, pwr->state);
674                 pwr = pwr->next;
675         }
676
677         pwr = power_events;
678         while (pwr) {
679                 if (pwr->type == PSTATE) {
680                         if (!pwr->state)
681                                 pwr->state = min_freq;
682                         svg_pstate(pwr->cpu, pwr->start_time, pwr->end_time, pwr->state);
683                 }
684                 pwr = pwr->next;
685         }
686 }
687
688 static void draw_wakeups(void)
689 {
690         struct wake_event *we;
691         struct per_pid *p;
692         struct per_pidcomm *c;
693
694         we = wake_events;
695         while (we) {
696                 int from = 0, to = 0;
697                 char *task_from = NULL, *task_to = NULL;
698
699                 /* locate the column of the waker and wakee */
700                 p = all_data;
701                 while (p) {
702                         if (p->pid == we->waker || p->pid == we->wakee) {
703                                 c = p->all;
704                                 while (c) {
705                                         if (c->Y && c->start_time <= we->time && c->end_time >= we->time) {
706                                                 if (p->pid == we->waker && !from) {
707                                                         from = c->Y;
708                                                         task_from = strdup(c->comm);
709                                                 }
710                                                 if (p->pid == we->wakee && !to) {
711                                                         to = c->Y;
712                                                         task_to = strdup(c->comm);
713                                                 }
714                                         }
715                                         c = c->next;
716                                 }
717                                 c = p->all;
718                                 while (c) {
719                                         if (p->pid == we->waker && !from) {
720                                                 from = c->Y;
721                                                 task_from = strdup(c->comm);
722                                         }
723                                         if (p->pid == we->wakee && !to) {
724                                                 to = c->Y;
725                                                 task_to = strdup(c->comm);
726                                         }
727                                         c = c->next;
728                                 }
729                         }
730                         p = p->next;
731                 }
732
733                 if (!task_from) {
734                         task_from = malloc(40);
735                         sprintf(task_from, "[%i]", we->waker);
736                 }
737                 if (!task_to) {
738                         task_to = malloc(40);
739                         sprintf(task_to, "[%i]", we->wakee);
740                 }
741
742                 if (we->waker == -1)
743                         svg_interrupt(we->time, to);
744                 else if (from && to && abs(from - to) == 1)
745                         svg_wakeline(we->time, from, to);
746                 else
747                         svg_partial_wakeline(we->time, from, task_from, to, task_to);
748                 we = we->next;
749
750                 free(task_from);
751                 free(task_to);
752         }
753 }
754
755 static void draw_cpu_usage(void)
756 {
757         struct per_pid *p;
758         struct per_pidcomm *c;
759         struct cpu_sample *sample;
760         p = all_data;
761         while (p) {
762                 c = p->all;
763                 while (c) {
764                         sample = c->samples;
765                         while (sample) {
766                                 if (sample->type == TYPE_RUNNING)
767                                         svg_process(sample->cpu, sample->start_time, sample->end_time, "sample", c->comm);
768
769                                 sample = sample->next;
770                         }
771                         c = c->next;
772                 }
773                 p = p->next;
774         }
775 }
776
777 static void draw_process_bars(void)
778 {
779         struct per_pid *p;
780         struct per_pidcomm *c;
781         struct cpu_sample *sample;
782         int Y = 0;
783
784         Y = 2 * numcpus + 2;
785
786         p = all_data;
787         while (p) {
788                 c = p->all;
789                 while (c) {
790                         if (!c->display) {
791                                 c->Y = 0;
792                                 c = c->next;
793                                 continue;
794                         }
795
796                         svg_box(Y, c->start_time, c->end_time, "process");
797                         sample = c->samples;
798                         while (sample) {
799                                 if (sample->type == TYPE_RUNNING)
800                                         svg_sample(Y, sample->cpu, sample->start_time, sample->end_time);
801                                 if (sample->type == TYPE_BLOCKED)
802                                         svg_box(Y, sample->start_time, sample->end_time, "blocked");
803                                 if (sample->type == TYPE_WAITING)
804                                         svg_waiting(Y, sample->start_time, sample->end_time);
805                                 sample = sample->next;
806                         }
807
808                         if (c->comm) {
809                                 char comm[256];
810                                 if (c->total_time > 5000000000) /* 5 seconds */
811                                         sprintf(comm, "%s:%i (%2.2fs)", c->comm, p->pid, c->total_time / 1000000000.0);
812                                 else
813                                         sprintf(comm, "%s:%i (%3.1fms)", c->comm, p->pid, c->total_time / 1000000.0);
814
815                                 svg_text(Y, c->start_time, comm);
816                         }
817                         c->Y = Y;
818                         Y++;
819                         c = c->next;
820                 }
821                 p = p->next;
822         }
823 }
824
825 static void add_process_filter(const char *string)
826 {
827         struct process_filter *filt;
828         int pid;
829
830         pid = strtoull(string, NULL, 10);
831         filt = malloc(sizeof(struct process_filter));
832         if (!filt)
833                 return;
834
835         filt->name = strdup(string);
836         filt->pid  = pid;
837         filt->next = process_filter;
838
839         process_filter = filt;
840 }
841
842 static int passes_filter(struct per_pid *p, struct per_pidcomm *c)
843 {
844         struct process_filter *filt;
845         if (!process_filter)
846                 return 1;
847
848         filt = process_filter;
849         while (filt) {
850                 if (filt->pid && p->pid == filt->pid)
851                         return 1;
852                 if (strcmp(filt->name, c->comm) == 0)
853                         return 1;
854                 filt = filt->next;
855         }
856         return 0;
857 }
858
859 static int determine_display_tasks_filtered(void)
860 {
861         struct per_pid *p;
862         struct per_pidcomm *c;
863         int count = 0;
864
865         p = all_data;
866         while (p) {
867                 p->display = 0;
868                 if (p->start_time == 1)
869                         p->start_time = first_time;
870
871                 /* no exit marker, task kept running to the end */
872                 if (p->end_time == 0)
873                         p->end_time = last_time;
874
875                 c = p->all;
876
877                 while (c) {
878                         c->display = 0;
879
880                         if (c->start_time == 1)
881                                 c->start_time = first_time;
882
883                         if (passes_filter(p, c)) {
884                                 c->display = 1;
885                                 p->display = 1;
886                                 count++;
887                         }
888
889                         if (c->end_time == 0)
890                                 c->end_time = last_time;
891
892                         c = c->next;
893                 }
894                 p = p->next;
895         }
896         return count;
897 }
898
899 static int determine_display_tasks(u64 threshold)
900 {
901         struct per_pid *p;
902         struct per_pidcomm *c;
903         int count = 0;
904
905         if (process_filter)
906                 return determine_display_tasks_filtered();
907
908         p = all_data;
909         while (p) {
910                 p->display = 0;
911                 if (p->start_time == 1)
912                         p->start_time = first_time;
913
914                 /* no exit marker, task kept running to the end */
915                 if (p->end_time == 0)
916                         p->end_time = last_time;
917                 if (p->total_time >= threshold && !power_only)
918                         p->display = 1;
919
920                 c = p->all;
921
922                 while (c) {
923                         c->display = 0;
924
925                         if (c->start_time == 1)
926                                 c->start_time = first_time;
927
928                         if (c->total_time >= threshold && !power_only) {
929                                 c->display = 1;
930                                 count++;
931                         }
932
933                         if (c->end_time == 0)
934                                 c->end_time = last_time;
935
936                         c = c->next;
937                 }
938                 p = p->next;
939         }
940         return count;
941 }
942
943
944
945 #define TIME_THRESH 10000000
946
947 static void write_svg_file(const char *filename)
948 {
949         u64 i;
950         int count;
951
952         numcpus++;
953
954
955         count = determine_display_tasks(TIME_THRESH);
956
957         /* We'd like to show at least 15 tasks; be less picky if we have fewer */
958         if (count < 15)
959                 count = determine_display_tasks(TIME_THRESH / 10);
960
961         open_svg(filename, numcpus, count, first_time, last_time);
962
963         svg_time_grid();
964         svg_legenda();
965
966         for (i = 0; i < numcpus; i++)
967                 svg_cpu_box(i, max_freq, turbo_frequency);
968
969         draw_cpu_usage();
970         draw_process_bars();
971         draw_c_p_states();
972         draw_wakeups();
973
974         svg_close();
975 }
976
977 static struct perf_event_ops event_ops = {
978         .comm                   = process_comm_event,
979         .fork                   = process_fork_event,
980         .exit                   = process_exit_event,
981         .sample                 = process_sample_event,
982         .ordered_samples        = true,
983 };
984
985 static int __cmd_timechart(void)
986 {
987         struct perf_session *session = perf_session__new(input_name, O_RDONLY,
988                                                          0, false, &event_ops);
989         int ret = -EINVAL;
990
991         if (session == NULL)
992                 return -ENOMEM;
993
994         if (!perf_session__has_traces(session, "timechart record"))
995                 goto out_delete;
996
997         ret = perf_session__process_events(session, &event_ops);
998         if (ret)
999                 goto out_delete;
1000
1001         end_sample_processing();
1002
1003         sort_pids();
1004
1005         write_svg_file(output_name);
1006
1007         pr_info("Written %2.1f seconds of trace to %s.\n",
1008                 (last_time - first_time) / 1000000000.0, output_name);
1009 out_delete:
1010         perf_session__delete(session);
1011         return ret;
1012 }
1013
1014 static const char * const timechart_usage[] = {
1015         "perf timechart [<options>] {record}",
1016         NULL
1017 };
1018
1019 #ifdef SUPPORT_OLD_POWER_EVENTS
1020 static const char * const record_old_args[] = {
1021         "record",
1022         "-a",
1023         "-R",
1024         "-f",
1025         "-c", "1",
1026         "-e", "power:power_start",
1027         "-e", "power:power_end",
1028         "-e", "power:power_frequency",
1029         "-e", "sched:sched_wakeup",
1030         "-e", "sched:sched_switch",
1031 };
1032 #endif
1033
1034 static const char * const record_new_args[] = {
1035         "record",
1036         "-a",
1037         "-R",
1038         "-f",
1039         "-c", "1",
1040         "-e", "power:cpu_frequency",
1041         "-e", "power:cpu_idle",
1042         "-e", "sched:sched_wakeup",
1043         "-e", "sched:sched_switch",
1044 };
1045
1046 static int __cmd_record(int argc, const char **argv)
1047 {
1048         unsigned int rec_argc, i, j;
1049         const char **rec_argv;
1050         const char * const *record_args = record_new_args;
1051         unsigned int record_elems = ARRAY_SIZE(record_new_args);
1052
1053 #ifdef SUPPORT_OLD_POWER_EVENTS
1054         if (!is_valid_tracepoint("power:cpu_idle") &&
1055             is_valid_tracepoint("power:power_start")) {
1056                 use_old_power_events = 1;
1057                 record_args = record_old_args;
1058                 record_elems = ARRAY_SIZE(record_old_args);
1059         }
1060 #endif
1061
1062         rec_argc = record_elems + argc - 1;
1063         rec_argv = calloc(rec_argc + 1, sizeof(char *));
1064
1065         if (rec_argv == NULL)
1066                 return -ENOMEM;
1067
1068         for (i = 0; i < record_elems; i++)
1069                 rec_argv[i] = strdup(record_args[i]);
1070
1071         for (j = 1; j < (unsigned int)argc; j++, i++)
1072                 rec_argv[i] = argv[j];
1073
1074         return cmd_record(i, rec_argv, NULL);
1075 }
1076
1077 static int
1078 parse_process(const struct option *opt __used, const char *arg, int __used unset)
1079 {
1080         if (arg)
1081                 add_process_filter(arg);
1082         return 0;
1083 }
1084
1085 static const struct option options[] = {
1086         OPT_STRING('i', "input", &input_name, "file",
1087                     "input file name"),
1088         OPT_STRING('o', "output", &output_name, "file",
1089                     "output file name"),
1090         OPT_INTEGER('w', "width", &svg_page_width,
1091                     "page width"),
1092         OPT_BOOLEAN('P', "power-only", &power_only,
1093                     "output power data only"),
1094         OPT_CALLBACK('p', "process", NULL, "process",
1095                       "process selector. Pass a pid or process name.",
1096                        parse_process),
1097         OPT_STRING(0, "symfs", &symbol_conf.symfs, "directory",
1098                     "Look for files with symbols relative to this directory"),
1099         OPT_END()
1100 };
1101
1102
1103 int cmd_timechart(int argc, const char **argv, const char *prefix __used)
1104 {
1105         argc = parse_options(argc, argv, options, timechart_usage,
1106                         PARSE_OPT_STOP_AT_NON_OPTION);
1107
1108         symbol__init();
1109
1110         if (argc && !strncmp(argv[0], "rec", 3))
1111                 return __cmd_record(argc, argv);
1112         else if (argc)
1113                 usage_with_options(timechart_usage, options);
1114
1115         setup_pager();
1116
1117         return __cmd_timechart();
1118 }