tj?2HddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZdZejeZgdZGddeZGd d eZGd d eZd ZGddZGddeZ ddZddZdS)N) as_completedThreadPoolExecutor)_prctl_pr_set_pdeathsigTORCH_MP_PARALLEL_START)ProcessContextProcessExceptionProcessExitedExceptionProcessRaisedExceptionspawn SpawnContextstart_processesc:eZdZddgZdededeffd ZdZxZS)r error_index error_pidmsgctt|||_||_||_dSN)super__init__rrr)selfrrr __class__s Y/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/torch/multiprocessing/spawn.pyrzProcessException.__init__#s5 &"cHt||j|j|jffSr)typerrrrs r __reduce__zProcessException.__reduce__)s!DzzDHd&6GGGr) __name__ __module__ __qualname__ __slots__strintrr __classcell__rs@rr r sr ,I#C#c#c###### HHHHHHHrr ceZdZdZdS)r zNException raised when a process failed due to an exception raised by the code.N)rr r!__doc__rrr r -sXXXXrr c NeZdZdZdgZ d dedededededzf fd Zd ZxZ S) r zTException raised when a process failed due to signal or exited with a specific code. exit_codeNrrr signal_namecjt|||||_||_dSr)rrr+r,)rrrrr+r,rs rrzProcessExitedException.__init__6s6 k9555"&rc`t||j|j|j|j|jffSr)rrrrr+r,rs rrz!ProcessExitedException.__reduce__Bs5 JJ     rr) rr r!r(r"r#r$rrr%r&s@rr r 1s^^ I#' ' '  ' ' '  ' 4Z ' ' ' ' ' '        rr cTttj ||g|RdS#t$rYdSt$rkddl}t |d5}tj| |dddn #1swxYwYtj dYdSwxYw)Nrwbr) rsignalSIGINTKeyboardInterrupt Exception tracebackopenpickledump format_excsysexit)fniargs error_filer5fhs r_wraprAOs FM***  1 t       *d # # 4r K ,,.. 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4  s8 & B'B'(B8 B'B B' B B'&B'cDeZdZdZdZdefdZddedzdedzfdZdS) rc^||_||_dt|D|_dS)Nc$i|] \}}|j|Sr))sentinel).0indexprocesss r z+ProcessContext.__init__..gs.   (6wG e   r) error_files processes enumerate sentinels)rrKrJs rrzProcessContext.__init__ds=&"  :CI:N:N   rc$d|jDS)Nc6g|]}t|jSr))r$pid)rFrHs r z'ProcessContext.pids..ls"???WGK  ???r)rKrs rpidszProcessContext.pidsks??????rtimeoutctj|z}|jD];}td|tjz }||zprocess dz terminated with signal )rrr+r,z terminated with exit code )rrr+rbz -- Process z& terminated with the following error: )lenrMmultiprocessing connectionwaitkeyspoprKrXexitcoder[is_alivelogwarningrP terminatekillosaccessrJR_OKr1Signalsname ValueErrorr r6r7loadr )rrSr\readyrrErGrHfailed_processrhrrr@original_tracers rrXzProcessContext.joinvso$ t~  ! # #4 *// N   ! !0      HN&&x00EnU+G LLNNN1$$# %  t~&&!+ +  #  ) ), 7 7 7~ $ $G!! $ GUUU!!### %%L,@bblSSS~  G!!  `K  LLNNNN 4y)+6@@ ~k2;H!||;!>8)449DD!;;;:xi:::DDD;,L{LLLdLL +,0& $ -U{UUUUUU +,0& $";/ 6 6 -"#[__N - - - - - - - - - - - - - - -V VVVV ~$S+~7IJJJs$6HH%$H%J$$J(+J()NN)rr r!rrRfloatr[rXr)rrrrcs   @@@''''']K]KEDL]Kut|]K]K]K]K]K]KrrceZdZfdZxZS)r cxtjddt||dS)Nzdaemon) tempfileNamedTemporaryFileclosernunlinkrrProcessrAstart)r=tfrHr>rr<mps r start_processz&start_processes..start_processs (' %      "'**arw'    '27""r) max_workersc<g|]}|Sr))submit)rFr=executorrs rrQz#start_processes..s'PPPQx}a88PPPr)rnenvirongetENV_VAR_PARALLEL_STARTrjinforc get_contextrangerrresultrrX)r<r>nprocsrXr start_methodstart_parallelrJrKr=idxrHtf_namefuturesfutcontextrrrs`` ` @@@rrrs  $$ JNN13 7 73 > > 2333  $\ 2 2B&6/KI########,  )v % %A$1M!$4$4 !C'&K $IcNN %  F 3 3 3 )xPPPPP%--PPPG#G,, ) )(+ %Wg#* C !( #  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )Y 44G llnn  llnn     s;ADD Dc||dkr"d|d}tj|tdt|||||dS)aSpawns ``nprocs`` processes that run ``fn`` with ``args``. If one of the processes exits with a non-zero exit status, the remaining processes are killed and an exception is raised with the cause of termination. In the case an exception was caught in the child process, it is forwarded and its traceback is included in the exception raised in the parent process. Args: fn (function): Function is called as the entrypoint of the spawned process. This function must be defined at the top level of a module so it can be pickled and spawned. This is a requirement imposed by multiprocessing. The function is called as ``fn(i, *args)``, where ``i`` is the process index and ``args`` is the passed through tuple of arguments. args (tuple): Arguments passed to ``fn``. nprocs (int): Number of processes to spawn. join (bool): Perform a blocking join on all processes. daemon (bool): The spawned processes' daemon flag. If set to True, daemonic processes will be created. start_method (str): (deprecated) this method will always use ``spawn`` as the start method. To use a different start method use ``start_processes()``. Returns: None if ``join`` is ``True``, :class:`~ProcessContext` if ``join`` is ``False`` r z3This method only supports start_method=spawn (got: zU). To use a different start_method use: torch.multiprocessing.start_processes(...)r{r|)r)r~r FutureWarningr)r<r>rrXrrrs rr r ,s_Bw :, : : :  c=Q7777 2tVT6 P P PPr)r)rTFr )loggingrcmultiprocessing.connectionrnr7r1r:rrUr~concurrent.futuresrrrr getLoggerrrj__all__r4r r r rArr rr r)rrrs !!!!  ????????%%%%%%3g!!    H H H H Hy H H HYYYYY-YYY     -   <(pKpKpKpKpKpKpKpKf11111>111$  C C C C L(Q(Q(Q(Q(Q(Qr