SIGCHLDEventHandler.handle()

Complexity

Conditions

4

Size

Total Lines

27

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes	1
Bugs	0	Features	0

"""
    @staticmethod
    def handle(_event, _event_data, spawner):
        """
        Handles an exit of a child and ends a job handler.

        :param * _event: Not used.
        :param * _event_data: Not used.
        :param enarksh.spawner.Spawner.Spawner spawner: The spawner.
        """
        del _event, _event_data

        try:
            pid = -1
            while pid != 0:
                pid, status = os.waitpid(-1, os.WNOHANG + os.WUNTRACED + os.WCONTINUED)
                if pid != 0:
                    job_handler = spawner.job_handlers[pid]

                    # Send message to controller that a job has finished.
                    message = JobFinishedMessage(job_handler.sch_id, job_handler.rnd_id, status)
                    message.send_message('controller')

                    # Inform the job handler the job has finished.
                    job_handler.set_job_has_finished()
        except OSError:
            # Ignore OSError. No more children to wait for.
            pass