§
    ð­½j(%  ã                   óH  — d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl	m
Z
 g d¢Zej        dk    p( eed¦  «        o eed¦  «        o eej        d	¦  «        Z G d
„ dej        ¦  «        Zej        Zd*d„Zej        dk    r*eg d¢z  Zd dlZd+ddœd„Zd„ Zd„ Zd„ Z G d„ de¦  «        Zn%eg d¢z  Zd dlZej        dk    Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Z G d„ d¦  «        Z  e e! e ¦   «         j"        ¦  «        e¦  «         d „ Z# e e!e$j%        ¦  «        e#¦  «          e e!e&j'        ¦  «        e#¦  «         d!„ Z(d"„ Z) eej*        e(¦  «         ej        dk    rd#„ Z+d$„ Z, eej        e+¦  «         nd%„ Z+d&„ Z, eej        e+¦  «          G d'„ d(e¬)¦  «        Z-dS ),é    )ÚABCMetaNé   )Úcontext)Úsend_handleÚrecv_handleÚForkingPicklerÚregisterÚdumpÚwin32ÚCMSG_LENÚ
SCM_RIGHTSÚsendmsgc                   ón   ‡ — e Zd Z	 i Zej        Zˆ fd„Zed„ ¦   «         Z	edd„¦   «         Z
ej        Zˆ xZS )r   c                 ó®   •—  t          ¦   «         j        |Ž  | j                             ¦   «         | _        | j                             | j        ¦  «         d S ©N)ÚsuperÚ__init__Ú_copyreg_dispatch_tableÚcopyÚdispatch_tableÚupdateÚ_extra_reducers)ÚselfÚargsÚ	__class__s     €úD/Users/bpa/Downloads/Python-3.11.17/Lib/multiprocessing/reduction.pyr   zForkingPickler.__init__&   sN   ø€ Ø�‰ŒÔ˜$ÐÐØ"Ô:×?Ò?ÑAÔAˆÔØÔ×"Ò" 4Ô#7Ñ8Ô8Ð8Ð8Ð8ó    c                 ó   — 	 || j         |<   d S r   )r   )ÚclsÚtypeÚreduces      r   r	   zForkingPickler.register+   s   € à4Ø$*ˆÔ˜DÑ!Ð!Ð!r   Nc                 óŽ   — t          j        ¦   «         } | ||¦  «                             |¦  «         |                     ¦   «         S r   )ÚioÚBytesIOr
   Ú	getbuffer)r   ÚobjÚprotocolÚbufs       r   ÚdumpszForkingPickler.dumps0   s;   € åŒj‰lŒlˆØˆˆC�ÑÔ×Ò Ñ$Ô$Ð$Ø�}Š}‰ŒÐr   r   )Ú__name__Ú
__module__Ú__qualname__r   Úcopyregr   r   r   Úclassmethodr	   r)   ÚpickleÚloadsÚ__classcell__)r   s   @r   r   r   !   s�   ø€ € € € € Ø3Ø€OØ%Ô4Ðð9ð 9ð 9ð 9ð 9ð
 ð+ð +ñ „[ð+ð ðð ð ñ „[ðð
 ŒL€E€E€E€E€Er   r   c                 óN   — 	 t          ||¦  «                             | ¦  «         d S r   )r   r
   )r&   Úfiler'   s      r   r
   r
   :   s)   € Ø=Ý�4˜Ñ"Ô"×'Ò'¨Ñ,Ô,Ð,Ð,Ð,r   )Ú	DupHandleÚ	duplicateÚsteal_handleF)Úsource_processc                ó€   — 	 t          j        ¦   «         }|€|}|€|}t          j        || |d|t           j        ¦  «        S )Nr   )Ú_winapiÚGetCurrentProcessÚDuplicateHandleÚDUPLICATE_SAME_ACCESS)ÚhandleÚtarget_processÚinheritabler7   Úcurrent_processs        r   r5   r5   G   sO   € àJÝ!Ô3Ñ5Ô5ˆØÐ!Ø,ˆNØÐ!Ø,ˆNÝÔ&Ø˜F NØˆ{�GÔ9ñ;ô ;ð 	;r   c           	      ó"  — 	 t          j        t           j        d| ¦  «        }	 t          j        ||t          j        ¦   «         ddt           j        t           j        z  ¦  «        t          j        |¦  «         S # t          j        |¦  «         w xY w©NFr   )r9   ÚOpenProcessÚPROCESS_DUP_HANDLEr;   r:   r<   ÚDUPLICATE_CLOSE_SOURCEÚCloseHandle)Ú
source_pidr=   Úsource_process_handles      r   r6   r6   S   s‹   € ØCÝ 'Ô 3ÝÔ&¨¨zñ!;ô !;Ðð	7ÝÔ*Ø% vÝÔ)Ñ+Ô+¨Q°ÝÔ-µÔ0NÑNñPô Põ
 ÔÐ 5Ñ6Ô6Ð6Ð6ø�GÔÐ 5Ñ6Ô6Ð6Ð6øøøs   £A A8 Á8Bc                 óh   — 	 t          |t          j        |¦  «        }|                      |¦  «         d S r   )r4   r9   r<   Úsend)Úconnr=   Údestination_pidÚdhs       r   r   r   _   s,   € Ø4Ý�v�wÔ<¸oÑNÔNˆØ�	Š	�"‰Œˆˆˆr   c                 óP   — 	 |                       ¦   «                              ¦   «         S r   )ÚrecvÚdetach)rK   s    r   r   r   d   s   € Ø7Ø�yŠy‰{Œ{×!Ò!Ñ#Ô#Ð#r   c                   ó   — e Zd Z	 dd„Zd„ ZdS )r4   Nc                 óH  — |€t          j        ¦   «         }t          j        t          j        d|¦  «        }	 t          j        t          j        ¦   «         |||dd¦  «        | _        t          j        |¦  «         n# t          j        |¦  «         w xY w|| _	        || _
        d S rB   )ÚosÚgetpidr9   rC   rD   r;   r:   Ú_handlerF   Ú_accessÚ_pid)r   r=   ÚaccessÚpidÚprocs        r   r   zDupHandle.__init__j   sš   € Øˆ{õ ”i‘k”k�ÝÔ&¥wÔ'AÀ5È#ÑNÔNˆDð*Ý&Ô6ÝÔ-Ñ/Ô/Ø˜D &¨%°ñ 4ô  4�”õ Ô# DÑ)Ô)Ð)Ð)ø•Ô# DÑ)Ô)Ð)Ð)øøøØ!ˆDŒLØˆDŒIˆIˆIs   ·/A; Á;Bc                 ól  — 	 | j         t          j        ¦   «         k    r| j        S t	          j        t          j        d| j         ¦  «        }	 t	          j        || j        t	          j        ¦   «         | j	        dt          j
        ¦  «        t	          j        |¦  «         S # t	          j        |¦  «         w xY w©NF)rW   rS   rT   rU   r9   rC   rD   r;   r:   rV   rE   rF   )r   rZ   s     r   rP   zDupHandle.detachy   s    € ØCàŒy�BœI™KœKÒ'Ð'à”|Ð#åÔ&¥wÔ'AÀ5Ø'+¤yñ2ô 2ˆDð*ÝÔ.Ø˜$œ,­Ô(AÑ(CÔ(CØ”L %­Ô)GñIô Iõ Ô# DÑ)Ô)Ð)Ð)ø•Ô# DÑ)Ô)Ð)Ð)øøøs   Á=B ÂB3r   )r*   r+   r,   r   rP   © r   r   r4   r4   h   s:   € € € € € Ø-ð	ð 	ð 	ð 	ð	*ð 	*ð 	*ð 	*ð 	*r   r4   )ÚDupFdÚsendfdsÚrecvfdsÚdarwinc                 ó2  — 	 t          j         d|¦  «        }t          t          |¦  «        dz  g¦  «        }|                      |gt          j        t          j        |fg¦  «         t          r(|                      d¦  «        dk    rt          d¦  «        ‚d S d S )NÚié   r   ó   Az%did not receive acknowledgement of fd)
ÚarrayÚbytesÚlenr   ÚsocketÚ
SOL_SOCKETr   ÚACKNOWLEDGErO   ÚRuntimeError)ÚsockÚfdsÚmsgs      r   r_   r_   ‘   s”   € Ø:ÝŒk˜#˜sÑ#Ô#ˆÝ•S˜‘X”X ‘^Ð$Ñ%Ô%ˆØ�Š�c�U�fÔ/µÔ1BÀCÐHÐIÑJÔJÐJÝð 	H˜4Ÿ9š9 Q™<œ<¨4Ò/Ð/ÝÐFÑGÔGÐGð	Hð 	HÐ/Ð/r   c                 ó$  — 	 t          j         d¦  «        }|j        |z  }|                      dt          j        |¦  «        ¦  «        \  }}}}|s	|st
          ‚	 t          r|                      d¦  «         t          |¦  «        dk    rt          dt          |¦  «        z  ¦  «        ‚|d         \  }}	}
|t          j
        k    r¨|	t          j        k    r˜t          |
¦  «        |j        z  dk    rt          ‚|                     |
¦  «         t          |¦  «        dz  |d         k    r6t          d                     t          |¦  «        |d         ¦  «        ¦  «        ‚t!          |¦  «        S n# t          t"          f$ r Y nw xY wt          d¦  «        ‚)	Nrc   r   re   zreceived %d items of ancdatar   rd   z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rf   ÚitemsizeÚrecvmsgri   Ú
CMSG_SPACEÚEOFErrorrk   rJ   rh   rl   rj   r   Ú
ValueErrorÚ	frombytesÚAssertionErrorÚformatÚlistÚ
IndexError)rm   ÚsizeÚaÚ
bytes_sizero   ÚancdataÚflagsÚaddrÚ
cmsg_levelÚ	cmsg_typeÚ	cmsg_datas              r   r`   r`   ™   s–  € Ø=ÝŒK˜ÑÔˆØ”Z $Ñ&ˆ
Ø$(§L¢L°µFÔ4EÀjÑ4QÔ4QÑ$RÔ$RÑ!ˆˆW�e˜TØð 	˜7ð 	ÝˆNð	Ýð  Ø—	’	˜$‘”�Ý�7‰|Œ|˜qÒ Ð Ý"Ð#AÝ#& w¡<¤<ñ$0ñ 1ô 1ð 1à/6°q¬zÑ,ˆJ˜	 9Ø�fÔ/Ò/Ð/Ø�VÔ.Ò.Ð.Ý�y‘>”> A¤JÑ.°!Ò3Ð3Ý$Ð$Ø—’˜IÑ&Ô&Ð&Ý�q‘6”6˜C‘< 3 q¤6Ò)Ð)Ý(Ø:×AÒAÝ ™FœF C¨¤Fñ,ô ,ñ-ô -ð -õ ˜A‘w”w�øøÝ�JÐ'ð 	ð 	ð 	ØˆDð	øøøåÐ2Ñ3Ô3Ð3s   ÁDE, Å,F Å?F c                 óÔ   — 	 t          j        |                      ¦   «         t           j        t           j        ¦  «        5 }t          ||g¦  «         d d d ¦  «         d S # 1 swxY w Y   d S r   )ri   ÚfromfdÚfilenoÚAF_UNIXÚSOCK_STREAMr_   )rK   r=   rL   Úss       r   r   r   µ   sš   € Ø4ÝŒ]˜4Ÿ;š;™=œ=­&¬.½&Ô:LÑMÔMð 	!ÐQRÝ�A˜�xÑ Ô Ð ð	!ð 	!ð 	!ñ 	!ô 	!ð 	!ð 	!ð 	!ð 	!ð 	!ð 	!ð 	!øøøð 	!ð 	!ð 	!ð 	!ð 	!ð 	!s   ¾AÁA!Á$A!c                 óÜ   — 	 t          j        |                      ¦   «         t           j        t           j        ¦  «        5 }t          |d¦  «        d         cd d d ¦  «         S # 1 swxY w Y   d S )Nr   r   )ri   r…   r†   r‡   rˆ   r`   )rK   r‰   s     r   r   r   º   s˜   € Ø7ÝŒ]˜4Ÿ;š;™=œ=­&¬.½&Ô:LÑMÔMð 	$ÐQRÝ˜1˜a‘=”= Ô#ð	$ð 	$ð 	$ð 	$ñ 	$ô 	$ð 	$ð 	$ð 	$ð 	$ð 	$ð 	$øøøð 	$ð 	$ð 	$ð 	$ð 	$ð 	$s   ¾A!Á!A%Á(A%c                 óà   — 	 t          j        ¦   «         }|�(|                     |                     | ¦  «        ¦  «        S t          rddlm} |                     | ¦  «        S t          d¦  «        ‚)Nr   )Úresource_sharerz&SCM_RIGHTS appears not to be available)r   Úget_spawning_popenr^   Úduplicate_for_childÚHAVE_SEND_HANDLEÚ rŒ   ru   )ÚfdÚ	popen_objrŒ   s      r   r^   r^   ¿   sw   € Ø)ÝÔ.Ñ0Ô0ˆ	ØÐ Ø—?’? 9×#@Ò#@ÀÑ#DÔ#DÑEÔEÐEÝð 	GØ)Ð)Ð)Ð)Ð)Ð)Ø"×(Ò(¨Ñ,Ô,Ð,åÐEÑFÔFÐFr   c                 óx   — | j         €t          | j        | j        j        ffS t          | j         | j        j        ffS r   )Ú__self__Úgetattrr   Ú__func__r*   ©Úms    r   Ú_reduce_methodr™   Î   s8   € Ø„zÐÝ˜œ a¤jÔ&9Ð:Ð:Ð:å˜œ Q¤ZÔ%8Ð9Ð9Ð9r   c                   ó   — e Zd Zd„ ZdS )Ú_Cc                 ó   — d S r   r]   )r   s    r   Úfz_C.fÔ   s   € Øˆr   N)r*   r+   r,   r�   r]   r   r   r›   r›   Ó   s#   € € € € € ðð ð ð ð r   r›   c                 ó,   — t           | j        | j        ffS r   )r•   Ú__objclass__r*   r—   s    r   Ú_reduce_method_descriptorr    Ù   s   € Ý�Q”^ Q¤ZÐ0Ð0Ð0r   c                 ó<   — t           | j        | j        | j        pi ffS r   )Ú_rebuild_partialÚfuncr   Úkeywords)Úps    r   Ú_reduce_partialr¦   ß   s   € Ý˜aœf a¤f¨a¬jÐ.>¸BÐ?Ð?Ð?r   c                 ó,   — t          j        | g|¢R i |¤ŽS r   )Ú	functoolsÚpartial)r£   r   r¤   s      r   r¢   r¢   á   s#   € ÝÔ˜TÐ5 DÐ5Ð5Ð5¨HÐ5Ð5Ð5r   c                 ó4   — ddl m} t           || ¦  «        ffS )Nr   )Ú	DupSocket)rŒ   r«   Ú_rebuild_socket)r‰   r«   s     r   Ú_reduce_socketr­   ê   s)   € Ø.Ð.Ð.Ð.Ð.Ð.Ý  ¨1¡¤ Ð/Ð/r   c                 ó*   — |                       ¦   «         S r   )rP   )Údss    r   r¬   r¬   í   s   € Ø�yŠy‰{Œ{Ðr   c                 ó|   — t          |                      ¦   «         ¦  «        }t          || j        | j        | j        ffS r   )r^   r†   r¬   Úfamilyr    Úproto)r‰   Údfs     r   r­   r­   ò   s1   € Ý�1—8’8‘:”:ÑÔˆÝ  Q¤X¨q¬v°q´wÐ ?Ð?Ð?r   c                 óZ   — |                       ¦   «         }t          j        ||||¬¦  «        S )N)r†   )rP   ri   )r³   r±   r    r²   r‘   s        r   r¬   r¬   õ   s(   € Ø�YŠY‰[Œ[ˆÝŒ}˜V T¨5¸Ð<Ñ<Ô<Ð<r   c                   ón   — e Zd Z	 eZeZeZeZeZej	        dk    re
Z
eZeZneZeZeZeZeZeZeZeZd„ ZdS )ÚAbstractReducerr   c                 ó˜  — t          t          t          ¦   «         j        ¦  «        t          ¦  «         t          t          t
          j        ¦  «        t          ¦  «         t          t          t          j	        ¦  «        t          ¦  «         t          t          j        t          ¦  «         t          t          j        t          ¦  «         d S r   )r	   r    r›   r�   r™   ry   Úappendr    ÚintÚ__add__r¨   r©   r¦   ri   r­   )r   r   s     r   r   zAbstractReducer.__init__  s   € Ý••b‘d”d”f‘”�~Ñ.Ô.Ð.Ý••d”kÑ"Ô"Õ$=Ñ>Ô>Ð>Ý••c”kÑ"Ô"Õ$=Ñ>Ô>Ð>Ý•Ô"¥OÑ4Ô4Ð4Ý•”¥Ñ/Ô/Ð/Ð/Ð/r   N)r*   r+   r,   r   r	   r
   r   r   ÚsysÚplatformr6   r5   r4   r_   r`   r^   r™   r    r¢   r­   r¬   r   r]   r   r   r¶   r¶   û   s‹   € € € € € ð ð $€NØ€HØ€DØ€KØ€Kà
„|�wÒÐØ#ˆØˆ	Øˆ	ˆ	àˆØˆØˆà#€NØ 9ÐØ'ÐØ#€NØ%€Oð0ð 0ð 0ð 0ð 0r   r¶   )Ú	metaclassr   r\   ).Úabcr   r-   r¨   r#   rS   r/   ri   r»   r�   r   Ú__all__r¼   Úhasattrr�   ÚPicklerr   r	   r
   r9   r5   r6   r   r   Úobjectr4   rf   rk   r_   r`   r^   r™   r›   r    r�   r    ry   r¸   r¹   rº   r¦   r¢   r©   r­   r¬   r¶   r]   r   r   ú<module>rÃ      sÅ  ðð Ð Ð Ð Ð Ð Ø €€€Ø Ð Ð Ð Ø 	€	€	€	Ø 	€	€	€	Ø €€€Ø €€€Ø 
€
€
€
à Ð Ð Ð Ð Ð à
NÐ
NÐ
N€ð ”L GÒ+ð 8Ø�W˜V ZÑ0Ô0ð 7Ø�W˜V \Ñ2Ô2ð7à�W˜Vœ]¨IÑ6Ô6ð ðð ð ð ð �V”^ñ ô ð ð. Ô"€ð-ð -ð -ð -ð „<�7ÒÐàÐ9Ð9Ð9Ñ9€GØ€N€N€Nð
;Ø$(ð
;ð 
;ð 
;ð 
;ð 
;ð
7ð 
7ð 
7ðð ð ð
$ð $ð $ð*ð *ð *ð *ð *�Fñ *ô *ð *ð *ðF Ð.Ð.Ð.Ñ.€GØ€L€L€Lð ”, (Ò*€KðHð Hð Hð4ð 4ð 4ð8!ð !ð !ð
$ð $ð $ð
	Gð 	Gð 	Gð:ð :ð :ð
ð ð ð ð ñ ô ð ð 	€ˆˆˆbˆb‰dŒdŒf‰Œ�~Ñ &Ô &Ð &ð1ð 1ð 1à €ˆˆˆdŒkÑ	Ô	Ð5Ñ 6Ô 6Ð 6Ø €ˆˆˆcŒkÑ	Ô	Ð5Ñ 6Ô 6Ð 6ð@ð @ð @ð6ð 6ð 6à €ˆÔ	˜OÑ ,Ô ,Ð ,ð „<�7ÒÐð0ð 0ð 0ðð ð à€HˆVŒ]˜NÑ+Ô+Ð+Ð+ð@ð @ð @ð=ð =ð =ð €HˆVŒ]˜NÑ+Ô+Ð+ð0ð 0ð 0ð 0ð 0 ð 0ñ 0ô 0ð 0ð 0ð 0r   