@@ -69,6 +69,7 @@ struct thread_trace {
6969 bool entry_pending ;
7070 unsigned long nr_events ;
7171 char * entry_str ;
72+ double runtime_ms ;
7273};
7374
7475static struct thread_trace * thread_trace__new (void )
@@ -109,8 +110,10 @@ struct trace {
109110 struct machine host ;
110111 u64 base_time ;
111112 unsigned long nr_events ;
113+ bool sched ;
112114 bool multiple_threads ;
113115 double duration_filter ;
116+ double runtime_ms ;
114117};
115118
116119static bool trace__filter_duration (struct trace * trace , double t )
@@ -389,6 +392,31 @@ static int trace__sys_exit(struct trace *trace, struct perf_evsel *evsel,
389392 return 0 ;
390393}
391394
395+ static int trace__sched_stat_runtime (struct trace * trace , struct perf_evsel * evsel ,
396+ struct perf_sample * sample )
397+ {
398+ u64 runtime = perf_evsel__intval (evsel , sample , "runtime" );
399+ double runtime_ms = (double )runtime / NSEC_PER_MSEC ;
400+ struct thread * thread = machine__findnew_thread (& trace -> host , sample -> tid );
401+ struct thread_trace * ttrace = thread__trace (thread );
402+
403+ if (ttrace == NULL )
404+ goto out_dump ;
405+
406+ ttrace -> runtime_ms += runtime_ms ;
407+ trace -> runtime_ms += runtime_ms ;
408+ return 0 ;
409+
410+ out_dump :
411+ printf ("%s: comm=%s,pid=%u,runtime=%" PRIu64 ",vruntime=%" PRIu64 ")\n" ,
412+ evsel -> name ,
413+ perf_evsel__strval (evsel , sample , "comm" ),
414+ (pid_t )perf_evsel__intval (evsel , sample , "pid" ),
415+ runtime ,
416+ perf_evsel__intval (evsel , sample , "vruntime" ));
417+ return 0 ;
418+ }
419+
392420static int trace__run (struct trace * trace , int argc , const char * * argv )
393421{
394422 struct perf_evlist * evlist = perf_evlist__new (NULL , NULL );
@@ -408,6 +436,13 @@ static int trace__run(struct trace *trace, int argc, const char **argv)
408436 goto out_delete_evlist ;
409437 }
410438
439+ if (trace -> sched &&
440+ perf_evlist__add_newtp (evlist , "sched" , "sched_stat_runtime" ,
441+ trace__sched_stat_runtime )) {
442+ printf ("Couldn't read the sched_stat_runtime tracepoint information!\n" );
443+ goto out_delete_evlist ;
444+ }
445+
411446 err = perf_evlist__create_maps (evlist , & trace -> opts .target );
412447 if (err < 0 ) {
413448 printf ("Problems parsing the target to trace, check your options!\n" );
@@ -521,6 +556,51 @@ static int trace__run(struct trace *trace, int argc, const char **argv)
521556 return err ;
522557}
523558
559+ static size_t trace__fprintf_threads_header (FILE * fp )
560+ {
561+ size_t printed ;
562+
563+ printed = fprintf (fp , "\n _____________________________________________________________________\n" );
564+ printed += fprintf (fp ," __) Summary of events (__\n\n" );
565+ printed += fprintf (fp ," [ task - pid ] [ events ] [ ratio ] [ runtime ]\n" );
566+ printed += fprintf (fp ," _____________________________________________________________________\n\n" );
567+
568+ return printed ;
569+ }
570+
571+ static size_t trace__fprintf_thread_summary (struct trace * trace , FILE * fp )
572+ {
573+ size_t printed = trace__fprintf_threads_header (fp );
574+ struct rb_node * nd ;
575+
576+ for (nd = rb_first (& trace -> host .threads ); nd ; nd = rb_next (nd )) {
577+ struct thread * thread = rb_entry (nd , struct thread , rb_node );
578+ struct thread_trace * ttrace = thread -> priv ;
579+ const char * color ;
580+ double ratio ;
581+
582+ if (ttrace == NULL )
583+ continue ;
584+
585+ ratio = (double )ttrace -> nr_events / trace -> nr_events * 100.0 ;
586+
587+ color = PERF_COLOR_NORMAL ;
588+ if (ratio > 50.0 )
589+ color = PERF_COLOR_RED ;
590+ else if (ratio > 25.0 )
591+ color = PERF_COLOR_GREEN ;
592+ else if (ratio > 5.0 )
593+ color = PERF_COLOR_YELLOW ;
594+
595+ printed += color_fprintf (fp , color , "%20s" , thread -> comm );
596+ printed += fprintf (fp , " - %-5d :%11lu [" , thread -> pid , ttrace -> nr_events );
597+ printed += color_fprintf (fp , color , "%5.1f%%" , ratio );
598+ printed += fprintf (fp , " ] %10.3f ms\n" , ttrace -> runtime_ms );
599+ }
600+
601+ return printed ;
602+ }
603+
524604static int trace__set_duration (const struct option * opt , const char * str ,
525605 int unset __maybe_unused )
526606{
@@ -571,6 +651,7 @@ int cmd_trace(int argc, const char **argv, const char *prefix __maybe_unused)
571651 OPT_CALLBACK (0 , "duration" , & trace , "float" ,
572652 "show only events with duration > N.M ms" ,
573653 trace__set_duration ),
654+ OPT_BOOLEAN (0 , "sched" , & trace .sched , "show blocking scheduler events" ),
574655 OPT_END ()
575656 };
576657 int err ;
@@ -595,5 +676,10 @@ int cmd_trace(int argc, const char **argv, const char *prefix __maybe_unused)
595676 if (!argc && perf_target__none (& trace .opts .target ))
596677 trace .opts .target .system_wide = true;
597678
598- return trace__run (& trace , argc , argv );
679+ err = trace__run (& trace , argc , argv );
680+
681+ if (trace .sched && !err )
682+ trace__fprintf_thread_summary (& trace , stdout );
683+
684+ return err ;
599685}
0 commit comments