OwlCyberSecurity - MANAGER
Edit File: context.cpython-310.opt-2.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 �� }|d u r td��|S )Nz cannot determine number of cpus)�os� cpu_count�NotImplementedError)�selfZnumr r r r ) s zBaseContext.cpu_countc C s( ddl m} || �� d�}|�� |S )Nr )� SyncManager��ctx)Zmanagersr � get_context�start)r r �mr r r �Manager1 s zBaseContext.ManagerTc C � ddl m} ||�S )Nr )�Pipe)� connectionr )r Zduplexr r r r r < � zBaseContext.Pipec C � ddl m} || �� d�S )Nr )�Lockr )� synchronizer" r )r r" r r r r" A � zBaseContext.Lockc C r! )Nr )�RLockr )r# r% r )r r% r r r r% F r$ zBaseContext.RLockNc C � ddl m} ||| �� d�S )Nr )� Conditionr )r# r' r )r �lockr' r r r r' K � zBaseContext.Conditionr c C r& )Nr )� Semaphorer )r# r* r )r �valuer* r r r r* P r) zBaseContext.Semaphorec C r& )Nr )�BoundedSemaphorer )r# r, r )r r+ r, r r r r, U r) z BaseContext.BoundedSemaphorec C r! )Nr )�Eventr )r# r- r )r r- r r r r- Z r$ zBaseContext.Eventc C �" ddl m} ||||| �� d�S )Nr )�Barrierr )r# r/ r )r Zparties�actionZtimeoutr/ r r r r/ _ s zBaseContext.Barrierr c C r& )Nr )�Queuer )�queuesr1 r )r �maxsizer1 r r r r1 d r) zBaseContext.Queuec C r& )Nr )� JoinableQueuer )r2 r4 r )r r3 r4 r r r r4 i r) zBaseContext.JoinableQueuec C r! )Nr )� SimpleQueuer )r2 r5 r )r r5 r r r r5 n r$ zBaseContext.SimpleQueuer c C s$ ddl m} |||||| �� d�S )Nr )�Pool)�context)Zpoolr6 r )r Z processesZ initializerZinitargsZmaxtasksperchildr6 r r r r6 s s �zBaseContext.Poolc G s ddl m} ||g|�R � S )Nr )�RawValue)� sharedctypesr8 )r �typecode_or_type�argsr8 r r r r8 z r) zBaseContext.RawValuec C s ddl m} |||�S )Nr )�RawArray)r9 r< )r r: �size_or_initializerr< r r r r< s zBaseContext.RawArray)r( c G s* ddl m} ||g|�R || �� d��S )Nr )�Value�r( r )r9 r> r )r r: r( r; r> r r r r> � s �zBaseContext.Valuec C r. )Nr )�Arrayr? )r9 r@ r )r r: r= r( r@ r r r r@ � s �zBaseContext.Arrayc C s6 t jdkrtt dd�rddlm} |� d S d S d S )N�win32�frozenFr )�freeze_support)�sys�platform�getattr�spawnrC )r rC r r r rC � s �zBaseContext.freeze_supportc C s ddl m} |� S )Nr )� get_logger)�utilrH )r rH r r r rH � s zBaseContext.get_loggerc C r )Nr )� log_to_stderr)rI rJ )r �levelrJ r r r rJ � r zBaseContext.log_to_stderrc C s ddl m} d S )Nr )r )� r )r r r r r �allow_connection_pickling� s z%BaseContext.allow_connection_picklingc C � ddl m} ||� d S )Nr )�set_executable)rG rO )r � executablerO r r r rO � s zBaseContext.set_executablec C rN )Nr )�set_forkserver_preload)� forkserverrQ )r Z module_namesrQ r r r rQ � 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)rU �r rW Zforcer r r �set_start_method� s z BaseContext.set_start_methodc C s t � �d�S �Nr )�globals�get�r r r r �reducer� s zBaseContext.reducerc C s |t � d< d S r^ )r_ )r r r r r rb � � c C � d S rX r ra r r r rV � s z BaseContext._check_available)TrX )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/ r1 r4 r5 r6 r8 r< r> r@ rC rH rJ rM rO rQ r r[ r] �propertyrb �setterrV r r r r r sT � r c @ s( e Zd ZdZedd� �Zedd� �ZdS )�ProcessNc C s t �� j�| �S rX )�_default_contextr ri �_Popen)� process_objr r r rk � s zProcess._Popenc C s t �� j�� S rX )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 rX )rj �_actual_context)r r7 r r r �__init__� s zDefaultContext.__init__Nc s, |d u r| j d u r | j| _ | j S t� �|�S rX )rq rj �superr )r rW �� __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 rX )rq rj rY rZ r r r r[ � s z DefaultContext.get_start_methodc C s> t jdkrdgS t jdkrddgnddg}tjr |�d� |S )NrA rG �darwin�forkrR )rD rE r �HAVE_SEND_HANDLE�append)r �methodsr r r �get_all_start_methods s z$DefaultContext.get_all_start_methodsrX re ) r r r ri rr r r] r[ r| � __classcell__r r rt r rp � s rp rA c @ � e Zd ZdZedd� �ZdS )� ForkProcessrx c C � ddl m} || �S �Nr )�Popen)Z popen_forkr� �rl r� r r r rk � zForkProcess._PopenN�r r r ro rf rk r r r r r � r c @ �( e Zd ZdZedd� �Zedd� �ZdS )� SpawnProcessrG c C r� r� )Zpopen_spawn_posixr� r� r r r rk r� �SpawnProcess._Popenc C rd rX r r r r r rm " � �SpawnProcess._after_forkNrn r r r r r� � r� c @ r~ )�ForkServerProcessrR 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 rY r ri r r r r r� . � r� c @ r� �� SpawnContextrG N�r r r rY r� ri r r r r r� 2 r� r� c @ s e Zd ZdZeZdd� ZdS )�ForkServerContextrR c C s t jstd��d S )Nz%forkserver start method not available)r ry rU ra r r r rV 9 s �z"ForkServerContext._check_availableN)r r r rY r� ri rV r r r r r� 6 s r� )rx rG rR rw rG rx c @ r� )r� rG c C r� r� )Zpopen_spawn_win32r� r� r r r rk M r� r� c C rd rX 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 rX )rS rj rq )rW r r r �_force_start_methodd s r� c C s t tdd �S )N�spawning_popen)rF �_tlsr r r r �get_spawning_popenm s r� c C s | t _d S rX )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 rD Z threadingrL r r �__all__� Exceptionr r r r �objectr Z BaseProcessri rp rE r r� r� r� r� r� rS rj r� Zlocalr� r� r� r� r r r r �<module> sL ? , � �