Lines Matching refs:atoms
61 struct sched_atom **atoms;
245 task->atoms = realloc(task->atoms, size);
246 BUG_ON(!task->atoms);
248 task->atoms[idx] = event;
258 return task->atoms[task->nr_events - 1];
487 process_sched_event(this_task, this_task->atoms[i]);
927 struct work_atoms *atoms;
930 atoms = container_of(node, struct work_atoms, node);
932 cmp = thread_lat_cmp(sort_list, &key, atoms);
938 BUG_ON(thread != atoms->thread);
939 return atoms;
972 struct work_atoms *atoms = zalloc(sizeof(*atoms));
973 if (!atoms)
976 atoms->thread = thread;
977 INIT_LIST_HEAD(&atoms->work_list);
978 __thread_latency_insert(&atom_root, atoms, &cmp_pid);
1000 add_sched_out_event(struct work_atoms *atoms,
1015 list_add_tail(&atom->list, &atoms->work_list);
1019 add_runtime_event(struct work_atoms *atoms, u64 delta, u64 timestamp __used)
1023 BUG_ON(list_empty(&atoms->work_list));
1025 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
1028 atoms->total_runtime += delta;
1032 add_sched_in_event(struct work_atoms *atoms, u64 timestamp)
1037 if (list_empty(&atoms->work_list))
1040 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
1054 atoms->total_lat += delta;
1055 if (delta > atoms->max_lat) {
1056 atoms->max_lat = delta;
1057 atoms->max_lat_at = timestamp;
1059 atoms->nb_atoms++;
1124 struct work_atoms *atoms = thread_atoms_search(&atom_root, thread, &cmp_pid);
1127 if (!atoms) {
1129 atoms = thread_atoms_search(&atom_root, thread, &cmp_pid);
1130 if (!atoms)
1132 add_sched_out_event(atoms, 'R', timestamp);
1135 add_runtime_event(atoms, runtime_event->runtime, timestamp);
1146 struct work_atoms *atoms;
1155 atoms = thread_atoms_search(&atom_root, wakee, &cmp_pid);
1156 if (!atoms) {
1158 atoms = thread_atoms_search(&atom_root, wakee, &cmp_pid);
1159 if (!atoms)
1161 add_sched_out_event(atoms, 'S', timestamp);
1164 BUG_ON(list_empty(&atoms->work_list));
1166 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
1194 struct work_atoms *atoms;
1205 atoms = thread_atoms_search(&atom_root, migrant, &cmp_pid);
1206 if (!atoms) {
1209 atoms = thread_atoms_search(&atom_root, migrant, &cmp_pid);
1210 if (!atoms)
1212 add_sched_out_event(atoms, 'R', timestamp);
1215 BUG_ON(list_empty(&atoms->work_list));
1217 atom = list_entry(atoms->work_list.prev, struct work_atom, list);
1798 printf("run atoms optimized: %ld\n",
