
    <hS*                         S r SSKrSSKrSSKrSSKrSSKJr  SSKJ	r	J
r
  SSKrSSKJr  SSKJr  SSKJr  SS	KJr  \S   r " S
 S\5      r " S S\
5      r\R2                  " \5         " S S5      r " S S\5      rg)zCBase classes to manage a Client's interaction with a running kernel    N)Empty)EventThread)ensure_async   )protocol_version_info)HBChannelABC)Sessionc                       \ rS rSrSrSrg)InvalidPortNumber   z/An exception raised for an invalid port number. N)__name__
__module____qualname____firstlineno____doc____static_attributes__r       jC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\jupyter_client/channels.pyr   r      s    9r   r   c            
         ^  \ rS rSr% SrSrSrSrSrSr	\
\S'   SrSrSr   SS\R                   \R$                     S\R                   \   S	\R(                  \R*                  \\4   \4   S
S4U 4S jjjr\\R6                  SS j5       5       rSS jrSS jrSS jrSS jr SS jr!S
\"4S jr#SS jr$SS jr%S\
S
S4S jr&Sr'U =r($ )	HBChannel"   zThe heartbeat channel which monitors the kernel heartbeat.

Note that the heartbeat channel is paused by default. As long as you start
this channel, the kernel manager will ensure that it is paused and un-paused
as appropriate.
NFg      ?time_to_deadcontextsessionaddressreturnc                 (  > [         TU ]  5         SU l        Xl        X l        [        U[        5      (       a  US   S:X  a  Sn[        U5      eSU-  nOUnXPl        SU l	        [        5       U l        SU l        [        R                  " 5       U l        g)a  Create the heartbeat monitor thread.

Parameters
----------
context : :class:`zmq.Context`
    The ZMQ context to use.
session : :class:`session.Session`
    The session to use.
address : zmq url
    Standard (ip, port) tuple that the kernel is listening on.
Tr   r   z*The port number for a channel cannot be 0.ztcp://%s:%iFN)super__init__daemonr   r   
isinstancetupler   r   _runningr   _exit_pausezmqPollerpoller)selfr   r   r   messageaddress_str	__class__s         r   r!   HBChannel.__init__4   s    " 	gu%%qzQF'00''1K!K" W
jjlr   c                  *    [         b  S[         l        g g )NT)r   _exitingr   r   r   _notice_exitHBChannel._notice_exitZ   s    
  !%I !r   c                    U R                   b?  U R                  R                  U R                   5        U R                   R                  5         U R                  c   eU R                  R                  [
        R                  5      U l         SU R                   l        U R                  c   eU R                   R                  U R                  5        U R                  R                  U R                   [
        R                  5        g )N  )socketr*   
unregistercloser   r(   REQlingerr   connectregisterPOLLINr+   s    r   _create_socketHBChannel._create_socketb   s    ;;"KK""4;;/KK||'''ll))#''2!||'''DLL)T[[#**5r   c                 h  #    U R                  5         SU l        SU l        U R                  c   eU R                  (       Gaj  U R                  (       a'  U R
                  R                  U R                  5        MJ  Sn[        U R                  R                  S5      5      I Sh  vN   [        R                  " 5       nU R
                  R                  U R                  5        [        U R                  R                  S5      5      U l        U R                  (       a.  [        U R                  R                  5       5      I Sh  vN   GM  U R                  (       a<  [        R                  " 5       U-
  nU R                  U5        U R                  5         GMg  U R                  (       a  GMi  gg GN
 Nm7f)z2The thread's main activity.  Call start() instead.TNg        s   pingr   )r?   r%   _beatingr6   r'   r&   waitr   r   sendtimeboolr*   pollrecvcall_handlers)r+   since_last_heartbeatrequest_times      r   
_async_runHBChannel._async_runo   s)    {{&&&mmm{{

 1 12#&  t{{//899999;LJJOOD--. !1!1!!45DM}}"4;;#3#3#5666'+yy{\'A$""#78##%3 mmm : 7s,   B!F2#F-$BF2F0A%F2+F20F2c                     [         R                  " 5       n[         R                  " U5        UR                  U R	                  5       5        UR                  5         g)zRun the heartbeat thread.N)asyncionew_event_loopset_event_looprun_until_completerL   r8   )r+   loops     r   runHBChannel.run   s<    %%'t$ 12

r   c                     SU l         g)zPause the heartbeat.TNr'   r>   s    r   pauseHBChannel.pause   s	    r   c                     SU l         g)zUnpause the heartbeat.FNrW   r>   s    r   unpauseHBChannel.unpause   s	    r   c                 t    U R                  5       (       a#  U R                  (       d  U R                  (       a  gg)z9Is the heartbeat running and responsive (and not paused).TF)is_aliver'   rB   r>   s    r   
is_beatingHBChannel.is_beating   s    ==??4;;4==r   c                     SU l         U R                  R                  5         U R                  5         U R	                  5         g)z2Stop the channel's event loop and join its thread.FN)r%   r&   setjoinr8   r>   s    r   stopHBChannel.stop   s)    

		

r   c                     U R                   b"   U R                   R                  SS9  SU l         gg! [         a     Nf = f)zClose the heartbeat thread.Nr   r:   r6   r8   	Exceptionr>   s    r   r8   HBChannel.close   H    ;;"!!!+ DK #     1 
>>rJ   c                     g)aA  This method is called in the ioloop thread when a message arrives.

Subclasses should override this method to handle incoming messages.
It is important to remember that this method is called in the thread
so that some logic must be done to ensure that the application level
handlers are called in the application thread.
Nr   )r+   rJ   s     r   rI   HBChannel.call_handlers   s     	r   )
rB   r&   r'   r%   r   r   r"   r*   r   r6   )NN r   N))r   r   r   r   r   r   r6   r   r1   r   float__annotations__r%   r'   rB   tOptionalr(   Contextr
   UnionTuplestrintr!   staticmethodatexitr<   r2   r?   rL   rT   rX   r[   rF   r_   rd   r8   rI   r   __classcell__r.   s   @r   r   r   "   s    GFGHL%HFH ,0'+35	$#CKK($# G$$# c*C/0	$#
 
$# $#L __&  &6 DD % D  r   r   c            	         ^  \ rS rSrSrSS\R                  S\S\R                  SS4U 4S jjjr
S	\R                  S\R                  \\R                  4   4S
 jrSS\R                  \   S\R                  \\R                  4   4S jjrS\R"                  \R                  \\R                  4      4S jrS\4S jrSS jr\rS\4S jrS\R                  \\R                  4   SS4S jrSS jrSrU =r$ )ZMQSocketChannel   zA ZMQ socket wrapperNr6   r   rS   r   c                 :   > [         TU ]  5         Xl        X l        g)zCreate a channel.

Parameters
----------
socket : :class:`zmq.Socket`
    The ZMQ socket to use.
session : :class:`session.Session`
    The session to use.
loop
    Unused here, for other implementations
N)r    r!   r6   r   )r+   r6   r   rS   r.   s       r   r!   ZMQSocketChannel.__init__   s     	.4r   kwargsc                     U R                   c   eU R                   R                  " S0 UD6nU R                  R                  U5      u  p4U R                  R	                  U5      $ Nr   r6   recv_multipartr   feed_identitiesdeserialize)r+   r   msgidentsmsgs        r   _recvZMQSocketChannel._recv   sT    {{&&&kk((262ll2237||''--r   timeoutc                     U R                   c   eUc  SO[        US-  5      nU R                   R                  U5      nU(       a  U R                  5       nU$ [        ez-Gets a message if there is one that is ready.Nr5   r6   ry   rG   r   r   r+   r   
timeout_msreadyress        r   get_msgZMQSocketChannel.get_msg   sR    {{&&&$_T#gn2E
  ,**,CJKr   c                 n    / n  UR                  U R                  5       5        M"  ! [         a     U$ f = f)*Get all messages that are currently ready.appendr   r   r+   msgss     r   get_msgsZMQSocketChannel.get_msgs   s?    DLLN+   s   & 
44c                 d    U R                   c   e[        U R                   R                  SS95      $ )*Is there a message that has been received?r   r   r6   rF   rG   r>   s    r   	msg_readyZMQSocketChannel.msg_ready   s/    {{&&&DKK$$Q$/00r   c                     U R                   b"   U R                   R                  SS9  SU l         gg! [         a     Nf = f)zClose the socket channel.Nr   rg   rh   r>   s    r   r8   ZMQSocketChannel.close   rk   rl   c                     U R                   SL$ )z"Test whether the channel is alive.N)r6   r>   s    r   r^   ZMQSocketChannel.is_alive  s    {{$&&r   r   c                 n    U R                   c   eU R                  R                  U R                   U5        g)z(Pass a message to the ZMQ socket to sendN)r6   r   rD   )r+   r   s     r   rD   ZMQSocketChannel.send  s*    {{&&&$++s+r   c                     g)zStart the socket channel.Nr   r>   s    r   startZMQSocketChannel.start  s    r   )r   r6   Nrp   )r   r   r   r   r   r(   Socketr
   rs   Anyr!   Dictrx   r   rt   rq   r   Listr   rF   r   r8   rd   r^   rD   r   r   r|   r}   s   @r   r   r      s   szz G 155 TX  ".aee .sAEEz(: .	qzz%0 	AFF3:<N 	!&&QUU
!34 14 1
 D'$ ',sAEEz* ,t ,
 r   r   c            	         ^  \ rS rSr% Sr\R                  R                  \S'   SS\R                  R                  S\	S\
R                  SS4U 4S jjjrS	\
R                  S\
R                  \\
R                  4   4S
 jr SS\
R                   \   S\
R                  \\
R                  4   4S jjrS\
R&                  \
R                  \\
R                  4      4S jrS\4S jrSrU =r$ )AsyncZMQSocketChanneli  zA ZMQ socket in an async APIr6   Nr   rS   r   c                    > [        U[        R                  R                  5      (       d  Sn[	        U5      e[
        TU ]  X5        g)zCreate a channel.

Parameters
----------
socket : :class:`zmq.asyncio.Socket`
    The ZMQ socket to use.
session : :class:`session.Session`
    The session to use.
loop
    Unused here, for other implementations
zSocket must be asyncioN)r#   r(   rO   r   
ValueErrorr    r!   )r+   r6   r   rS   r   r.   s        r   r!   AsyncZMQSocketChannel.__init__  s8     &#++"4"455*CS/!)r   r   c                    #    U R                   c   eU R                   R                  " S0 UD6I S h  vN nU R                  R                  U5      u  p4U R                  R	                  U5      $  N<7fr   r   )r+   r   r   _r   s        r   r   AsyncZMQSocketChannel._recv(  s_     {{&&&KK..888,,..s3||''-- 9s   /A0A.=A0r   c                    #    U R                   c   eUc  SO[        US-  5      nU R                   R                  U5      I Sh  vN nU(       a  U R                  5       I Sh  vN nU$ [        e N+ N7fr   r   r   s        r   r   AsyncZMQSocketChannel.get_msg.  se      {{&&&$_T#gn2E
kk&&z22

$CJK 3$s$   AA3A/A3"A1#A31A3c                    #    / n  UR                  U R                  5       I Sh  vN 5        M*   N
! [         a     U$ f = f7f)r   Nr   r   s     r   r   AsyncZMQSocketChannel.get_msgs;  sE     $,,.01 0 s/   A2 02 A2 
A AA  Ac                    #    U R                   c   e[        U R                   R                  SS9I Sh  vN 5      $  N7f)r   Nr   r   r   r>   s    r   r   AsyncZMQSocketChannel.msg_readyE  s8     {{&&&$++**1*55665s   1><	>r   r   )r   r   r   r   r   r(   rO   r   rr   r
   rs   r   r!   r   rx   r   rt   rq   r   r   r   rF   r   r   r|   r}   s   @r   r   r     s    &KK*s{{11 *G *155 *\` * *".AEE .affS!%%Z.@ . ,0zz%(	
QUU
	qvvc155j'9 : 7 7 7r   r   )r   rO   r{   rE   typingrs   queuer   	threadingr   r   zmq.asyncior(   jupyter_core.utilsr   _versionr   channelsabcr	   r   r
   major_protocol_versionri   r   r   r<   r   r   r   r   r   <module>r      s}    I      #  + + %  /q1 		 	] ]@   i  J JZ67, 67r   