comparison mercurial/worker.py @ 49231:4d42a5fb70bf

worker: add docstring to _blockingreader

49230:5d28246b9acc

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


class _blockingreader:
    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

            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)

49231:4d42a5fb70bf

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


class _blockingreader:
    """Wrap unbuffered stream such that pickle.load() works with it.

    pickle.load() expects that calls to read() and readinto() read as many
    bytes as requested. On EOF, it is fine to read fewer bytes. In this case,
    pickle.load() raises an EOFError.
    """

    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

            return pos

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

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

        buf = bytearray(size)