ó ù2¢\c@stdZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZmZd d lmZd d lmZmZdd lmZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdZdZ defdeefdee fefdeefgZ!dS(s®Tornado handlers for kernels. Preliminary documentation at https://github.com/ipython/ipython/wiki/IPEP-16%3A-Notebook-multi-directory-dashboard-and-URL-mapping#kernels-api iÿÿÿÿN(tdedent(tgentweb(tFuture(tIOLoop(t date_default(t cast_unicode(t url_path_joint url_escapei(t APIHandler(tAuthenticatedZMQStreamHandlertdeserialize_binary_message(tprotocol_versiontMainKernelHandlercBs>eZejejd„ƒƒZejejd„ƒƒZRS(ccs?|j}tj|jƒƒV}|jtj|dtƒƒdS(Ntdefault(tkernel_managerRt maybe_futuret list_kernelstfinishtjsontdumpsR(tselftkmtkernels((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pytgets ccsÑ|j}|jƒ}|dkr4i|jd6}n|jd|jƒtj|jd|dƒƒV}|j|ƒ}t |j ddt |ƒƒ}|j d|ƒ|j dƒ|jtj|dtƒƒdS(Ntnamet kernel_nametapiRtLocationiÉR(Rt get_json_bodytNonetdefault_kernel_namet setdefaultRRt start_kernelt kernel_modelRtbase_urlRt set_headert set_statusRRRR(RRtmodelt kernel_idtlocation((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pytpost#s     (t__name__t __module__Rt authenticatedRt coroutineRR)(((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR st KernelHandlercBs5eZejd„ƒZejejd„ƒƒZRS(cCsE|j}|j|ƒ|j|ƒ}|jtj|dtƒƒdS(NR(Rt_check_kernel_idR"RRRR(RR'RR&((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR9s  ccs;|j}tj|j|ƒƒV|jdƒ|jƒdS(NiÌ(RRRtshutdown_kernelR%R(RR'R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pytdelete@s  (R*R+RR,RRR-R1(((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR.7stKernelActionHandlercBs#eZejejd„ƒƒZRS(ccsÎ|j}|dkr2|j|ƒ|jdƒn|dkrÀytj|j|ƒƒVWn6tk r‘}|jjddt ƒ|jdƒqÀX|j |ƒ}|j t j |dtƒƒn|jƒdS(Nt interruptiÌtrestartsException restarting kerneltexc_infoiôR(Rtinterrupt_kernelR%RRtrestart_kernelt ExceptiontlogterrortTrueR"twriteRRRR(RR'tactionRteR&((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR)Ks    (R*R+RR,RR-R)(((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR2IstZMQChannelsHandlercBseZdZiZed„ƒZed„ƒZed„ƒZed„ƒZd„Z d„Z d„Z d„Z d „Z d „Zejd „ƒZejd „ƒZejd „ƒZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(s]There is one ZMQChannelsHandler per running kernel and it oversees all the sessions. cCs|jj}|jjd|ƒS(Ntkernel_info_timeout(RR@tsettingsR(Rt km_default((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR@is cCs|jjddƒS(Ntiopub_msg_rate_limiti(RAR(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRCnscCs|jjddƒS(Ntiopub_data_rate_limiti(RAR(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRDrscCs|jjddƒS(Ntrate_limit_windowgð?(RAR(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyREvscCs d|jjt|ddƒfS(Ns%s(%s)R't uninitialized(t __class__R*tgetattr(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyt__repr__zscCsf|j}|jj}xJdD]B}t|d|ƒ}||jd|ƒ|j|<}||_qWdS(Ntshelltiopubtstdintconnect_tidentity(RJRKRL(RtsessiontbsessionRHR'tchannelstchannel(RRRNRRtmethtstream((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyt create_stream}s     csêˆj}|jˆjƒ}y |j}Wnƒtk r­ˆjjdˆjƒˆjdkru|j ˆjƒˆ_nˆjj ˆj ƒˆj j ˆjdƒˆj|_n6X|jƒs͈jjdƒn|j‡fd†ƒˆjS(ssend a request for kernel_infosRequesting kernel info from %stkernel_info_requests'Waiting for pending kernel_info requestcsˆj|jƒƒS(N(t_finish_kernel_infotresult(tf(R(sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyt™tN(Rt get_kernelR't_kernel_info_futuretAttributeErrorR9tdebugtkernel_info_channelRt connect_shellton_recvt_handle_kernel_info_replyROtsendtdonetadd_done_callback(RRtkerneltfuture((RsAlib/python2.7/site-packages/notebook/services/kernels/handlers.pytrequest_kernel_info…s    cCsç|jj|ƒ\}}y|jj|ƒ}Wn.|jjddtƒ|jjiƒdSX|d}|jjd|ƒ|ddks˜d|kr´|jjd |ƒi}n|j |ƒ|j rÚ|j j ƒnd|_ dS( sbprocess the kernel_info_reply enabling msg spec adaptation, if necessary sBad kernel_info replyR5NtcontentsReceived kernel info: %stmsg_typetkernel_info_replyR s/Kernel info request failed, assuming current %s( ROtfeed_identitiest deserializeR9R:R;R]t set_resultR_RWR`tcloseR(Rtmsgtidentstinfo((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRcœs     cCs|jdtƒ}|tkrYt|jdƒdƒ|j_|jjd||jƒn|j j ƒs{|j j |ƒndS(s“Finish handling kernel_info reply Set up protocol adaptation, if needed, and signal that connection can continue. R t.is&Adapting to protocol v%s for kernel %sN( Rtclient_protocol_versiontinttsplitROt adapt_versionR9RsR'R]ReRo(RRsR ((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRWµs  cCs‰tt|ƒjƒd|_i|_d|_d|_tƒ|_ tƒ|_ d|_ d|_ d|_ t|_t|_g|_dS(NR[i(tsuperR?t initializeRt zmq_streamRQR'R`RR]t _close_futuret session_keyt_iopub_window_msg_countt_iopub_window_byte_counttFalset_iopub_msgs_exceededt_iopub_data_exceededt_iopub_window_byte_queue(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRzÂs           c#s•ttˆƒjƒˆjƒVˆjjˆjƒ}|jjˆj_ˆj ƒ‰‡‡fd†}t j ƒ}|j |j ƒˆj|ƒˆVdS(Ncs7ˆjƒrdSˆjjdˆjƒˆjiƒdS(s*Don't wait forever for the kernel to replyNs-Timeout waiting for kernel_info reply from %s(ReR9twarningR'Ro((RhR(sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pytgive_upãs (RyR?tpre_gett_register_sessionRR\R'ROtkeyRiRtcurrentt add_timeoutttimeR@(RRgR…tloop((RhRsAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR†Ös   ccs0t|dƒ|_tt|ƒjd|ƒVdS(NtasciiR'(RR'RyR?R(RR'((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRîsccsod|j|jjf|_|jj|jƒ}|r[|jjd|jƒ|jƒVn||j|j((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR’s4       cCsÑ|js |jjd|ƒdSt|tƒr>t|ƒ}ntj|ƒ}|jddƒ}|dkr‡|jj d|ƒd}n||jkr­|jj d|ƒdS|j|}|j j ||ƒdS(Ns'Received message on closed websocket %rRRs(No channel specified, assuming shell: %sRJsNo such channel: %r( RQR9R_t isinstancetbytesR RtloadstpopRR„RORd(RRqRRRT((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyt on_message%s    cs ˆjj|ƒ\}}ˆjj|ƒ}|d‰‡‡fd†}t|ddƒ}|dd}|dkrÇ|dkrÇ|djd ƒd krÇgˆ_d ˆ_d ˆ_t ˆ_ t ˆ_ n|dkrƒ|dd d hkrƒt j ƒjƒ} xftˆjƒd krbˆjd } | | d kr^ˆj| d8_ˆjd8_ˆjd =qýPqýWˆjd7_|dkr¦tg|D]} t| ƒ^qˆƒ} nd } ˆj| 7_ˆjj| ˆj| fƒtˆjƒˆj} tˆjƒˆj}ˆjd kr\| ˆjkr\ˆj s tˆ_ |tdjˆjˆjƒƒƒq nDˆj r | dˆjkr t ˆ_ ˆj s ˆjjdƒq nˆjd krø|ˆjkrøˆj s<tˆ_ |tdjˆjˆjƒƒƒq<nDˆj r<|dˆjkr<t ˆ_ ˆj s<ˆjjdƒq<nˆj sNˆj rƒˆjd8_ˆj| 8_ˆjjdƒdSnttˆƒj||ƒdS(Nt parent_headercsjˆjj|ƒˆjjddi|dd6dd6dˆƒ}d|d <ˆjtj|d tƒƒdS( NRTRjs ttexttstderrRtparentRKRRR(R9R„RORqt write_messageRRR(t error_messageRq(R©R(sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyt write_stderr<s   RRtheaderRkRKtstatusRjtexecution_statetidleit comm_opent execute_inputiRTs IOPub message rate exceeded. The notebook server will temporarily stop sending output to the client in order to avoid crashing it. To change this limit, set the config variable `--NotebookApp.iopub_msg_rate_limit`. Current values: NotebookApp.iopub_msg_rate_limit={} (msgs/sec) NotebookApp.rate_limit_window={} (secs) gš™™™™™é?siopub messages resumeds IOPub data rate exceeded. The notebook server will temporarily stop sending output to the client in order to avoid crashing it. To change this limit, set the config variable `--NotebookApp.iopub_data_rate_limit`. Current values: NotebookApp.iopub_data_rate_limit={} (bytes/sec) NotebookApp.rate_limit_window={} (secs) iÿÿÿÿ(RORmRnRHRRRƒR~RR€RR‚RR‰R‹R•tsumtappendREtfloatRCR;RtformatR9R„RDR¤RyR?R–(RRTR Rrt fed_msg_listRqR¬RRRktnowtqueuedtxt byte_counttmsg_ratet data_rate((R©RsAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR–8sj 1     !   (   "     "  cCstt|ƒjƒ|jS(N(RyR?RpR|(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRp¥scCsW|jjd|jƒ|jj|jƒ|krG|jj|jƒn|j}|j|krç|j|jƒ|j |j|j ƒ|j |j|j dƒ|j |jdkrç|j |j|j|jƒ|jjdƒdSnxP|jjƒD]?\}}|dk r÷|jƒ r÷|jdƒ|jƒq÷q÷Wi|_|jjdƒdS(NsWebsocket closed %sR‘i(R9R_R}RŽRR¤RR'tnotify_disconnecttremove_restart_callbackR›Rœt_kernel_connectionststart_bufferingRQR|RoRR˜R™RbRp(RRRRRT((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyton_close©s(   cCs{|jjddƒ}|r5|jƒ r5|jƒn|jjdi|d6ƒ}d|d<|jtj |dt ƒƒdS(NRKR®R¯RRR( RQRRR™tflushRORqRªRRR(RR®RKRq((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyt_send_status_messageÊs   cCs$tjd|jƒ|jdƒdS(Nskernel %s restartedt restarting(tloggingtwarnR'RÄ(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR›×scCs$tjd|jƒ|jdƒdS(Nskernel %s restarted failed!R‘(RÆR:R'RÄ(R((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyRœÛs(R*R+t__doc__RŽtpropertyR@RCRDRERIRURiRcRWRzRR-R†RR‡R’R¥R–RpRÂRÄR›Rœ(((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyR?_s.      #  m  ! s"(?P\w+-\w+-\w+-\w+-\w+)s(?Prestart|interrupt)s /api/kernelss/api/kernels/%ss/api/kernels/%s/%ss/api/kernels/%s/channels("RÈRRÆttextwrapRttornadoRRttornado.concurrentRttornado.ioloopRtjupyter_client.jsonutilRtipython_genutils.py3compatRtnotebook.utilsRRt base.handlersR tbase.zmqhandlersR R tjupyter_clientR RuR R.R2R?t_kernel_id_regext_kernel_action_regextdefault_handlers(((sAlib/python2.7/site-packages/notebook/services/kernels/handlers.pyts.  ÿ‡