+
    ~j$                        ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIHtHt ^ RI	H
t
 ^RIHt ^RIHtHtHt ^RIHtHtHtHtHt ^RIHtHtHtHtHt  ! R	 R
4      tR R ltR R ltR# )    )annotationsN)Callable	Coroutine)	FrameTypelogger)aiolog_exceptionstime_ms)Messagearecv_messageasend_messagerecv_messagesend_message)IPC_MESSAGESInitializeRequestInitializeResponsePingRequestPongResponsec                  R    ] tR t^tR R ltR R ltR R ltR R ltR	 R
 ltRt	R# )_ProcClientc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )   mp_cchzsocket.socketlog_cchzsocket.socket | Noneinitialize_fncz0Callable[[InitializeRequest, _ProcClient], None]main_task_fnczBCallable[[aio.ChanReceiver[Message]], Coroutine[None, None, None]]returnNone )formats   "s/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/ipc/proc_client.py__annotate___ProcClient.__annotate__   s>     
" 
"
" &
" I	
"
 Z
" 

"    c                	8    Wn         W0n        W@n        R V n        R# )FN)_mp_cch_initialize_fnc_main_task_fnc_initialized)selfr   r   r   r   s   &&&&&r"   __init___ProcClient.__init__   s     -+!r%   c                   V ^8  d   QhRR/# r   r   r   r    )r!   s   "r"   r#   r$   #   s     J JD Jr%   c           	     	0    \         P                  P                  P                  V P                  4      p\        V\        4      p\        V\        4      '       g   Q R 4       hW n	         V P                  V P                  V 4       \        V\        4       4       RT n        TP!                  4        R#   \         d&   p\        T\        \        T4      R7      4       h Rp?ii ; i  \         P                  P"                   d   p\%        R4      ThRp?ii ; i)z-first message must be proto.InitializeRequest)errorNTz failed to initialize proc_client)r	   duplex_unix_Duplexopenr'   r   r   
isinstancer   	_init_reqr(   r   r   	Exceptionstrr*   detachDuplexClosedRuntimeError)r+   cch	first_reqes   &   r"   
initialize_ProcClient.initialize#   s    	J//))..t||<C$S,7Ii):;; ?; 'N$$T^^T:S"4"67
 !%DJJL  S"43q6"BC ++ 	JABI	Js<   A&C% )0B2 C% 2C"= CC""C% %DDDc                   V ^8  d   QhRR/# r/   r    )r!   s   "r"   r#   r$   9   s     F FT Fr%   c                	   V P                   '       g   \        R 4      h\        P                  ! 4       p\        P                  ! V4       VP                  V P                  P                  4       RVn         VP                  V P                  4       RR7      V n        V P                  P                  4       '       g    VP                  V P                  4       K>   VP                  VP                  4       4       R#   \         d     Kn  i ; i  \         d     L@i ; i  TP                  TP                  4       4       i ; i)zproc_client not initializedg?proc_client_mainnameN)r*   r;   asyncionew_event_loopset_event_loop	set_debugr6   asyncio_debugslow_callback_durationcreate_task_monitor_task_taskdonerun_until_completeKeyboardInterruptshutdown_default_executor)r+   loops   & r"   run_ProcClient.run9   s      <==%%'t$t~~334&)#	F))$*<*<*>EW)XDJjjoo''++DJJ7 ( ##D$B$B$DE )  
 ! 		 ##D$B$B$DEsO   6AD =C< D D <DD 
DD DD DD !E c                    V ^8  d   QhRRRR/# )r   msgr   r   r   r    )r!   s   "r"   r#   r$   Q   s     - -g -$ -r%   c                	N   "   \        V P                  V4      G R j  xL
  R #  L5iN)r   _acch)r+   rW   s   &&r"   send_ProcClient.sendQ   s     DJJ,,,s   %#%c                   V ^8  d   QhRR/# r/   r    )r!   s   "r"   r#   r$   T   s     =& =&T =&r%   c                	  a aaa	"   \         P                  P                  P                  S P                  4      G R j  xL
 S n         \        P                  ! 4       o\         P                  ! S P                  P                  ^
,           4      o	\         P                  \        ,          ! 4       o\        \        R7      R VV	V 3R ll4       p\        \        R7      R V	3R ll4       p\        P                  ! V! 4       RR7      pR pS P                  P                   ^ 8  d   \        P                  ! V! 4       RR7      p\        P                  ! S P#                  S4      R	R7      pR
 VV3R llpVP%                  V4       Ve   VP%                  V4       VP%                  V4       SP'                  4       G R j  xL
  \         P(                  ! W54      G R j  xL
  Ve   \         P(                  ! V4      G R j  xL
  S P
                  P+                  4       G R j  xL
  R #  EL Lk LO L/ L  S P
                  P+                  4       G R j  xL 
  i ; i5i)Nr   c                   V ^8  d   QhRR/# r/   r    )r!   s   "r"   r#   /_ProcClient._monitor_task.<locals>.__annotate__]   s     , ,$ ,r%   c                    <"     \        SP                  \        4      G Rj  xL
 p \        P                  ! \        P                  4      ;_uu_ 4        SP                  4        RRR4       \        T \        4      '       d<   \        SP                  \        T P                  \        4       R7      4      G Rj  xL
  SP!                  T 4       K   L  \        P                  P
                   d     R# i ; i  + '       g   i     L; i LR5i)TN)last_timestamp	timestamp)r   rZ   r   r	   r2   r:   
contextlibsuppressSleepFinishedresetr5   r   r   r   rc   r   send_nowait)rW   ipc_chping_timeoutr+   s    r"   _read_ipc_task1_ProcClient._monitor_task.<locals>._read_ipc_task\   s     $1$**l$KK $,,S->->??$**, @ "#{33+ JJ(QXQZ[  
 &&s+ L??77  @?s\   DC CC ,DC9%AD9D:DC C62D5C66D9D			Dc                   V ^8  d   QhRR/# r/   r    )r!   s   "r"   r#   r`   p   s      d r%   c                 ^   <"   S G R j  xL
  \        R\        P                  R7       R #  L!5i)Nz2worker process is not responding.. worker crashed?file)printsysstderr)rj   s   r"   _self_health_check5_ProcClient._monitor_task.<locals>._self_health_checko   s&     """H #s   -+"-ipc_readrD   health_checkmain_task_entrypointc                    V ^8  d   QhRRRR/# )r   _zasyncio.Task[None]r   r   r    )r!   s   "r"   r#   r`      s      . 4 r%   c                   < \         P                  ! \        P                  4      ;_uu_ 4        SP	                  4        R R R 4       SP                  4        R #   + '       g   i     L"; irY   )rd   re   rF   InvalidStateErrorsetclose)rz   	exit_flagri   s   &r"   _done_cb+_ProcClient._monitor_task.<locals>._done_cb   s>    (()B)BCCMMO D  DCs   AA)	)r	   r2   _AsyncDuplexr4   r'   rZ   rF   Eventsleepr6   rj   Chanr   r
   r   rL   ping_intervalr)   add_done_callbackwaitcancel_and_waitaclose)
r+   rk   rt   	read_taskhealth_check_task	main_taskr   r   ri   rj   s
   f      @@@r"   rM   _ProcClient._monitor_taskT   s    ??77<<T\\JJ
;	&I99T^^%@%@2%EFLXXg&(F6*, , +,$ 6* +  ++N,<:NI;?~~++a/$+$7$78J8LSa$b!++##F+2HI  ''1 ,!33H=''1.."""%%i;;; ,))*;<<< **##%%%y Kl #;< &$**##%%%s|   7IH#	IE2H. :H&;H. H(!H. :H*;H. ?IH,I&H. (H. *H. ,I.IIII)rZ   r6   r(   r*   r)   r'   rN   N)
__name__
__module____qualname____firstlineno__r,   r?   rT   r[   rM   __static_attributes__r    r%   r"   r   r      s"    
"J,F0-=& =&r%   r   c                   V ^8  d   QhRR/# r/   r    )r!   s   "r"   r#   r#      s     g g gr%   c                 	   ^ RI p ^ RIp^ RIp^ RIp^ RIp^ RIp^ RIHp ^ RIH	p ^ RI
pVP                  RR4      P                  4       R09   d   R# VP                  RVP                  4       4      p	V! V	4      P                  RRR7       VP                  R	V	R
RV! 4       P                    RVP#                  4        R2RR7      ;_uu_ 4       p
\%        RR1 2V
R7       \%        RV! 4       P&                   RV! 4       P                    R2V
R7       \%        R1 R2V
R7       VP)                  V
RR7       \%        RV
R7         V P*                  ! 4       pVEe   \%        R1V
R7       \%        RV
R7       \%        R1V
R7       V P.                  ! V4      p\%        R\1        V4       R2V
R7       \3        V^4       EF  w  r\%        RV R\1        V4       R2V
R7       \%        RVP5                  4        2V
R7       \%        RVP7                  4        2V
R7       VP7                  4       '       g   \%        RVP9                  4        2V
R7        VP;                  4       p\%        R\1        V4       2V
R7       \%        RV
R7       V F  pVP=                  V^V
R7       K  	   VPA                  4       p\%        R!V 2V
R7       \C        VR"R4      ;p'       d!   \%        R#V
R7       VP=                  VV
R7       M^ VPE                  4       pV'       dF   \%        R%V 2V
R7       \%        R&V
R7       VPG                  \I        V4      VVPJ                  V
R7       \%        R(V
R7       EK  	  M\%        R)V
R7         VPO                  4       pVPQ                  4       pVPR                  R2,          p\%        R3V
R7       \%        R+V
R7       \%        R1V
R7       \%        R,VR- R.2V
R7       \%        R/VPT                  R2,          R- R.2V
R7       RRR4       R#   \,         d    Rp ELi ; i  \>         d   p\%        R T 2T
R7        Rp?ELRp?ii ; i  \>         d   p\%        R$T 2T
R7        Rp?ELRp?ii ; i  \>         d   p\%        R'T 2T
R7        Rp?ELBRp?ii ; i  \>         d.   p\%        R*T 2T
R7       TPM                  T
R7        Rp?EL\Rp?ii ; i  \>         d     Li ; i  + '       g   i     R# ; i)4zQImplementation of stack trace dumping (callable directly or from signal handler).N)current_process)PathLK_DUMP_STACK_TRACES0LK_DUMP_DIRT)parentsexist_okwFzlivekit-agents-pid--z.stacktrace)modedirdeleteprefixsuffix
ro   zProcess z (pid z) stack trace dump)rp   all_threadszASYNCIO TASKSzTotal tasks: z

--- Task /z ---zName: zDone: zCancelled: zStack frames: zStack trace:)limitrp   zCould not get stack: zCoroutine: cr_framezCoroutine frame:zCould not get coroutine: zException: zException traceback:zCould not get exception:  zNo asyncio event loop runningzError dumping asyncio tasks: zMEMORY USAGEzRSS: z.2fz MBzVMS: )r   falsenoz<============================================================i   z=
============================================================)+rF   faulthandlerostempfiletime	tracebackmultiprocessingr   pathlibr   psutilgetenvlower
gettempdirmkdirNamedTemporaryFilepidtime_nsrq   rE   dump_tracebackget_running_loopr;   	all_taskslen	enumerateget_namerO   	cancelled	get_stackprint_stackr7   get_corogetattr	exceptionprint_exceptiontype__traceback__	print_excProcessmemory_inforssvms)rF   r   r   r   r   r   r   r   r   r   frS   tasksitaskstackframer>   coror   excprocessr   	memory_mbs                           r"   _dump_stack_traces_implr      s   /	yy'-3359MMyy(;(;(=>CIOOD4O0		$	$$_%6%:%:$;1T\\^<LAN 
% 
 
 
8*oA&(--.f_5F5J5J4KK]^	
 	
"oA&###=d6	(//1 hQ'oA.hQ'))$/c%j\41=(2GAKs!CJ<t<1EF4==?"341=F499;-0q999;;DNN,<+=>QGG$(NN$4E!N3u:,"?aH!.q9). ) 5 5e11 5 M */
K#'==?D!Kv"6Q?+24T+JJxJ %&8q A ) 5 5hQ 5 GK"&.."2C" %C5&9 B %&<1 E ) 9 9$s)S#J[J[bc 9 d "1%%G  3J 5A>
	nn&G!--/K#;7I/*.q)(#E)C,15E+//[9#>cBKe
 
(   2  ) G!$9!"=AFFG  ) K!$=aS"AJJK  ) K!$=aS"AJJK  	(1!5A>Q''	(  		g
 
 
s  A3S' PC7R	AP AQ	2R4Q2AQ2R#S'$R1S'3BSPRPR Q	+Q	;RQ	R	Q/	Q*	$R*Q/	/R2R	=R	RR	RS&"SS'SS'S$!S'#S$$S''S8	c               $    V ^8  d   QhRRRRRR/# )r   signumintrz   zFrameType | Noner   r   r    )r!   s   "r"   r#   r#      s"      s '7 D r%   c                    \        4        R# )z3Signal handler wrapper for _dump_stack_traces_impl.N)r   )r   rz   s   &&r"   _dump_stack_tracesr      s    r%   ) 
__future__r   rF   rd   socketrr   collections.abcr   r   typesr   logr   utilsr	   r
   r   channelr   r   r   r   r   protor   r   r   r   r   r   r   r   r    r%   r"   <module>r      sL    "    
 /   0 0 V V {& {&|gTr%   