Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 169481
b: refs/heads/master
c: 97ea1a7
h: refs/heads/master
i:
  169479: f2eed37
v: v3
  • Loading branch information
Frederic Weisbecker authored and Ingo Molnar committed Oct 8, 2009
1 parent b86df0a commit ac3dd41
Show file tree
Hide file tree
Showing 4 changed files with 14 additions and 69 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 2e538c4a1847291cf01218d4fe7bb4dc60fef7cf
refs/heads/master: 97ea1a7fa62af0d8d49a0fc12796b0073537c9d8
46 changes: 6 additions & 40 deletions trunk/tools/perf/builtin-sched.c
Original file line number Diff line number Diff line change
Expand Up @@ -638,7 +638,7 @@ process_comm_event(event_t *event, unsigned long offset, unsigned long head)
{
struct thread *thread;

thread = threads__findnew(event->comm.pid, &threads, &last_match);
thread = threads__findnew(event->comm.tid, &threads, &last_match);

dump_printf("%p [%p]: perf_event_comm: %s:%d\n",
(void *)(offset + head),
Expand Down Expand Up @@ -1034,36 +1034,6 @@ add_sched_in_event(struct work_atoms *atoms, u64 timestamp)
atoms->nb_atoms++;
}

static struct thread *
threads__findnew_from_ctx(u32 pid, struct trace_switch_event *switch_event)
{
struct thread *th;

th = threads__findnew_nocomm(pid, &threads, &last_match);
if (th->comm)
return th;

if (pid == switch_event->prev_pid)
thread__set_comm(th, switch_event->prev_comm);
else
thread__set_comm(th, switch_event->next_comm);
return th;
}

static struct thread *
threads__findnew_from_wakeup(struct trace_wakeup_event *wakeup_event)
{
struct thread *th;

th = threads__findnew_nocomm(wakeup_event->pid, &threads, &last_match);
if (th->comm)
return th;

thread__set_comm(th, wakeup_event->comm);

return th;
}

static void
latency_switch_event(struct trace_switch_event *switch_event,
struct event *event __used,
Expand All @@ -1089,10 +1059,8 @@ latency_switch_event(struct trace_switch_event *switch_event,
die("hm, delta: %Ld < 0 ?\n", delta);


sched_out = threads__findnew_from_ctx(switch_event->prev_pid,
switch_event);
sched_in = threads__findnew_from_ctx(switch_event->next_pid,
switch_event);
sched_out = threads__findnew(switch_event->prev_pid, &threads, &last_match);
sched_in = threads__findnew(switch_event->next_pid, &threads, &last_match);

out_events = thread_atoms_search(&atom_root, sched_out, &cmp_pid);
if (!out_events) {
Expand Down Expand Up @@ -1158,7 +1126,7 @@ latency_wakeup_event(struct trace_wakeup_event *wakeup_event,
if (!wakeup_event->success)
return;

wakee = threads__findnew_from_wakeup(wakeup_event);
wakee = threads__findnew(wakeup_event->pid, &threads, &last_match);
atoms = thread_atoms_search(&atom_root, wakee, &cmp_pid);
if (!atoms) {
thread_atoms_insert(wakee);
Expand Down Expand Up @@ -1418,10 +1386,8 @@ map_switch_event(struct trace_switch_event *switch_event,
die("hm, delta: %Ld < 0 ?\n", delta);


sched_out = threads__findnew_from_ctx(switch_event->prev_pid,
switch_event);
sched_in = threads__findnew_from_ctx(switch_event->next_pid,
switch_event);
sched_out = threads__findnew(switch_event->prev_pid, &threads, &last_match);
sched_in = threads__findnew(switch_event->next_pid, &threads, &last_match);

curr_thread[this_cpu] = sched_in;

Expand Down
32 changes: 7 additions & 25 deletions trunk/tools/perf/util/thread.c
Original file line number Diff line number Diff line change
Expand Up @@ -6,17 +6,15 @@
#include "util.h"
#include "debug.h"

static struct thread *thread__new(pid_t pid, int set_comm)
static struct thread *thread__new(pid_t pid)
{
struct thread *self = calloc(1, sizeof(*self));

if (self != NULL) {
self->pid = pid;
if (set_comm) {
self->comm = malloc(32);
if (self->comm)
snprintf(self->comm, 32, ":%d", self->pid);
}
self->comm = malloc(32);
if (self->comm)
snprintf(self->comm, 32, ":%d", self->pid);
self->maps = RB_ROOT;
INIT_LIST_HEAD(&self->removed_maps);
}
Expand Down Expand Up @@ -52,10 +50,8 @@ static size_t thread__fprintf(struct thread *self, FILE *fp)
return ret;
}

static struct thread *
__threads__findnew(pid_t pid, struct rb_root *threads,
struct thread **last_match,
int set_comm)
struct thread *
threads__findnew(pid_t pid, struct rb_root *threads, struct thread **last_match)
{
struct rb_node **p = &threads->rb_node;
struct rb_node *parent = NULL;
Expand Down Expand Up @@ -84,8 +80,7 @@ __threads__findnew(pid_t pid, struct rb_root *threads,
p = &(*p)->rb_right;
}

th = thread__new(pid, set_comm);

th = thread__new(pid);
if (th != NULL) {
rb_link_node(&th->rb_node, parent, p);
rb_insert_color(&th->rb_node, threads);
Expand All @@ -95,19 +90,6 @@ __threads__findnew(pid_t pid, struct rb_root *threads,
return th;
}

struct thread *
threads__findnew(pid_t pid, struct rb_root *threads, struct thread **last_match)
{
return __threads__findnew(pid, threads, last_match, 1);
}

struct thread *
threads__findnew_nocomm(pid_t pid, struct rb_root *threads,
struct thread **last_match)
{
return __threads__findnew(pid, threads, last_match, 0);
}

struct thread *
register_idle_thread(struct rb_root *threads, struct thread **last_match)
{
Expand Down
3 changes: 0 additions & 3 deletions trunk/tools/perf/util/thread.h
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,6 @@ int thread__set_comm(struct thread *self, const char *comm);
struct thread *
threads__findnew(pid_t pid, struct rb_root *threads, struct thread **last_match);
struct thread *
threads__findnew_nocomm(pid_t pid, struct rb_root *threads,
struct thread **last_match);
struct thread *
register_idle_thread(struct rb_root *threads, struct thread **last_match);
void thread__insert_map(struct thread *self, struct map *map);
int thread__fork(struct thread *self, struct thread *parent);
Expand Down

0 comments on commit ac3dd41

Please sign in to comment.