Lines Matching refs:threads

52 	struct thread_map *threads;  in thread_map__new_by_pid()  local
63 threads = thread_map__alloc(items); in thread_map__new_by_pid()
64 if (threads != NULL) { in thread_map__new_by_pid()
66 thread_map__set_pid(threads, i, atoi(namelist[i]->d_name)); in thread_map__new_by_pid()
67 threads->nr = items; in thread_map__new_by_pid()
68 atomic_set(&threads->refcnt, 1); in thread_map__new_by_pid()
75 return threads; in thread_map__new_by_pid()
80 struct thread_map *threads = thread_map__alloc(1); in thread_map__new_by_tid() local
82 if (threads != NULL) { in thread_map__new_by_tid()
83 thread_map__set_pid(threads, 0, tid); in thread_map__new_by_tid()
84 threads->nr = 1; in thread_map__new_by_tid()
85 atomic_set(&threads->refcnt, 1); in thread_map__new_by_tid()
88 return threads; in thread_map__new_by_tid()
97 struct thread_map *threads = thread_map__alloc(max_threads); in thread_map__new_by_uid() local
99 if (threads == NULL) in thread_map__new_by_uid()
106 threads->nr = 0; in thread_map__new_by_uid()
107 atomic_set(&threads->refcnt, 1); in thread_map__new_by_uid()
131 while (threads->nr + items >= max_threads) { in thread_map__new_by_uid()
139 tmp = thread_map__realloc(threads, max_threads); in thread_map__new_by_uid()
143 threads = tmp; in thread_map__new_by_uid()
147 thread_map__set_pid(threads, threads->nr + i, in thread_map__new_by_uid()
155 threads->nr += items; in thread_map__new_by_uid()
161 return threads; in thread_map__new_by_uid()
164 free(threads); in thread_map__new_by_uid()
173 zfree(&threads); in thread_map__new_by_uid()
190 struct thread_map *threads = NULL, *nt; in thread_map__new_by_pid_str() local
220 nt = thread_map__realloc(threads, total_tasks); in thread_map__new_by_pid_str()
224 threads = nt; in thread_map__new_by_pid_str()
227 thread_map__set_pid(threads, j++, atoi(namelist[i]->d_name)); in thread_map__new_by_pid_str()
230 threads->nr = total_tasks; in thread_map__new_by_pid_str()
236 if (threads) in thread_map__new_by_pid_str()
237 atomic_set(&threads->refcnt, 1); in thread_map__new_by_pid_str()
238 return threads; in thread_map__new_by_pid_str()
246 zfree(&threads); in thread_map__new_by_pid_str()
252 struct thread_map *threads = thread_map__alloc(1); in thread_map__new_dummy() local
254 if (threads != NULL) { in thread_map__new_dummy()
255 thread_map__set_pid(threads, 0, -1); in thread_map__new_dummy()
256 threads->nr = 1; in thread_map__new_dummy()
257 atomic_set(&threads->refcnt, 1); in thread_map__new_dummy()
259 return threads; in thread_map__new_dummy()
264 struct thread_map *threads = NULL, *nt; in thread_map__new_by_tid_str() local
291 nt = thread_map__realloc(threads, ntasks); in thread_map__new_by_tid_str()
296 threads = nt; in thread_map__new_by_tid_str()
297 thread_map__set_pid(threads, ntasks - 1, tid); in thread_map__new_by_tid_str()
298 threads->nr = ntasks; in thread_map__new_by_tid_str()
301 if (threads) in thread_map__new_by_tid_str()
302 atomic_set(&threads->refcnt, 1); in thread_map__new_by_tid_str()
303 return threads; in thread_map__new_by_tid_str()
306 zfree(&threads); in thread_map__new_by_tid_str()
322 static void thread_map__delete(struct thread_map *threads) in thread_map__delete() argument
324 if (threads) { in thread_map__delete()
327 WARN_ONCE(atomic_read(&threads->refcnt) != 0, in thread_map__delete()
329 for (i = 0; i < threads->nr; i++) in thread_map__delete()
330 free(thread_map__comm(threads, i)); in thread_map__delete()
331 free(threads); in thread_map__delete()
348 size_t thread_map__fprintf(struct thread_map *threads, FILE *fp) in thread_map__fprintf() argument
352 threads->nr, threads->nr > 1 ? "s" : ""); in thread_map__fprintf()
353 for (i = 0; i < threads->nr; ++i) in thread_map__fprintf()
354 printed += fprintf(fp, "%s%d", i ? ", " : "", thread_map__pid(threads, i)); in thread_map__fprintf()
404 void thread_map__read_comms(struct thread_map *threads) in thread_map__read_comms() argument
408 for (i = 0; i < threads->nr; ++i) in thread_map__read_comms()
409 comm_init(threads, i); in thread_map__read_comms()