o `j @s~ddlZddlmZzddlmZWn eydZYnwddZddZddd Z eZ edur3eZ e fd d Z d d Z dS)N)crc)crc32ccCs|d>|d?A}|dkr||dS|dkr&|d|d@B||d?dS|dkrD|d|d@B|d|d?d@B||d ?d S|d krl|d|d@B|d|d?d@B|d|d ?d@B||d ?d S|dkr|d|d@B|d|d?d@B|d|d ?d@B|d|d ?d@B||d?dS|d@}|dL}d}|r|d|B|d@}|dL}|d7}|s|||S)ad Encode an integer to a varint presentation. See https://developers.google.com/protocol-buffers/docs/encoding?csw=1#varints on how those can be produced. Arguments: value (int): Value to encode write (function): Called per byte that needs to be writen Returns: int: Number of bytes written ??r)valuewritebitsirrO/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/record/util.py encode_varint sJ      rcCs|d>|d?A}|dkrdS|dkrdS|dkrdS|dkr d S|d kr&d S|d kr,d S|dkr2dS|dkr8dS|dkr>dSdS)zL Number of bytes needed to encode an integer in variable-length format. rrrrr r r rrrrllr ll r)rrrrsize_of_varint?s(rcCs||}|d@s|d?|dfS|d@s|d?dA|dfS|dM}|d7}d} ||}||d@|>O}|d7}|d@sH|d?|d@ A|fS|d7}|dkrTtdq)) az Decode an integer from a varint presentation. See https://developers.google.com/protocol-buffers/docs/encoding?csw=1#varints on how those can be produced. Arguments: buffer (bytearray): buffer to read from. pos (int): optional position to read from Returns: (int, int): Decoded int value and next read position rrrr @zOut of int64 range) ValueError)bufferposresultshiftbrrr decode_varintXs$ r)cCs||S)zG Calculate CRC-32C (Castagnoli) checksum over a memoryview of data r)memview_crc32crrr calc_crc32c}sr,cCst|d@}|S)z@ Calculate simple CRC-32 checksum over a memoryview of data l)binasciicrc32)r*rrrr calc_crc32sr/)r) r-kafka.record._crc32cr crc32c_pyrcrc32c_c ImportErrorrrr)r+r,r/rrrrs  5