MhS*dZddlZddlZddlZddlZddlmZddlm Z m Z ddl Z ddl mZddlmZddlmZdd lmZedZGd d eZGd d e ZejeGddZGddeZdS)zCBase classes to manage a Client's interaction with a running kernelN)Empty)EventThread) ensure_async)protocol_version_info) HBChannelABC)SessionceZdZdZdS)InvalidPortNumberz/An exception raised for an invalid port number.N)__name__ __module__ __qualname____doc__W/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/jupyter_client/channels.pyr r s99Drr c XeZdZUdZdZdZdZdZdZe e d<dZ dZ dZ ddejejdejed ejejeefefd dffd Zeejdd Zdd ZddZddZddZddZ d e!fdZ"ddZ#ddZ$de d dfdZ%xZ&S) HBChannelzThe 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_deadcontextsessionaddressreturncftd|_||_||_t |t r#|ddkrd}t|d|z}n|}||_d|_ t|_ d|_ tj|_dS)aKCreate 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. Trrz*The port number for a channel cannot be 0.z tcp://%s:%iFN)super__init__daemonrr isinstancetupler r_runningr_exit_pausezmqPollerpoller)selfrrrmessage address_str __class__s rrzHBChannel.__init__4s"    gu % % "qzQF'000''1KK!K"  WW  jll rc0tdt_dSdS)NT)r_exitingrrr _notice_exitzHBChannel._notice_exitZs  !%I    ! rc|j8|j|j|j|jJ|jt j|_d|j_|jJ|j |j|j |jt j dS)N) socketr' unregistercloserr%REQlingerrconnectregisterPOLLINr(s r_create_socketzHBChannel._create_socketbs ; " K " "4; / / / K     |'''l))#'22 ! |''' DL))) T[#*55555rcK|d|_d|_|jJ|jr:|jr |j|j/d}t|j dd{Vtj }|j|jt|j d|_|jr-t|jd{V|jrAtj |z }|||8|j8dSdS)z2The thread's main activity. Call start() instead.TNgspingr)r:r"_beatingr1r$r#waitrrsendtimeboolr'pollrecv call_handlers)r(since_last_heartbeat request_times r _async_runzHBChannel._async_runos{   {&&&m {   1222#& t{//8899 9 9 9 9 9 9 99;;L JOOD- . . . !1!1!!4!455DM} "4;#3#3#5#5666666666 '+y{{\'A$""#7888##%%%3m     rctj}tj||||dS)zRun the heartbeat thread.N)asyncionew_event_loopset_event_looprun_until_completerFr3)r(loops rrunz HBChannel.runsP%''t$$$  1 1222 rcd|_dS)zPause the heartbeat.TNr$r9s rpausezHBChannel.pauses  rcd|_dS)zUnpause the heartbeat.FNrOr9s runpausezHBChannel.unpauses  rcN|r|js |jrdSdS)z9Is the heartbeat running and responsive (and not paused).TF)is_aliver$r<r9s r is_beatingzHBChannel.is_beatings. ==?? 4; 4= 45rcd|_|j||dS)z2Stop the channel's event loop and join its thread.FN)r"r#setjoinr3r9s rstopzHBChannel.stops9    rc|j6 |jdn#t$rYnwxYwd|_dSdS)zClose the heartbeat thread.Nrr5r1r3 Exceptionr9s rr3zHBChannel.close^ ; "  !!!++++    DKKK # " % 22rDcdS)aiThis 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(rDs rrCzHBChannel.call_handlerss  r)NNrrN)'r rrrrr1rr-rfloat__annotations__r"r$r<tOptionalr%Contextr UnionTuplestrintr staticmethodatexitr7r.r:rFrMrPrRr@rUrYr3rC __classcell__r+s@rrr"sG FGHL%H FH,0'+35 $#$#CK($#G$$#c*C/0 $#  $#$#$#$#$#$#L _&&&_\& 6 6 6 6    DD % D        rrc zeZdZdZddejdedejddffd Z dejdej e ejffd Z dd ej edej e ejffd Zdejej e ejffd Zdefd ZddZeZdefdZdej e ejfddfdZddZxZS)ZMQSocketChannelzA ZMQ socket wrapperNr1rrLrcdt||_||_dS)aCreate 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)rrr1r)r(r1rrLr+s rrzZMQSocketChannel.__init__s- .4  rkwargsc |jJ|jjdi|}|j|\}}|j|SNrr1recv_multipartrfeed_identities deserialize)r(rrmsgidentsmsgs r_recvzZMQSocketChannel._recvsY{&&&(dk(22622l22377 t|''---rtimeoutc|jJ|dnt|dz}|j|}|r|}|Stz-Gets a message if there is one that is ready.Nr0r1rjrAr|rr(r} timeout_msreadyress rget_msgzZMQSocketChannel.get_msgs]{&&&$_TT#gn2E2E    ,,  **,,CJKrcg} ||n#t$rYnwxYw:|S)*Get all messages that are currently ready.appendrrr(msgss rget_msgszZMQSocketChannel.get_msgssZ   DLLNN++++       s '- ::cd|jJt|jdSz*Is there a message that has been received?Nr)r}r1r@rAr9s r msg_readyzZMQSocketChannel.msg_readys1{&&&DK$$Q$//000rc|j6 |jdn#t$rYnwxYwd|_dSdS)zClose the socket channel.Nrr[r\r9s rr3zZMQSocketChannel.closer^r_c|jduS)z"Test whether the channel is alive.N)r1r9s rrTzZMQSocketChannel.is_alives{$&&rrycX|jJ|j|j|dS)z(Pass a message to the ZMQ socket to sendN)r1rr>)r(rys rr>zZMQSocketChannel.sends0{&&& $+s+++++rcdS)zStart the socket channel.Nrr9s rstartzZMQSocketChannel.start s rNra)r rrrr%Socketr rdAnyrDictrir|rerbrListrr@rr3rYrTr>rrmrns@rrprpsszG15TX".ae.sAEz(:....  qz%0 AF3:rsII ########++++++++++++%%%%%%/q1        ] ] ] ] ] ] ] ] @ i J J J J J J J J Z6767676767,6767676767r