§ µåC�åovãó0—ddlZddlZddlZddlmZddlmZdZGd„de¦«ZGd„d e¦«Z Gd „d e¦«Z Gd „d e¦«Z Gd„de ¦«Z Gd„dej¦«ZGd„de ¦«Zejdkr°Gd„dej¦«ZGd„dej¦«ZGd„dej¦«ZGd„de ¦«ZGd„de ¦«ZGd„d e ¦«Ze¦«e¦«e¦«d!œZejd"kreed#¦«ZnPeed$¦«Zn>Gd%„dej¦«ZGd&„de ¦«Zd#e¦«iZeed#¦«Zd'„Zej¦«Zd(„Zd)„Zd*„ZdS)+éNé)Úprocess)Ú reduction©có—eZdZdS)Ú ProcessErrorN©Ú__name__Ú __module__Ú __qualname__róúD/opt/alt/python-internal/lib64/python3.11/multiprocessing/context.pyrró€€€€€Ø€Dr rcó—eZdZdS)ÚBufferTooShortNr rr rrrrr rcó—eZdZdS)Ú TimeoutErrorNr rr rrrrr rcó—eZdZdS)ÚAuthenticationErrorNr rr rrrrr rcó„—eZdZeZeZeZeZeej ¦«Z eej ¦«Z eej ¦«Z d„Z d„Z d&d„Zd„Zd„Zd'd„Zd(d „Zd(d „Zd „Zd)d „Zd*d„Zd*d„Zd„Z d+d„Zd„Zd„Zddœd„Zddœd„Zd„Zd„Zd'd„Z d„Z!d„Z"d„Z#d'd„Z$d,d!„Z%d,d"„Z&e'd#„¦«Z(e(j)d$„¦«Z(d%„Z*dS)-Ú BaseContextcóP— tj¦«}|€td¦«‚|S)Nzcannot determine number of cpus)ÚosÚ cpu_countÚNotImplementedError)ÚselfÚnums rrzBaseContext.cpu_count)s)€Ø6ÝŒl‰nŒnˆØ ˆ;Ý%Ð&GÑHÔHÐ HàˆJr cóx— ddlm}|| ¦«¬¦«}| ¦«|S)Nr)Ú SyncManager©Úctx)ÚmanagersrÚ get_contextÚstart)rrÚms rÚManagerzBaseContext.Manager1sK€ð ð *Ð)Ð)Ð)Ð)Ð)Ø ˆK˜D×,Ò,Ñ.Ô.Ð /Ñ /Ô /ˆØ �Љ Œ ˆ ؈r Tcó&— ddlm}||¦«S)Nr)ÚPipe)Ú connectionr()rÚduplexr(s rr(zBaseContext.Pipe<s%€Ø?Ø$Ð$Ð$Ð$Ð$Ð$؈t�F‰|Œ|Ðr cóL— ddlm}|| ¦«¬¦«S)Nr)ÚLockr )Ú synchronizer,r#)rr,s rr,zBaseContext.LockAs6€Ø1Ø%Ð%Ð%Ð%Ð%Ð%؈t˜×(Ò(Ñ*Ô*Ð+Ñ+Ô+Ð+r cóL— ddlm}|| ¦«¬¦«S)Nr)ÚRLockr )r-r/r#)rr/s rr/zBaseContext.RLockFs6€Ø-Ø&Ð&Ð&Ð&Ð&Ð&؈u˜×)Ò)Ñ+Ô+Ð,Ñ,Ô,Ð,r NcóN— ddlm}||| ¦«¬¦«S)Nr)Ú Conditionr )r-r1r#)rÚlockr1s rr1zBaseContext.ConditionKs8€Ø(Ø*Ð*Ð*Ð*Ð*Ð*؈y˜ 4×#3Ò#3Ñ#5Ô#5Ð6Ñ6Ô6Ð6r rcóN— ddlm}||| ¦«¬¦«S)Nr)Ú Semaphorer )r-r4r#)rÚvaluer4s rr4zBaseContext.SemaphorePs8€Ø(Ø*Ð*Ð*Ð*Ð*Ð*؈y˜ D×$4Ò$4Ñ$6Ô$6Ð7Ñ7Ô7Ð7r cóN— ddlm}||| ¦«¬¦«S)Nr)ÚBoundedSemaphorer )r-r7r#)rr5r7s rr7zBaseContext.BoundedSemaphoreUs9€Ø0Ø1Ð1Ð1Ð1Ð1Ð1ØÐ ¨4×+;Ò+;Ñ+=Ô+=Ð>Ñ>Ô>Ð>r cóL— ddlm}|| ¦«¬¦«S)Nr)ÚEventr )r-r9r#)rr9s rr9zBaseContext.EventZs6€Ø%Ø&Ð&Ð&Ð&Ð&Ð&؈u˜×)Ò)Ñ+Ô+Ð,Ñ,Ô,Ð,r cóR— ddlm}||||| ¦«¬¦«S)Nr)ÚBarrierr )r-r;r#)rÚpartiesÚactionÚtimeoutr;s rr;zBaseContext.Barrier_s<€Ø&Ø(Ð(Ð(Ð(Ð(Ð(؈w�w ¨°T×5EÒ5EÑ5GÔ5GÐHÑHÔHÐHr rcóN— ddlm}||| ¦«¬¦«S)Nr)ÚQueuer )Úqueuesr@r#)rÚmaxsizer@s rr@zBaseContext.Queueds8€Ø$Ø!Ð!Ð!Ð!Ð!Ð!؈u�W $×"2Ò"2Ñ"4Ô"4Ð5Ñ5Ô5Ð5r cóN— ddlm}||| ¦«¬¦«S)Nr)Ú JoinableQueuer )rArDr#)rrBrDs rrDzBaseContext.JoinableQueueis8€Ø$Ø)Ð)Ð)Ð)Ð)Ð)؈}˜W¨$×*:Ò*:Ñ*<Ô*<Ð=Ñ=Ô=Ð=r cóL— ddlm}|| ¦«¬¦«S)Nr)Ú SimpleQueuer )rArFr#)rrFs rrFzBaseContext.SimpleQueuens6€Ø$Ø'Ð'Ð'Ð'Ð'Ð'؈{˜t×/Ò/Ñ1Ô1Ð2Ñ2Ô2Ð2r rcóT— ddlm}|||||| ¦«¬¦«S)Nr)ÚPool)Úcontext)ÚpoolrHr#)rÚ processesÚ initializerÚinitargsÚmaxtasksperchildrHs rrHzBaseContext.PoolssH€à+ØÐÐÐÐÐØˆt�I˜{¨HÐ6FØ ×,Ò,Ñ.Ô.ð0ñ0ô0ð 0r có"— ddlm}||g|¢RŽS)Nr)ÚRawValue)Ú sharedctypesrP)rÚtypecode_or_typeÚargsrPs rrPzBaseContext.RawValuezs0€Ø%Ø*Ð*Ð*Ð*Ð*Ð*؈xÐ(Ð0¨4Ð0Ð0Ð0Ð0r có(— ddlm}|||¦«S)Nr)ÚRawArray)rQrU)rrRÚsize_or_initializerrUs rrUzBaseContext.RawArrays+€Ø$Ø*Ð*Ð*Ð*Ð*Ð*؈xÐ(Ð*=Ñ>Ô>Ð>r )r2cóN— ddlm}||g|¢R|| ¦«dœŽS)Nr)ÚValue©r2r!)rQrXr#)rrRr2rSrXs rrXzBaseContext.Value„sU€Ø2Ø'Ð'Ð'Ð'Ð'Ð'؈uÐ%ð-¨ð-ð-°4Ø×)Ò)Ñ+Ô+ð-ð-ð-ð -r cóR— ddlm}||||| ¦«¬¦«S)Nr)ÚArrayrY)rQr[r#)rrRrVr2r[s rr[zBaseContext.ArrayŠsG€Ø1Ø'Ð'Ð'Ð'Ð'Ð'؈uÐ%Ð':ÀØ×)Ò)Ñ+Ô+ð-ñ-ô-ð -r có|— tjdkr(ttdd¦«rddlm}|¦«dSdSdS)NÚwin32ÚfrozenFr)Úfreeze_support)ÚsysÚplatformÚgetattrÚspawnr_)rr_s rr_zBaseContext.freeze_support�s[€ð õ Œ<˜7Ò "Ð "¥w­s°H¸eÑ'DÔ'DÐ "Ø -Ð -Ð -Ð -Ð -Ð -Ø ˆNÑ Ô Ð Ð Ð ð #Ð "Ð "Ð "r có$— ddlm}|¦«S)Nr)Ú get_logger)Úutilre)rres rrezBaseContext.get_logger˜s'€ð ð %Ð$Ð$Ð$Ð$Ð$؈z‰|Œ|Ðr có&— ddlm}||¦«S)Nr)Ú log_to_stderr)rfrh)rÚlevelrhs rrhzBaseContext.log_to_stderrŸs'€ØFØ'Ð'Ð'Ð'Ð'Ð'؈}˜UÑ#Ô#Ð#r có— ddlm}dS)Nr)r))Úr))rr)s rÚallow_connection_picklingz%BaseContext.allow_connection_pickling¤s!€ð ð !Ð Ð Ð Ð Ð Ð Ð r có*— ddlm}||¦«dS)Nr)Úset_executable)rcrn)rÚ executablerns rrnzBaseContext.set_executable¬s1€ð ð *Ð)Ð)Ð)Ð)Ð)؈�zÑ"Ô"Ð"Ð"Ð"r có*— ddlm}||¦«dS)Nr)Úset_forkserver_preload)Ú forkserverrq)rÚ module_namesrqs rrqz"BaseContext.set_forkserver_preload´s2€ð ð 7Ð6Ð6Ð6Ð6Ð6ØÐ˜|Ñ,Ô,Ð,Ð,Ð,r có–—|€|S t|}n!#t$rtd|z¦«d‚wxYw| ¦«|S)Nzcannot find context for %r)Ú_concrete_contextsÚKeyErrorÚ ValueErrorÚ_check_available)rÚmethodr!s rr#zBaseContext.get_context»sj€Ø ˆ>؈Kð NÝ$ VÔ,ˆCˆCøÝð Nð Nð NÝÐ9¸FÑBÑCÔCÈÐ Mð Nøøøà ×ÒÑÔÐØˆ s† ”2Fcó—|jS©N)Ú_name©rÚ allow_nones rÚget_start_methodzBaseContext.get_start_methodÅs €ØŒzÐr có —td¦«‚)Nz+cannot set start method of concrete context)rw©rryÚforces rÚset_start_methodzBaseContext.set_start_methodÈs€ÝÐFÑGÔGÐGr cóF— t¦« d¦«S©Nr)ÚglobalsÚget©rs rÚreducerzBaseContext.reducerËs€ð (å‰yŒy�}Š}˜[Ñ)Ô)Ð)r có(—|t¦«d<dSr…)r†)rrs rr‰zBaseContext.reducerÑs€à!*�‰ Œ �+ÑÐÐr có—dSr{rrˆs rrxzBaseContext._check_availableÕs€Ø ˆr )Tr{)r)NN)r)NNrN©F)+r r r rrrrÚ staticmethodrÚcurrent_processÚparent_processÚactive_childrenrr&r(r,r/r1r4r7r9r;r@rDrFrHrPrUrXr[r_rerhrlrnrqr#rrƒÚpropertyr‰Úsetterrxrr rrrs¨€€€€€à€LØ#€NØ€LØ-Ðà"�l 7Ô#:Ñ;Ô;€OØ!�\ 'Ô"8Ñ9Ô9€NØ"�l 7Ô#:Ñ;Ô;€Oðððð ð ð ððððð ,ð,ð,ð -ð-ð-ð 7ð7ð7ð7ð 8ð8ð8ð8ð ?ð?ð?ð?ð -ð-ð-ð IðIðIðIð 6ð6ð6ð6ð >ð>ð>ð>ð 3ð3ð3ð ?AØ"ð0ð0ð0ð0ð1ð1ð1ð ?ð?ð?ð 37ð-ð-ð-ð-ð-ð DHð-ð-ð-ð-ð-ð ðððððð$ð$ð$ð$ð !ð!ð!ð#ð#ð#ð-ð-ð-ðððððððððHðHðHðHðð*ð*ñ„Xð*ð  „^ð+ð+ñ„^ð+ð ð ð ð ð r rcó>—eZdZdZed„¦«Zed„¦«ZdS)ÚProcessNcód—t ¦«j |¦«Sr{)Ú_default_contextr#r”Ú_Popen)Ú process_objs rr—zProcess._PopenÞs%€å×+Ò+Ñ-Ô-Ô5×<Ò<¸[ÑIÔIÐIr cób—t ¦«j ¦«Sr{)r–r#r”Ú _after_forkrr rršzProcess._after_forkâs#€å×+Ò+Ñ-Ô-Ô5×AÒAÑCÔCÐCr ©r r r Ú _start_methodr�r—ršrr rr”r”ÜsU€€€€€Ø€MØðJðJñ„\ðJððDðDñ„\ðDðDðDr r”có@‡—eZdZeZd„Zdˆfd„ Zd d„Zd d„Zd„ZˆxZ S) ÚDefaultContextcó"—||_d|_dSr{)r–Ú_actual_context)rrIs rÚ__init__zDefaultContext.__init__és€Ø 'ˆÔØ#ˆÔÐÐr Ncó~•—|€|j€ |j|_|jSt¦« |¦«Sr{)r r–Úsuperr#)rryÚ __class__s €rr#zDefaultContext.get_contextís=ø€Ø ˆ>ØÔ#Ð+Ø'+Ô'<�Ô$ØÔ'Ð 'å‘7”7×&Ò& vÑ.Ô.Ð .r Fcó„—|j�|std¦«‚|€ |r d|_dS| |¦«|_dS)Nzcontext has already been set)r Ú RuntimeErrorr#r�s rrƒzDefaultContext.set_start_methodõsQ€Ø Ô Ð +°EÐ +ÝÐ=Ñ>Ô>Ð >Ø ˆ>˜eˆ>Ø#'ˆDÔ Ø ˆFØ#×/Ò/°Ñ7Ô7ˆÔÐÐr cóH—|j€|rdS|j|_|jjSr{)r r–r|r}s rrzDefaultContext.get_start_methodýs/€Ø Ô Ð 'Øð Ø�tØ#'Ô#8ˆDÔ ØÔ#Ô)Ð)r cóž—tjdkrdgStjdkrddgnddg}tjr| d¦«|S)Nr]rcÚdarwinÚforkrr)r`rarÚHAVE_SEND_HANDLEÚappend)rÚmethodss rÚget_all_start_methodsz$DefaultContext.get_all_start_methodssZ€Ý Œ<˜7Ò "Ð "Ø�9Ð å+.¬<¸8Ò+CÐ+C�w Ð'Ð'È&ÐRYÐIZˆGÝÔ)ð -Ø—’˜|Ñ,Ô,Ð,؈Nr r{rŒ) r r r r”r¡r#rƒrr®Ú __classcell__)r¤s@rržržæsˆø€€€€€Ø€Gð$ð$ð$ð/ð/ð/ð/ð/ð/ð8ð8ð8ð8ð*ð*ð*ð*ðððððððr ržr]có(—eZdZdZed„¦«ZdS)Ú ForkProcessrªcó$—ddlm}||¦«S©Nr)ÚPopen)Ú popen_forkr´©r˜r´s rr—zForkProcess._Popens$€à )Ð )Ð )Ð )Ð )Ð )Ø�5˜Ñ%Ô%Ð %r N©r r r rœr�r—rr rr±r±s2€€€€€Øˆ Ø ð &ð &ñ Œð &ð &ð &r r±có>—eZdZdZed„¦«Zed„¦«ZdS)Ú SpawnProcessrccó$—ddlm}||¦«Sr³)Úpopen_spawn_posixr´r¶s rr—zSpawnProcess._Popenó$€à 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø�5˜Ñ%Ô%Ð %r có—dSr{rrr rršzSpawnProcess._after_fork"ó €ð ˆDr Nr›rr rr¹r¹óM€€€€€Øˆ Ø ð &ð &ñ Œð &ð ð ð ñ Œð ð ð r r¹có(—eZdZdZed„¦«ZdS)ÚForkServerProcessrrcó$—ddlm}||¦«Sr³)Úpopen_forkserverr´r¶s rr—zForkServerProcess._Popen)s$€à /Ð /Ð /Ð /Ð /Ð /Ø�5˜Ñ%Ô%Ð %r Nr·rr rrÁrÁ's2€€€€€Ø$ˆ Ø ð &ð &ñ Œð &ð &ð &r rÁcó—eZdZdZeZdS)Ú ForkContextrªN)r r r r|r±r”rr rrÅrÅ.s€€€€€ØˆØˆˆˆr rÅcó—eZdZdZeZdS©Ú SpawnContextrcN©r r r r|r¹r”rr rrÈrÈ2ó€€€€€ØˆØˆˆˆr rÈcó—eZdZdZeZd„ZdS)ÚForkServerContextrrcó<—tjstd¦«‚dS)Nz%forkserver start method not available)rr«rwrˆs rrxz"ForkServerContext._check_available9s)€ÝÔ-ð JÝ Ð!HÑIÔIÐIð Jð Jr N)r r r r|rÁr”rxrr rrÌrÌ6s2€€€€€ØˆØ#ˆð Jð Jð Jð Jð Jr rÌ)rªrcrrr©rcrªcó>—eZdZdZed„¦«Zed„¦«ZdS)r¹rccó$—ddlm}||¦«Sr³)Úpopen_spawn_win32r´r¶s rr—zSpawnProcess._PopenMr¼r có—dSr{rrr rršzSpawnProcess._after_forkRr¾r Nr›rr rr¹r¹Kr¿r có—eZdZdZeZdSrÇrÉrr rrÈrÈWrÊr có4—t|t_dSr{)rur–r )rys rÚ_force_start_methodrÔds€Ý'9¸&Ô'AÕÔ$Ð$Ð$r có.—ttdd¦«S)NÚspawning_popen)rbÚ_tlsrr rÚget_spawning_popenrØms€Ý •4Ð)¨4Ñ 0Ô 0Ð0r có—|t_dSr{)r×rÖ)Úpopens rÚset_spawning_popenrÛps€Ø…DÔÐÐr cój—t¦«€$tdt|¦«jz¦«‚dS)NzF%s objects should only be shared between processes through inheritance)rØr¦Útyper )Úobjs rÚassert_spawningrßss>€ÝÑÔÐ#Ýð #Ý%)¨#¡Y¤YÔ%7ñ 8ñôð ð$Ð#r ) rr`Ú threadingrkrrÚ__all__Ú ExceptionrrrrÚobjectrÚ BaseProcessr”ržrar±r¹rÁrÅrÈrÌrur–rÔÚlocalr×rØrÛrßrr rúræsñðØ € € € Ø € € € ØÐÐÐàÐÐÐÐÐØÐÐÐÐÐà €ð  ð ð ð ð �9ñ ô ð ð ð ð ð ð �\ñ ô ð ð ð ð ð ð �<ñ ô ð ð ð ð ð ð ˜,ñ ô ð ðx ðx ðx ðx ðx �&ñx ôx ðx ð|DðDðDðDðDˆgÔ!ñDôDðDð%ð%ð%ð%ð%�[ñ%ô%ð%ðX„<�7ÒÐð&ð&ð&ð&ð&�gÔ)ñ&ô&ð&ð ð ð ð ð �wÔ*ñ ô ð ð&ð&ð&ð&ð&˜GÔ/ñ&ô&ð&ððððð�kñôðððððð�{ñôððJðJðJðJðJ˜KñJôJðJð� ‘ ” Ø�‘”Ø'Ð'Ñ)Ô)ððÐð  „|�xÒÐð*˜>Ð*<¸WÔ*EÑFÔFÐÐà)˜>Ð*<¸VÔ*DÑEÔEÐÐð ð ð ð ð �wÔ*ñ ô ð ððððð�{ñôðð ��‘”ðÐð&�~Ð&8¸Ô&AÑBÔBÐð BðBðBð€y„ÑÔ€ð1ð1ð1ð ð ð ðððððr