Lines Matching refs:atoms
43 struct sched_atom **atoms; member
251 task->atoms = realloc(task->atoms, size); in get_new_event()
252 BUG_ON(!task->atoms); in get_new_event()
254 task->atoms[idx] = event; in get_new_event()
264 return task->atoms[task->nr_events - 1]; in last_event()
528 perf_sched__process_event(sched, this_task->atoms[i]); in thread_func()
818 struct work_atoms *atoms; in thread_atoms_search() local
821 atoms = container_of(node, struct work_atoms, node); in thread_atoms_search()
823 cmp = thread_lat_cmp(sort_list, &key, atoms); in thread_atoms_search()
829 BUG_ON(thread != atoms->thread); in thread_atoms_search()
830 return atoms; in thread_atoms_search()
863 struct work_atoms *atoms = zalloc(sizeof(*atoms)); in thread_atoms_insert() local
864 if (!atoms) { in thread_atoms_insert()
869 atoms->thread = thread__get(thread); in thread_atoms_insert()
870 INIT_LIST_HEAD(&atoms->work_list); in thread_atoms_insert()
871 __thread_latency_insert(&sched->atom_root, atoms, &sched->cmp_pid); in thread_atoms_insert()
883 add_sched_out_event(struct work_atoms *atoms, in add_sched_out_event() argument
900 list_add_tail(&atom->list, &atoms->work_list); in add_sched_out_event()
905 add_runtime_event(struct work_atoms *atoms, u64 delta, in add_runtime_event() argument
910 BUG_ON(list_empty(&atoms->work_list)); in add_runtime_event()
912 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in add_runtime_event()
915 atoms->total_runtime += delta; in add_runtime_event()
919 add_sched_in_event(struct work_atoms *atoms, u64 timestamp) in add_sched_in_event() argument
924 if (list_empty(&atoms->work_list)) in add_sched_in_event()
927 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in add_sched_in_event()
941 atoms->total_lat += delta; in add_sched_in_event()
942 if (delta > atoms->max_lat) { in add_sched_in_event()
943 atoms->max_lat = delta; in add_sched_in_event()
944 atoms->max_lat_at = timestamp; in add_sched_in_event()
946 atoms->nb_atoms++; in add_sched_in_event()
1022 struct work_atoms *atoms = thread_atoms_search(&sched->atom_root, thread, &sched->cmp_pid); in latency_runtime_event() local
1027 if (!atoms) { in latency_runtime_event()
1030 atoms = thread_atoms_search(&sched->atom_root, thread, &sched->cmp_pid); in latency_runtime_event()
1031 if (!atoms) { in latency_runtime_event()
1035 if (add_sched_out_event(atoms, 'R', timestamp)) in latency_runtime_event()
1039 add_runtime_event(atoms, runtime, timestamp); in latency_runtime_event()
1049 struct work_atoms *atoms; in latency_wakeup_event() local
1055 atoms = thread_atoms_search(&sched->atom_root, wakee, &sched->cmp_pid); in latency_wakeup_event()
1056 if (!atoms) { in latency_wakeup_event()
1059 atoms = thread_atoms_search(&sched->atom_root, wakee, &sched->cmp_pid); in latency_wakeup_event()
1060 if (!atoms) { in latency_wakeup_event()
1064 if (add_sched_out_event(atoms, 'S', timestamp)) in latency_wakeup_event()
1068 BUG_ON(list_empty(&atoms->work_list)); in latency_wakeup_event()
1070 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_wakeup_event()
1104 struct work_atoms *atoms; in latency_migrate_task_event() local
1115 atoms = thread_atoms_search(&sched->atom_root, migrant, &sched->cmp_pid); in latency_migrate_task_event()
1116 if (!atoms) { in latency_migrate_task_event()
1120 atoms = thread_atoms_search(&sched->atom_root, migrant, &sched->cmp_pid); in latency_migrate_task_event()
1121 if (!atoms) { in latency_migrate_task_event()
1125 if (add_sched_out_event(atoms, 'R', timestamp)) in latency_migrate_task_event()
1129 BUG_ON(list_empty(&atoms->work_list)); in latency_migrate_task_event()
1131 atom = list_entry(atoms->work_list.prev, struct work_atom, list); in latency_migrate_task_event()