comparison mercurial/worker.py @ 49217:13dfad0f9f7a

branching: merge stable into default

49212:d3d3495a5749

    return min(max(countcpus(), 4), 32)


def ismainthread():
    return threading.current_thread() == threading.main_thread()


class _blockingreader:
    def __init__(self, wrapped):
        self._wrapped = wrapped

49217:13dfad0f9f7a

    return min(max(countcpus(), 4), 32)


def ismainthread():
    return threading.current_thread() == threading.main_thread()


class _blockingreader(object):
    def __init__(self, wrapped):
        self._wrapped = wrapped

    # Do NOT implement readinto() by making it delegate to
    # _wrapped.readinto(), since that is unbuffered. The unpickler is fine
    # with just read() and readline(), so we don't need to implement it.

    if (3, 8, 0) <= sys.version_info[:3] < (3, 8, 2):

        # This is required for python 3.8, prior to 3.8.2.  See issue6444.
        def readinto(self, b):
            pos = 0
            size = len(b)

            while pos < size:
                ret = self._wrapped.readinto(b[pos:])
                if not ret:
                    break
                pos += ret

            return pos

    def readline(self):
        return self._wrapped.readline()

    # issue multiple reads until size is fulfilled
    def read(self, size=-1):
        if size < 0:
            return self._wrapped.readall()

        buf = bytearray(size)
        view = memoryview(buf)
        pos = 0

        while pos < size:
            ret = self._wrapped.readinto(view[pos:])
            if not ret:
                break
            pos += ret

        del view
        del buf[pos:]
        return bytes(buf)


class _blockingreader:
    def __init__(self, wrapped):
        self._wrapped = wrapped