o i8@sddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ej dkr=ddl Z ddlZddlmZgdZeed ZejejfZejejd Zejd kr\eed <d ZGdddZeZejZejZej Z ej!Z!ej"Z"dddZ#ddZ$dS)N) sem_unlink)util)spawnwin32) duplicate)ensure_runningregister unregisterpthread_sigmask)folderfileposixsemlockFc@sLeZdZddZddZddZddZd d Zd d Zd dZ ddZ dS)ResourceTrackercCst|_d|_d|_dSN) threadingLock_lock_fd_pidselfri/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/joblib/externals/loky/backend/resource_tracker.py__init__Rs  zResourceTracker.__init__cCs||jSr)rrrrrrgetfdWszResourceTracker.getfdc Cs*|j|jdur@|r WddSt|jtjdkr5z t|jdWn ty4Ynwd|_d|_t dg}z | t j Wn tyUYnwt\}}t jdkrqtt|dd}t||}dtjd |d td }zjzD| |t}|gtd |}td |ztrttj t!t"|||}Wtrttj#t!n trttj#t!wwWn t$yt|w||_||_Wt jdkrt%&|nt|nt jdkrt%&|wt|wWddSWddS1swYdS)zMake sure that resource tracker process is running. This can be run from any process. Usually a child process will use the resource created by its parent.Nrrz^resource_tracker: process died unexpectedly, relaunching. Some folders/sempahores might leak.rT) inheritablezfrom z import main; main(z, )z-czlaunching resource tracker: )'rr _check_aliveosclosenamewaitpidrOSErrorwarningswarnappendsysstderrfileno Exceptionpipeplatformrmsvcrt get_osfhandlemain __module__VERBOSErget_executabler_args_from_interpreter_flagsdebug _HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_UNBLOCK BaseException_winapi CloseHandle) r fds_to_passrw_rcmdexeargspidrrrr[s                 C$zResourceTracker.ensure_runningcCs*z |dddWdStyYdSw)z8Check for the existence of the resource tracker process.PROBEFT)_sendBrokenPipeErrorrrrrrs  zResourceTracker._check_alivecC||d||dS)z6Register a named resource, and increment its refcount.REGISTERNrrIrr"rtyperrrr zResourceTracker.registercCrK)z2Unregister a named resource with resource tracker. UNREGISTERNrMrNrrrr rPzResourceTracker.unregistercCrK)z@Decrement the refcount of a resource, and delete it if it hits 0 MAYBE_UNLINKNrMrNrrr maybe_unlinkrPzResourceTracker.maybe_unlinkcCsRt|dkr td|d|d|dd}t|j|}|t|ks'JdS)Niz name too long: ascii)len ValueErrorencoder writer)rrCr"rOmsgnbytesrrrrIs zResourceTracker._sendN) __name__r1 __qualname__rrrrr r rSrIrrrrrPsL  rc sr tjtjdttjtjttjtjtr"ttj t t j t j fD]}z|Wq(ty9Yq(wrAtdddtD}zmt jdkrXt|tj}t|d(} |}|dkrjnz|d d }|d d |d d |d }}}|dkrWq_|tvrtd|d|dtt|dkr|||vrd |||<n |||d 7<rtd|d|d|||dn|dkr|||=rtd|d|dt |dnm|dkrW|||d 8<rtd|d|d|||d|||d krV|||=zr0td|t||Wn&tyU} zt!"d|d| WYd} ~ n d} ~ wwnt#d |Wnt$y}z t j%t &Wn t$yzYnwYnwq`Wdn 1swYWfd!d"} |'D]\}} |d#krq| | |qd#|vr| |d#d#n*fd!d"} |'D]\}} |d#krΐq| | |qd#|vr| |d#d#wwrtd$dSdS)%zRun resource tracker.)levelz Main resource tracker is runningcSsi|]}|iqSrr).0rOrrr szmain..rrbTrVrTrrrGzCannot register z/ for automatic cleanup: unknown resource type (z1). Resource type should be one of the following: rLz*[ResourceTracker] incremented refcount of  z (current rrQz[ResourceTracker] unregister z : registry(rRz*[ResourceTracker] decremented refcount of [ResourceTracker] unlink resource_tracker: : Nzunrecognized command c s|rztdt|d|dWn tyYnw|D]1}zt||r1td|WqtyO}ztd|d|WYd}~qd}~wwdS)Nz%resource_tracker: There appear to be z leaked z objects to clean up at shutdownrfrgrh)r%r&rWr+_CLEANUP_FUNCSrr5)rtype_registryrOr"everboserr_unlink_resources3s.  "zmain.._unlink_resourcesr zresource tracker shut down)(r log_to_stderrDEBUGr7SIGINTSIG_IGNSIGTERMr6r r;r9r(stdinstdoutr!r+r5rikeysr-r.open_osfhandler O_RDONLYopenreadlinestripdecodesplitjoinrXlistrWr%r& RuntimeErrorr< excepthookexc_infoitems) fdrmfregistrylinesplittedrCr"rOrkrnrjrrlrr0s              H     r0c st|}tjdkr@t\}}z%ddlmddlm}fdd|D}|||Wt|t|St|t|wd dd |D}zt ||ddd d ddd \}} } }t | W| St ymY| Sw) Nrr_mk_inheritable) fork_execcsg|]}|qSrr)r`rrrr fsz"spawnv_passfds..recss|] }d|dVqdS)"Nr)r`xrrr lsz!spawnv_passfds..Tr)sortedr(r-r r, reductionrrr!r~r= CreateProcessr>r<) pathrEpassfds errpipe_read errpipe_writer_passrC_htrFrrrr:_s.          r:)r)%r shutilr(r7r%r_multiprocessingrmultiprocessingrrHrr-r=r.multiprocessing.reductionr__all__hasattrr6rqrsr9rmtreeunlinkrir"r2r_resource_trackerrr rSr rr0r:rrrrs@-        y