OwlCyberSecurity - MANAGER
Edit File: context.cpython-310.pyc
o �?OgM- � @ s� d dl Z d dlZd dlZddlmZ ddlmZ dZG dd� de�ZG dd � d e�Z G d d � d e�Z G d d � d e�Z G dd� de �Z G dd� dej�ZG dd� de �Zejdkr�G dd� dej�ZG dd� dej�ZG dd� dej�ZG dd � d e �ZG d d � d e �ZG d d � d e �Ze� e� e� d!�Zejd"kr�eed# �Zn#eed$ �Zn G d%d� dej�ZG d&d � d e �Zd#e� iZeed# �Zd'd(� Ze�� Z d)d*� Z d+d,� Z d-d.� Z dS )/� N� )�process)� reduction� c @ � e Zd ZdS )� ProcessErrorN��__name__� __module__� __qualname__r r r �>/opt/alt/python310/lib64/python3.10/multiprocessing/context.pyr � r c @ r )�BufferTooShortNr r r r r r r r c @ r )� TimeoutErrorNr r r r r r r r c @ r )�AuthenticationErrorNr r r r r r r r c @ s\ e Zd ZeZeZeZeZeej �Z eej �Z eej �Z dd� Z dd� Z dCdd�Zdd � Zd d � ZdDd d�ZdEdd�ZdEdd�Zdd� ZdFdd�ZdGdd�ZdGdd �Zd d � Z dHd d!�Zd"d#� Zd$d%� Zdd&�d'd(�Z dd&�d)d*�Z d+d,� Z d-d.� Z dDd/d0�Z d1d2� Z!d3d4� Z"d5d6� Z#dDd7d8�Z$dId:d;�Z%dId<d=�Z&e'd>d?� �Z(e(j)d@d?� �Z(dAdB� Z*d S )J� BaseContextc C s t �� }|du r td��|S )z(Returns the number of CPUs in the systemNz cannot determine number of cpus)�os� cpu_count�NotImplementedError)�selfZnumr 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)Zmanagersr � get_context�start)r r �mr r r �Manager1 s zBaseContext.ManagerTc C � ddl m} ||�S )z1Returns two connection object connected by a piper )�Pipe)� connectionr )r Zduplexr r r r r < � zBaseContext.Pipec C � ddl m} || �� d�S )z#Returns a non-recursive lock objectr )�Lockr )� synchronizer" r )r r" r r r r" A � zBaseContext.Lockc C r! )z Returns a recursive lock objectr )�RLockr )r# r% r )r r% r r r r% F r$ zBaseContext.RLockNc C � ddl m} ||| �� d�S )zReturns a condition objectr )� Conditionr )r# r' r )r �lockr' r r r r' K � zBaseContext.Conditionr c C r& )zReturns a semaphore objectr )� Semaphorer )r# r* r )r �valuer* r r r r* P r) zBaseContext.Semaphorec C r& )z"Returns a bounded semaphore objectr )�BoundedSemaphorer )r# r, r )r r+ r, r r r r, U r) z BaseContext.BoundedSemaphorec C r! )zReturns an event objectr )�Eventr )r# r- r )r r- r r r r- Z r$ zBaseContext.Eventc C � ddl m} ||||| �� d�S )zReturns a barrier objectr )�Barrierr )r# r/ r )r Zparties�actionZtimeoutr/ r r r r/ _ s zBaseContext.Barrierr c C r& )�Returns a queue objectr )�Queuer )�queuesr2 r )r �maxsizer2 r r r r2 d r) zBaseContext.Queuec C r& )r1 r )� JoinableQueuer )r3 r5 r )r r4 r5 r r r r5 i r) zBaseContext.JoinableQueuec C r! )r1 r )� SimpleQueuer )r3 r6 r )r r6 r r r r6 n r$ zBaseContext.SimpleQueuer c C s" ddl m} |||||| �� d�S )z Returns a process pool objectr )�Pool)�context)Zpoolr7 r )r Z processesZ initializerZinitargsZmaxtasksperchildr7 r r r r7 s s �zBaseContext.Poolc G s ddl m} ||g|�R � S )zReturns a shared objectr )�RawValue)� sharedctypesr9 )r �typecode_or_type�argsr9 r r r r9 z r) 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 r. )z#Returns a synchronized shared arrayr )�Arrayr@ )r: rA r )r r; r> r( rA r r r rA � s �zBaseContext.Arrayc C s4 t jdkrtt 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�spawnrD )r rD r r r rD � 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)�utilrI )r rI r r r rI � s zBaseContext.get_loggerc C r )z8Turn on logging and add a handler which prints to stderrr )� log_to_stderr)rJ rK )r �levelrK r r r rK � r 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 � 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)rH rP )r � executablerP r r r rP � s zBaseContext.set_executablec C rO )zkSet list of module names to try to load in forkserver process. This is really just a hint. r )�set_forkserver_preloadN)� forkserverrR )r Z module_namesrR r r r rR � s z"BaseContext.set_forkserver_preloadc C sB |d u r| S zt | }W n ty td| �d �w |�� |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 Z allow_noner r r �get_start_method� s z BaseContext.get_start_methodc C s t d��)Nz+cannot set start method of concrete context)rV �r rX Zforcer r r �set_start_method� s z BaseContext.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 )r_ )r r r r r rb � � c C � d S rY r ra r r r rW � s z BaseContext._check_available)TrY )r )NN)r )NNr N�F)+r r r r r r r � staticmethodr Zcurrent_processZparent_processZactive_childrenr r r r" r% r' r* r, r- r/ r2 r5 r6 r7 r9 r= r? rA rD rI rK rN rP rR r r\ r^ �propertyrb �setterrW r r r r r sT � r c @ s( e Zd ZdZedd� �Zedd� �ZdS )�ProcessNc C s t �� j�| �S rY )�_default_contextr ri �_Popen)� process_objr r r rk � s zProcess._Popenc C s t �� j�� S rY )rj r ri � _after_forkr r r r rm � rc zProcess._after_fork�r r r � _start_methodrf rk rm r r r r ri � s ri c sF e Zd ZeZdd� Zd � fdd� Zddd�Zdd d �Zd d � Z� Z S )�DefaultContextc C s || _ d | _d S rY )rj �_actual_context)r r8 r r r �__init__� s zDefaultContext.__init__Nc s, |d u r| j d u r | j| _ | j S t� �|�S rY )rq rj �superr )r rX �� __class__r r r � s zDefaultContext.get_contextFc C s< | j d ur |s td��|d u r|rd | _ d S | �|�| _ d S )Nz context has already been set)rq � RuntimeErrorr r] r r r r^ � s z DefaultContext.set_start_methodc C s" | j d u r |r d S | j| _ | j jS rY )rq rj rZ r[ r r r r\ � s z DefaultContext.get_start_methodc C s> t jdkrdgS t jdkrddgnddg}tjr |�d� |S )NrB rH �darwin�forkrS )rE rF r �HAVE_SEND_HANDLE�append)r �methodsr r r �get_all_start_methods s z$DefaultContext.get_all_start_methodsrY re ) r r r ri rr r r^ r\ r| � __classcell__r r rt r rp � s rp rB c @ � e Zd ZdZedd� �ZdS )� ForkProcessrx c C � ddl m} || �S �Nr )�Popen)Z popen_forkr� �rl r� r r r rk r zForkProcess._PopenN�r r r ro rf rk r r r r r � r c @ �( e Zd ZdZedd� �Zedd� �ZdS )� SpawnProcessrH c C r� r� )Zpopen_spawn_posixr� r� r r r rk r �SpawnProcess._Popenc C rd rY r r r r r rm " � �SpawnProcess._after_forkNrn r r r r r� � r� c @ r~ )�ForkServerProcessrS c C r� r� )Zpopen_forkserverr� r� r r r rk ) r zForkServerProcess._PopenNr� r r r r r� ' r� r� c @ � e Zd ZdZeZdS )� ForkContextrx N)r r r rZ r ri r r r r r� . � r� c @ r� �� SpawnContextrH N�r r r rZ r� ri r r r r r� 2 r� r� c @ s e Zd ZdZeZdd� ZdS )�ForkServerContextrS c C s t jstd��d S )Nz%forkserver start method not available)r ry rV ra r r r rW 9 s �z"ForkServerContext._check_availableN)r r r rZ r� ri rW r r r r r� 6 s r� )rx rH rS rw rH rx c @ r� )r� rH c C r� r� )Zpopen_spawn_win32r� r� r r r rk M r r� c C rd rY r r r r r rm R r� r� Nrn r r r r r� K r� c @ r� r� r� r r r r r� W r� c C s t | t_d S rY )rT rj rq )rX r r r �_force_start_methodd s r� c C s t tdd �S )N�spawning_popen)rG �_tlsr r r r �get_spawning_popenm s r� c C s | t _d S rY )r� r� )�popenr r r �set_spawning_popenp s r� c C s t � d u rtdt| �j ��d S )NzF%s objects should only be shared between processes through inheritance)r� rv �typer )�objr r r �assert_spawnings s ���r� ) r rE Z threadingrM r r �__all__� Exceptionr r r r �objectr Z BaseProcessri rp rF r r� r� r� r� r� rT rj r� Zlocalr� r� r� r� r r r r �<module> sL ? , � �