comparison mercurial/hook.py @ 45737:b3e8d8e4a40d

hook: ignore EPIPE when flushing stdout/stderr

This fixes the bug described in the parent commit.
test-transaction-rollback-on-sigpipe.t is updated to show the new
behavior.

Differential Revision: https://phab.mercurial-scm.org/D9152

45736:2c6b054e22d0

# GNU General Public License version 2 or any later version.

from __future__ import absolute_import

import contextlib
import os
import sys

from .i18n import _
from .pycompat import getattr

    finally:
        # The stderr is fully buffered on Windows when connected to a pipe.
        # A forcible flush is required to make small stderr data in the
        # remote side available to the client immediately.
        procutil.stderr.flush()

        if _redirect and oldstdout >= 0:
            procutil.stdout.flush()  # write hook output to stderr fd
            os.dup2(oldstdout, stdoutno)
            os.close(oldstdout)


def runhooks(ui, repo, htype, hooks, throw=False, **args):

45737:b3e8d8e4a40d

# GNU General Public License version 2 or any later version.

from __future__ import absolute_import

import contextlib
import errno
import os
import sys

from .i18n import _
from .pycompat import getattr

    finally:
        # The stderr is fully buffered on Windows when connected to a pipe.
        # A forcible flush is required to make small stderr data in the
        # remote side available to the client immediately.
        try:
            procutil.stderr.flush()
        except IOError as err:
            if err.errno not in (errno.EPIPE, errno.EIO, errno.EBADF):
                raise error.StdioError(err)

        if _redirect and oldstdout >= 0:
            try:
                procutil.stdout.flush()  # write hook output to stderr fd
            except IOError as err:
                if err.errno not in (errno.EPIPE, errno.EIO, errno.EBADF):
                    raise error.StdioError(err)
            os.dup2(oldstdout, stdoutno)
            os.close(oldstdout)


def runhooks(ui, repo, htype, hooks, throw=False, **args):