Method tasks_start

qiling/extensions/multitask.py:355–390

This will start emulation until all tasks get done. count: Stop after sceduling *count* times. <=0 disables this check. timeout: Stop after *timeout* ms. <=0 disables this check.

(self, count: int = 0, timeout: int = 0)

                super().emu_stop()

    def tasks_start(self, count: int = 0, timeout: int = 0):
        """ This will start emulation until all tasks get done.
            count: Stop after sceduling *count* times. <=0 disables this check.
            timeout: Stop after *timeout* ms. <=0 disables this check.
        """
        workset = [] # type: List[gevent.Greenlet]
        self._to_stop = False
        self._count = count

        if self._nested_started != 0:
            print("Warning: tasks_start is called inside an uc_emu_start!")
            return

        with NestedCounter(self):

            if self._count <= 0:
                self._count = 0

            if self._multitask_enabled:

                if timeout > 0:
                    workset.append(gevent.spawn(self._timeout_main, timeout))

                while len(self._tasks) != 0 and not self._to_stop:

                    new_workset = [ v for v in workset if not v.dead]

                    for utk_id in self._tasks:
                        new_workset.append(gevent.spawn(self._task_main, utk_id))

                    workset = new_workset

                    gevent.joinall(workset, raise_error=True)

                if len(self._tasks) == 0:
                    self._multitask_enabled = False