comparison mercurial/worker.py @ 32042:8f8ad0139b8b

worker: propagate exit code to main process

Follows up 86cd09bc13ba.

32041:38963a53ab0d

            def workerfunc():
                os.close(rfd)
                for i, item in func(*(staticargs + (pargs,))):
                    os.write(wfd, '%d %s\n' % (i, item))

            # make sure we use os._exit in all code paths. otherwise the worker
            # may do some clean-ups which could cause surprises like deadlock.
            # see sshpeer.cleanup for example.
            try:
                try:
                    scmutil.callcatch(ui, workerfunc)
                finally:
                    ui.flush()
            except KeyboardInterrupt:
                os._exit(255)
            except: # never return, therefore no re-raises

                    ui.traceback()
                    ui.flush()
                finally:
                    os._exit(255)
            else:
                os._exit(0)
        pids.add(pid)
    os.close(wfd)
    fp = os.fdopen(rfd, pycompat.sysstr('rb'), 0)
    def cleanup():
        signal.signal(signal.SIGINT, oldhandler)

32042:8f8ad0139b8b

            def workerfunc():
                os.close(rfd)
                for i, item in func(*(staticargs + (pargs,))):
                    os.write(wfd, '%d %s\n' % (i, item))
                return 0

            # make sure we use os._exit in all code paths. otherwise the worker
            # may do some clean-ups which could cause surprises like deadlock.
            # see sshpeer.cleanup for example.
            ret = 0
            try:
                try:
                    ret = scmutil.callcatch(ui, workerfunc)
                finally:
                    ui.flush()
            except KeyboardInterrupt:
                os._exit(255)
            except: # never return, therefore no re-raises

                    ui.traceback()
                    ui.flush()
                finally:
                    os._exit(255)
            else:
                os._exit(ret & 255)
        pids.add(pid)
    os.close(wfd)
    fp = os.fdopen(rfd, pycompat.sysstr('rb'), 0)
    def cleanup():
        signal.signal(signal.SIGINT, oldhandler)