dtj+<ddlZddlZddlZddlZddlZddlmZddlmZ ddl m Z ej dkrddl Z ddlZddlmZgdZeed ZejejfZd Zeejejd Zejd kr,ddlZeed redejidZGdde ZeZ e j!Z!e j"Z"e j#Z#e j$Z$e j%Z%ddZ&dZ'dS)N)util)ResourceTracker)spawnwin32) duplicate)ensure_runningregister unregisterpthread_sigmaskc td)Nz-noop should never be registered or cleaned up) RuntimeError)names l/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/joblib/externals/loky/backend/resource_tracker.py cleanup_nooprAs F G GG)noopfolderfileposix sem_unlinksemlockFcHeZdZdZdZdZdZdZd dZdZ fd Z xZ S) raResource tracker with refcounting scheme. This class is an extension of the multiprocessing ResourceTracker class which implements a reference counting scheme to avoid unlinking shared resources still in use in other processes. This feature is notably used by `joblib.Parallel` to share temporary folders and memory mapped files between the main process and the worker processes. The actual implementation of the refcounting scheme is in the main function, which is run in a dedicated process. c4|d||dS)z@Decrement the refcount of a resource, and delete it if it hits 0 MAYBE_UNLINKN)_send)selfrrtypes r maybe_unlinkzResourceTracker.maybe_unlinkms >4/////rc*|S)a Make 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. This function is necessary for backward compatibility with python versions before 3.13.7. )_ensure_running_and_writers rr zResourceTracker.ensure_runningqs--///rctj|jtjdkr3 |jtj|jdn#t $rYnwxYwd|_d|_tjddS)Nrrz]resource_tracker: process died unexpectedly, relaunching. Some folders/semaphores might leak.) osclose_fdr_pidwaitpidOSErrorwarningswarnr"s r_teardown_dead_processz&ResourceTracker._teardown_dead_process|s  7g   9(Jty!,,,       2     s!A AAcg} |tjn#t$rYnwxYwt j\}}tjdkr9ttj |d}t j ||}dtj d|dtd} ||tj}|gt#jd|}t#jd | t(r$t+jt*jt0t3|||}t(r$t+jt*jt0n1#t(r%t+jt*jt0wwxYw||_||_n##t:$rt j |wxYw tjdkrt=j|dSt j |dS#tjdkrt=j|wt j |wxYw) NrT) inheritablezfrom z import main; main(z, )z-czlaunching resource tracker: ) appendsysstderrfileno Exceptionr$pipeplatformrmsvcrt get_osfhandler%main __module__VERBOSErget_executabler_args_from_interpreter_flagsdebug _HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_UNBLOCKr&r' BaseException_winapi CloseHandle) r fds_to_passrw_rcmdexeargspids r_launchzResourceTracker._launchsd      sz0022 3 3 3 3    D wyy1 <7 " "6/22EEEB HQKKKAIdoII!IIwIII    q ! ! !&((CI$;==ItISID Jf#>#>3s88#>#>!!!!!rcttdsdS tdS#t$rYdSwxYw)N__del__)hasattr_ResourceTrackersuperr[ChildProcessError)r __class__s rr[zResourceTracker.__del__s^'33  F  GGOO          DD s < A  A )N) __name__r: __qualname____doc__rr r,rPr!rSr[ __classcell__)r`s@rrr^s  000 0 0 0   6222h<???         rrc * rtjtjtjtjtjtjtjtjtr$tjtj ttj tj fD]'} |#t$rY$wxYwrtjddt"D} tjdkrt)j|t,j}t1|d5}|D]n} |dd}|dd|d d |d }}}|t"vrzmain..s===er===rrrbascii:rrzCannot register z/ for automatic cleanup: unknown resource type (z1). Resource type should be one of the following: PROBEREGISTERz*[ResourceTracker] incremented refcount of  z (current r/ UNREGISTERz[ResourceTracker] unregister z : registry(rz*[ResourceTracker] decremented refcount of [ResourceTracker] unlink resource_tracker: : Nzunrecognized command cJ|r: tjdt|d|dn#t$rYnwxYw|D]b} t ||rt jd|2#t$r$}tjd|d|Yd}~[d}~wwxYwdS)Nz%resource_tracker: There appear to be z leaked z objects to clean up at shutdownrsrtru)r*r+rXr4_CLEANUP_FUNCSrr>)rtype_registryrreverboses r_unlink_resourceszmain.._unlink_resourcesds# M/~..//8=/// !D& F FF"5)$///G #Et#E#EFFF FFFM"Dt"D"Dq"D"DEEEEEEEEF F Fs$(. ;;.A22 B <BB rzresource tracker shut down)'r log_to_stderrDEBUGr@SIGINTSIG_IGNSIGTERMr?r rDrBr1stdinstdoutr%r4r>rwkeysr6r7open_osfhandler$O_RDONLYopenstripdecodesplitjoin ValueErrorlistrXr*r+rrE excepthookexc_infoitems) fdrzfregistrylinesplittedrLrrryr{rxs ` rr9r9s- ,,,, M&-000 M&.&.111Ev13CDDDi $  GGIIII    D 7 5666==~':':'<'<===Hn< <7 " "&r2;77B "d^^E qD D C#zz||227;;AA#FFH! !B$00   %C N22(=t==6;== $N$7$7$9$9::==g~~ **x6645HUOD11$UOD111Q6111" J!E#(!E!E+/!E!E,4UOD,A!E!E!E  ,,$UOD1" J!=!=!=u!=!=,/MM!=!=!=.. ---2---" J!E#(!E!E+/!E!E,4UOD,A!E!E!E $E?40A55 ( 5 "#*!&$(J(JD(J(J%&%&%&!/u 5d ; ; ; ;#,""" ( $F$F$F$F$F!"!"!"!"!"!"!"!""6++J3+J+JKKK$ 777(AD E E E E E E E E E E E E E E E P F F F F F*&.^^%5%5 9 9 !E>  !!.%8888 x    hx0( ; ; ;E F F F F F*&.^^%5%5 9 9 !E>  !!.%8888 x    hx0( ; ; ; ; 1 /0000011s;C CC?P-O F4N .MN  M2M-(N -M22N O O N54O 5 O ?O O O OO  O P-OP- O!P--A Q8c ~tjdkr7d|D}|d}tj|||St |}dd|D} tj||ddddddd \}}}}tj |n#t$rYnwxYw|S)Nrc8g|]}|dS)utf-8)encode)riargs r z"spawnv_passfds..s$444 7##444rrrqc3"K|] }d|dV dS)"Nrh)rixs r z!spawnv_passfds..s*..Ax1xxx......rTr) r1r6rrrCsortedrrF CreateProcessrGrE)pathrNpassfdsrL_htrOs rrCrCs |w44t444{{7##"4w777//hh....... #1c4tQdDMAr3   # # # #    D  s75B-- B:9B:)r)(r$shutilr1r@r*multiprocessingr multiprocessing.resource_trackerrr]rr6rFr7multiprocessing.reductionr__all__r\r?r~rrBrrmtreeunlinkrwr_multiprocessingupdaterr;_resource_trackerr r rr getfdr9rCrhrrrsR  <7NNNMMM333333 7 6 6 122 M6>2HHH m I 7gw.. +6     XXXXX&XXXv$O%%"1  % -  ) H1H1H1H1Vr