File: //opt/saltstack/salt/lib/python3.10/multiprocessing/__pycache__/context.cpython-310.pyc
o
�N�gM- � @ 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/saltstack/salt/lib/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)�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)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$ r0 r )r �parties�action�timeoutr0 r r r r0 _ s zBaseContext.Barrierr c C r' )�Returns a queue objectr )�Queuer )�queuesr5 r )r �maxsizer5 r r r r5 d r* zBaseContext.Queuec C r' )r4 r )�
JoinableQueuer )r6 r8 r )r r7 r8 r r r r8 i r* zBaseContext.JoinableQueuec C r" )r4 r )� SimpleQueuer )r6 r9 r )r r9 r r r r9 n r% zBaseContext.SimpleQueuer c C s" ddl m} |||||| �� d�S )z Returns a process pool objectr )�Pool)�context)�poolr: r )r Z processesZ initializerZinitargsZmaxtasksperchildr: r r r r: 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 r* zBaseContext.RawValuec C s ddl m} |||�S )zReturns a shared arrayr )�RawArray)r> rA )r r? �size_or_initializerrA r r r rA s
zBaseContext.RawArray)r) c G s( ddl m} ||g|�R || �� d��S )z$Returns a synchronized shared objectr )�Value�r) r )r> rC r )r r? r) r@ rC r r r rC � s �zBaseContext.Valuec C r/ )z#Returns a synchronized shared arrayr )�ArrayrD )r> rE r )r r? rB r) rE r r r rE � 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�spawnrH )r rH r r r rH � 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)�utilrM )r rM r r r rM � s zBaseContext.get_loggerc C r )z8Turn on logging and add a handler which prints to stderrr )�
log_to_stderr)rN rO )r �levelrO r r r rO � 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)rL rT )r �
executablerT r r r rT � s zBaseContext.set_executablec C rS )zkSet list of module names to try to load in forkserver process.
This is really just a hint.
r )�set_forkserver_preloadN)�
forkserverrV )r Z module_namesrV r r r rV � 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)rZ �r r\ �forcer 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 )rd )r r r r r rg � � c C � d S r] r rf r r r r[ � s z BaseContext._check_available)Tr] )r )NN)r )NNr N�F)+r r
r r r r r � staticmethodr �current_processZparent_processZactive_childrenr r r r# r& r( r+ r- r. r0 r5 r8 r9 r: r= rA rC rE rH rM rO rR rT rV r r` rc �propertyrg �setterr[ r r r r r sT
�
r c @ s( e Zd ZdZedd� �Zedd� �ZdS )�ProcessNc C s t �� j�| �S r] )�_default_contextr ro �_Popen)� process_objr r r rq � s zProcess._Popenc C s t �� j�� S r] )rp r ro � _after_forkr r r r rs � rh zProcess._after_fork�r r
r �
_start_methodrk rq rs r r r r ro � s
ro c sF e Zd ZeZdd� Zd
� fdd� Zddd�Zdd d
�Zd d � Z� Z S )�DefaultContextc C s || _ d | _d S r] )rp �_actual_context)r r; r r r �__init__� s
zDefaultContext.__init__Nc s, |d u r| j d u r
| j| _ | j S t� �|�S r] )rw rp �superr )r r\ �� __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)rw � RuntimeErrorr ra r r r rc � s z DefaultContext.set_start_methodc C s" | j d u r
|r d S | j| _ | j jS r] )rw rp r^ r_ r r r r` � s
z DefaultContext.get_start_methodc C s> t jdkrdgS t jdkrddgnddg}tjr |�d� |S )NrF rL �darwin�forkrW )rI rJ r �HAVE_SEND_HANDLE�append)r �methodsr r r �get_all_start_methods s
z$DefaultContext.get_all_start_methodsr] rj )
r r
r ro rx r rc r` r� �
__classcell__r r rz r rv � s
rv rF c @ � e Zd ZdZedd� �ZdS )� ForkProcessr~ c C � ddl m} || �S �Nr )�Popen)Z
popen_forkr� �rr r� r r r rq r! zForkProcess._PopenN�r r
r ru rk rq r r r r r� � r� c @ �( e Zd ZdZedd� �Zedd� �ZdS )� SpawnProcessrL c C r� r� )Zpopen_spawn_posixr� r� r r r rq r! �SpawnProcess._Popenc C ri r] r r r r r rs " � �SpawnProcess._after_forkNrt r r r r r� �
r� c @ r� )�ForkServerProcessrW c C r� r� )Zpopen_forkserverr� r� r r r rq ) r! zForkServerProcess._PopenNr� r r r r r� ' r� r� c @ � e Zd ZdZeZdS )� ForkContextr~ N)r r
r r^ r� ro r r r r r� . � r� c @ r� �� SpawnContextrL N�r r
r r^ r� ro r r r r r� 2 r� r� c @ s e Zd ZdZeZdd� ZdS )�ForkServerContextrW c C s t jstd��d S )Nz%forkserver start method not available)r r rZ rf r r r r[ 9 s �z"ForkServerContext._check_availableN)r r
r r^ r� ro r[ r r r r r� 6 s r� )r~ rL rW r} rL r~ c @ r� )r� rL c C r� r� )Zpopen_spawn_win32r� r� r r r rq M r! r� c C ri r] r r r r r rs R r� r� Nrt 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 r] )rX rp rw )r\ r r r �_force_start_methodd s r� c C s t tdd �S )N�spawning_popen)rK �_tlsr r r r �get_spawning_popenm s r� c C s
| t _d S r] )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� r| �typer )�objr r r �assert_spawnings s
���r� ) r rI � threadingrQ r r �__all__� Exceptionr r r r �objectr Z BaseProcessro rv rJ r� r� r� r� r� r� rX rp r� �localr� r� r� r� r r r r �<module> sL ?
, �
�