Lines Matching refs:task
256 def feed(self, task): argument
262 self._last_start = task.time_in(time_unit)
263 self._last_finish = task.time_out(time_unit)
265 self._time_in = task.time_in()
266 time_in = task.time_in(time_unit)
267 time_out = task.time_out(time_unit)
274 self._last_finish = task.time_out(time_unit)
275 self._last_start = task.time_in(time_unit)
412 for task in db["tid"][tid]:
413 pid = task.pid
414 comm = task.comm
416 runtimes.append(task.runtime(time_unit))
417 time_in.append(task.time_in())
418 timespans.feed(task)
637 def _print_task_finish(task): argument
648 if str(task.tid) in args.highlight_tasks_map:
649 c_row_set = _COLORS[args.highlight_tasks_map[str(task.tid)]]
651 if task.comm in args.highlight_tasks_map:
652 c_row_set = _COLORS[args.highlight_tasks_map[task.comm]]
659 if task.pid == task.tid:
662 if task.tid in db["tid"]:
664 last_tid_task = db["tid"][task.tid][-1]
669 timespan_gap_tid.feed(task)
677 line_out = fmt.format(c_row_set, task.time_in(), task.time_out(), task.cpu,
678 task.pid, c_tid_set, task.tid, c_tid_reset, c_row_set, task.comm,
679 task.runtime(time_unit), out_in, out_out, in_in, in_out,
682 line_out = fmt.format(c_row_set, task.time_in(), task.time_out(), task.cpu,
683 task.pid, c_tid_set, task.tid, c_tid_reset, c_row_set, task.comm,
684 task.runtime(time_unit), out_in, c_row_reset) + "\n"
700 def _record_by_tid(task): argument
701 tid = task.tid
704 db["tid"][tid].append(task)
708 def _record_by_cpu(task): argument
709 cpu = task.cpu
712 db["cpu"][cpu].append(task)
716 def _record_global(task): argument
718 db["global"].append(task)
733 task = db["running"][_id]
734 task.schedule_out_at(time)
740 task.update_pid(pid)
745 if not _limit_filtered(tid, pid, task.comm) and not args.summary_only:
746 _print_task_finish(task)
747 _record_by_tid(task)
748 _record_by_cpu(task)
749 _record_global(task)
765 task = Task(_id, tid, cpu, comm)
766 task.schedule_in_at(time)
767 db["running"][_id] = task