Lines Matching refs:thread
22 int thread__init_maps(struct thread *thread, struct machine *machine) in thread__init_maps() argument
24 pid_t pid = thread->pid_; in thread__init_maps()
26 if (pid == thread->tid || pid == -1) { in thread__init_maps()
27 thread->maps = maps__new(machine); in thread__init_maps()
29 struct thread *leader = __machine__findnew_thread(machine, pid, pid); in thread__init_maps()
31 thread->maps = maps__get(leader->maps); in thread__init_maps()
36 return thread->maps ? 0 : -1; in thread__init_maps()
39 struct thread *thread__new(pid_t pid, pid_t tid) in thread__new()
43 struct thread *thread = zalloc(sizeof(*thread)); in thread__new() local
45 if (thread != NULL) { in thread__new()
46 thread->pid_ = pid; in thread__new()
47 thread->tid = tid; in thread__new()
48 thread->ppid = -1; in thread__new()
49 thread->cpu = -1; in thread__new()
50 thread->lbr_stitch_enable = false; in thread__new()
51 INIT_LIST_HEAD(&thread->namespaces_list); in thread__new()
52 INIT_LIST_HEAD(&thread->comm_list); in thread__new()
53 init_rwsem(&thread->namespaces_lock); in thread__new()
54 init_rwsem(&thread->comm_lock); in thread__new()
66 list_add(&comm->list, &thread->comm_list); in thread__new()
67 refcount_set(&thread->refcnt, 1); in thread__new()
68 RB_CLEAR_NODE(&thread->rb_node); in thread__new()
70 thread->nsinfo = nsinfo__new(pid); in thread__new()
71 srccode_state_init(&thread->srccode_state); in thread__new()
74 return thread; in thread__new()
77 free(thread); in thread__new()
81 void thread__delete(struct thread *thread) in thread__delete() argument
86 BUG_ON(!RB_EMPTY_NODE(&thread->rb_node)); in thread__delete()
88 thread_stack__free(thread); in thread__delete()
90 if (thread->maps) { in thread__delete()
91 maps__put(thread->maps); in thread__delete()
92 thread->maps = NULL; in thread__delete()
94 down_write(&thread->namespaces_lock); in thread__delete()
96 &thread->namespaces_list, list) { in thread__delete()
100 up_write(&thread->namespaces_lock); in thread__delete()
102 down_write(&thread->comm_lock); in thread__delete()
103 list_for_each_entry_safe(comm, tmp_comm, &thread->comm_list, list) { in thread__delete()
107 up_write(&thread->comm_lock); in thread__delete()
109 nsinfo__zput(thread->nsinfo); in thread__delete()
110 srccode_state_free(&thread->srccode_state); in thread__delete()
112 exit_rwsem(&thread->namespaces_lock); in thread__delete()
113 exit_rwsem(&thread->comm_lock); in thread__delete()
114 thread__free_stitch_list(thread); in thread__delete()
115 free(thread); in thread__delete()
118 struct thread *thread__get(struct thread *thread) in thread__get() argument
120 if (thread) in thread__get()
121 refcount_inc(&thread->refcnt); in thread__get()
122 return thread; in thread__get()
125 void thread__put(struct thread *thread) in thread__put() argument
127 if (thread && refcount_dec_and_test(&thread->refcnt)) { in thread__put()
148 if (!list_empty(&thread->node)) in thread__put()
149 list_del_init(&thread->node); in thread__put()
150 thread__delete(thread); in thread__put()
154 static struct namespaces *__thread__namespaces(const struct thread *thread) in __thread__namespaces() argument
156 if (list_empty(&thread->namespaces_list)) in __thread__namespaces()
159 return list_first_entry(&thread->namespaces_list, struct namespaces, list); in __thread__namespaces()
162 struct namespaces *thread__namespaces(struct thread *thread) in thread__namespaces() argument
166 down_read(&thread->namespaces_lock); in thread__namespaces()
167 ns = __thread__namespaces(thread); in thread__namespaces()
168 up_read(&thread->namespaces_lock); in thread__namespaces()
173 static int __thread__set_namespaces(struct thread *thread, u64 timestamp, in __thread__set_namespaces() argument
176 struct namespaces *new, *curr = __thread__namespaces(thread); in __thread__set_namespaces()
182 list_add(&new->list, &thread->namespaces_list); in __thread__set_namespaces()
197 int thread__set_namespaces(struct thread *thread, u64 timestamp, in thread__set_namespaces() argument
202 down_write(&thread->namespaces_lock); in thread__set_namespaces()
203 ret = __thread__set_namespaces(thread, timestamp, event); in thread__set_namespaces()
204 up_write(&thread->namespaces_lock); in thread__set_namespaces()
208 struct comm *thread__comm(const struct thread *thread) in thread__comm() argument
210 if (list_empty(&thread->comm_list)) in thread__comm()
213 return list_first_entry(&thread->comm_list, struct comm, list); in thread__comm()
216 struct comm *thread__exec_comm(const struct thread *thread) in thread__exec_comm() argument
220 list_for_each_entry(comm, &thread->comm_list, list) { in thread__exec_comm()
233 if (second_last && !last->start && thread->pid_ == thread->tid) in thread__exec_comm()
239 static int ____thread__set_comm(struct thread *thread, const char *str, in ____thread__set_comm() argument
242 struct comm *new, *curr = thread__comm(thread); in ____thread__set_comm()
245 if (!thread->comm_set) { in ____thread__set_comm()
253 list_add(&new->list, &thread->comm_list); in ____thread__set_comm()
256 unwind__flush_access(thread->maps); in ____thread__set_comm()
259 thread->comm_set = true; in ____thread__set_comm()
264 int __thread__set_comm(struct thread *thread, const char *str, u64 timestamp, in __thread__set_comm() argument
269 down_write(&thread->comm_lock); in __thread__set_comm()
270 ret = ____thread__set_comm(thread, str, timestamp, exec); in __thread__set_comm()
271 up_write(&thread->comm_lock); in __thread__set_comm()
275 int thread__set_comm_from_proc(struct thread *thread) in thread__set_comm_from_proc() argument
283 thread->pid_, thread->tid) >= (int)sizeof(path)) && in thread__set_comm_from_proc()
286 err = thread__set_comm(thread, comm, 0); in thread__set_comm_from_proc()
292 static const char *__thread__comm_str(const struct thread *thread) in __thread__comm_str() argument
294 const struct comm *comm = thread__comm(thread); in __thread__comm_str()
302 const char *thread__comm_str(struct thread *thread) in thread__comm_str() argument
306 down_read(&thread->comm_lock); in thread__comm_str()
307 str = __thread__comm_str(thread); in thread__comm_str()
308 up_read(&thread->comm_lock); in thread__comm_str()
314 int thread__comm_len(struct thread *thread) in thread__comm_len() argument
316 if (!thread->comm_len) { in thread__comm_len()
317 const char *comm = thread__comm_str(thread); in thread__comm_len()
320 thread->comm_len = strlen(comm); in thread__comm_len()
323 return thread->comm_len; in thread__comm_len()
326 size_t thread__fprintf(struct thread *thread, FILE *fp) in thread__fprintf() argument
328 return fprintf(fp, "Thread %d %s\n", thread->tid, thread__comm_str(thread)) + in thread__fprintf()
329 maps__fprintf(thread->maps, fp); in thread__fprintf()
332 int thread__insert_map(struct thread *thread, struct map *map) in thread__insert_map() argument
336 ret = unwind__prepare_access(thread->maps, map, NULL); in thread__insert_map()
340 maps__fixup_overlappings(thread->maps, map, stderr); in thread__insert_map()
341 maps__insert(thread->maps, map); in thread__insert_map()
346 static int __thread__prepare_access(struct thread *thread) in __thread__prepare_access() argument
350 struct maps *maps = thread->maps; in __thread__prepare_access()
356 err = unwind__prepare_access(thread->maps, map, &initialized); in __thread__prepare_access()
366 static int thread__prepare_access(struct thread *thread) in thread__prepare_access() argument
371 err = __thread__prepare_access(thread); in thread__prepare_access()
376 static int thread__clone_maps(struct thread *thread, struct thread *parent, bool do_maps_clone) in thread__clone_maps() argument
379 if (thread->pid_ == parent->pid_) in thread__clone_maps()
380 return thread__prepare_access(thread); in thread__clone_maps()
382 if (thread->maps == parent->maps) { in thread__clone_maps()
384 thread->pid_, thread->tid, parent->pid_, parent->tid); in thread__clone_maps()
388 return do_maps_clone ? maps__clone(thread, parent->maps) : 0; in thread__clone_maps()
391 int thread__fork(struct thread *thread, struct thread *parent, u64 timestamp, bool do_maps_clone) in thread__fork() argument
398 err = thread__set_comm(thread, comm, timestamp); in thread__fork()
403 thread->ppid = parent->tid; in thread__fork()
404 return thread__clone_maps(thread, parent, do_maps_clone); in thread__fork()
407 void thread__find_cpumode_addr_location(struct thread *thread, u64 addr, in thread__find_cpumode_addr_location() argument
419 thread__find_symbol(thread, cpumodes[i], addr, al); in thread__find_cpumode_addr_location()
425 struct thread *thread__main_thread(struct machine *machine, struct thread *thread) in thread__main_thread() argument
427 if (thread->pid_ == thread->tid) in thread__main_thread()
428 return thread__get(thread); in thread__main_thread()
430 if (thread->pid_ == -1) in thread__main_thread()
433 return machine__find_thread(machine, thread->pid_, thread->pid_); in thread__main_thread()
436 int thread__memcpy(struct thread *thread, struct machine *machine, in thread__memcpy() argument
446 if (!thread__find_map(thread, cpumode, ip, &al) || !al.map->dso || in thread__memcpy()
458 void thread__free_stitch_list(struct thread *thread) in thread__free_stitch_list() argument
460 struct lbr_stitch *lbr_stitch = thread->lbr_stitch; in thread__free_stitch_list()
477 zfree(&thread->lbr_stitch); in thread__free_stitch_list()