+
    ir1  c                   s   . ROt ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	H
t
Ht ^RIHt ^RIHt ]P                  P                   t^RIHtHtHtHtHt  ! R R ]4      t]! 4       t ! R	 R]4      t ! R
 R]4      tR# )QueueSimpleQueueJoinableQueueN)EmptyFull)
connection)context)debuginfoFinalizeregister_after_fork
is_exitingc                   s   a  ] tR t^!t o RR ltR tR tR tRR ltRR lt	RR lt
R	 tR
 tR tR tR tR tR tR tR tR t]R 4       t]R 4       t]R 4       t]R 4       t]! ]P8                  4      tRtV tR# )r    c               s   V^ 8:  d   ^RI Hp Wn        \        P                  ! RR7      w  V n        V n        VP                  4       V n        \        P                  ! 4       V n        \        P                  R8X  d	   RV n        MVP                  4       V n        VP                  V4      V n        RV n        V P%                  4        \        P                  R8w  d   \'        V \(        P*                  4       R# R# )    )SEM_VALUE_MAXFZduplexwin32N)Zsynchronizer   _maxsizer   Pipe_reader_writerLock_rlockosZgetpid_opidsysplatform_wlockZBoundedSemaphore_sem_ignore_epipe_resetr
   r    _after_forkselfZmaxsizectx   &&$//usr/lib64/python3.14/multiprocessing/queues.py__init__ZQueue.__init__#   s    a<=%/__E%B"dlhhjYY[
<<7"DK((*DK((1	"<<7"e&7&78 #    c                s    \         P                  ! V 4       V P                  V P                  V P                  V P
                  V P                  V P                  V P                  V P                  3# N)
r   assert_spawningr   r   r   r   r   r   r   r   r       &r#   __getstate__ZQueue.__getstate__7   sP    %""DMM4<<T[[$))TZZA 	Ar%   c           	     s    Vw  V n         V n        V n        V n        V n        V n        V n        V n        V P                  4        R # r&   )	r   r   r   r   r   r   r   r   r   r    Zstate   &&r#   __setstate__ZQueue.__setstate__<   s5    <A	:	T]DL$,	dk49djr%   c                s@    \        R 4       V P                  RR7       R# )zQueue._after_fork()T)
after_forkN)r   r   r(   r)   r#   r   ZQueue._after_forkA   s    #$t$r%   c                s   V'       d   V P                   P                  4        M.\        P                  ! \        P                  ! 4       4      V n         \
        P                  ! 4       V n        R V n        R V n	        RV n
        RV n        R V n        V P                  P                  V n        V P                   P"                  V n        V P                   P&                  V n        R # )NF)	_notemptyZ_at_fork_reinit	threading	Conditionr   collectionsZdeque_buffer_thread_jointhread_joincancelled_closed_closer   
send_bytes_send_bytesr   
recv_bytes_recv_bytespoll_poll)r    r.   r,   r#   r   ZQueue._resetE   s    NN**,&001ABDN"((*#<<22<<22\\&&
r%   Nc                s   V P                   '       d   \        R V : R24      hV P                  P                  W#4      '       g   \        hV P
                  ;_uu_ 4        V P                  f   V P                  4        V P                  P                  V4       V P
                  P                  4        RRR4       R#   + '       g   i     R# ; izQueue z
 is closedN)r7   
ValueErrorr   acquirer   r/   r4   _start_threadr3   appendnotifyr    objblocktimeout   &&&&r#   putZ	Queue.putT   s    <<<vdXZ899yy  00J^^^||#""$LL$NN!!#	 ^^^s   AB<<C	c                sZ   V P                   '       d   \        R V : R24      hV'       dM   VfI   V P                  ;_uu_ 4        V P                  4       pRRR4       V P                  P                  4        MV'       d   \        P                  ! 4       V,           pV P                  P                  W4      '       g   \        h V'       d;   X\        P                  ! 4       ,
          pV P                  V4      '       g   \        hMV P                  4       '       g   \        hV P                  4       pV P                  P                  4        V P                  P                  4        \        P                  X4      #   + '       g   i     EL/; i  T P                  P                  4        i ; ir?   )r7   r@   r   r<   r   releasetimeZ	monotonicrA   r   r>   _ForkingPicklerloads)r    rG   rH   resZdeadlines   &&&  r#   getZ	Queue.get`   s   <<<vdXZ899W_&&( II>>+g5;;&&u66
&&)99G::g..# /K&&(		!!###%$$S))) $ ##%s*   E:F 2F >F 0F :F	F*c                sX    V P                   V P                  P                  4       ,
          # r&   )r   r   Z	get_valuer(   r)   r#   qsizeZQueue.qsizez   s    }}tyy22444r%   c                ,    V P                  4       '       * # r&   r>   r(   r)   r#   emptyZQueue.empty~       ::<r%   c                sJ    V P                   P                  P                  4       # r&   )r   _semlock_is_zeror(   r)   r#   fullZ
Queue.full   s    yy!!**,,r%   c                s$    V P                  R 4      # F)rP   r(   r)   r#   
get_nowaitZQueue.get_nowait   s    xxr%   c                s&    V P                  VR 4      # rY   )rJ   r    rF   r,   r#   
put_nowaitZQueue.put_nowait   s    xxU##r%   c                s\    R V n         V P                  pV'       d   RV n        V! 4        R# R# TN)r7   r8   )r    close   & r#   r^   ZQueue.close   s&    DKG r%   c                sd    \        R 4       V P                  '       d   V P                  4        R# R# )zQueue.join_thread()N)r   r5   r(   r)   r#   join_threadZQueue.join_thread   s(    #$ r%   c                s    \        R 4       RV n         V P                  P                  4        R#   \         d     R# i ; i)zQueue.cancel_join_thread()TN)r   r6   r5   ZcancelZAttributeErrorr(   r)   r#   cancel_join_threadZQueue.cancel_join_thread   s<    *+"	##% 		s   0 ??c                s    V P                   P                  4        \        P                  R 8X  d   V P                  P                  4        V P                  4        V P                  4        R# )r   N)r   r^   r   r   r   r`   r(   r)   r#   _terminate_brokenZQueue._terminate_broken   sG     	 <<7"LL 

r%   c                s>   \        R 4       V P                  P                  4        \        P                  ! \
        P                  V P                  V P                  V P                  V P                  V P                  P                  V P                  P                  V P                  V P                  V P                  3	RRR7      V n         \        R4       V P                   P#                  4        \        R4       T P$                  '       gL   \'        T P                   \
        P(                  \*        P,                  ! T P                   4      .RR7      T n        \'        T \
        P0                  T P                  T P                  .^
R7      T n        R#    RT n        h ; i)	zQueue._start_thread()ZQueueFeederThreadT)ZtargetZargsZnameZdaemonzdoing self._thread.start()z... done self._thread.start()N)Zexitpriorityi)r   r3   Zclearr0   ZThreadr    _feedr/   r:   r   r   r^   r   r   _on_queue_feeder_errorr   r4   Zstartr6   r	   _finalize_joinweakrefZrefr5   _finalize_closer8   r(   r)   r#   rB   ZQueue._start_thread   s5   %& 	 '';;,,0@0@++t||114<<3E3E$$d&A&A)) %
	./LL 12 """'e22T\\*+ D %''\\4>>*	  DLs   0F 
Fc                s    \        R 4       V ! 4       pVe   VP                  4        \        R4       R# \        R4       R# )zjoining queue threadNz... queue thread joinedz... queue thread already dead)r   join)ZtwrZthreadr_   r#   re   ZQueue._finalize_join   s3    $%KKM+,12r%   c                s    \        R 4       V;_uu_ 4        V P                  \        4       VP                  4        RRR4       R#   + '       g   i     R# ; i)ztelling queue thread to quitN)r   rC   	_sentinelrD   )buffernotemptyr,   r#   rg   ZQueue._finalize_close   s2    ,-XMM)$OO XXXs   &AA	c	                sJ   \        R 4       VP                  p	VP                  p
VP                  pV P                  p\
        p\        P                  R8w  d   VP                  pVP                  pMRp  V	! 4         V '       g   V! 4        V
! 4          V! 4       pVVJ d   \        R4       V! 4        V! 4        R# \        P                  V4      pVf   V! V4       KL  V! 4         V! V4       X! 4        Ke    T
! 4        i ; i  X! 4        i ; i  \         d     K  i ; i  \         dv   pT'       d'   \        TR^ 4      \        P                  8X  d    Rp?R# \        4       '       d   \!        RT4        Rp?R# TP                  4        T! TX4        Rp?EK+  Rp?ii ; i)z$starting thread to feed data to piper   Nz%feeder thread got sentinel -- exitingerrnozerror in queue thread: %s)r   rA   rK   waitZpopleftri   r   r   rM   dumpsZ
IndexErrorZ	ExceptionZgetattrrl   ZEPIPEr   r   )rj   rk   r9   Z	writelockZreader_closeZwriter_closeZignore_epipeZonerrorZ	queue_semZnacquireZnreleaseZnwaitZbpopleftZsentinelZwacquireZwreleaserF   es   &&&&&&&&&         r#   rc   ZQueue._feed   s\    	45####>><<7" ((H ((HH-$
!J&j(?!"IJ(N(N" .33C8#+&sO$J+ *3 (
' J& !)
!  $GAw$:ekk$I
 <<4a8 %%'AsOO#$s~   4D" <C8 C8 D" 'D <*D 'D /	D 8	DD" 	DD DD" DD" "F"-(FF=FF"c                s.    ^ RI pVP                  4        R# )z
Private API hook called when feeding data in the background thread
raises an exception.  For overriding by concurrent.futures.
N)	tracebackZ	print_exc)ro   rF   rp   s   && r#   rd   ZQueue._on_queue_feeder_error$  s     	r%   )r3   r8   r7   r   r6   r5   r   r/   r   r>   r   r<   r   r   r:   r4   r   r   r   rY   r]   ) __name__
__module____qualname____firstlineno__r$   r*   r-   r   r   rJ   rP   rQ   rT   rX   rZ   r\   r^   r`   ra   rb   rB   Zstaticmethodre   rg   rc   rd   classmethodtypesGenericAlias__class_getitem____static_attributes____classdictcell__Z__classdict__   @r#   r    r    !   s     9(A

%'
$*45 -$%N 3 3   <$ <$|   $E$6$67r%   c                   sL   a  ] tR tRt o R
R ltR tR tRR ltR tR t	R	t
V tR# )r   i:  c               s    \         P                  WVR 7       VP                  ^ 4      V n        VP	                  4       V n        R# ))r!   N)r    r$   Z	Semaphore_unfinished_tasksr1   _condr   r"   r#   r$   ZJoinableQueue.__init__<  s0    t#.!$q!1]]_
r%   c                sf    \         P                  V 4      V P                  V P                  3,           # r&   )r    r*   r   r~   r(   r)   r#   r*   ZJoinableQueue.__getstate__A  s'    !!$'4::t7M7M*NNNr%   c                sZ    \         P                  WR R 4       VRR  w  V n        V n        R # )Ni)r    r-   r   r~   r+   r,   r#   r-   ZJoinableQueue.__setstate__D  s+    4s,-223Z*
D*r%   Nc           	     s4   V P                   '       d   \        R V : R24      hV P                  P                  W#4      '       g   \        hV P
                  ;_uu_ 4        V P                  ;_uu_ 4        V P                  f   V P                  4        V P                  P                  V4       V P                  P                  4        V P
                  P                  4        RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; ir?   )r7   r@   r   rA   r   r/   r   r4   rB   r3   rC   r~   rK   rD   rE   rI   r#   rJ   ZJoinableQueue.putH  s    <<<vdXZ899yy  00J^^^TZZZ||#""$LL$""**,NN!!# (^^ZZ^^^s%   D3A.C3	!D3D>DD	c                sH   V P                   ;_uu_ 4        V P                  P                  R 4      '       g   \        R4      hV P                  P                  P                  4       '       d   V P                   P                  4        RRR4       R#   + '       g   i     R# ; i)Fz!task_done() called too many timesN)r   r~   rA   r@   rV   rW   Z
notify_allr(   r)   r#   	task_doneZJoinableQueue.task_doneU  se    ZZZ))11%88 !DEE%%..7799

%%'	 ZZZs   AB,BB!	c                s    V P                   ;_uu_ 4        V P                  P                  P                  4       '       g   V P                   P	                  4        R R R 4       R #   + '       g   i     R # ; ir&   )r   r~   rV   rW   rm   r(   r)   r#   rh   ZJoinableQueue.join\  s@    ZZZ))22;;==

! ZZZs   AA$$A5	)r   r~   rq   r]   )rr   rs   rt   ru   r$   r*   r-   rJ   r   rh   rz   r{   r|   r}   r#   r   r   :  s)     %
O8$(" "r%   c                   sn   a  ] tR tRt o R tR tR tR tR tR t	R t
]! ]P                  4      tR	tV tR
# )r   ie  c               s   \         P                  ! R R7      w  V n        V n        VP	                  4       V n        V P                  P                  V n        \        P                  R8X  d
   RV n
        R# VP	                  4       V n
        R# )Fr   r   N)r   r   r   r   r   r   r=   r>   r   r   r   )r    r!   s   &$r#   r$   ZSimpleQueue.__init__g  sW    %/__E%B"dlhhj\\&&
<<7"DK((*DKr%   c                sn    V P                   P                  4        V P                  P                  4        R # r&   )r   r^   r   r(   r)   r#   r^   ZSimpleQueue.closep  s"    r%   c                rR   r&   rS   r(   r)   r#   rT   ZSimpleQueue.emptyt  rU   r%   c                s    \         P                  ! V 4       V P                  V P                  V P                  V P
                  3# r&   )r   r'   r   r   r   r   r(   r)   r#   r*   ZSimpleQueue.__getstate__w  s/    %dllDKKEEr%   c                sr    Vw  V n         V n        V n        V n        V P                   P                  V n        R # r&   )r   r   r   r   r=   r>   r+   r,   r#   r-   ZSimpleQueue.__setstate__{  s)    AF>t|T[$+\\&&
r%   c                s    V P                   ;_uu_ 4        V P                  P                  4       pR R R 4       \        P	                  X4      #   + '       g   i     L%; ir&   )r   r   r;   rM   rN   )r    rO   r_   r#   rP   ZSimpleQueue.get  s=    [[[,,))+C  $$S)) [s   AA	c                s   \         P                  V4      pV P                  f   V P                  P	                  V4       R # V P                  ;_uu_ 4        V P                  P	                  V4       R R R 4       R #   + '       g   i     R # ; ir&   )rM   rn   r   r   r9   r[   r,   r#   rJ   ZSimpleQueue.put  sU    ##C(;;LL##C('', s   A;;B	)r>   r   r   r   r   N)rr   rs   rt   ru   r$   r^   rT   r*   r-   rP   rJ   rv   rw   rx   ry   rz   r{   r|   r}   r#   r   r   e  s<     % F'*- $E$6$67r%   )r    r   r   )Z__all__r   r   r0   r2   rL   rw   rf   rl   Zqueuer   r   Z r   r   Z	reductionZForkingPicklerrM   Zutilr   r   r	   r
   r   Zobjectr    ri   r   r   ) r%   r#   <module>r      su    4 
 	         ##22 H HL8F L8^ H	%"E %"V*8& *8r%   