
    ϑi                         S SK r S SKrS SKrS SKrSSKJr  Sr\" 5       qS r	S r
S r " S S	5      r\R                  S
:X  d!  \R                  S:X  d  \R                  \
5        SqS rg)    N   )coreg      @c                  x    [          H  n   U R                  5         M     g ! [        R                   a     M1  f = fN)multiprocess_queue_set
get_nowaitqueueEmpty)
data_queues    \/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/io/multiprocess_utils.py_clear_multiprocess_queue_setr       s=    ,
%%'  - ;; s   !99c                  B    [        5         [        R                  " 5         g r   )r   r   _cleanup_mmap_fds     r   _cleanupr   +   s    !#r   c                  .    [         R                  " 5         g r   )r   r   r   r   r   _cleanup_mmapr   3   s    r   c                   F    \ rS rSr\" 5       r\" 5       r\/ 4S j5       rSr	g)CleanupFuncRegistrar9   c                 f   ^ ^^^ U U4S jmUU 4S jnSU4S jjmUU 4S jnU" U5        U" T5        g )Nc                     > TT R                   ;  a$   T" 5         T R                   R                  T5        g g ! T R                   R                  T5        f = fr   )_executed_func_setadd)clsfunctions   r   _func_executor5CleanupFuncRegistrar.register.<locals>._func_executorA   sL    s5559J**..x8	 6 **..x8s	   7 Ac                    > [        U 5      (       d  [        U  S35      eU TR                  ;  a2  [        R                  " T5        TR                  R                  U 5        g g )Nz is not callable object.)callable	TypeError_registered_func_setatexitregisterr   )r   r   r   s    r   _func_register5CleanupFuncRegistrar.register.<locals>._func_registerH   sT    H%%8*,D EFFs777/((,,X6 8r   c                 |   > T" 5         U b1  U [         R                  :X  a  [        e[        R                  " U 5        g g r   )signalSIGINTKeyboardInterruptsysexit)signumframer   s     r   _signal_handler6CleanupFuncRegistrar.register.<locals>._signal_handlerP   s2    !V]]*++  "r   c                   > [        U 5      n U  H  n[        R                  " UT5      nU[        R                  [        R                  4;  d  M@  U[        R                  :X  a  U[        R
                  L a  Mi  UTR                  ;  d  M{  [        R                  " U5        TR                  R                  U5        M     g r   )
setr)   SIG_DFLSIG_IGNr*   default_int_handlerr#   r$   r%   r   )signalssigorig_handlerr0   r   s      r   _signal_register7CleanupFuncRegistrar.register.<locals>._signal_registerW   s    'lG%}}S/B'GGv}},(F,F,FF #3+C+CC50044\B r   )NNr   )r   r   r7   r&   r:   r   r0   s   ``   @@r   r%   CleanupFuncRegistrar.register?   s*    	9	7	!	C 	!x r   r   N)
__name__
__module____qualname____firstlineno__r3   r   r#   classmethodr%   __static_attributes__r   r   r   r   r   9   s'    5(* (! (!r   r   darwinwin32Fc                     ^ [         (       a  g [        R                  " [        R                  5      m[	        T5      (       d  S mU4S jn [        R                  " [        R                  U 5        Sq g )Nc                 H   > [         R                  " 5         Tb	  T" X5        g g r   )r   _throw_error_if_process_failed)r.   r/   current_handlers     r   __handler__)_set_SIGCHLD_handler.<locals>.__handler__   s$     	++-&F* 'r   T)_SIGCHLD_handler_setr)   	getsignalSIGCHLDr!   )rI   rH   s    @r   _set_SIGCHLD_handlerrN   x   sO    &&v~~6OO$$+ MM&..+.r   )r$   r	   r)   r,   	frameworkr   MP_STATUS_CHECK_INTERVALr3   r   r   r   r   r   platformr%   rK   rN   r   r   r   <module>rR      sv       
   
  /! /!p 	 CLLG$;!!(+   r   