hgext/fsmonitor/pywatchman/pybser.py

49847:31bbf7a28a75

BSER_NULL = b"\x0a"
BSER_TEMPLATE = b"\x0b"
BSER_SKIP = b"\x0c"
BSER_UTF8STRING = b"\x0d"

if compat.PYTHON3:
    STRING_TYPES = (str, bytes)
    unicode = str

    def tobytes(i):
        return str(i).encode("ascii")

    long = int
else:
    STRING_TYPES = (unicode, str)
    tobytes = bytes

# Leave room for the serialization header, which includes
# our overall length.  To make things simpler, we'll use an
# int32 for the header
EMPTY_HEADER = b"\x00\x01\x05\x00\x00\x00\x00"

def _buf_pos(buf, pos):
    ret = buf[pos]
    # Normalize the return type to bytes
    if compat.PYTHON3 and not isinstance(ret, bytes):
        ret = bytes((ret,))
    return ret


class _bser_buffer:

                    val_len,
                )
            else:
                raise RuntimeError("Cannot represent this mapping value")
            self.wpos += needed
            if compat.PYTHON3:
                iteritems = val.items()
            else:
                iteritems = val.iteritems()  # noqa: B301 Checked version above
            for k, v in iteritems:
                self.append_string(k)
                self.append_recursive(v)
        elif isinstance(val, abc.Iterable) and isinstance(val, abc.Sized):
            val_len = len(val)

49848:139f713010ea

BSER_NULL = b"\x0a"
BSER_TEMPLATE = b"\x0b"
BSER_SKIP = b"\x0c"
BSER_UTF8STRING = b"\x0d"

STRING_TYPES = (str, bytes)
unicode = str


def tobytes(i):
    return str(i).encode("ascii")


long = int

# Leave room for the serialization header, which includes
# our overall length.  To make things simpler, we'll use an
# int32 for the header
EMPTY_HEADER = b"\x00\x01\x05\x00\x00\x00\x00"

def _buf_pos(buf, pos):
    ret = buf[pos]
    # Normalize the return type to bytes
    if not isinstance(ret, bytes):
        ret = bytes((ret,))
    return ret


class _bser_buffer:

                    val_len,
                )
            else:
                raise RuntimeError("Cannot represent this mapping value")
            self.wpos += needed
            iteritems = val.items()
            for k, v in iteritems:
                self.append_string(k)
                self.append_recursive(v)
        elif isinstance(val, abc.Iterable) and isinstance(val, abc.Sized):
            val_len = len(val)