Lines Matching refs:atoms
41 struct sched_atom **atoms;
254 task->atoms = realloc(task->atoms, size);
255 BUG_ON(!task->atoms);
257 task->atoms[idx] = event;
267 return task->atoms[task->nr_events - 1];
497 perf_sched__process_event(sched, this_task->atoms[i]);
790 struct work_atoms *atoms;
793 atoms = container_of(node, struct work_atoms, node);
795 cmp = thread_lat_cmp(sort_list, &key, atoms);
801 BUG_ON(thread != atoms->thread);
802 return atoms;
835 struct work_atoms *atoms = zalloc(sizeof(*atoms));
836 if (!atoms) {
841 atoms->thread = thread;
842 INIT_LIST_HEAD(&atoms->work_list);
843 __thread_latency_insert(&sched->atom_root, atoms, &sched->cmp_pid);
855 add_sched_out_event(struct work_atoms *atoms,
872 list_add_tail(&atom->list, &atoms->work_list);
877 add_runtime_event(struct work_atoms *atoms, u64 delta,
882 BUG_ON(list_empty(&atoms->work_list));
884 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
887 atoms->total_runtime += delta;
891 add_sched_in_event(struct work_atoms *atoms, u64 timestamp)
896 if (list_empty(&atoms->work_list))
899 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
913 atoms->total_lat += delta;
914 if (delta > atoms->max_lat) {
915 atoms->max_lat = delta;
916 atoms->max_lat_at = timestamp;
918 atoms->nb_atoms++;
994 struct work_atoms *atoms = thread_atoms_search(&sched->atom_root, thread, &sched->cmp_pid);
999 if (!atoms) {
1002 atoms = thread_atoms_search(&sched->atom_root, thread, &sched->cmp_pid);
1003 if (!atoms) {
1007 if (add_sched_out_event(atoms, 'R', timestamp))
1011 add_runtime_event(atoms, runtime, timestamp);
1022 struct work_atoms *atoms;
1032 atoms = thread_atoms_search(&sched->atom_root, wakee, &sched->cmp_pid);
1033 if (!atoms) {
1036 atoms = thread_atoms_search(&sched->atom_root, wakee, &sched->cmp_pid);
1037 if (!atoms) {
1041 if (add_sched_out_event(atoms, 'S', timestamp))
1045 BUG_ON(list_empty(&atoms->work_list));
1047 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
1075 struct work_atoms *atoms;
1086 atoms = thread_atoms_search(&sched->atom_root, migrant, &sched->cmp_pid);
1087 if (!atoms) {
1091 atoms = thread_atoms_search(&sched->atom_root, migrant, &sched->cmp_pid);
1092 if (!atoms) {
1096 if (add_sched_out_event(atoms, 'R', timestamp))
1100 BUG_ON(list_empty(&atoms->work_list));
1102 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
1595 printf("run atoms optimized: %ld\n",
