Lines Matching refs:atoms
43 struct sched_atom **atoms; member
253 task->atoms = realloc(task->atoms, size); in get_new_event()
254 BUG_ON(!task->atoms); in get_new_event()
256 task->atoms[idx] = event; in get_new_event()
266 return task->atoms[task->nr_events - 1]; in last_event()
530 perf_sched__process_event(sched, this_task->atoms[i]); in thread_func()
823 struct work_atoms *atoms; in thread_atoms_search() local
826 atoms = container_of(node, struct work_atoms, node); in thread_atoms_search()
828 cmp = thread_lat_cmp(sort_list, &key, atoms); in thread_atoms_search()
834 BUG_ON(thread != atoms->thread); in thread_atoms_search()
835 return atoms; in thread_atoms_search()
868 struct work_atoms *atoms = zalloc(sizeof(*atoms)); in thread_atoms_insert() local
869 if (!atoms) { in thread_atoms_insert()
874 atoms->thread = thread__get(thread); in thread_atoms_insert()
875 INIT_LIST_HEAD(&atoms->work_list); in thread_atoms_insert()
876 __thread_latency_insert(&sched->atom_root, atoms, &sched->cmp_pid); in thread_atoms_insert()
888 add_sched_out_event(struct work_atoms *atoms, in add_sched_out_event() argument
905 list_add_tail(&atom->list, &atoms->work_list); in add_sched_out_event()
910 add_runtime_event(struct work_atoms *atoms, u64 delta, in add_runtime_event() argument
915 BUG_ON(list_empty(&atoms->work_list)); in add_runtime_event()
917 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in add_runtime_event()
920 atoms->total_runtime += delta; in add_runtime_event()
924 add_sched_in_event(struct work_atoms *atoms, u64 timestamp) in add_sched_in_event() argument
929 if (list_empty(&atoms->work_list)) in add_sched_in_event()
932 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in add_sched_in_event()
946 atoms->total_lat += delta; in add_sched_in_event()
947 if (delta > atoms->max_lat) { in add_sched_in_event()
948 atoms->max_lat = delta; in add_sched_in_event()
949 atoms->max_lat_at = timestamp; in add_sched_in_event()
951 atoms->nb_atoms++; in add_sched_in_event()
1032 struct work_atoms *atoms = thread_atoms_search(&sched->atom_root, thread, &sched->cmp_pid); in latency_runtime_event() local
1040 if (!atoms) { in latency_runtime_event()
1043 atoms = thread_atoms_search(&sched->atom_root, thread, &sched->cmp_pid); in latency_runtime_event()
1044 if (!atoms) { in latency_runtime_event()
1048 if (add_sched_out_event(atoms, 'R', timestamp)) in latency_runtime_event()
1052 add_runtime_event(atoms, runtime, timestamp); in latency_runtime_event()
1065 struct work_atoms *atoms; in latency_wakeup_event() local
1074 atoms = thread_atoms_search(&sched->atom_root, wakee, &sched->cmp_pid); in latency_wakeup_event()
1075 if (!atoms) { in latency_wakeup_event()
1078 atoms = thread_atoms_search(&sched->atom_root, wakee, &sched->cmp_pid); in latency_wakeup_event()
1079 if (!atoms) { in latency_wakeup_event()
1083 if (add_sched_out_event(atoms, 'S', timestamp)) in latency_wakeup_event()
1087 BUG_ON(list_empty(&atoms->work_list)); in latency_wakeup_event()
1089 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_wakeup_event()
1127 struct work_atoms *atoms; in latency_migrate_task_event() local
1141 atoms = thread_atoms_search(&sched->atom_root, migrant, &sched->cmp_pid); in latency_migrate_task_event()
1142 if (!atoms) { in latency_migrate_task_event()
1146 atoms = thread_atoms_search(&sched->atom_root, migrant, &sched->cmp_pid); in latency_migrate_task_event()
1147 if (!atoms) { in latency_migrate_task_event()
1151 if (add_sched_out_event(atoms, 'R', timestamp)) in latency_migrate_task_event()
1155 BUG_ON(list_empty(&atoms->work_list)); in latency_migrate_task_event()
1157 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_migrate_task_event()