
    Αi                     0    S SK r S SKrS SKr " S S5      rg)    Nc                   ^    \ rS rSrSS jrSS jrS rSS jrSS jrS r	SS	 jr
S
 rS rSrg)
ETCDClient   c                 t   X0l         SnX@R                   :  a   [        R                  " XS9U l         X@R                   :  a  [        SU R                    S35      eg ! [         a?  nUS-  n[        R
                  " SU S35        [        R                  " S5         S nAOS nAff = fX@R                   :  a  M  N)Nr   )hostport   z-Initialize etcd client failed with exception , retry after 1 second.z+Initialize etcd client failed failed after  times.)	retry_timesetcd3client	Exceptionlogginginfotimesleep
ValueError)selfr   r   r   timeses         k/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/distributed/launch/utils/etcd_client.py__init__ETCDClient.__init__   s    &&&&#ll@ $$$=d>N>N=OwW  %  
CA3F]^ 

1	 &&&s   A 
B%&5B  B%Nc                 l   SnXPR                   :  a   U R                  R                  XX45      $ XPR                   :  a  [        SU R                    S35      eg ! [         a?  nUS-  n[        R
                  " SU S35        [        R                  " S5         S nAOS nAff = fXPR                   :  a  M  N)Nr   r	   zPut failed with exception r
   zPut failed after r   )	r   r   putr   r   r   r   r   r   )r   keyvalueleaseprev_kvr   r   s          r   r   ETCDClient.put)   s    &&&{{s5BB $$$01A1A0B'JKK %  
03JK 

1 &&&s   A 
B!"5BB!c                 v   SnX R                   :  a   U R                  R                  U5      $ X R                   :  a  [        SU SU R                    S35      eg ! [         aB  nUS-  n[        R
                  " SU SU S35        [        R                  " S5         S nAOS nAff = fX R                   :  a  M  N)Nr   r	   zGet  failed with exception r
    failed after r   )	r   r   getr   r   r   r   r   r   )r   r   r   r   s       r   r%   ETCDClient.get8   s    &&&{{s++ $$$se>$*:*:);7C  %  
3%6qc9PQ 

1	 &&&   A 
B&$8B!!B&c                 x   SnX@R                   :  a   U R                  R                  XU5      $ X@R                   :  a  [        SU SU R                    S35      eg ! [         aB  nUS-  n[        R
                  " SU SU S35        [        R                  " S5         S nAOS nAff = fX@R                   :  a  M  N)Nr   r	   zDelete r#   r
   r$   r   )	r   r   deleter   r   r   r   r   r   )r   r   r    return_responser   r   s         r   r)   ETCDClient.deleteJ   s    &&&{{))#HH $$$#nT-=-=,>gF  %  
cU"9!<ST 

1	 &&&s   A 
B'%8B""B'c                 v   SnX@R                   :  a   U R                  R                  U5      $ X@R                   :  a  [        SU SU R                    S35      eg ! [         aB  nUS-  n[        R
                  " SU SU S35        [        R                  " S5         S nAOS nAff = fX@R                   :  a  M  N)Nr   r	   zGet prefix r#   r
   r$   r   )	r   r   
get_prefixr   r   r   r   r   r   )r   
key_prefix
sort_ordersort_targetr   r   s         r   r-   ETCDClient.get_prefix\   s    &&&{{--j99 $$$j\8H8H7IQ  %  
!*-DQCG^_ 

1	 &&&r'   c                 v   SnX R                   :  a   U R                  R                  U5      $ X R                   :  a  [        SU SU R                    S35      eg ! [         aB  nUS-  n[        R
                  " SU SU S35        [        R                  " S5         S nAOS nAff = fX R                   :  a  M  N)Nr   r	   zDelete prefix r#   r
   r$   r   )	r   r   delete_prefixr   r   r   r   r   r   )r   prefixr   r   s       r   r3   ETCDClient.delete_prefixn   s    &&&{{0088 $$$ t7G7G6HP  %  
$VH,CA3F]^ 

1	 &&&r'   c                 j   SnX0R                   :  a   U R                  R                  X5      $ X0R                   :  a  [        SU R                    S35      eg ! [         a?  nUS-  n[        R
                  " SU S35        [        R                  " S5         S nAOS nAff = fX0R                   :  a  M  N)Nr   r	   zLease failed with exception r
   zLease failed after r   )	r   r   r   r   r   r   r   r   r   )r   ttllease_idr   r   s        r   r   ETCDClient.lease   s    &&&{{((77 $$$243C3C2DGLMM %  
21#5LM 

1	 &&&   A 
B !5BB c                 n   SnX@R                   :  a   U R                  R                  " X40 UD6$ X@R                   :  a  [        SU R                    S35      eg ! [         a?  nUS-  n[        R
                  " SU S35        [        R                  " S5         S nAOS nAff = fX@R                   :  a  M  N)Nr   r	   z0Add watch prefix callback failed with exception r
   z'Add watch prefix callback failed after r   )	r   r   add_watch_prefix_callbackr   r   r   r   r   r   )r   r.   callbackkwargsr   r   s         r   r<   $ETCDClient.add_watch_prefix_callback   s    &&&
{{<<,2  $$$9$:J:J9K7S  %  
FqcI`a 

1 &&&s   A 
B"#5BB"c                 j   SnX R                   :  a   U R                  R                  U5      $ X R                   :  a  [        SU R                    S35      eg ! [         a?  nUS-  n[        R
                  " SU S35        [        R                  " S5         S nAOS nAff = fX R                   :  a  M  N)Nr   r	   z#Cancel watch failed with exception r
   zCancel watch failed after r   )	r   r   cancel_watchr   r   r   r   r   r   )r   watch_idr   r   s       r   rA   ETCDClient.cancel_watch   s    &&&{{//99 $$$,T-=-=,>gF  %  
9!<ST 

1	 &&&r:   )r   r   )   )NF)FF)Nr   )N)__name__
__module____qualname____firstlineno__r   r   r%   r)   r-   r3   r   r<   rA   __static_attributes__     r   r   r      s1    &L$$$$N (rK   r   )r   r   r   r   rJ   rK   r   <module>rL      s      _ _rK   