Edit File: buffer.cpython-311.pyc
� �*vh� � �< � G d � de � � Z G d� d� � ZdS )c �0 � e Zd ZdZd� Zd� Zd� Zd� Zd� ZdS )� LineBufferz� Allows to accumulate data, and than iterate over it getting tokens split by line breaks ' '. If at the end there is no line break, the data will sit in the line buffer until more data with line break comes in. c � � d| _ d S �N� ��buf��selfs �Q/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/utils/buffer.py�__init__zLineBuffer.__init__ � � ������ c �& � | xj |z c_ d S �Nr �r �datas r �appendzLineBuffer.append s � � ���D�����r c � � | S r � r s r �__iter__zLineBuffer.__iter__ � � �� r c � � | j � d� � }|dk r(| j d|� }| j |dz d � | _ |S t �)N� ���� � )r �find� StopIteration)r �pos�results r �__next__zLineBuffer.__next__ sN � ��h�m�m�D�!�!�� �"�9�9��X�a��e�_�F��x��a�� � �*�D�H��M��r c � � d| _ d S r r r s r �cleanzLineBuffer.clean r r N) �__name__� __module__� __qualname__�__doc__r r r r! r# r r r r r si � � � � � �� �� � �� � �� � � � � �� � � � r r c �( � e Zd Zdd�Zd� Zd� Zd� ZdS )� SizeBuffer� c �" � d| _ || _ d S )Nr )�_buf� _size_len)r �size_lens r r zSizeBuffer.__init__ s � ��� �!����r c �& � | xj |z c_ d S r )r, r s r r zSizeBuffer.append# s � � � � �T�� � � � r c � � | S r r r s r r zSizeBuffer.__iter__& r r c �D � | j st �t � | j d | j � d� � }t | j | j d � � � |k r:| j | j | j |z � }| j | j |z d � | _ |S t �)N�big)r, r �int� from_bytesr- �len)r �sizer s r r! zSizeBuffer.__next__) s� � ��y� � � ��~�~�d�i�(8�$�.�(8� 9�5�A�A�� �t�y�� �)�)�*� +� +�t� 3� 3��9�T�^�d�n�t�.C� C�D�D� � �$�.�4�"7�"9�"9�:�D�I��K��r N)r* )r$ r% r& r r r r! r r r r) r) sU � � � � � �"� "� "� "�� � �� � � � � � � r r) N)�objectr r) r r r �<module>r8 sa ��� � � � �� � � �: � � � � � � � � � r
Back to File Manager