
    &`i                         d dl mZmZ d dlmZ daed             Z G d de          Z G d de          Z G d	 d
e          Z	d Z
dS )    )ABCabstractmethod)contextmanagerNc              #   8   K   t           }| a 	 d V  |a d S # |a w xY wN)_current_server)rremotes     w/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/util/client/server/server_stubs.pycurrent_serverr      s:       FO! &    s    c                   6    e Zd Zd Zd Zed             Zd ZdS )ClientReferenceSentinelc                 "    || _         || _        d S r   )	client_idid)selfr   r   s      r   __init__z ClientReferenceSentinel.__init__   s    "    c                 l    |                                  }|| j        | j        | j        ffS t          |ffS r   )get_remote_obj	__class__r   r   identity)r   
remote_objs     r   
__reduce__z"ClientReferenceSentinel.__reduce__   s<    ((**
NT^TW$=>>:-((r   c                     d S r    )r   s    r   r   z&ClientReferenceSentinel.get_remote_obj   s    r   c                     t           d S t           j                            | j        d           }|d S |                    | j        d           S r   )r   client_side_ref_mapgetr   r   )r   
client_maps     r   get_real_ref_from_serverz0ClientReferenceSentinel.get_real_ref_from_server!   sH    "4$8<<T^TRR
4~~dgt,,,r   N)__name__
__module____qualname__r   r   r   r   r!   r   r   r   r   r      s\          ) ) )   ^- - - - -r   r   c                       e Zd Zd ZdS )ClientReferenceActorc                 t    |                                  }|d S t                              || j        d           S r   )r!   r   lookup_or_register_actorr   r   real_ref_ids     r   r   z#ClientReferenceActor.get_remote_obj,   s?    3355477
 
 	
r   Nr"   r#   r$   r   r   r   r   r&   r&   +   #        
 
 
 
 
r   r&   c                       e Zd Zd ZdS )ClientReferenceFunctionc                 t    |                                  }|d S t                              || j        d           S r   )r!   r   lookup_or_register_funcr   r)   s     r   r   z&ClientReferenceFunction.get_remote_obj7   s?    3355466
 
 	
r   Nr+   r   r   r   r.   r.   6   r,   r   r.   c                     | S r   r   )xs    r   r   r   A   s    Hr   )abcr   r   
contextlibr   r   r   r   r&   r.   r   r   r   r   <module>r5      s    # # # # # # # # % % % % % % ! ! !- - - - -c - - -2
 
 
 
 
2 
 
 

 
 
 
 
5 
 
 
    r   