7 #include "thread-stack.h"
13 #include <api/fs/fs.h>
15 int thread__init_map_groups(struct thread
*thread
, struct machine
*machine
)
17 struct thread
*leader
;
18 pid_t pid
= thread
->pid_
;
20 if (pid
== thread
->tid
|| pid
== -1) {
21 thread
->mg
= map_groups__new(machine
);
23 leader
= __machine__findnew_thread(machine
, pid
, pid
);
25 thread
->mg
= map_groups__get(leader
->mg
);
30 return thread
->mg
? 0 : -1;
33 struct thread
*thread__new(pid_t pid
, pid_t tid
)
37 struct thread
*thread
= zalloc(sizeof(*thread
));
44 INIT_LIST_HEAD(&thread
->comm_list
);
46 if (unwind__prepare_access(thread
) < 0)
49 comm_str
= malloc(32);
53 snprintf(comm_str
, 32, ":%d", tid
);
54 comm
= comm__new(comm_str
, 0, false);
59 list_add(&comm
->list
, &thread
->comm_list
);
60 atomic_set(&thread
->refcnt
, 1);
61 RB_CLEAR_NODE(&thread
->rb_node
);
71 void thread__delete(struct thread
*thread
)
73 struct comm
*comm
, *tmp
;
75 BUG_ON(!RB_EMPTY_NODE(&thread
->rb_node
));
77 thread_stack__free(thread
);
80 map_groups__put(thread
->mg
);
83 list_for_each_entry_safe(comm
, tmp
, &thread
->comm_list
, list
) {
84 list_del(&comm
->list
);
87 unwind__finish_access(thread
);
92 struct thread
*thread__get(struct thread
*thread
)
95 atomic_inc(&thread
->refcnt
);
99 void thread__put(struct thread
*thread
)
101 if (thread
&& atomic_dec_and_test(&thread
->refcnt
)) {
103 * Remove it from the dead_threads list, as last reference
106 list_del_init(&thread
->node
);
107 thread__delete(thread
);
111 struct comm
*thread__comm(const struct thread
*thread
)
113 if (list_empty(&thread
->comm_list
))
116 return list_first_entry(&thread
->comm_list
, struct comm
, list
);
119 struct comm
*thread__exec_comm(const struct thread
*thread
)
121 struct comm
*comm
, *last
= NULL
;
123 list_for_each_entry(comm
, &thread
->comm_list
, list
) {
132 int __thread__set_comm(struct thread
*thread
, const char *str
, u64 timestamp
,
135 struct comm
*new, *curr
= thread__comm(thread
);
138 /* Override the default :tid entry */
139 if (!thread
->comm_set
) {
140 err
= comm__override(curr
, str
, timestamp
, exec
);
144 new = comm__new(str
, timestamp
, exec
);
147 list_add(&new->list
, &thread
->comm_list
);
150 unwind__flush_access(thread
);
153 thread
->comm_set
= true;
158 int thread__set_comm_from_proc(struct thread
*thread
)
165 if (!(snprintf(path
, sizeof(path
), "%d/task/%d/comm",
166 thread
->pid_
, thread
->tid
) >= (int)sizeof(path
)) &&
167 procfs__read_str(path
, &comm
, &sz
) == 0) {
169 err
= thread__set_comm(thread
, comm
, 0);
175 const char *thread__comm_str(const struct thread
*thread
)
177 const struct comm
*comm
= thread__comm(thread
);
182 return comm__str(comm
);
185 /* CHECKME: it should probably better return the max comm len from its comm list */
186 int thread__comm_len(struct thread
*thread
)
188 if (!thread
->comm_len
) {
189 const char *comm
= thread__comm_str(thread
);
192 thread
->comm_len
= strlen(comm
);
195 return thread
->comm_len
;
198 size_t thread__fprintf(struct thread
*thread
, FILE *fp
)
200 return fprintf(fp
, "Thread %d %s\n", thread
->tid
, thread__comm_str(thread
)) +
201 map_groups__fprintf(thread
->mg
, fp
);
204 void thread__insert_map(struct thread
*thread
, struct map
*map
)
206 map_groups__fixup_overlappings(thread
->mg
, map
, stderr
);
207 map_groups__insert(thread
->mg
, map
);
210 static int thread__clone_map_groups(struct thread
*thread
,
211 struct thread
*parent
)
215 /* This is new thread, we share map groups for process. */
216 if (thread
->pid_
== parent
->pid_
)
219 if (thread
->mg
== parent
->mg
) {
220 pr_debug("broken map groups on thread %d/%d parent %d/%d\n",
221 thread
->pid_
, thread
->tid
, parent
->pid_
, parent
->tid
);
225 /* But this one is new process, copy maps. */
226 for (i
= 0; i
< MAP__NR_TYPES
; ++i
)
227 if (map_groups__clone(thread
->mg
, parent
->mg
, i
) < 0)
233 int thread__fork(struct thread
*thread
, struct thread
*parent
, u64 timestamp
)
237 if (parent
->comm_set
) {
238 const char *comm
= thread__comm_str(parent
);
241 err
= thread__set_comm(thread
, comm
, timestamp
);
246 thread
->ppid
= parent
->tid
;
247 return thread__clone_map_groups(thread
, parent
);
250 void thread__find_cpumode_addr_location(struct thread
*thread
,
251 enum map_type type
, u64 addr
,
252 struct addr_location
*al
)
255 const u8 cpumodes
[] = {
256 PERF_RECORD_MISC_USER
,
257 PERF_RECORD_MISC_KERNEL
,
258 PERF_RECORD_MISC_GUEST_USER
,
259 PERF_RECORD_MISC_GUEST_KERNEL
262 for (i
= 0; i
< ARRAY_SIZE(cpumodes
); i
++) {
263 thread__find_addr_location(thread
, cpumodes
[i
], type
, addr
, al
);