+
    –°³ju
  ã                   ó†   € ^ RI Ht ^ RIt^ RIHt ^RIHtHt ^RIH	t	 R t
]P                  R 4       tR t ! R	 R
4      tR# )é    )ÚpartialN)ÚFuture)Ú	functionsÚ	rpc_async)ÚUNSET_RPC_TIMEOUTc                 óB   € \        V P                  4       V4      ! V/ VB # ©N©ÚgetattrÚlocal_value©ÚrrefÚ	func_nameÚargsÚkwargss   &&&&Úa/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/distributed/rpc/rref_proxy.pyÚ_local_invoker      s"   € Ü�4×#Ñ#Ó% yÔ1°4ÐB¸6ÑBÐBó    c                 óB   € \        V P                  4       V4      ! V/ VB # r	   r
   r   s   &&&&r   Ú_local_invoke_async_executionr      s"   € ä�4×#Ñ#Ó% yÔ1°4ÐB¸6ÑBÐBr   c                 óê   a aaaaaaa	a
€ VVVVV V3R  lo	S P                  SRR7      pS\        Jd   VP                  4        S	! V4      # \        4       o
VV	V
3R lpV
3R loVP	                  V4       S
# )c                 ód  <€ V P                  4       p\        p\        V\        P                  P
                  4      ;'       g%    \        V\        P                  P
                  4      pV'       g%   \        VS4      p\        VR 4      '       d   \        pS! S	P                  4       VS	SSS3S
R7      # )Ú_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_contÚ$_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                 óŒ   <€  S! V 4      P                  S4       R #   \         d   pSP                  T4        R p?R # R p?ii ; ir	   )ÚthenÚBaseExceptionÚset_exception)ÚfutÚexÚ_complete_opr)   Úresults   & €€€r   Ú_wrap_rref_type_contÚ)_invoke_rpc.<locals>._wrap_rref_type_cont5   s<   ø€ ð)Ù Ó$×)Ñ)¨,Ö7øÜ ô )Ø×$Ñ$ R×(Ò(ûð)ús   ƒ œA§>¾Ac                 óœ   <€  SP                  V P                  4       4       R #   \         d   pSP                  T4        R p?R # R p?ii ; ir	   )Ú
set_resultr   r.   r/   )r0   r1   r3   s   & €r   r2   Ú!_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   ffffjl  @@@r   Ú_invoke_rpcr;      se   ÿø€ ÷
ò 
ð( �~‰~ g¸ˆ~Ó>€Hà”iÓØ�‰ŒÙ˜xÓ(Ð(ô  ›ˆ÷	)õ	)ð 	�‰Ð*Ô+Øˆr   c                   ó2   a € ] tR t^Gt o ]3R ltR tRtV tR# )Ú	RRefProxyc                ó*   € Wn         W n        W0n        R # r	   )r   r(   Úrpc_timeout)Úselfr   r(   r   s   &&&&r   Ú__init__ÚRRefProxy.__init__H   s   € ØŒ	ØŒØ"Ör   c                ób   € \        \        V P                  V P                  WP                  4      # r	   )r   r;   r   r(   r?   )r@   r   s   &&r   Ú__getattr__ÚRRefProxy.__getattr__M   s&   € ÜÜ˜Ÿ™ D§L¡L°)×=MÑ=Mó
ð 	
r   )r(   r?   r   N)	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   rA   rD   Ú__static_attributes__Ú__classdictcell__)Ú__classdict__s   @r   r=   r=   G   s   ø‡ € Ø.?ô #÷

ð 
r   r=   )Ú	functoolsr   r   Útorch.futuresr   Ú r   r   Ú	constantsr   r   Úasync_executionr   r;   r=   © r   r   Ú<module>rS      sF   ðå ã Ý  ç "Ý (òCð ×ÑñCó ðCò.÷f	
ó 	
r   