Ë
    g^(hq
  ã                   ó„   — d dl mZ d dlZd dlmZ ddlmZmZ ddlm	Z	 d„ Z
ej                  d„ «       Zd	„ Z G d
„ d«      Zy)é    )ÚpartialN)ÚFutureé   )Ú	functionsÚ	rpc_async)ÚUNSET_RPC_TIMEOUTc                 óB   —  t        | j                  «       |«      |i |¤ŽS ©N©ÚgetattrÚlocal_value©ÚrrefÚ	func_nameÚargsÚkwargss       ú^/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/torch/distributed/rpc/rref_proxy.pyÚ_local_invoker      s$   € Ø1Œ7�4×#Ñ#Ó% yÓ1°4ÐB¸6ÑBÐBó    c                 óB   —  t        | j                  «       |«      |i |¤ŽS r
   r   r   s       r   Ú_local_invoke_async_executionr      s$   € à1Œ7�4×#Ñ#Ó% yÓ1°4ÐB¸6ÑBÐBr   c                 óâ   ‡ ‡‡‡‡‡‡‡	‡
— ˆˆˆˆˆ ˆfd„Š	‰ j                  ‰d¬«      }‰t        k7  r|j                  «         ‰	|«      S t        «       Š
ˆˆ	ˆ
fd„}ˆ
fd„Š|j	                  |«       ‰
S )Nc                 ó@  •— | j                  «       }t        }t        |t        j                  j
                  «      xs$ t        |t        j                  j
                  «      }|st        |‰«      }t        |d«      rt        } ‰‰	j                  «       |‰	‰‰‰f‰
¬«      S )NÚ_wrapped_async_rpc_function)r   Útimeout)Úvaluer   Ú
issubclassÚtorchÚjitÚScriptModuleÚ_Cr   Úhasattrr   Úowner)Úrref_futÚ	rref_typeÚ_invoke_funcÚbypass_typeÚfuncr   r   r   Úrpc_apir   r   s        €€€€€€r   Ú_rref_type_contz$_invoke_rpc.<locals>._rref_type_cont   s�   ø€ Ø—N‘NÓ$ˆ	ä$ˆä  ¬E¯I©I×,BÑ,BÓCò 
ÄzØ”u—x‘x×,Ñ,óH
ˆñ Ü˜9 iÓ0ˆDÜ�tÐ:Ô;Ü<�áØ�J‰J‹LØØ˜	 4¨Ð0Øô	
ð 	
r   F)r   Úblockingc                 ó„   •— 	  ‰| «      j                  ‰«       y # t        $ r}‰j                  |«       Y d }~y d }~ww xY wr
   )ÚthenÚBaseExceptionÚset_exception)ÚfutÚexÚ_complete_opr*   Úresults     €€€r   Ú_wrap_rref_type_contz)_invoke_rpc.<locals>._wrap_rref_type_cont5   s<   ø€ ð)Ù Ó$×)Ñ)¨,Õ7øÜ ò )Ø×$Ñ$ R×(Ñ(ûð)ús   ƒ ›	?¤:º?c                 ó”   •— 	 ‰j                  | j                  «       «       y # t        $ r}‰j                  |«       Y d }~y d }~ww xY wr
   )Ú
set_resultr   r.   r/   )r0   r1   r3   s     €r   r2   z!_invoke_rpc.<locals>._complete_op;   s=   ø€ ð)Ø×!Ñ! #§)¡)£+Õ.øÜ ò )Ø×$Ñ$ R×(Ñ(ûð)ús   ƒ# £	A¬AÁA)Ú	_get_typer   Úwaitr   r-   )r   r)   r   r   r   r   r$   r4   r2   r*   r3   s   ``````  @@@r   Ú_invoke_rpcr9      se   ÿø€ ÷
ñ 
ð( �~‰~ g¸ˆ~Ó>€Hà”)ÒØ�‰ŒÙ˜xÓ(Ð(ô  ›ˆö	)ô	)ð 	�‰Ð*Ô+Øˆr   c                   ó   — e Zd Zefd„Zd„ Zy)Ú	RRefProxyc                 ó.   — || _         || _        || _        y r
   )r   r)   Úrpc_timeout)Úselfr   r)   r   s       r   Ú__init__zRRefProxy.__init__H   s   € ØˆŒ	ØˆŒØ"ˆÕr   c                 ód   — t        t        | j                  | j                  || j                  «      S r
   )r   r9   r   r)   r=   )r>   r   s     r   Ú__getattr__zRRefProxy.__getattr__M   s(   € ÜÜ˜Ÿ™ D§L¡L°)¸T×=MÑ=Mó
ð 	
r   N)Ú__name__Ú
__module__Ú__qualname__r   r?   rA   © r   r   r;   r;   G   s   „ Ø.?ó #ó

r   r;   )Ú	functoolsr   r   Útorch.futuresr   Ú r   r   Ú	constantsr   r   Úasync_executionr   r9   r;   rE   r   r   ú<module>rK      sF   ðå ã Ý  ç "Ý (òCð ×ÑñCó ðCò.÷f	
ò 	
r   