⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib
/
python3.12
/
multiprocessing
/
__pycache__
/
View File Name :
context.cpython-312.pyc
CRh- d dl Z d dlZd dlZddlmZ ddlmZ dZ G d de Z G d d e Z G d d e Z G d d e Z G d de Z G d dej Z G d de Zej" dk7 r G d dej Z G d dej Z G d dej Z G d d e Z G d d e Z G d d e Z e e e d!Zej" d"k( r eed# Zn@ eed$ Zn4 G d% dej Z G d& d e Zd# e iZ eed# Zd' Z ej6 Z d( Z d) Z d* Z y)+ N )process) reduction c e Zd Zy) ProcessErrorN__name__ __module__ __qualname__r ./usr/lib/python3.12/multiprocessing/context.pyr r r r c e Zd Zy)BufferTooShortNr r r r r r r r r c e Zd Zy) TimeoutErrorNr r r r r r r r r c e Zd Zy)AuthenticationErrorNr r r r r r r r r c e Zd ZeZeZeZeZ eej Z eej Z eej Z d Z d Z d"dZd Zd Zd#dZd$d Zd$d Zd Zd%d Zd&d Zd&dZd Z d'dZd Zd ZdddZ dddZ d Z d Z d#dZ d Z!d Z"d Z#d#d Z$d(d Z%d(d Z&e'd Z(e(jR d Z(d! Z*y)) BaseContextc H t j }| t d |S )z(Returns the number of CPUs in the systemz cannot determine number of cpus)os cpu_countNotImplementedError)selfnums r r zBaseContext.cpu_count) s# lln ;%&GH HJr c ` ddl m} || j }|j |S )zReturns 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 ) SyncManagerctx)managersr get_contextstart)r r ms r ManagerzBaseContext.Manager1 s( * D , , . / r Tc ddl m} || S )z1Returns two connection object connected by a piper )Pipe) connectionr( )r duplexr( s r r( zBaseContext.Pipe< s $F|r c < ddl m} || j S )z#Returns a non-recursive lock objectr )Lockr ) synchronizer, r# )r r, s r r, zBaseContext.LockA s %((*++r c < ddl m} || j S )z Returns a recursive lock objectr )RLockr )r- r/ r# )r r/ s r r/ zBaseContext.RLockF &))+,,r Nc > ddl m} ||| j S )zReturns a condition objectr ) Conditionr )r- r2 r# )r lockr2 s r r2 zBaseContext.ConditionK s *4#3#3#566r c > ddl m} ||| j S )zReturns a semaphore objectr ) Semaphorer )r- r5 r# )r valuer5 s r r5 zBaseContext.SemaphoreP s *D$4$4$677r c > ddl m} ||| j S )z"Returns a bounded semaphore objectr )BoundedSemaphorer )r- r8 r# )r r6 r8 s r r8 z BaseContext.BoundedSemaphoreU s 1 4+;+;+=>>r c < ddl m} || j S )zReturns an event objectr )Eventr )r- r: r# )r r: s r r: zBaseContext.EventZ r0 r c B ddl m} ||||| j S )zReturns a barrier objectr )Barrierr )r- r< r# )r partiesactiontimeoutr< s r r< zBaseContext.Barrier_ s (wT5E5E5GHHr c > ddl m} ||| j S )Returns a queue objectr )Queuer )queuesrB r# )r maxsizerB s r rB zBaseContext.Queued s !W$"2"2"455r c > ddl m} ||| j S )rA r ) JoinableQueuer )rC rF r# )r rD rF s r rF zBaseContext.JoinableQueuei s ) W$*:*:*<==r c < ddl m} || j S )rA r ) SimpleQueuer )rC rH r# )r rH s r rH zBaseContext.SimpleQueuen s 't / / 122r c D ddl m} |||||| j S )z Returns a process pool objectr )Pool)context)poolrJ r# )r processes initializerinitargsmaxtasksperchildrJ s r rJ zBaseContext.Pools s) I{H6F , , .0 0r c ddl m} ||g| S )zReturns a shared objectr )RawValue) sharedctypesrR )r typecode_or_typeargsrR s r rR zBaseContext.RawValuez s *(0400r c ddl m} ||| S )zReturns a shared arrayr )RawArray)rS rW )r rT size_or_initializerrW s r rW zBaseContext.RawArray s *(*=>>r )r3 c D ddl m} ||g||| j dS )z$Returns a synchronized shared objectr )Valuer3 r! )rS rZ r# )r rT r3 rU rZ s r rZ zBaseContext.Value s/ '% - -4 ))+- -r c B ddl m} ||||| j S )z#Returns a synchronized shared arrayr )Arrayr[ )rS r] r# )r rT rX r3 r] s r r] zBaseContext.Array s& '%': ))+- -r c j t j dk( r t t dd rddlm} | yyy)zCheck whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. win32frozenFr )freeze_supportN)sysplatformgetattrspawnra )r ra s r ra zBaseContext.freeze_support s- <<7 "wsHe'D - (E "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 %|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} y)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} || y)zSets 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} || y)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 |,r c z || S t | }|j |S # t $ r t d|z d w xY w)Nzcannot find context for %r)_concrete_contextsKeyError ValueError_check_available)r methodr! s r r# zBaseContext.get_context sU >K N$V,C N 9F BC M Ns ! :c | j S N)_namer allow_nones r get_start_methodz BaseContext.get_start_method s zzr c t d )Nz+cannot set start method of concrete context)ry r r{ forces r set_start_methodz BaseContext.set_start_method s FGGr c 4 t j d S )z_Controls how objects will be reduced to a form that can be shared with other processes.r )globalsgetr s r reducerzBaseContext.reducer s y}}[))r c |t d< y )Nr )r )r r s r r zBaseContext.reducer s !* + r c y r} r r s r rz z BaseContext._check_available s r )Tr} )r )NN)r )NNr NF)+r r r r r r r staticmethodr current_processparent_processactive_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-"7#:#:;O!'"8"89N"7#:#:;O , - 7 8 ? - I 6 > 3 ?A "01 ? 37 - DH - $ !#-H * * ^^+ + r r c 0 e Zd ZdZed Zed Zy)ProcessNc \ t j j j | S r} )_default_contextr# r _Popen) process_objs r r zProcess._Popen s" ++-55<<[IIr c Z t j j j S r} )r r# r _after_forkr r r r zProcess._after_fork s ++-55AACCr r r r _start_methodr r r r r r r r s1 MJ J D Dr r c @ e Zd ZeZd Zd fd ZddZddZd Z xZ S )DefaultContextc || _ d | _ y r} )r _actual_context)r rK s r __init__zDefaultContext.__init__ s ' # r c x |)| j | j | _ | j S t | | S r} )r r superr# )r r{ __class__s r r# zDefaultContext.get_context s> >##+'+'<'<$'' '7&v. .r c z | j |s t d | |rd | _ y | j | | _ y )Nz context has already been set)r RuntimeErrorr# r s r r z DefaultContext.set_start_method sA +E => > >e#'D # / / 7 r c n | j |ry | j | _ | j j S r} )r r r~ r s r r z DefaultContext.get_start_method s4 '#'#8#8D ##)))r c t j dk( rdgS t j dk( rddgnddg}t j r|j d |S )z=Returns a list of the supported start methods, default first.r_ re darwinforkrt )rb rc r HAVE_SEND_HANDLEappend)r methodss r get_all_start_methodsz$DefaultContext.get_all_start_methods sM <<7 "9 +.<<8+Cw'&RYIZG))|,Nr r} r ) r r r r r r# r r r __classcell__)r s @r r r s! G$/8*r r r_ c e Zd ZdZed Zy) ForkProcessr c ddl m} || S Nr )Popen) popen_forkr r r s r r zForkProcess._Popen s )% %r Nr r r r r r r r r r r s & &r r c 0 e Zd ZdZed Zed Zy) SpawnProcessre c ddl m} || S r )popen_spawn_posixr r s r r zSpawnProcess._Popen 0% %r c y r} r r r r r zSpawnProcess._after_fork# r Nr r r r r r - & & r r c e Zd ZdZed Zy)ForkServerProcessrt c ddl m} || S r )popen_forkserverr r s r r zForkServerProcess._Popen* s /% %r Nr r r r r r ( s $ & &r r c e Zd ZdZeZy) ForkContextr N)r r r r~ r r r r r r r / s r r c e Zd ZdZeZy SpawnContextre Nr r r r~ r r r r r r r 3 r r c e Zd ZdZeZd Zy)ForkServerContextrt c : t j s t d y )Nz%forkserver start method not available)r r ry r s r rz z"ForkServerContext._check_available: s -- !HII .r N)r r r r~ r r rz r r r r r 7 s # Jr r )r re rt r re r c 0 e Zd ZdZed Zed Zy)r re c ddl m} || S r )popen_spawn_win32r r s r r zSpawnProcess._PopenN r r c y r} r r r r r zSpawnProcess._after_forkS r r Nr r r r r r L r r c e Zd ZdZeZyr r r r r r r X r r c ( t | t _ y r} )rw r r )r{ s r _force_start_methodr e s '9&'A$r c $ t t dd S )Nspawning_popen)rd _tlsr r r get_spawning_popenr n s 4)4 00r c | t _ y r} )r r )popens r set_spawning_popenr q s Dr c Z t !t dt | j z y )NzF%s objects should only be shared between processes through inheritance)r r typer )objs r assert_spawningr t s4 # #%)#Y%7%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 |Dg!! D&[ &Z <<7&g)) & w** &G / / & k { JK J ') ||x **<W*EF)*<V*DE w** { &&8&AB B y1 r