ó Û¤[c@sdZddlmZddlZddlZddlmZddlmZddl m Z m Z m Z m Z mZmZddlmZddlmZd d lmZd d lmZd d lmZmZmZdefd„ƒYZdefd„ƒYZejeƒdS(sAn in-process kerneliÿÿÿÿ(tcontextmanagerN(tInteractiveShellABC(t json_clean(tAnytEnumtInstancetListtTypetdefault(t IPythonKernel(tZMQInteractiveShelli(t INPROCESS_KEY(t DummySocketi(t OutStreamtBackgroundSockett IOPubThreadtInProcessKernelcBseZeeddeƒƒZedddƒZeƒZ eƒZ eƒZ e deƒZ eƒZeƒZeedƒZeeƒZed ƒd „ƒZeeƒZed ƒd „ƒZeed ƒZd „Zd„Zd„Zd„Zed„Ze d„ƒZ!d„Z"edƒd„ƒZ#edƒd„ƒZ$edƒd„ƒZ%edƒd„ƒZ&edƒd„ƒZ'RS(!s0ipykernel.inprocess.client.InProcessKernelClientt allow_nonettktgtktwxtqttqt4tinlinet default_valuet iopub_threadcCst|jƒ}|jƒ|S(N(Rt_underlying_iopub_sockettstart(tselftthread((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_default_iopub_thread9s t iopub_socketcCs |jjS(N(Rtbackground_socket(R((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_default_iopub_socketAscKsBtt|ƒj||jj|jddgƒ||j_dS(Ntnamest message_sent(tsuperRt__init__Rtobservet _io_dispatchtshelltkernel(Rttraits((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyR%GscCs3|jƒ!tt|ƒj|||ƒWdQXdS(s( Override for temporary IO redirection. N(t_redirected_ioR$Rtexecute_request(Rtstreamtidenttparent((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyR,Ms cCst|j_dS(s3 Override registration of dispatchers for streams. N(tFalseR(texit_now(R((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyRRscCsdS(s/ The in-process kernel doesn't abort requests. N((RR-((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt _abort_queueVscCsÖd|_tjjƒtjjƒttd|d|ƒƒ}|jj d||ƒ}xS|j D]4}|jj|ddkr`|j j |ƒPq`q`Wt jdƒtƒSx |jdkrÎ|j jƒq¯W|jS(Ntprompttpasswordu input_requesttheadertsessions'No frontend found for raw_input request(tNonet raw_input_strtsyststderrtflushtstdoutRtdictR6tmsgt frontendst stdin_channelt call_handlerstloggingterrortstrtprocess_events(RR3R.R/R4tcontentR>tfrontend((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_input_requestZs    ccsHtjtj}}|j|jt_t_dV||t_t_dS(s0 Temporarily redirect IO to the kernel. N(R9R<R:(Rt sys_stdoutt sys_stderr((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyR+tscCsI|jj|jdtƒ\}}x!|jD]}|jj|ƒq+WdS(s9 Called when a message is sent to the IO socket. tcopyN(R6trecvRR0R?t iopub_channelRA(RtchangeR.R>RG((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyR's!tlogcCs tjtƒS(N(RBt getLoggert__name__(R((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt _default_logˆsR6cCs#ddlm}|d|dtƒS(Niÿÿÿÿ(tSessionR/tkey(tjupyter_client.sessionRSR (RRS((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_default_sessionŒst shell_classcCstS(N(tInProcessInteractiveShell(R((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_default_shell_class‘sR<cCst|j|jdƒS(Nustdout(R R6R(R((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_default_stdout•sR:cCst|j|jdƒS(Nustderr(R R6R(R((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyt_default_stderr™s(RRRRRR((((RQt __module__RRtTrueR?RtguiRR8R<R:RRWt shell_streamstcontrol_streamR RRRRRRRR!t stdin_socketR%R,RR2R0RHRR+R'RRRVRYRZR[(((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyRs:                 RXcBsDeZeddeƒZdd„Zdd„Zdeed„Z RS(s,ipykernel.inprocess.ipkernel.InProcessKernelRcCsEddlm}|s%|jj}n||d|jƒ||_dS(s&Enable GUI integration for the kernel.iÿÿÿÿ(t enable_guiR)N(tipykernel.eventloopsRbR)R^tactive_eventloop(RR^Rb((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyRbªs cCs+|s|jj}ntt|ƒj|ƒS(s-Enable matplotlib integration for the kernel.(R)R^R$RXtenable_matplotlib(RR^((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyRe³scCs1|s|jj}ntt|ƒj|||ƒS(s"Activate pylab support at runtime.(R)R^R$RXt enable_pylab(RR^t import_alltwelcome_message((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyRf¹sN( RQR\RR]R)R7RbReR0Rf(((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyRX¡s    (t__doc__t contextlibRRBR9tIPython.core.interactiveshellRtipykernel.jsonutilRt traitletsRRRRRRtipykernel.ipkernelR tipykernel.zmqshellR t constantsR tsocketR tiostreamR RRRRXtregister(((s;lib/python2.7/site-packages/ipykernel/inprocess/ipkernel.pyts  .‰