mercurial/worker.py

48945:55d132525155

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

48946:642e31cb55f0

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