+
    ~j                       ^ RI Ht ^ RIt^ RIHtHt ^ RIHt ^ RIH	t	 ^RI
HtHt ^RIHt ] ! R R	4      4       t] ! R
 R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t] ! R R4      4       t]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]]P6                  ]/tR# )     )annotationsN)	dataclassfield)ClassVar)agent)JobAcceptArgumentsRunningJobInfo)channelc                      ] tR t^t$ Rt^ tR]R&   RtR]R&   ^ tR]R&   ^ t	R]R	&   ^ t
R]R
&   RtR]R&   R R ltR R ltRtR# )InitializeRequestzisent by the main process to the subprocess to initialize it. this is going to call initialize_process_fncClassVar[int]MSG_IDFboolasyncio_debugfloatping_intervalping_timeouthigh_ping_threshold str
http_proxyc                    V ^8  d   QhRRRR/#    bz
io.BytesIOreturnNone )formats   "m/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/ipc/proto.py__annotate__InitializeRequest.__annotate__   s     1 1z 1d 1    c                	F   \         P                  ! WP                  4       \         P                  ! WP                  4       \         P                  ! WP
                  4       \         P                  ! WP                  4       \         P                  ! WP                  4       R # N)	r
   
write_boolr   write_floatr   r   r   write_stringr   selfr   s   &&r    writeInitializeRequest.write   sd    1001A112A001A778Q0r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r"   !   s     1 1j 1T 1r#   c                	   \         P                  ! V4      V n        \         P                  ! V4      V n        \         P                  ! V4      V n        \         P                  ! V4      V n        \         P                  ! V4      V n        R # r%   )	r
   	read_boolr   
read_floatr   r   r   read_stringr   r)   s   &&r    readInitializeRequest.read!   s`    $..q1$//2#..q1#*#5#5a#8 !--a0r#   )r   r   r   r   r   N)__name__
__module____qualname____firstlineno____doc__r   __annotations__r   r   r   r   r   r+   r2   __static_attributes__r   r#   r    r   r      sQ    sFMM4M5L%!""J11 1r#   r   c                  P    ] tR t^)t$ Rt^tR]R&   RtR]R&   R R ltR	 R
 lt	Rt
R# )InitializeResponsezmark the process as initializedr   r   r   r   errorc                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   InitializeResponse.__annotate__0   s     , ,z ,d ,r#   c                	F    \         P                  ! WP                  4       R # r%   )r
   r(   r=   r)   s   &&r    r+   InitializeResponse.write0   s    Q

+r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r?   3   s     , ,j ,T ,r#   c                	<    \         P                  ! V4      V n        R # r%   )r
   r1   r=   r)   s   &&r    r2   InitializeResponse.read3   s    ((+
r#   )r=   N)r4   r5   r6   r7   r8   r   r9   r=   r+   r2   r:   r   r#   r    r<   r<   )   s'    )FME3O,, ,r#   r<   c                  P    ] tR t^7t$ Rt^tR]R&   ^ tR]R&   R R ltR R	 lt	R
t
R# )PingRequestzHsent by the main process to the subprocess to check if it is still aliver   r   int	timestampc                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   PingRequest.__annotate__>   s     . .z .d .r#   c                	F    \         P                  ! WP                  4       R # r%   )r
   
write_longrH   r)   s   &&r    r+   PingRequest.write>   s    1nn-r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   rJ   A   s     . .j .T .r#   c                	<    \         P                  ! V4      V n        R # r%   )r
   	read_longrH   r)   s   &&r    r2   PingRequest.readA   s     **1-r#   )rH   N)r4   r5   r6   r7   r8   r   r9   rH   r+   r2   r:   r   r#   r    rF   rF   7   s(    RFMIs.. .r#   rF   c                  ^    ] tR t^Et$ Rt^tR]R&   ^ tR]R&   ^ tR]R&   R R lt	R	 R
 lt
RtR# )PongResponsezresponse to a PingRequestr   r   rG   last_timestamprH   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   PongResponse.__annotate__M   s     . .z .d .r#   c                	    \         P                  ! WP                  4       \         P                  ! WP                  4       R # r%   )r
   rL   rT   rH   r)   s   &&r    r+   PongResponse.writeM   s(    11121nn-r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   rV   Q   s     . .j .T .r#   c                	r    \         P                  ! V4      V n        \         P                  ! V4      V n        R # r%   )r
   rP   rT   rH   r)   s   &&r    r2   PongResponse.readQ   s'    %//2 **1-r#   )rT   rH   N)r4   r5   r6   r7   r8   r   r9   rT   rH   r+   r2   r:   r   r#   r    rS   rS   E   s2    #FMNCIs.. .r#   rS   c                  ^    ] tR t^Vt$ Rt^tR]R&   ]! RR7      tR]R&   R R	 lt	R
 R lt
RtR# )StartJobRequestzsent by the main process to the subprocess to start a job, the subprocess will only
receive this message if the process is fully initialized (after sending a InitializeResponse).r   r   F)initr	   running_jobc                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   StartJobRequest.__annotate__^   s     	9 	9z 	9d 	9r#   c                	   V P                   P                  p\        P                  ! WP                   P                  P                  4       4       \        P                  ! WP                  4       \        P                  ! WP                  4       \        P                  ! WP                  4       \        P                  ! WP                   P                  4       \        P                  ! WP                   P                  4       \        P                  ! WP                   P                  4       \        P                  ! WP                   P                  4       R # r%   )r_   accept_argumentsr
   write_bytesjobSerializeToStringr(   nameidentitymetadataurltoken	worker_idr&   fake_job)r*   r   accept_argss   && r    r+   StartJobRequest.write^   s    &&77A//33EEGHQ 0 01Q 4 45Q 4 45Q 0 0 4 45Q 0 0 6 67Q 0 0 : :;1..778r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   ra   i   s     
 
j 
T 
r#   c           
     	   \         P                  ! 4       pVP                  \        P                  ! V4      4       \        \        \        P                  ! V4      \        P                  ! V4      \        P                  ! V4      R 7      V\        P                  ! V4      \        P                  ! V4      \        P                  ! V4      \        P                  ! V4      R7      V n	        R# ))rg   rh   ri   )rc   re   rj   rk   rl   rm   N)
r   JobParseFromStringr
   
read_bytesr	   r   r1   r/   r_   )r*   r   re   s   && r    r2   StartJobRequest.readi   s    iikG..q12)/((+ ,,Q/ ,,Q/
 ##A&%%a())!,&&q)
r#   )r_   N)r4   r5   r6   r7   r8   r   r9   r   r_   r+   r2   r:   r   r#   r    r]   r]   V   s2    f FM"'U"3K3	9
 
r#   r]   c                  P    ] tR t^zt$ Rt^tR]R&   RtR]R&   R R ltR	 R
 lt	Rt
R# )ShutdownRequestzsent by the main process to the subprocess to indicate that it should shut down
gracefully. the subprocess will follow with a ExitInfo messager   r   r   r   reasonc                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   ShutdownRequest.__annotate__        - -z -d -r#   c                	F    \         P                  ! WP                  4       R # r%   r
   r(   rx   r)   s   &&r    r+   ShutdownRequest.write       Q,r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   rz           - -j -T -r#   c                	<    \         P                  ! V4      V n        R # r%   r
   r1   rx   r)   s   &&r    r2   ShutdownRequest.read       ))!,r#   rx   Nr4   r5   r6   r7   r8   r   r9   rx   r+   r2   r:   r   r#   r    rw   rw   z   s-    F FMFC-- -r#   rw   c                  P    ] tR t^t$ Rt^tR]R&   RtR]R&   R R ltR	 R
 lt	Rt
R# )ExitingzIsent by the subprocess to the main process to indicate that it is exitingr   r   r   r   rx   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   Exiting.__annotate__   r{   r#   c                	F    \         P                  ! WP                  4       R # r%   r}   r)   s   &&r    r+   Exiting.write   r   r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r      r   r#   c                	<    \         P                  ! V4      V n        R # r%   r   r)   s   &&r    r2   Exiting.read   r   r#   r   Nr   r   r#   r    r   r      s(    SFMFC-- -r#   r   c                  l    ] tR t^t$ Rt^tR]R&   RtR]R&   RtR]R&   Rt	R	]R
&   R R lt
R R ltRtR# )InferenceRequestz=sent by a subprocess to the main process to request inferencer   r   r   r   method
request_idr#   bytesdatac                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   InferenceRequest.__annotate__   s     * *z *d *r#   c                	    \         P                  ! WP                  4       \         P                  ! WP                  4       \         P                  ! WP
                  4       R # r%   )r
   r(   r   r   rd   r   r)   s   &&r    r+   InferenceRequest.write   s8    Q,Q0Ayy)r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r      s     * *j *T *r#   c                	    \         P                  ! V4      V n        \         P                  ! V4      V n        \         P                  ! V4      V n        R # r%   )r
   r1   r   r   rt   r   r)   s   &&r    r2   InferenceRequest.read   s8    ))!,!--a0&&q)	r#   )r   r   r   N)r4   r5   r6   r7   r8   r   r9   r   r   r   r+   r2   r:   r   r#   r    r   r      s<    GFMFCJD%*
* *r#   r   c                  l    ] tR t^t$ Rt^tR]R&   RtR]R&   RtR]R	&   Rt	R]R
&   R R lt
R R ltRtR# )InferenceResponsezresponse to an InferenceRequestr   r   r   r   r   Nzbytes | Noner   r=   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   InferenceResponse.__annotate__   s     , ,z ,d ,r#   c                	&   \         P                  ! WP                  4       \         P                  ! WP                  R J4       V P                  e!   \         P
                  ! WP                  4       \         P                  ! WP                  4       R # r%   )r
   r(   r   r&   r   rd   r=   r)   s   &&r    r+   InferenceResponse.write   sY    Q01iit3499 99-Q

+r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r      s     , ,j ,T ,r#   c                	    \         P                  ! V4      V n        \         P                  ! V4      pV'       d   \         P                  ! V4      V n        \         P                  ! V4      V n        R # r%   )r
   r1   r   r/   rt   r   r=   )r*   r   has_datas   && r    r2   InferenceResponse.read   sK    !--a0$$Q'**1-DI((+
r#   )r   r=   r   )r4   r5   r6   r7   r8   r   r9   r   r   r=   r+   r2   r:   r   r#   r    r   r      s;    )FMJD,E3O,, ,r#   r   c                  B    ] tR t^t$ Rt^	tR]R&   R R ltR R ltRt	R	# )
DumpStackTraceRequestzEsent by the main process to request a stack trace dump before killingr   r   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   "DumpStackTraceRequest.__annotate__         z d r#   c                	    R # r%   r   r)   s   &&r    r+   DumpStackTraceRequest.write       r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r            j T r#   c                	    R # r%   r   r)   s   &&r    r2   DumpStackTraceRequest.read   r   r#   r   N)
r4   r5   r6   r7   r8   r   r9   r+   r2   r:   r   r#   r    r   r      s    OFM r#   r   c                  >    ] tR t^t$ ^
tR]R&   R R ltR R ltRtR# )	ShutdownRequestAckr   r   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   ShutdownRequestAck.__annotate__   r   r#   c                	    R # r%   r   r)   s   &&r    r+   ShutdownRequestAck.write   r   r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r      r   r#   c                	    R # r%   r   r)   s   &&r    r2   ShutdownRequestAck.read   r   r#   r   N	r4   r5   r6   r7   r   r9   r+   r2   r:   r   r#   r    r   r          FM r#   r   c                  >    ] tR t^t$ ^tR]R&   R R ltR R ltRtR# )	ShuttingDownr   r   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   ShuttingDown.__annotate__   r   r#   c                	    R # r%   r   r)   s   &&r    r+   ShuttingDown.write   r   r#   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r    r!   r      r   r#   c                	    R # r%   r   r)   s   &&r    r2   ShuttingDown.read   r   r#   r   Nr   r   r#   r    r   r      r   r#   r   )
__future__r   iodataclassesr   r   typingr   livekit.protocolr   re   r   r	   r   r
   r   r<   rF   rS   r]   rw   r   r   r   r   r   r   r   IPC_MESSAGESr   r#   r    <module>r      s   " 	 (  " 4  1 1 16 
, 
, 
, 
. 
. 
. . . .   
  
  
F - - - 
- 
- 
- * * *& , , ,. 	 	 	       /1OONNG-/  "71r#   