ó Ýà‹]c@@sÓdZddlmZddlZddlZddlmZmZddlZddl Z ddl m Z ddl m Z ddl mZe dZd efd „ƒYZd efd „ƒYZejeƒdS( sCBase classes to manage a Client's interaction with a running kerneli(tabsolute_importN(tThreadtEvent(tZMQError(tprotocol_version_infoi(t HBChannelABCtInvalidPortNumbercB@seZRS((t__name__t __module__(((s6lib/python2.7/site-packages/jupyter_client/channels.pyRst HBChannelcB@sÅeZdZd Zd Zd Zd ZeZ dZ d Z d Z d Z d Zd d d d„Zeejd„ƒƒZd„Zd„Zd„Zd„Zd„Zd „Zd „Zd „Zd „ZRS(sôThe 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. gð?cC@s©tt|ƒjƒt|_||_||_t|tƒro|ddkrbd}t |ƒ‚nd|}n||_ t |_ t ƒ|_t |_tjƒ|_dS(sKCreate 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. iis*The port number for a channel cannot be 0.s tcp://%s:%iN(tsuperR t__init__tTruetdaemontcontexttsessiont isinstancettupleRtaddresstFalset_runningRt_exitt_pausetzmqtPollertpoller(tselfRRRtmessage((s6lib/python2.7/site-packages/jupyter_client/channels.pyR 2s         cC@stdk rtt_ndS(N(R tNoneR t_exiting(((s6lib/python2.7/site-packages/jupyter_client/channels.pyt _notice_exitQs cC@s†|jdk r2|jj|jƒ|jjƒn|jjtjƒ|_d|j_|jj |j ƒ|jj |jtj ƒdS(Niè( tsocketRRt unregistertcloseRRtREQtlingertconnectRtregistertPOLLIN(R((s6lib/python2.7/site-packages/jupyter_client/channels.pyt_create_socketYs cC@sÌ|jtjƒ|}t|dƒ}g}x™trÇy|jjd|ƒ}Wnqtk r¢}|jtjkrœ|jtjƒ|}t|dƒ}qÄ‚q/t k rÂ|j r¼PqÄ‚q/XPq/W|S(spoll for heartbeat replies until we reach self.time_to_dead. Ignores interrupts, and returns the result of poll(), which will be an empty list if no messages arrived before the timeout, or the event tuple if there is a message to receive. gü©ñÒMbP?iè( t time_to_deadttimetmaxR RtpollRterrnotEINTRt ExceptionR(Rt start_timet until_deadteventste((s6lib/python2.7/site-packages/jupyter_client/channels.pyt_pollds$   cC@s|jƒt|_t|_xë|jr |jrJ|jj|jƒqnd}|jj dƒt j ƒ}|j |ƒ}|rÓt|_|jj ƒ|jt j ƒ|}|dkr|jj|ƒqqqt |_t j ƒ|}|j|ƒ|jƒqqWdS(s2The thread's main activity. Call start() instead.gtpingiN(R'R Rt_beatingRRtwaitR(RtsendR)R3trecvRt call_handlers(Rtsince_last_heartbeatt request_timetreadyt remainder((s6lib/python2.7/site-packages/jupyter_client/channels.pytrun…s.            cC@s t|_dS(sPause the heartbeat.N(R R(R((s6lib/python2.7/site-packages/jupyter_client/channels.pytpauseªscC@s t|_dS(sUnpause the heartbeat.N(RR(R((s6lib/python2.7/site-packages/jupyter_client/channels.pytunpause®scC@s+|jƒr#|j r#|jr#tStSdS(s9Is the heartbeat running and responsive (and not paused).N(tis_aliveRR5R R(R((s6lib/python2.7/site-packages/jupyter_client/channels.pyt is_beating²scC@s.t|_|jjƒ|jƒ|jƒdS(s2Stop the channel's event loop and join its thread.N(RRRtsettjoinR!(R((s6lib/python2.7/site-packages/jupyter_client/channels.pytstop¹s   cC@sJ|jdk rFy|jjddƒWntk r9nXd|_ndS(NR#i(RRR!R.(R((s6lib/python2.7/site-packages/jupyter_client/channels.pyR!Às  cC@sdS(siThis 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. N((RR:((s6lib/python2.7/site-packages/jupyter_client/channels.pyR9ÈsN(RRt__doc__RRRRRRRR(RRRR5R t staticmethodtatexitR%RR'R3R>R?R@RBRER!R9(((s6lib/python2.7/site-packages/jupyter_client/channels.pyR s. ! %     (RFt __future__RRHR,t threadingRRR)RRtjupyter_clientRt channelsabcRtmajor_protocol_versionR.RR R%(((s6lib/python2.7/site-packages/jupyter_client/channels.pyts     ´