
    Αi8                     ^    S SK Jr  S SKJr  S SKJrJr  S SKJr  / r	S r
S rS rS rSS
 jrg	)   )core)global_scope)default_main_programdefault_startup_program)generatec                 L   ^ ^ U 4S jmU4S jnUT l         ST l        ST l        T $ )Nc                  n   > [        5       n U R                  TR                  5      nUR                  5       $ N)r   find_varname
get_reader)scopevarreaders     U/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/base/layers/io.py__get_reader__3monkey_patch_reader_methods.<locals>.__get_reader__   s)    nnV[[)~~    c                  .   > T " 5       R                  5       $ r
   )reset)r   s   r   r   *monkey_patch_reader_methods.<locals>.reset   s    %%''r   T)r   stop_gradientpersistable)r   r   r   s   ` @r   monkey_patch_reader_methodsr      s+     
( FLFFMr   c                    U R                  UR                  [        R                  R                  R
                  S9nUR                  R                  UR                  R                  5       5        UR                  R                  UR                  R                  5       5        UR                  R                  UR                  R                  5       5        SUl        U$ )N)r   typeT)
create_varr   r   VarDescVarTypeREADERdesc
set_shapesshapes
set_dtypesdtypesset_lod_levels
lod_levelsr   )blockr   new_vars      r   _copy_reader_var_r*   &   s    CHH4<<3G3G3N3NOGLLCHHOO-.LLCHHOO-.LL 3 3 56GNr   c                    UR                   n0 nU HC  n/ X4'   UR                  U5      nU H%  nX4   R                  U R                  U5      5        M'     ME     UR                  n0 nU HC  n/ X'   UR                  U5      nU H%  nX   R                  U R                  U5      5        M'     ME     U R                  UR                  UUUR                  5       S9n	U	$ )Nr   inputsoutputsattrs)	input_namesinputappendr   output_namesoutput	append_opr   	all_attrs)
r(   opinput_param_namesnew_input_map
param_name	arg_namesarg_nameoutput_param_namesnew_output_mapnew_ops
             r   _copy_reader_create_op_r@   /   s    M'
$&!HHZ(	!H%,,UYYx-@A " ( N(
%'"IIj)	!H&--eii.AB " ) __WWlln	  F Mr   c                    [        U 5      n[        5       R                  5       nUR                  US9nUR	                  U SU0SU/0US9nSUl        [        5       R                  5       n[        Xu5      n[        Xv5        [        U5      $ )Nr   UnderlyingReaderOutr,   T)
unique_namer   current_blockr   r5   r   r   r*   r@   r   )	op_typer   r/   var_namestartup_blkstartup_var
startup_opmain_prog_blockmain_prog_vars	            r   "__create_shared_decorated_reader__rN   I   s    7#H)+99;K((h(7K&&"F+&	 ' J #K*,::<O%oCMO8&}55r   Nc                     Ub  UO
[        U 5      n[        5       R                  5       nUR                  US9nUR	                  U SU0SU/0US9  [        U5      $ )NrB   rC   rD   r,   )rE   r   rF   r   r5   r   )rG   r   r/   r   new_reader_namemain_blk
new_readers          r   $__create_unshared_decorated_reader__rS   Z   so    ".dK4HO#%335H$$/$:J"F+%	   'z22r   r
   ) r   executorr   	frameworkr   r   rE   r   __all__r   r*   r@   rN   rS    r   r   <module>rY      s1     # E 1
46"
3r   