Je ,dZddlmZddlZddlZddlZddlZddlmZm Z m Z m Z ddl Z ddl mZddlmZmZddlmZej*eZe j0ej2j4d<Gd d ee Zy) zk In addition to the remote_call mechanism implemented in CommBase: - Send a message to a debugging kernel )contextmanagerN) QEventLoopQObjectQTimerSignal)tunnel)CommBase CommError)openssh_tunnelcommceZdZdZeZeZeeZfdZ dZ dZ dZ dZ eddZdfd Zdd Zdd Zd Z dfd Zfd ZfdZdZdZfdZdZxZS) KernelCommzf Class with the necessary attributes and methods to handle communications with a console. ctt| d|_d|_|j d|j |j d|jy)N _async_error_set_comm_port)superr__init__remote_comm_port kernel_clientregister_call_handlerrr)self __class__s P/usr/lib/python3/dist-packages/spyder/plugins/ipythonconsole/comms/kernelcomm.pyrzKernelComm.__init__(sO j$(* $! "">43D3DE ""#3T5H5HIcptjdk(rtj|i|St dg|i|S)Nnt)osname zmqtunnelparamiko_tunnelr )rargskwargss r ssh_tunnelzKernelComm.ssh_tunnel1s8 77d?,,d=f= =!$888 8rc *|||jk(ry||_|j}t|drP|j\}}}t j dd}|}|j }|j||||||d|}t|dr|j|k(sw||_|jj} |jd| } |j| |j|j|_|jj!yy) zSet comm port.Nssh_parametersr )timeout comm_portr )identity)rrhasattrr%rselect_random_portsipr#r)sessionbsession_create_connected_socketshell_channel_classioloop comm_channel_sig_comm_port_changedemit) rportclienthostnamesshkeypassword local_port remote_port remote_ipr*sockets rrzKernelComm._set_comm_port7s <44#8#88  $## 6+ ,)/)>)> &Hfh"66q9! S! "/3D   +  G sA== B  B c2|jjduS)z'Check if the comm channel is connected.N)rr3)rs rcomm_channel_connectedz!KernelComm.comm_channel_connectedes!!..d::rc#2K|rdy|js)|jjtd|j |}|D]-}|j j |j|d_/ d|j |}|D]-}|j j|j|d_/y#|j |}|D]-}|j j|j|d_/wxYww)z*Use comm_channel instead of shell_channel.NzComm not connected.r ) rJ remote_call_send_comm_configr rCrr3_comms _send_channel shell_channel)rrA queue_messagerGs rcomm_channel_managerzKernelComm.comm_channel_manageris   **,     0 0 212 2''0 1G""// KK  ( 6 1 6 ++G4G" 6&&44 G$V,: 6++G4G" 6&&44 G$V,: 6s BDC ADADDc|j }|j|j|5tt||||dddy#1swYyxYw)z1Override to use the comm_channel for all replies.N)rJrRcalling_comm_idrr_set_call_return_value)r call_dictdatais_errorrQrs rrUz!KernelComm._set_call_return_valuesW!7799  & &t';';] K + *d :4 + + + +s AAcN|j|}|D]}|j|=y)zu Remove the comm without notifying the other side. Use when the other side is already down. N)rCrN)rrArGs rremovezKernelComm.removes/ ''0 %G G$ %rc|r|j|j|}|D]'}|j|djdiddd)y)z/Ask kernel to close comm and send confirmation.r comm_closeN)rHrCrN _send_msg)rrAshutdown_channelrGs rclosezKernelComm.closesW   & & (''0 4G KK  ( 2 2b$d 4 4rc6||_d|j_ |j|jj |j dt jiy#t$r.tjdt|jzYywxYw)z$Open comm through the kernel client.Npickle_protocol)rWzOUnable to open comm due to unexistent comm manager: kernel_client.comm_manager=) rr3_register_comm comm_managernew_comm _comm_namepickleHIGHEST_PROTOCOLrBloggerinfostr)rrs r open_commzKernelComm.open_comms**.'    **33DOO%v'>'>K@3A B  KK.03M4N4N0OP  sAA!!4BBc6tt| ||||||S)zGet a handler for remote calls.) interruptblockingcallbackrAr( display_error)rrrL)rrmrnrorAr(rprs rrLzKernelComm.remote_calls.Z2(XWM3K KrcZd|vr|j|dtt||S)zA call was receivedr))rrron_incoming_call)rrVrs rrrzKernelComm.on_incoming_calls0 ) #    + 6 7Z7 BBrc|d}d|vxr|d}|jjs-|r tdtj dt |y|d}d|vxr|d}|xs|}|r^|j sN|jjd}tjdt |z|r td  |j|| 5tt|;|||cdddS#1swYyxYw#t$r6}|rtj d t |t |Yd}~yd}~wwxYw) z0 Interupt the kernel if needed. settingsrnKernel is deadz+Dropping message because kernel is dead: %sNrmFz1Dropping interrupt because comm is disconnected: z#Cannot block on a disconnected comm)rQz'Dropping message because of exception: )ris_alive RuntimeErrorrhrirjrJrLrMdebugr rRrr_get_call_return_value) rrV call_datarArtrnrmers rryz!KernelComm._get_call_return_valuesbZ()Bhz.B!!**,"#344 A NZ(8+E0E ) T88:     0 0 2I LLCI  EFF **y=+: 3ZEy'3 3 3 3  =F N  s6D$D9 DD D D E,E  Ecfd}djj}j|j||y)zWait for the other side reply.c jvSN) _reply_inbox)call_idrsr got_replyz)KernelComm._wait_reply..got_replysd/// /rzTimeout while waiting for {}N)format_reply_waitlist_wait_sig_got_reply)rr call_namer(r timeout_msgs`` r _wait_replyzKernelComm._wait_replys; 05;;  "  9d11;Hrc|ry|jjs tdtd}t |}|j d|j j|j|jjjj|j|j|j|j|dz|s|js|j|j|jjjj|j|ry|jjs tdt||j|s|j!|j|j|jjjj|jy)z Wait until condition() is True by running an event loop. signal: qt signal that should interrupt the event loop. timeout_msg: Message to display in case of a timeout. timeout: time in seconds before a timeout NruTi)rrvrwrr setSingleShotr(connectquit hb_channel kernel_diedstartisActive disconnect TimeoutErrorexec_stop)r conditionsignalrr( wait_loop wait_timeouts rrzKernelComm._waits ; !!**,/0 0t$ d| ""4( $$Y^^4 %%1199)..Iy~~& 7T>*+((*!!)..1""--99DDNN$;))224&'788";// OO + )..) %%11<< NN rcbtt| |||jj y)z3 A blocking call received a reply. N)rr_handle_remote_call_replyrr5)rmsg_dictbufferrs rrz$KernelComm._handle_remote_call_reply#s+ j$9 f    "rcz|jD](}|jjt|d*y)zR Handle an error that was raised on the other side and sent back. T)text is_tracebackN) format_errorsig_exception_occurredr5dict)r error_wrapperlines rrzKernelComm._async_error+s:"..0 D  ' ' , ,$T2  r)Fr~)NT)FFNNNF)__name__ __module__ __qualname____doc__rrr4rrrr#rrHrJrrRrUrZr_rkrLrrryrrrr __classcell__)rs@rrrs XN#X#D\J9 /:3";660+% 4 EI>CKC 0dI)V#rr)r contextlibrloggingrrfjupyter_client qtpy.QtCorerrrrzmqzmq.sshrrspyder_kernels.comms.commbaser r 'spyder.plugins.ipythonconsole.utils.sshr getLoggerrrhDEALERrchannel_socket_typesrrrrsk& ;; '=B   8 $7:jj++F3T7Tr