⾙hb3ddlZddlZddlZddlZddlmZgZdZddlm Z m Z m Z m Z m Z mZmZGddZGdd ej"ZGd d eZed eeDe_ej,d k7rGddej"ZGddej"ZGddej"ZGddeZGddeZGddeZeeedZeedZn4Gddej"ZGddeZdeiZeedZdZej@Z!d Z"d!Z#d"Z$y)#N)processzIforce_execv is not supported as the billiard C extension is not installed) ProcessErrorBufferTooShort TimeoutErrorAuthenticationErrorTimeLimitExceededSoftTimeLimitExceededWorkerLostErrorcbeZdZeZeZeZeZeZeZe Z e e jZ e e jZ eedrdZndZdZd"dZdZdZd#d Zd$d Zd$d Zd Zd%d Zd&dZd&dZdZ d'dZdZdZdZ dZ!dZ"dZ#d#dZ$dZ%dZ&dZ'd#dZ(d(dZ)d#dZ*dZ+d Z,d!Z-y)) BaseContext cpu_countcHtj}| td|S)z(Returns the number of CPUs in the systemcannot determine number of cpus)osrNotImplementedError)selfnums L/var/www/Befach/backend/env/lib/python3.12/site-packages/billiard/context.pyrzBaseContext.cpu_count2s#,,.C{)*KLL cDtjdk(r ttjd}ndtjvstjdk(rSd}tjdk(rd|z} tj|5}t|j}dddn tjd}d k\r|Std #t t f$rd}Y%wxYw#1swYIxYw#t $rd}YBwxYw#t ttf$rd}Y^wxYw) Nwin32NUMBER_OF_PROCESSORSrbsddarwinz/sbin/sysctl -n hw.ncpuz/usrSC_NPROCESSORS_ONLNrr) sysplatformintrenviron ValueErrorKeyErrorpopenreadsysconfOSErrorAttributeErrorr)rrcommps rrzBaseContext.cpu_count:s ||w&bjj)?@AC#,,&#,,(*B0<<8+!D=D$,1!!&&(m, **%:;Cax )*KLL)#H-C,,!C #G^<CsMC2C5C)!C5+DC&%C&)C2.C55 DDDDc`ddlm}||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)rr+ms rManagerzBaseContext.ManagerTs( * D,,. /  rc"ddlm}||||S)z1Returns two connection object connected by a piper)Pipe) connectionr4)rduplex rnonblock wnonblockr4s rr4zBaseContext.Pipe_s$FIy11rc<ddlm}||jS)z#Returns a non-recursive lock objectr)Lockr,) synchronizer:r/)rr:s rr:zBaseContext.Lockds%((*++rc<ddlm}||jS)zReturns a recursive lock objectr)RLockr,)r;r=r/)rr=s rr=zBaseContext.RLocki&))+,,rNc>ddlm}|||jS)zReturns a condition objectr) Conditionr,)r;r@r/)rlockr@s rr@zBaseContext.Conditionns*4#3#3#566rc>ddlm}|||jS)zReturns a semaphore objectr) Semaphorer,)r;rCr/)rvaluerCs rrCzBaseContext.Semaphoress*D$4$4$677rc>ddlm}|||jS)z"Returns a bounded semaphore objectr)BoundedSemaphorer,)r;rFr/)rrDrFs rrFzBaseContext.BoundedSemaphorexs14+;+;+=>>rc<ddlm}||jS)zReturns an event objectr)Eventr,)r;rHr/)rrHs rrHzBaseContext.Event}r>rcBddlm}|||||jS)zReturns a barrier objectr)Barrierr,)r;rJr/)rpartiesactiontimeoutrJs rrJzBaseContext.Barriers(wT5E5E5GHHrc>ddlm}|||jS)Returns a queue objectr)Queuer,)queuesrPr/)rmaxsizerPs rrPzBaseContext.Queues!W$"2"2"455rc>ddlm}|||jS)rOr) JoinableQueuer,)rQrTr/)rrRrTs rrTzBaseContext.JoinableQueues)W$*:*:*<==rc<ddlm}||jS)rOr) SimpleQueuer,)rQrVr/)rrVs rrVzBaseContext.SimpleQueues't//122rc^ddlm}|||||||||| | | | | |||||jS)zReturns a process pool objectr)Pool)context)poolrXr/)r processes initializerinitargsmaxtasksperchildrM soft_timeoutlost_worker_timeout max_restartsmax_restart_freq on_process_upon_process_downon_timeout_seton_timeout_cancelthreads semaphoreputlocks allow_restartrXs rrXzBaseContext.PoolsJ I{H6F\+> "2M#^5FY- ,,. 0 0rc ddlm}||g|S)zReturns a shared objectr)RawValue) sharedctypesrl)rtypecode_or_typeargsrls rrlzBaseContext.RawValues*(0400rc ddlm}|||S)zReturns a shared arrayr)RawArray)rmrq)rrnsize_or_initializerrqs rrqzBaseContext.RawArrays*(*=>>rchddlm}|jdd}||g|||jdS)z$Returns a synchronized shared objectr)ValuerATrAr-)rmrtgetr/)rrnrokwargsrtrAs rrtzBaseContext.Values?'zz&$'%--4))+- -rcfddlm}|jdd}|||||jS)z#Returns a synchronized shared arrayr)ArrayrATru)rmryrvr/)rrnrrrorwryrAs rryzBaseContext.Arrays6'zz&$'%':))+- -rcjtjdk(r ttddrddlm}|yyy)zCheck whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. rfrozenFr)freeze_supportN)rrgetattrspawnr|)rr|s rr|zBaseContext.freeze_supports- <<7 "wsHe'D -  (E "rcddlm}|S)zZReturn package logger -- if it does not already exist then it is created. r) get_logger)utilr)rrs rrzBaseContext.get_loggers %|rcddlm}||S)z8Turn on logging and add a handler which prints to stderrr) log_to_stderr)rr)rlevelrs rrzBaseContext.log_to_stderrs'U##rcddlm}y)zVInstall support for sending connections and sockets between processes r)r5N)r5)rr5s rallow_connection_picklingz%BaseContext.allow_connection_picklings !rc ddlm}||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)r~r)r executablers rrzBaseContext.set_executables *z"rc ddlm}||y)zkSet list of module names to try to load in forkserver process. This is really just a hint. r)set_forkserver_preloadN) forkserverr)r module_namesrs rrz"BaseContext.set_forkserver_preloads 7|,rcx||S t|}|j|S#t$rtd|zwxYw)Nzcannot find context for %r)_concrete_contextsr"r!_check_available)rmethodr-s rr/zBaseContext.get_contextsS >K D$V,C   D9FBC C Ds !9c|jSN)_namer allow_nones rget_start_methodzBaseContext.get_start_methods zzrctd)Nz+cannot set start method of concrete context)r!)rrs rset_start_methodzBaseContext.set_start_methodsFGGrc0|jxsddk(S)Nfork)rrs rforking_is_enabledzBaseContext.forking_is_enableds%%'16f< 3 ?A?C48EIBF;@ 01 ? --$ !#-H=: rr c eZdZdZedZy)ProcessNc\tjjj|Sr)_default_contextr/r_Popen) process_objs rrzProcess._Popens"++-55<<[IIrrrr _start_methodrrrrrrr sMJJrrc@eZdZeZdZdfd ZddZddZdZxZ S)DefaultContextc ||_d|_yr)r_actual_context)rrYs r__init__zDefaultContext.__init__s '#rc|)|j|j|_|jStt||Sr)rrsuperrr/)rr __class__s rr/zDefaultContext.get_contexts@ >##+'+'<'<$'' ':6B Brcz|j |s td| |rd|_y|j||_y)Nzcontext has already been set)r RuntimeErrorr/)rrrs rrzDefaultContext.set_start_method$sA    +E=> > >e#'D #//7rcn|j|ry|j|_|jjSr)rrrrs rrzDefaultContext.get_start_method,s4    '#'#8#8D ##)))rcbtjdk(rdgSddlm}|jrgdSddgS)Nrr~r reductionrr~rr)rrrrHAVE_SEND_HANDLErrs rget_all_start_methodsz$DefaultContext.get_all_start_methods3s3 <<7 "9  #))66((rrr) rrrrrr/rrr __classcell__)rs@rrrs"G$C8*)rrc#2K|]}|ddk7s |yw)r_Nr).0xs r r=sLA! aLs rc eZdZdZedZy) ForkProcessrcddlm}||SNr)Popen) popen_forkrrrs rrzForkProcess._PopenHs )% %rNrrrrrrEs  &  &rrc eZdZdZedZy) SpawnProcessr~cddlm}||Sr)popen_spawn_posixrrs rrzSpawnProcess._PopenP 0% %rNrrrrrrM  &  &rrc eZdZdZedZy)ForkServerProcessrcddlm}||Sr)popen_forkserverrrs rrzForkServerProcess._PopenXs /% %rNrrrrrrUs$  &  &rrceZdZdZeZy) ForkContextrN)rrrrrrrrrrr]s rrceZdZdZeZy SpawnContextr~Nrrrrrrrrrrra rrceZdZdZeZdZy)ForkServerContextrc>ddlm}|js tdy)Nrrz%forkserver start method not available)rrrr!rs rrz"ForkServerContext._check_availableis #-- !HII.rN)rrrrrrrrrrrres# Jrrrrc eZdZdZedZy)rr~cddlm}||Sr)popen_spawn_win32rrs rrzSpawnProcess._PopenzrrNrrrrrrwrrceZdZdZeZyrrrrrrrrrr~c(t|t_yr)rrr)rs r_force_start_methodrs'9&'A$rc$ttddS)Nspawning_popen)r}_tlsrrrget_spawning_popenrs 4)4 00rc|t_yr)rr)r#s rset_spawning_popenrs DrcZt!tdt|jzy)NzF%s objects should only be shared between processes through inheritance)rrtyper)objs rassert_spawningrs4# #%)#Y%7%7 8  $r)%rr threadingrrr__all__r exceptionsrrrrr r r r BaseProcessrrlistdirrrrrrrrrrrlocalrrrrrrrrsu   b b RJg!!J&)[&)PL^)<LL <<7&g))&&w**&&G//&k{JKJ ') &&8&@A&w**&{ &&8&ABBy1  r