q&fBNddlZ ddlmZdZdZddZy#e$r ddlmZYwxYw) N)bser)pybserscd}t|}|dkDrK|jtj|zj ||}||dk(r|S||z }||z}|dkDrK|S)zRead 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)lenreadintoctypesc_char from_buffer)fpbufoffset remainingls A/usr/lib/python3/dist-packages/hgext/fsmonitor/pywatchman/load.py _read_bytesr)soFCI a- KK2??VL M 9QM! Q a- Mcbtjd}tt}tj|zj |}t ||}|t|krytj|}|t|kDrtj||tj|t|z zj |t|} t || }|t| kr tdtjtj|zj |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_HEADERr r rrpdu_lenresize RuntimeErrorloads) r mutablevalue_encoding value_errorsr SNIFF_BUFFER_SIZEheaderread_len total_lenbodys rloadr#As$  % %d +CL)mm// < r's7:! / 0)?! !s  $$