OwlCyberSecurity - MANAGER
Edit File: _android_support.cpython-313.opt-2.pyc
� ���g� � � � S SK r S SKrS SKJr S SKJrJr Sr\S- rS r " S S\ R 5 r " S S \ R 5 r S r S rS r " S S5 rg)� N)�RLock)�sleep�timei� � c � � [ R ( a g [ U 5 q[ US[ R R 5 5 [ l [ US[ R R 5 5 [ l g )Nz python.stdoutz python.stderr)�sys� executable�Logcat�logcat� TextLogStream�stdout�fileno�stderr)�android_log_write� stdout_prio� stderr_prios �7/opt/alt/python313/lib64/python3.13/_android_support.py� init_streamsr sY � � �~�~�� �%� &�F� ��_�c�j�j�&7�&7�&9�;�C�J� ��_�c�j�j�&7�&7�&9�;�C�J� c �T ^ � \ rS rSrS U 4S jjrS rS rS rS r\ S 5 r Sr U =r $ ) r �' c � >� UR SS5 UR SS5 [ TU ] " [ XU5 40 UD6 [ 5 U l / U l SU l g )N�encodingzUTF-8�errors�backslashreplacer )� setdefault�super�__init__�BinaryLogStreamr �_lock�_pending_bytes�_pending_bytes_count)�self�prio�tagr �kwargs� __class__s �r r �TextLogStream.__init__( sX �� � ���*�g�.����(�$6�7� ��� ��F�;�F�v�F��W�� � ���$%��!r c �8 � SU R R < S3$ )Nz<TextLogStream �>)�bufferr% �r# s r �__repr__�TextLogStream.__repr__4 s � � ���� � � 3�1�5�5r c � � [ U[ 5 ( d! [ S[ U5 R 35 e[ R U5 nU R UR SS9 H8 nU( d M US [ nU[ S nU R U5 U( a M, M: S S S 5 [ U5 $ ! , ( d f N= f)Nz"write() argument must be str, not T)�keepends) � isinstance�str� TypeError�type�__name__�__str__r � splitlines�MAX_CHARS_PER_WRITE� _write_chunk�len)r# �s�line�chunks r �write�TextLogStream.write7 s� � ��!�S�!�!��4�T�!�W�5E�5E�4F�G�I� I� �K�K��N�� �Z�Z�� � �d� �3���d� �!5�"5� 6�E� � 3� 4�5�D��%�%�e�,� �d� 4� � �1�v� � �Z�s �B7�4*B7� B7�7 Cc � � UR U R U R 5 nU R [ U5 - [ :� a U R 5 U R R U5 U =R [ U5 - sl U R ( d* UR S5 ( d U R [ :� a U R 5 g g )N� ) �encoder r r" r: �MAX_BYTES_PER_WRITE�flushr! �append� write_through�endswith)r# r; �bs r r9 �TextLogStream._write_chunkN s� � � �H�H�T�]�]�D�K�K� 0�� � $� $�s�1�v� -�0C� C� �J�J�L� ���"�"�1�%� �!�!�S��V�+�!� � � ��z�z�%� � ��(�(�+>�>� �J�J�L� ?r c � � U R U R R SR U R 5 5 U R R 5 SU l S S S 5 g ! , ( d f g = f)Nr r )r r+ r> �joinr! �clearr" r, s r rD �TextLogStream.flush\ sN � � �Z�Z� �K�K� � �c�h�h�t�':�':� ;� <� � � � %� %� '�()�D� %� �Z�Z�s �AA,�, A:c � � g�NT� r, s r �line_buffering� TextLogStream.line_bufferingd s � �r )r r! r" �N) r5 � __module__� __qualname__�__firstlineno__r r- r> r9 rD �propertyrQ �__static_attributes__� __classcell__)r' s @r r r ' s0 �� � &�6��. � *� �� �r r c �6 � \ rS rSrS S jrS rS rS rS rSr g) r �i Nc �( � Xl X l X0l g rS )r$ r% �_fileno)r# r$ r% r s r r �BinaryLogStream.__init__j s � �� ��� � r c �$ � SU R < S3$ )Nz<BinaryLogStream r* )r% r, s r r- �BinaryLogStream.__repr__o s � �"�4�8�8�,�a�0�0r c � � grO rP r, s r �writable�BinaryLogStream.writabler s � �r c �* � [ U5 [ La [ [ U5 5 nU( a+ [ R U R U R U5 [ U5 $ ! [ a# [ S[ U5 R 35 S ef = f)Nz)write() argument must be bytes-like, not ) r4 �bytes� memoryviewr3 r5 r r> r$ r% r: )r# rH s r r> �BinaryLogStream.writeu s} � � ��7�%� � ��*�Q�-�(�� � �L�L����D�H�H�a� 0��1�v� �� � � �?��Q��@P�@P�?Q�R��� � �s �A% �%-Bc �` � U R c [ R " S5 eU R $ )Nr )r] �io�UnsupportedOperationr, s r r �BinaryLogStream.fileno� s' � � �<�<� ��)�)�(�3� 3��|�|�r )r] r$ r% rS ) r5 rT rU rV r r- rb r> r rX rP r r r r i s � � � 1�� � r r i i � c � � \ rS rSrS rS rSrg)r � c �Z � Xl [ 5 U l SU l [ 5 U l g )Nr )r r r � _bucket_levelr �_prev_write_time)r# r s r r �Logcat.__init__� s# � �!2� ��W�� � ��� $��� r c � � UR SS5 nU R [ 5 nU =R X@R - [ - - sl [ S[ U R [ 5 5 U l X@l U =R [ [ U5 - [ U5 - - sl U R S: a [ U R * [ - 5 U R XU5 S S S 5 g ! , ( d f g = f)N� s ��r ) �replacer r rp rq �MAX_BYTES_PER_SECOND�max�min� BUCKET_SIZE�PER_MESSAGE_OVERHEADr: r r )r# r$ r% �message�nows r r> � Logcat.write� s� � � �/�/�'�;�7�� �Z�Z��&�C� � � ��,�,�,�0D�D� F� � "%�Q��D�,>�,>� �(L�!M�D� �$'� !� � � �"6��S��"A�C��L�"P� P� ��!�!�A�%��t�)�)�)�,@�@�A� � "� "�4�g� 6� �Z�Z�s �CC:�: D)rp r rq r N)r5 rT rU rV r r> rX rP r r r r � s � �'� 7r r )ri r � threadingr r r rC r8 r � TextIOWrapperr � RawIOBaser rv ry rz r rP r r �<module>r� sp �� � � � � � � *�Q�.� � ;�?�B�$�$� ?�D �b�l�l� �L #� � � � � �7� 7r