§ ,'ßÁzæ¦ãó"—ddlZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z dgZ ejdkrddlZGd„d e¦«Zn%Gd „d e¦«Zd „Zd „Ze jee¦«Gd „de¦«ZGd„de¦«ZdS)éN)Ú defaultdicté)Ú reductionÚassert_spawning)ÚutilÚ BufferWrapperÚwin32có@—eZdZ ej¦«Zd„Zd„Zd„ZdS)ÚArenacót—||_td¦«D]p}dtj¦«t |j¦«fz}t jd||¬¦«}tj¦«dkrn$|  ¦«Œqtd¦«‚||_ ||_ |j|j f|_ dS)Nédz pym-%d-%séÿÿÿÿ©ÚtagnamerzCannot find name for new mmap)ÚsizeÚrangeÚosÚgetpidÚnextÚ_randÚmmapÚ_winapiÚ GetLastErrorÚcloseÚFileExistsErrorÚnameÚbufferÚ_state)ÚselfrÚirÚbufs úA/opt/alt/python-internal/lib64/python3.11/multiprocessing/heap.pyÚ__init__zArena.__init__&s®€ØˆDŒIݘ3‘Z”Zð Gð G�Ø"¥b¤i¡k¤kµ4¸¼ Ñ3CÔ3CÐ%DÑD�Ý”i  D°$Ð7Ñ7Ô7�ÝÔ'Ñ)Ô)¨QÒ.Ð.Ø�Eà— ’ ‘ ” � � å%Ð&EÑFÔFÐF؈DŒI؈DŒKØœ9 d¤iÐ0ˆDŒKˆKˆKócó.—t|¦«|jS©N)rr)rs r"Ú __getstate__zArena.__getstate__5s€Ý ˜DÑ !Ô !Ð !Ø”;Ð r$có~—|x\|_|_|_tjd|j|j¬¦«|_dS)Nrr)rrrrr)rÚstates r"Ú __setstate__zArena.__setstate__9s7€Ø16Ð 6Ñ ˆDŒI�t”y 4¤;åœ) B¨¬ ¸4¼9ÐEÑEÔEˆDŒKˆKˆKr$N) Ú__name__Ú __module__Ú __qualname__ÚtempfileÚ_RandomNameSequencerr#r'r*©r$r"r r s]€€€€€ð ð-�Ô,Ñ.Ô.ˆð 1ð 1ð 1ð ð ð ð Fð Fð Fð Fð Fr$r có@—eZdZ ejdkrdgZngZdd„Zd„ZdS)r Úlinuxz/dev/shmrcó¨—||_||_|dkr™tjdt j¦«z| |¦«¬¦«\|_}t j|¦«tj |tj |jf¦«t j |j|¦«tj |j|j¦«|_ dS)Nrzpym-%d-)ÚprefixÚdir)rÚfdr.ÚmkstemprrÚ _choose_dirÚunlinkrÚFinalizerÚ ftruncaterr)rrr6rs r"r#zArena.__init__Ms¯€ØˆDŒI؈DŒGØ�RŠxˆxõ!)Ô 0Ø%¥b¤i¡k¤kÑ1Ø×)Ò)¨$Ñ/Ô/ð!1ñ!1ô!1‘ �”˜õ” ˜$‘”�Ý” ˜d¥B¤H¨t¬w¨jÑ9Ô9Ð9Ý” ˜TœW dÑ+Ô+Ð+Ýœ) D¤G¨T¬YÑ7Ô7ˆDŒKˆKˆKr$có’—|jD]-}tj|¦«}|j|jz|kr|cSŒ.t j¦«Sr&)Ú_dir_candidatesrÚstatvfsÚf_bavailÚf_frsizerÚ get_temp_dir)rrÚdÚsts r"r8zArena._choose_dir[sT€ðÔ)ð ð �Ý”Z ‘]”]�Ø”; ¤Ñ,°Ò4Ð4Ø�H�H�Hð5åÔ$Ñ&Ô&Ð &r$N)r)r+r,r-ÚsysÚplatformr=r#r8r0r$r"r r CsY€€€€€ð ð Œ<˜7Ò "Ð "Ø)˜lˆOˆOà ˆOð 8ð 8ð 8ð 8ð 'ð 'ð 'ð 'ð 'r$có„—|jdkrtd¦«‚t|jt j|j¦«ffS)NrzDArena is unpicklable because forking was enabled when it was created)r6Ú ValueErrorÚ rebuild_arenarrÚDupFd)Úas r"Ú reduce_arenarKdsF€Ø Œ4�2Š:ˆ:ÝðGñHôHð Hå˜qœv¥y¤°q´tÑ'<Ô'<Ð=Ð=Ð=r$cóF—t|| ¦«¦«Sr&)r Údetach)rÚdupfds r"rHrHjs€Ý�T˜5Ÿ<š<™>œ>Ñ*Ô*Ð*r$cóz—eZdZdZdZdZejfd„Ze d„¦«Z d„Z d„Z d„Z d„Zd „Zd „Zd „Zd „Zd „ZdS)ÚHeapéi@có—tj¦«|_tj¦«|_||_g|_i|_i|_ i|_ tt¦«|_ g|_g|_d|_d|_dS©Nr)rrÚ_lastpidÚ threadingÚLockÚ_lockÚ_sizeÚ_lengthsÚ _len_to_seqÚ_start_to_blockÚ_stop_to_blockrÚsetÚ_allocated_blocksÚ_arenasÚ_pending_free_blocksÚ _n_mallocsÚ_n_frees)rrs r"r#z Heap.__init__{s�€Ýœ ™ œ ˆŒ Ý”^Ñ%Ô%ˆŒ àˆŒ àˆŒ ðˆÔð "ˆÔð!ˆÔõ"-­SÑ!1Ô!1ˆÔ؈Œ ð%'ˆÔ!ðˆŒØˆŒ ˆ ˆ r$có—|dz }||z|zS)Nrr0)ÚnÚ alignmentÚmasks r"Ú_roundupz Heap._roundup˜s€ð˜1‰}ˆØ�D‘˜T˜EÑ!Ð!r$có.—| t|j|¦«tj¦«}|j|jkr|xjdzc_t jd|¦«t|¦«}|j   |¦«|d|fS)Néz"allocating a new mmap of length %dr) rgÚmaxrXrÚPAGESIZEÚ_DOUBLE_ARENA_SIZE_UNTILrÚinfor r_Úappend)rrÚlengthÚarenas r"Ú _new_arenazHeap._new_arenažs…€à—’�s 4¤:¨tÑ4Ô4µd´mÑDÔDˆð Œ:˜Ô5Ò 5Ð 5Ø ˆJŒJ˜!‰OˆJŒJÝ Œ Ð6¸Ñ?Ô?Ð?Ý�f‘ ” ˆØ Œ ×Ò˜EÑ"Ô"Ð"Ø�q˜&Ð!Ð!r$cóT—|j}||jkrdS|j |¦«}|j|df=|j||f=|j |¦«|j|}| |d|f¦«|s$|j|=|j  |¦«dSdSrS) rÚ_DISCARD_FREE_SPACE_LARGER_THANr^Úpopr[r\r_ÚremoverZrY)rrproÚblocksÚseqs r"Ú_discard_arenazHeap._discard_arenaªsÇ€à”ˆð �DÔ8Ò 8Ð 8Ø ˆFØÔ'×+Ò+¨EÑ2Ô2ˆà Ô  %¨ Ð ,Ø Ô  ¨ Ð 0Ø Œ ×Ò˜EÑ"Ô"Ð"ØÔ˜vÔ&ˆØ � Š �E˜1˜fÐ%Ñ&Ô&Ð&Øð )ØÔ  Ð(Ø ŒM× Ò  Ñ (Ô (Ð (Ð (Ð (ð )ð )r$cóH—tj|j|¦«}|t|j¦«kr| |¦«S|j|}|j|}| ¦«}|s|j|=|j|=|\}}}|j||f=|j||f=|Sr&) ÚbisectÚ bisect_leftrYÚlenrqrZrtr[r\) rrr rorwÚblockrpÚstartÚstops r"Ú_mallocz Heap._malloc¼s®€å Ô ˜tœ}¨dÑ 3Ô 3ˆØ •�D”MÑ"Ô"Ò "Ð "Ø—?’? 4Ñ(Ô(Ð (à”] 1Ô%ˆFØÔ" 6Ô*ˆCØ—G’G‘I”IˆEØð ?ØÔ$ VÐ,¨d¬m¸AÐ.>à$ш��tØ Ô  %¨ Ð 0Ø Ô  ¨  Ð .؈ r$cóè—|\}}} |j||f}| |¦«\}}n#t$rYnwxYw |j||f}| |¦«\}}n#t$rYnwxYw|||f}||z } |j| |¦«n5#t$r(|g|j|<t j|j|¦«YnwxYw||j||f<||j||f<dSr&) r\Ú_absorbÚKeyErrorr[rZrnrzÚinsortrY) rr}rpr~rÚ prev_blockÚ_Ú next_blockros r"Ú_add_free_blockzHeap._add_free_blockÍsY€à$ш��tð 0ØÔ,¨e°U¨^Ô<ˆJð—|’| JÑ/Ô/‰HˆE�1�1øõð ð ð Ø ˆDð øøøð  /ØÔ-¨u°d¨mÔ<ˆJð—l’l :Ñ.Ô.‰GˆAˆtˆtøõð ð ð Ø ˆDð øøøð ˜˜tÐ$ˆØ˜‘ˆð 1Ø Ô ˜VÔ $× +Ò +¨EÑ 2Ô 2Ð 2Ð 2øÝð 1ð 1ð 1Ø(- wˆDÔ ˜VÑ $Ý ŒM˜$œ-¨Ñ 0Ô 0Ð 0Ð 0Ð 0ð 1øøøð05ˆÔ˜e U˜^Ñ,Ø-2ˆÔ˜U D˜MÑ*Ð*Ð*s0ˆ0° =¼=ÁA)Á) A6Á5A6 B%Â%/CÃCcóÔ—|\}}}|j||f=|j||f=||z }|j|}| |¦«|s"|j|=|j |¦«||fSr&)r[r\rZrurY)rr}rpr~rrorws r"r‚z Heap._absorbës‡€à$ш��tØ Ô  %¨ Ð 0Ø Ô  ¨  Ð .à˜‘ˆØÔ˜vÔ&ˆØ � Š �5ÑÔÐØð )ØÔ  Ð(Ø ŒM× Ò  Ñ (Ô (Ð (à�dˆ{Ðr$cóŒ—|\}}}|j|}| ||f¦«|s| |¦«dSdSr&)r^rurx)rr}rpr~rrvs r"Ú_remove_allocated_blockzHeap._remove_allocated_blockús]€Ø"шˆu�dØÔ'¨Ô.ˆØ� Š �u˜d�mÑ$Ô$Ð$Øð 'à × Ò  Ñ &Ô &Ð &Ð &Ð &ð 'ð 'r$có²— |j ¦«}n#t$rYdSwxYw| |¦«| |¦«ŒWr&)r`rtÚ IndexErrorrˆr‹©rr}s r"Ú_free_pending_blockszHeap._free_pending_blockssq€ð 0ð ØÔ1×5Ò5Ñ7Ô7��øÝð ð ð Ø��ð øøøà × Ò  Ñ 'Ô 'Ð 'Ø × (Ò (¨Ñ /Ô /Ð /ð  0s ƒ� +ª+có(—tj¦«|jkr9td tj¦«|j¦«¦«‚|j d¦«s|j |¦«dS |xj dz c_ |  ¦«|  |¦«|  |¦«|j  ¦«dS#|j  ¦«wxYw)Nz$My pid ({0:n}) is not last pid {1:n}Fr)rrrTrGÚformatrWÚacquirer`rnrbr�rˆr‹ÚreleaserŽs r"Úfreez Heap.free s€õ Œ9‰;Œ;˜$œ-Ò 'Ð 'ÝØ6×=Ò=Ý”I‘K”K ¤ ñ/ô/ñ0ô0ð 0ðŒz×!Ò! %Ñ(Ô(ð %ð Ô %× ,Ò ,¨UÑ 3Ô 3Ð 3Ð 3Ð 3ð %Ø� ”  Ñ"� ” Ø×)Ò)Ñ+Ô+Ð+Ø×$Ò$ UÑ+Ô+Ð+Ø×,Ò,¨UÑ3Ô3Ð3à” ×"Ò"Ñ$Ô$Ð$Ð$Ð$ø�” ×"Ò"Ñ$Ô$Ð$Ð$øøøs  AC6Ã6Dcó¸—|dkr"td |¦«¦«‚tj|kr"t d |¦«¦«‚t j¦«|jkr| ¦«|j 5|xj dz c_ |  ¦«|  t|d¦«|j¦«}| |¦«\}}}||z}||kr| |||f¦«|j| ||f¦«|||fcddd¦«S#1swxYwYdS)NrúSize {0:n} out of rangeúSize {0:n} too larger)rGr‘rDÚmaxsizeÚ OverflowErrorrrrTr#rWrar�rgrjÚ _alignmentr€rˆr^Úadd)rrrpr~rÚ real_stops r"Úmallocz Heap.malloc(s‘€à �!Š8ˆ8ÝÐ6×=Ò=¸dÑCÔCÑDÔDÐ DÝ Œ;˜$Ò Ð ÝÐ 6× =Ò =¸dÑ CÔ CÑDÔDÐ DÝ Œ9‰;Œ;˜$œ-Ò 'Ð 'Ø �MŠM‰OŒOˆOØ ŒZð -ð -Ø ˆOŒO˜qÑ ˆOŒOà × %Ò %Ñ 'Ô 'Ð 'Ø—=’=¥ T¨1¡¤¨t¬Ñ?Ô?ˆDØ#'§<¢<°Ñ#5Ô#5Ñ ˆU�E˜4Ø ™ ˆIؘ4ÒÐð×$Ò$ e¨Y¸Ð%=Ñ>Ô>Ð>Ø Ô " 5Ô )× -Ò -¨u°iÐ.@Ñ AÔ AÐ Aؘ5 )Ð,ð -ð -ð -ð -ñ -ô -ð -ð -ð -ð -ð -ð -øøøð -ð -ð -ð -ð -ð -sÂB0EÅEÅEN)r+r,r-ršrsrlrrkr#Ú staticmethodrgrqrxr€rˆr‚r‹r�r”r�r0r$r"rPrPss €€€ð€Jà&3Ð#Ø,Ðà œMððððð:ð"ð"ñ„\ð"ð "ð "ð "ð)ð)ð)ð$ððð"3ð3ð3ð< ð ð ð'ð'ð'ð0ð0ð0ð%ð%ð%ð8-ð-ð-ð-ð-r$rPcó.—eZdZe¦«Zd„Zd„ZdS)rcóX—|dkr"td |¦«¦«‚tj|kr"t d |¦«¦«‚t j |¦«}||f|_tj |t jj |f¬¦«dS)Nrr–r—)Úargs) rGr‘rDr˜r™rÚ_heapr�rrr:r”)rrr}s r"r#zBufferWrapper.__init__Fs˜€Ø �!Š8ˆ8ÝÐ6×=Ò=¸dÑCÔCÑDÔDÐ DÝ Œ;˜$Ò Ð ÝÐ 6× =Ò =¸dÑ CÔ CÑDÔDÐ DÝÔ#×*Ò*¨4Ñ0Ô0ˆØ˜d�mˆŒ Ý Œ �d�MÔ/Ô4¸E¸8ÐDÑDÔDÐDÐDÐDr$có\—|j\\}}}}t|j¦«|||z…Sr&)rÚ memoryviewr)rrpr~rrs r"Úcreate_memoryviewzBufferWrapper.create_memoryviewOs3€Ø%)¤[Ñ"ш��t˜dݘ%œ,Ñ'Ô'¨¨e°D©jÐ(8Ô9Ð9r$N)r+r,r-rPr¢r#r¥r0r$r"rrBs@€€€€€à ˆD‰FŒF€EðEðEðEð:ð:ð:ð:ð:r$)rzÚ collectionsrrrrDr.rUÚcontextrrÚrÚ__all__rErÚobjectr rKrHÚregisterrPrr0r$r"úr¬sœðð€ € € Ø#Ð#Ð#Ð#Ð#Ð#Ø € € € Ø € € € Ø € € € Ø€€€ØÐÐÐà/Ð/Ð/Ð/Ð/Ð/Ð/Ð/ØÐÐÐÐÐà Ð €ð „<�7ÒÐà€N€N€NðFðFðFðFðF�ñFôFðFðFðH'ð'ð'ð'ð'�ñ'ô'ð'ðB>ð>ð>ð +ð+ð+ð€IÔ�u˜lÑ+Ô+Ð+ð I-ðI-ðI-ðI-ðI-ˆ6ñI-ôI-ðI-ð^:ð:ð:ð:ð:�Fñ:ô:ð:ð:ð:r$