
    Αit                     R   S SK r S SKr " S S5      r\S:X  Ga  \" S5      rSSS.r\R                  5        H  u  rr\R                  \\5        M     \R                  S	5      r\" \5        \R                  5        H  u  rr\\   \:X  a  M   e   \R                  S
S5        \" \R                  S
5      5        \R                  S
5      S:X  d   e\R                  S
5        \" \R                  S5      5        \" \R                  S5      5        \R                  S5      S:X  d   egg)    Nc                   @    \ rS rSrS
S jrS rS rS rS rSS jr	Sr
g	)KVClient   c                 T    UR                  S5      (       a  UU l        g SU 3U l        g )Nzhttp://)
startswithendpoint)selfr   s     i/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/distributed/launch/utils/kv_client.py__init__KVClient.__init__   s-     ++I66H 	>EhZ<P 	    c                     UR                  S5      (       a  UOSU 3nU R                   U 3n [        R                  " X2S SS9nUR                  S:X  a  gg!    g= f)N/T)datatimeoutfollow_redirects   F)r   r   httpxpoststatus_code)r	   keyvalueurs        r
   putKVClient.put   sb    ^^C((c#i}}ocU#	

1$NA}}#	   &A Ac                     UR                  S5      (       a  UOSU 3nU R                   U 3n [        R                  " US SS9nUR                  S:X  a"  UR                  5       nUR                  US5      $ g!    g= f)Nr   Tr   r   r    errorr   r   r   getr   json)r	   r   r   r   rets        r
   r#   KVClient.get&   s{    ^^C((c#i}}ocU#			!TDAA}}#ffhwwsB''	s   AA8 8A<c                     UR                  S5      (       a  UOSU 3nU R                   U 3n [        R                  " US SS9nUR                  S:X  a  UR                  5       $ g !    g= f)Nr   Tr   r   r    r"   r	   r   r   r   s       r
   
get_prefixKVClient.get_prefix3   sl    ^^C((c#i}}ocU#			!TDAA}}#vvx $	s   5A& &A*c                     UR                  S5      (       a  UOSU 3nU R                   U 3n [        R                  " US SS9nUR                  S:X  a  gg!    g= f)Nr   Tr   r   F)r   r   r   deleter   r(   s       r
   r,   KVClient.delete=   sb    ^^C((c#i}}ocU#	QtDA}}#	r   c                     [         R                   " 5       U-   n[         R                   " 5       U:  a2  U R                  S5      S:X  a  g[         R                   " 5       U:  a  M1  g g )N/healthyokT)timer#   )r	   r   ends      r
   wait_server_readyKVClient.wait_server_readyI   sD    iikG#iikCxx
#t+ iikCr   )r   N)zlocalhost:2379)   )__name__
__module____qualname____firstlineno__r   r   r#   r)   r,   r3   __static_attributes__ r   r
   r   r      s     



r   r   __main__zhttp://localhost:8090rank1rank2)z
/workers/1z
/workers/2z/workersr   r   z/keyr/   r0   )r1   r   r   r6   clir   itemskvr   r)   xprintr#   r,   r;   r   r
   <module>rE      s    9 9x z
*
+C!9D

11 z"A	!H

1tqyy  GGE7	#''%.775>W$$$JJu	#''&/	#''*
77:$&&&! r   