OwlCyberSecurity - MANAGER
Edit File: context.cpython-311.pyc
� �����/�gM-�����������������������0����d�dl�Z�d�dlZd�dlZddlmZ�ddlmZ�dZ�G�d��de������������Z�G�d��d e������������Z �G�d ��de������������Z �G�d��d e������������Z�G�d��de������������Z �G�d��dej��������������������Z�G�d��de ������������Zej��������dk����r��G�d��dej��������������������Z�G�d��dej��������������������Z�G�d��dej��������������������Z�G�d��de ������������Z�G�d��de ������������Z�G�d��d e ������������Z�e���������������e���������������e��������������d!�Zej��������d"k����r�eed#���������������������ZnP�eed$���������������������Zn>�G�d%��dej��������������������Z�G�d&��de ������������Zd#�e��������������iZ�eed#���������������������Zd'��Z�ej����������������������Zd(��Zd)��Zd*��ZdS�)+�����N����)�process)� reduction��c�������������������������e�Zd�ZdS�)�ProcessErrorN��__name__� __module__�__qualname__r���������>/opt/alt/python311/lib64/python3.11/multiprocessing/context.pyr���r����������������������Dr ���r���c�������������������������e�Zd�ZdS�)�BufferTooShortNr ���r���r ���r���r���r������r���r ���r���c�������������������������e�Zd�ZdS�)�TimeoutErrorNr ���r���r ���r���r���r������r���r ���r���c�������������������������e�Zd�ZdS�)�AuthenticationErrorNr ���r���r ���r���r���r������r���r ���r���c������������������������e�Zd�ZeZeZeZeZ�eej ��������������������Z �eej ��������������������Z �eej��������������������Zd��Zd��Z d&d�Zd��Zd��Zd'd�Zd(d �Zd(d�Zd��Zd)d �Zd*d�Zd*d�Zd��Z � �d+d�Zd��Zd��Zdd�d�Zdd�d�Zd��Zd��Zd'd�Z d��Z!d��Z"d��Z#d'd�Z$d,d!�Z%d,d"�Z&e'd#����������������Z(e(j)��������d$����������������Z(d%��Z*dS�)-�BaseContextc������������������N�����t����������j����������������������}|�t����������d�������������|S�)z(Returns the number of CPUs in the systemNzcannot determine number of cpus)�os� cpu_count�NotImplementedError)�self�nums��� r���r���zBaseContext.cpu_count)���s&�������l�n�n���;�%�&G�H�H�H��Jr ���c������������������v�����ddl�m}��||�������������������������������������������������}|������������������������������������|S�)z�Returns a manager associated with a running server process The managers methods such as `Lock()`, `Condition()` and `Queue()` can be used to create shared objects. r���)�SyncManager��ctx)�managersr����get_context�start)r���r����ms��� r����ManagerzBaseContext.Manager1���sF������� *�)�)�)�)�)��K�D�,�,�.�.�/�/�/�� ��� � � ��r ���Tc������������������$�����ddl�m}��||������������S�)z1Returns two connection object connected by a piper���)�Pipe)� connectionr(���)r����duplexr(���s��� r���r(���zBaseContext.Pipe<���s"������$�$�$�$�$�$��t�F�|�|�r ���c������������������J�����ddl�m}��||�������������������������������������������������S�)z#Returns a non-recursive lock objectr���)�Lockr ���)�synchronizer,���r#���)r���r,���s��� r���r,���zBaseContext.LockA���s3������%�%�%�%�%�%��t��(�(�*�*�+�+�+�+r ���c������������������J�����ddl�m}��||�������������������������������������������������S�)zReturns a recursive lock objectr���)�RLockr ���)r-���r/���r#���)r���r/���s��� r���r/���zBaseContext.RLockF����3������&�&�&�&�&�&��u��)�)�+�+�,�,�,�,r ���Nc������������������L�����ddl�m}��|||�������������������������������������������������S�)zReturns a condition objectr���)� Conditionr ���)r-���r2���r#���)r����lockr2���s��� r���r2���zBaseContext.ConditionK���s5������*�*�*�*�*�*��y��4�#3�#3�#5�#5�6�6�6�6r ���r���c������������������L�����ddl�m}��|||�������������������������������������������������S�)zReturns a semaphore objectr���)� Semaphorer ���)r-���r5���r#���)r����valuer5���s��� r���r5���zBaseContext.SemaphoreP���s5������*�*�*�*�*�*��y��D�$4�$4�$6�$6�7�7�7�7r ���c������������������L�����ddl�m}��|||�������������������������������������������������S�)z"Returns a bounded semaphore objectr���)�BoundedSemaphorer ���)r-���r8���r#���)r���r6���r8���s��� r���r8���zBaseContext.BoundedSemaphoreU���s6������1�1�1�1�1�1����4�+;�+;�+=�+=�>�>�>�>r ���c������������������J�����ddl�m}��||�������������������������������������������������S�)zReturns an event objectr���)�Eventr ���)r-���r:���r#���)r���r:���s��� r���r:���zBaseContext.EventZ���r0���r ���c������������������P�����ddl�m}��|||||�������������������������������������������������S�)zReturns a barrier objectr���)�Barrierr ���)r-���r<���r#���)r����parties�action�timeoutr<���s��� r���r<���zBaseContext.Barrier_���s9������(�(�(�(�(�(��w�w���T�5E�5E�5G�5G�H�H�H�Hr ���r���c������������������L�����ddl�m}��|||�������������������������������������������������S�)�Returns a queue objectr���)�Queuer ���)�queuesrB���r#���)r����maxsizerB���s��� r���rB���zBaseContext.Queued���s5������!�!�!�!�!�!��u�W�$�"2�"2�"4�"4�5�5�5�5r ���c������������������L�����ddl�m}��|||�������������������������������������������������S�)rA���r���)� JoinableQueuer ���)rC���rF���r#���)r���rD���rF���s��� r���rF���zBaseContext.JoinableQueuei���s5������)�)�)�)�)�)��}�W�$�*:�*:�*<�*<�=�=�=�=r ���c������������������J�����ddl�m}��||�������������������������������������������������S�)rA���r���)�SimpleQueuer ���)rC���rH���r#���)r���rH���s��� r���rH���zBaseContext.SimpleQueuen���s3������'�'�'�'�'�'��{�t�/�/�1�1�2�2�2�2r ���r���c������������������R�����ddl�m}��||||||�������������������������������������������������S�)zReturns a process pool objectr���)�Pool)�context)�poolrJ���r#���)r���� processes�initializer�initargs�maxtasksperchildrJ���s��� r���rJ���zBaseContext.Pools���sG������� �������t�I�{�H�6F� �,�,�.�.�0��0��0�� 0r ���c������������������ �����ddl�m}��||g|�R���S�)zReturns a shared objectr���)�RawValue)�sharedctypesrR���)r����typecode_or_type�argsrR���s��� r���rR���zBaseContext.RawValuez���s-������*�*�*�*�*�*��x�(�0�4�0�0�0�0r ���c������������������&�����ddl�m}��|||������������S�)zReturns a shared arrayr���)�RawArray)rS���rW���)r���rT����size_or_initializerrW���s��� r���rW���zBaseContext.RawArray���s(������*�*�*�*�*�*��x�(�*=�>�>�>r ���)r3���c�����������������L�����ddl�m}��||g|�R�||������������������������������������d��S�)z$Returns a synchronized shared objectr���)�Value�r3���r!���)rS���rZ���r#���)r���rT���r3���rU���rZ���s��� r���rZ���zBaseContext.Value����sR������'�'�'�'�'�'��u�%��-���-��-�4��)�)�+�+�-��-��-�� -r ���c�����������������P�����ddl�m}��|||||�������������������������������������������������S�)z#Returns a synchronized shared arrayr���)�Arrayr[���)rS���r]���r#���)r���rT���rX���r3���r]���s��� r���r]���zBaseContext.Array����sD������'�'�'�'�'�'��u�%�':���)�)�+�+�-��-��-�� -r ���c������������������z�����t�����������j��������dk����r(t����������t�����������dd������������rddlm}��|���������������dS�dS�dS�)z�Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. �win32�frozenFr���)�freeze_supportN)�sys�platform�getattr�spawnra���)r���ra���s��� r���ra���zBaseContext.freeze_support����sV��������<�7�"�"�w�s�H�e�'D�'D�"�-�-�-�-�-�-��N�������#�"�"�"r ���c������������������"�����ddl�m}��|��������������S�)zZReturn package logger -- if it does not already exist then it is created. r���)� get_logger)�utilrg���)r���rg���s��� r���rg���zBaseContext.get_logger����s"������� %�$�$�$�$�$��z�|�|�r ���c������������������$�����ddl�m}��||������������S�)z8Turn on logging and add a handler which prints to stderrr���)� log_to_stderr)rh���rj���)r����levelrj���s��� r���rj���zBaseContext.log_to_stderr����s$������'�'�'�'�'�'��}�U�#�#�#r ���c�����������������������ddl�m}�dS�)zVInstall support for sending connections and sockets between processes r���)r)���N)��r)���)r���r)���s��� r����allow_connection_picklingz%BaseContext.allow_connection_pickling����s������� !� � � � � � � r ���c������������������(�����ddl�m}��||�������������dS�)z�Sets the path to a python.exe or pythonw.exe binary used to run child processes instead of sys.executable when using the 'spawn' start method. Useful for people embedding Python. r���)�set_executableN)re���rp���)r���� executablerp���s��� r���rp���zBaseContext.set_executable����s,������ � *�)�)�)�)�)���z�"�"�"�"�"r ���c������������������(�����ddl�m}��||�������������dS�)zkSet list of module names to try to load in forkserver process. This is really just a hint. r���)�set_forkserver_preloadN)� forkserverrs���)r����module_namesrs���s��� r���rs���z"BaseContext.set_forkserver_preload����s-������� 7�6�6�6�6�6���|�,�,�,�,�,r ���c�����������������������|�|�S� �t�����������|���������}n!#�t����������$�r�t����������d|z��������������d��w�xY�w|������������������������������������|S�)Nzcannot find context for %r)�_concrete_contexts�KeyError� ValueError�_check_available)r����methodr!���s��� r���r#���zBaseContext.get_context����sj�������>��K� N�$�V�,�C�C���� N�� N�� N��9�F�B�C�C��M� N����������� s���� ��2Fc�����������������������|�j���������S��N)�_name�r���� allow_nones��� r����get_start_methodzBaseContext.get_start_method����s �������z�r ���c������������������ �����t����������d�������������)Nz+cannot set start method of concrete context)ry����r���r{����forces��� r����set_start_methodzBaseContext.set_start_method����s�������F�G�G�Gr ���c������������������D�����t���������������������������������������������d������������S�)z_Controls how objects will be reduced to a form that can be shared with other processes.r���)�globals�get�r���s��� r����reducerzBaseContext.reducer����s��������y�y�}�}�[�)�)�)r ���c������������������(�����|t������������������������d<���d�S�)Nr���)r����)r���r���s��� r���r����zBaseContext.reducer����s������!*�� � �+���r ���c�����������������������d�S�r}���r���r����s��� r���rz���zBaseContext._check_available����s�������r ���)Tr}���)r���)NN)r���)NNr���N�F)+r ���r���r���r���r���r���r����staticmethodr����current_process�parent_process�active_childrenr���r&���r(���r,���r/���r2���r5���r8���r:���r<���rB���rF���rH���rJ���rR���rW���rZ���r]���ra���rg���rj���rn���rp���rs���r#���r����r�����propertyr�����setterrz���r���r ���r���r���r������s���������������L�#�N��L�-��"�l�7�#:�;�;�O�!�\�'�"8�9�9�N�"�l�7�#:�;�;�O������ �� �� �������� ,��,��,� -��-��-� 7��7��7��7� 8��8��8��8� ?��?��?��?� -��-��-� I��I��I��I� 6��6��6��6� >��>��>��>� 3��3��3� �?A�"�0��0��0��0�1��1��1� ?��?��?� �37��-��-��-��-��-��DH��-��-��-��-��-�����������$��$��$��$� !��!��!�#��#��#�-��-��-���������������H��H��H��H���*��*���X�*� � �^�+��+���^�+� �� �� �� �� r ���r���c��������������������>�����e�Zd�ZdZed����������������Zed����������������ZdS�)�ProcessNc������������������d�����t����������������������������������������������j�����������������������������|�������������S�r}���)�_default_contextr#���r�����_Popen)�process_objs��� r���r����zProcess._Popen����s%�������+�+�-�-�5�<�<�[�I�I�Ir ���c�������������������b�����t����������������������������������������������j�������������������������������������������S�r}���)r����r#���r�����_after_forkr���r ���r���r����zProcess._after_fork����s#�������+�+�-�-�5�A�A�C�C�Cr ����r ���r���r���� _start_methodr����r����r����r���r ���r���r����r��������sU���������������M��J��J���\�J���D��D���\�D��D��Dr ���r����c��������������������@�������e�Zd�ZeZd��Zd��fd� Zd d�Zd d�Zd��Z��xZ S�) �DefaultContextc������������������"�����||�_���������d�|�_��������d�S�r}���)r�����_actual_context)r���rK���s��� r����__init__zDefaultContext.__init__����s������ '���#����r ���Nc������������������~������|�|�j����������|�j��������|�_���������|�j���������S�t���������������������������������������������|������������S�r}���)r����r�����superr#���)r���r{���� __class__s��� �r���r#���zDefaultContext.get_context����s=��������>��#�+�'+�'<��$��'�'��7�7�&�&�v�.�.�.r ���Fc�����������������������|�j����������|st����������d�������������|�|r d�|�_���������d�S�|����������������������|������������|�_���������d�S�)Nzcontext has already been set)r�����RuntimeErrorr#���r����s��� r���r����zDefaultContext.set_start_method����sQ��������+�E�+��=�>�>�>��>�e�>�#'�D� ��F�#�/�/��7�7����r ���c������������������H�����|�j����������|rd�S�|�j��������|�_���������|�j���������j��������S�r}���)r����r����r~���r���s��� r���r����zDefaultContext.get_start_method����s/��������'��� ��t�#'�#8�D� ��#�)�)r ���c�����������������������t�����������j��������dk����rdgS�t�����������j��������dk����rddgnddg}t����������j��������r|���������������������d�������������|S�)Nr_���re����darwin�forkrt���)rb���rc���r����HAVE_SEND_HANDLE�append)r����methodss��� r����get_all_start_methodsz$DefaultContext.get_all_start_methods��sZ�������<�7�"�"��9��+.�<�8�+C�+C�w��'�'�&�RY�IZ�G��)�� -����|�,�,�,��Nr ���r}���r����) r ���r���r���r����r����r#���r����r����r����� __classcell__)r����s���@r���r����r��������s�����������������G�$��$��$�/��/��/��/��/��/�8��8��8��8�*��*��*��*�������������r ���r����r_���c��������������������(�����e�Zd�ZdZed����������������ZdS�)�ForkProcessr����c������������������$�����ddl�m}��||�������������S��Nr���)�Popen)� popen_forkr�����r����r����s��� r���r����zForkProcess._Popen��s$������)�)�)�)�)�)��5��%�%�%r ���N�r ���r���r���r����r����r����r���r ���r���r����r������s2��������������� � � &�� &�� �� &�� &�� &r ���r����c��������������������>�����e�Zd�ZdZed����������������Zed����������������ZdS�)�SpawnProcessre���c������������������$�����ddl�m}��||�������������S�r����)�popen_spawn_posixr����r����s��� r���r����zSpawnProcess._Popen���$������0�0�0�0�0�0��5��%�%�%r ���c������������������������d�S�r}���r���r���r ���r���r����zSpawnProcess._after_fork"��� ������� �Dr ���Nr����r���r ���r���r����r�������M��������������� � � &�� &�� �� &�� � �� �� �� �� �� r ���r����c��������������������(�����e�Zd�ZdZed����������������ZdS�)�ForkServerProcessrt���c������������������$�����ddl�m}��||�������������S�r����)�popen_forkserverr����r����s��� r���r����zForkServerProcess._Popen)��s$������/�/�/�/�/�/��5��%�%�%r ���Nr����r���r ���r���r����r����'��s2��������������$� � � &�� &�� �� &�� &�� &r ���r����c�������������������������e�Zd�ZdZeZdS�)�ForkContextr����N)r ���r���r���r~���r����r����r���r ���r���r����r����.��s�������������������r ���r����c�������������������������e�Zd�ZdZeZdS���SpawnContextre���N�r ���r���r���r~���r����r����r���r ���r���r����r����2����������������������r ���r����c�������������������������e�Zd�ZdZeZd��ZdS�)�ForkServerContextrt���c������������������<�����t�����������j��������st����������d�������������d�S�)Nz%forkserver start method not available)r���r����ry���r����s��� r���rz���z"ForkServerContext._check_available9��s)�������-�� J� �!H�I�I�I� J�� Jr ���N)r ���r���r���r~���r����r����rz���r���r ���r���r����r����6��s2����������������#�� J�� J�� J�� J�� Jr ���r����)r����re���rt���r����re���r����c��������������������>�����e�Zd�ZdZed����������������Zed����������������ZdS�)r����re���c������������������$�����ddl�m}��||�������������S�r����)�popen_spawn_win32r����r����s��� r���r����zSpawnProcess._PopenM��r����r ���c������������������������d�S�r}���r���r���r ���r���r����zSpawnProcess._after_forkR��r����r ���Nr����r���r ���r���r����r����K��r����r ���c�������������������������e�Zd�ZdZeZdS�r����r����r���r ���r���r����r����W��r����r ���c������������������4�����t�����������|����������t����������_��������d�S�r}���)rw���r����r����)r{���s��� r����_force_start_methodr����d��s������'9�&�'A��$�$�$r ���c�������������������.�����t����������t����������dd�������������S�)N�spawning_popen)rd����_tlsr���r ���r����get_spawning_popenr����m��s�������4�)�4�0�0�0r ���c�����������������������|�t�����������_��������d�S�r}���)r����r����)�popens��� r����set_spawning_popenr����p��s�������D���r ���c������������������j�����t�������������������������$t����������dt����������|�������������j��������z���������������d�S�)NzF%s objects should only be shared between processes through inheritance)r����r�����typer ���)�objs��� r����assert_spawningr����s��s>���������#�� #�%)�#�Y�Y�%7� 8����� ��$�#r ���) r���rb���� threadingrm���r���r����__all__� Exceptionr���r���r���r����objectr����BaseProcessr����r����rc���r����r����r����r����r����r����rw���r����r�����localr����r����r����r����r���r ���r����<module>r�������s������ � � � �� � � � ��������������������������������� �� �� �� �� �� �9�� �� �� � �� �� �� �� �\�� �� �� � �� �� �� �� �<�� �� �� � �� �� �� �� �,�� �� �� �x ��x ��x ��x ��x �&��x ��x ��x �|D��D��D��D��D�g�!��D��D��D�%��%��%��%��%�[��%��%��%�X��<�7���&��&��&��&��&�g�)��&��&��&� �� �� �� �� �w�*�� �� �� �&��&��&��&��&�G�/��&��&��&����������k����������������{�������J��J��J��J��J�K��J��J��J���� � �����'�'�)�)����� ��|�x����*�>�*<�W�*E�F�F���)�>�*<�V�*D�E�E��� �� �� �� �� �w�*�� �� �� ����������{������� � ��������&�~�&8��&A�B�B��B��B��B���y�����1��1��1� �� �� ���������r ���