⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.145
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib64
/
python3.9
/
multiprocessing
/
__pycache__
/
View File Name :
context.cpython-39.opt-1.pyc
a �����DOg�+����������������������@���s���d�dl�Z�d�dlZd�dlZddlmZ�ddlmZ�dZG�dd��de�ZG�dd ��d e�Z G�d d��de�Z G�dd ��d e�ZG�dd��de�Z G�dd��dej�ZG�dd��de �Zejdk�rRG�dd��dej�ZG�dd��dej�ZG�dd��dej�ZG�dd��de �ZG�dd��de �ZG�dd ��d e �Ze��e��e��d!�Zejd"k�rDeed#��Zneed$��Zn8G�d%d��dej�ZG�d&d��de �Zd#e��iZeed#��Zd'd(��Ze���Zd)d*��Zd+d,��Zd-d.��ZdS�)/�����N����)�process)� reduction��c�������������������@���s���e�Zd�ZdS�)�ProcessErrorN��__name__� __module__�__qualname__r���r���r����//usr/lib64/python3.9/multiprocessing/context.pyr������s���r���c�������������������@���s���e�Zd�ZdS�)�BufferTooShortNr���r���r���r���r���r������s���r���c�������������������@���s���e�Zd�ZdS�)�TimeoutErrorNr���r���r���r���r���r ������s���r ���c�������������������@���s���e�Zd�ZdS�)�AuthenticationErrorNr���r���r���r���r���r������s���r���c�������������������@���sX��e�Zd�ZeZeZeZeZeej �Z eej �Z eej�Zdd��Zdd��Z dCdd�Zdd ��Zd d��ZdDd d�ZdEdd�ZdFdd�Zdd��ZdGdd�ZdHdd�ZdIdd�Zdd��ZdJd d!�Zd"d#��Zd$d%��Zdd&�d'd(�Zdd&�d)d*�Zd+d,��Zd-d.��ZdKd/d0�Z d1d2��Z!d3d4��Z"d5d6��Z#dLd7d8�Z$dMd:d;�Z%dNd<d=�Z&e'd>d?���Z(e(j)d@d?���Z(dAdB��Z*dS�)O�BaseContextc�����������������C���s"���t����}|du�rtd��n|S�dS�)z(Returns the number of CPUs in the systemNzcannot determine number of cpus)�os� cpu_count�NotImplementedError)�self�numr���r���r���r���)���s���� zBaseContext.cpu_countc�����������������C���s&���ddl�m}�||����d�}|����|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����mr���r���r����Manager1���s����zBaseContext.ManagerTc�����������������C���s���ddl�m}�||�S�)z1Returns two connection object connected by a piper���)�Pipe)� connectionr���)r����duplexr���r���r���r���r���<���s����zBaseContext.Pipec�����������������C���s���ddl�m}�||����d�S�)z#Returns a non-recursive lock objectr���)�Lockr���)�synchronizer ���r���)r���r ���r���r���r���r ���A���s����zBaseContext.Lockc�����������������C���s���ddl�m}�||����d�S�)zReturns a recursive lock objectr���)�RLockr���)r!���r"���r���)r���r"���r���r���r���r"���F���s����zBaseContext.RLockNc�����������������C���s���ddl�m}�|||����d�S�)zReturns a condition objectr���)� Conditionr���)r!���r#���r���)r����lockr#���r���r���r���r#���K���s����zBaseContext.Conditionr���c�����������������C���s���ddl�m}�|||����d�S�)zReturns a semaphore objectr���)� Semaphorer���)r!���r%���r���)r����valuer%���r���r���r���r%���P���s����zBaseContext.Semaphorec�����������������C���s���ddl�m}�|||����d�S�)z"Returns a bounded semaphore objectr���)�BoundedSemaphorer���)r!���r'���r���)r���r&���r'���r���r���r���r'���U���s����zBaseContext.BoundedSemaphorec�����������������C���s���ddl�m}�||����d�S�)zReturns an event objectr���)�Eventr���)r!���r(���r���)r���r(���r���r���r���r(���Z���s����zBaseContext.Eventc�����������������C���s ���ddl�m}�|||||����d�S�)zReturns a barrier objectr���)�Barrierr���)r!���r)���r���)r����parties�action�timeoutr)���r���r���r���r)���_���s����zBaseContext.Barrierr���c�����������������C���s���ddl�m}�|||����d�S�)�Returns a queue objectr���)�Queuer���)�queuesr.���r���)r����maxsizer.���r���r���r���r.���d���s����zBaseContext.Queuec�����������������C���s���ddl�m}�|||����d�S�)r-���r���)� JoinableQueuer���)r/���r1���r���)r���r0���r1���r���r���r���r1���i���s����zBaseContext.JoinableQueuec�����������������C���s���ddl�m}�||����d�S�)r-���r���)�SimpleQueuer���)r/���r2���r���)r���r2���r���r���r���r2���n���s����zBaseContext.SimpleQueuer���c�����������������C���s"���ddl�m}�||||||����d�S�)zReturns a process pool objectr���)�Pool)�context)�poolr3���r���)r���� processes�initializer�initargs�maxtasksperchildr3���r���r���r���r3���s���s���� �zBaseContext.Poolc�����������������G���s���ddl�m}�||g|�R���S�)zReturns a shared objectr���)�RawValue)�sharedctypesr:���)r����typecode_or_type�argsr:���r���r���r���r:���z���s����zBaseContext.RawValuec�����������������C���s���ddl�m}�|||�S�)zReturns a shared arrayr���)�RawArray)r;���r>���)r���r<����size_or_initializerr>���r���r���r���r>������s����zBaseContext.RawArray)r$���c����������������G���s(���ddl�m}�||g|�R�||����d��S�)z$Returns a synchronized shared objectr���)�Value�r$���r���)r;���r@���r���)r���r<���r$���r=���r@���r���r���r���r@�������s�����zBaseContext.Valuec����������������C���s ���ddl�m}�|||||����d�S�)z#Returns a synchronized shared arrayr���)�ArrayrA���)r;���rB���r���)r���r<���r?���r$���rB���r���r���r���rB�������s�����zBaseContext.Arrayc�����������������C���s,���t�jdkr(tt�dd�r(ddlm}�|���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�spawnrE���)r���rE���r���r���r���rE�������s����zBaseContext.freeze_supportc�����������������C���s���ddl�m}�|��S�)zZReturn package logger -- if it does not already exist then it is created. r���)� get_logger)�utilrJ���)r���rJ���r���r���r���rJ�������s����zBaseContext.get_loggerc�����������������C���s���ddl�m}�||�S�)z8Turn on logging and add a handler which prints to stderrr���)� log_to_stderr)rK���rL���)r����levelrL���r���r���r���rL�������s����zBaseContext.log_to_stderrc�����������������C���s���ddl�m}�dS�)zVInstall support for sending connections and sockets between processes r���)r���N)��r���)r���r���r���r���r����allow_connection_pickling����s����z%BaseContext.allow_connection_picklingc�����������������C���s���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)rI���rP���)r���� executablerP���r���r���r���rP�������s����zBaseContext.set_executablec�����������������C���s���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)� forkserverrR���)r����module_namesrR���r���r���r���rR�������s����z"BaseContext.set_forkserver_preloadc�����������������C���sF���|d�u�r|�S�zt�|�}W�n �ty8���td|��d��Y�n0�|����|S�)Nzcannot find context for %r)�_concrete_contexts�KeyError� ValueError�_check_available)r����methodr���r���r���r���r�������s����zBaseContext.get_contextFc�����������������C���s���|�j�S��N)�_name�r���� allow_noner���r���r����get_start_method����s����zBaseContext.get_start_methodc�����������������C���s���t�d��d�S�)Nz+cannot set start method of concrete context)rW����r���rY����forcer���r���r����set_start_method����s����zBaseContext.set_start_methodc�����������������C���s���t����d�S�)z_Controls how objects will be reduced to a form that can be shared with other processes.r���)�globals�get�r���r���r���r����reducer����s����zBaseContext.reducerc�����������������C���s���|t���d<�d�S�)Nr���)rb���)r���r���r���r���r���re�������s����c�����������������C���s���d�S�rZ���r���rd���r���r���r���rX�������s����zBaseContext._check_available)T)N)r���)r���)NN)r���)r���)NNr���N)N)N)F)F)+r���r ���r ���r���r���r ���r����staticmethodr����current_process�parent_process�active_childrenr���r���r���r ���r"���r#���r%���r'���r(���r)���r.���r1���r2���r3���r:���r>���r@���rB���rE���rJ���rL���rO���rP���rR���r���r^���ra����propertyre����setterrX���r���r���r���r���r������sR��� ��� r���c�������������������@���s���e�Zd�ZdZedd���ZdS�)�ProcessNc�����������������C���s���t����j�|��S�rZ���)�_default_contextr���rl����_Popen)�process_objr���r���r���rn�������s����zProcess._Popen�r���r ���r ���� _start_methodrf���rn���r���r���r���r���rl�������s���rl���c�����������������������sF���e�Zd�ZeZdd��Zd ��fdd� Zddd�Zdd d �Zdd��Z���Z S�)�DefaultContextc�����������������C���s���||�_�d�|�_d�S�rZ���)rm����_actual_context)r���r4���r���r���r����__init__����s����zDefaultContext.__init__Nc��������������������s0���|d�u�r |�j�d�u�r|�j|�_�|�j�S�t���|�S�d�S�rZ���)rs���rm����superr���)r���rY����� __class__r���r���r�������s ���� zDefaultContext.get_contextFc�����������������C���s<���|�j�d�ur|std��|d�u�r,|r,d�|�_�d�S�|��|�|�_�d�S�)Nzcontext has already been set)rs����RuntimeErrorr���r_���r���r���r���ra�������s����zDefaultContext.set_start_methodc�����������������C���s"���|�j�d�u�r|rd�S�|�j|�_�|�j�jS�rZ���)rs���rm���r[���r\���r���r���r���r^�������s ���� zDefaultContext.get_start_methodc�����������������C���sB���t�jdkrdgS�t�jdkr"ddgnddg}tjr:|�d��|S�d�S�)NrC���rI����darwin�forkrS���)rF���rG���r����HAVE_SEND_HANDLE�append)r����methodsr���r���r����get_all_start_methods���s���� z$DefaultContext.get_all_start_methods)N)F)F) r���r ���r ���rl���rt���r���ra���r^���r~���� __classcell__r���r���rv���r���rr�������s��� rr���rC���c�������������������@���s���e�Zd�ZdZedd���ZdS�)�ForkProcessrz���c�����������������C���s���ddl�m}�||��S��Nr���)�Popen)� popen_forkr�����ro���r����r���r���r���rn�����s����zForkProcess._PopenNrp���r���r���r���r���r������s���r����c�������������������@���s���e�Zd�ZdZedd���ZdS�)�SpawnProcessrI���c�����������������C���s���ddl�m}�||��S�r����)�popen_spawn_posixr����r����r���r���r���rn�����s�����SpawnProcess._PopenNrp���r���r���r���r���r������s���r����c�������������������@���s���e�Zd�ZdZedd���ZdS�)�ForkServerProcessrS���c�����������������C���s���ddl�m}�||��S�r����)�popen_forkserverr����r����r���r���r���rn��� ��s����zForkServerProcess._PopenNrp���r���r���r���r���r������s���r����c�������������������@���s���e�Zd�ZdZeZdS�)�ForkContextrz���N)r���r ���r ���r[���r����rl���r���r���r���r���r����%��s���r����c�������������������@���s���e�Zd�ZdZeZdS���SpawnContextrI���N�r���r ���r ���r[���r����rl���r���r���r���r���r����)��s���r����c�������������������@���s���e�Zd�ZdZeZdd��ZdS�)�ForkServerContextrS���c�����������������C���s���t�jstd��d�S�)Nz%forkserver start method not available)r���r{���rW���rd���r���r���r���rX���0��s����z"ForkServerContext._check_availableN)r���r ���r ���r[���r����rl���rX���r���r���r���r���r����-��s���r����)rz���rI���rS���ry���rI���rz���c�������������������@���s���e�Zd�ZdZedd���ZdS�)r����rI���c�����������������C���s���ddl�m}�||��S�r����)Zpopen_spawn_win32r����r����r���r���r���rn���D��s����r����Nrp���r���r���r���r���r����B��s���c�������������������@���s���e�Zd�ZdZeZdS�r����r����r���r���r���r���r����I��s���c�����������������C���s���t�|��t_d�S�rZ���)rU���rm���rs���)rY���r���r���r����_force_start_methodV��s����r����c�������������������C���s���t�tdd��S�)N�spawning_popen)rH����_tlsr���r���r���r����get_spawning_popen_��s����r����c�����������������C���s ���|�t�_d�S�rZ���)r����r����)�popenr���r���r����set_spawning_popenb��s����r����c�����������������C���s ���t���d�u�rtdt|��j���d�S�)NzF%s objects should only be shared between processes through inheritance)r����rx����typer���)�objr���r���r����assert_spawninge��s���� ��r����) r���rF���� threadingrN���r���r����__all__� Exceptionr���r���r ���r����objectr����BaseProcessrl���rr���rG���r����r����r����r����r����r����rU���rm���r�����localr����r����r����r����r���r���r���r����<module>���sJ����?,��