o

�]Lb��@sfdd
lm
Z
mZmZ
ddlZzddlmZ
Wney%


ddlmZ
Yn
wdZ	dd�Z
dd
d�
ZdS)
�)�absolute_import�division�print_functionN�
)
�bser)
�pybsers
cCs\d
}t|
�
}|d
kr,|�
tj|�|
|��
}|dus|d
kr |S||7}||8}|d
ks
|S)z�Read bytes from a file-like object

    @param fp: File-like object that implements read(int)
    @type fp: file

    @param buf: Buffer to read into
    @type buf: bytes

    @return: buf
    r
N)�len�readinto�ctypes�c_char�from_buffer)�fp�buf�offset�	remaining�
l�r�A/usr/lib/python3/dist-packages/hgext/fsmonitor/pywatchman/load.py�_read_bytes,s







�rTc
Cs�t�
d
�
}tt�
}tj|�|�
}t||�}|t|�
krdSt�|�
}|t|�
kr/t�	||�
tj|t|�
�|t|�
�}	t||	�}|t|	�
krMt
d�
�
t�tj|�|d�|
||�S)atDeserialize a BSER-encoded blob.

    @param fp: The file-object to deserialize.
    @type file:

    @param mutable: Whether to return mutable results.
    @type mutable: bool

    @param value_encoding: Optional codec to use to decode values. If
                           unspecified or None, return values as bytestrings.
    @type value_encoding: str

    @param value_errors: Optional error handler for codec. 'strict' by default.
                         The other most common argument is 'surrogateescape' on
                         Python 3. If value_encoding is None, this is ignored.
    @type value_errors: str
    i Nzbser data ended earlyr
)r
�create_string_bufferr�EMPTY_HEADERrrrr�pdu_len�resize�RuntimeError�loads)
r
�mutable�value_encoding�value_errorsr�SNIFF_BUFFER_SIZE�header�read_len�	total_len�bodyrrr�loadDs*










�






�r#)TNN)�
__future__rrrr
�r�ImportErrorrrrr#rrrr�<module>
s


�