ó ‹²,]c@sdddlZddlZddljZddlZddlZddlmZm Z m Z m Z m Z m Z ddlmZddlZddlmZmZdZdZdefd„ƒYZd efd „ƒYZed kr`eejƒZed ƒZejƒd „Zd„Zd„Zej j!eƒej"j!eƒej#j!eƒej$ƒndS(iÿÿÿÿN(tQObjecttQProcesstQProcessEnvironmenttQSocketNotifiertQTimertSignal(t QApplication(t debug_printtget_module_pathiès 127.0.0.1t AsyncClientcBs†eZdZeƒZeƒZeeƒZd d d d d d d„Z d„Z d„Z d„Z d„Z d„Zd„Zd„ZRS( sL A class which handles a connection to a client through a QProcess. cCsÖtt|ƒjƒ|ptj|_||_||_|p@||_||_||_ ||_ t |_ t |_ d|_d|_tjƒ|_tjƒjj|jƒt|ƒ|_|jjj|jƒdS(N(tsuperR t__init__tsyst executablet extra_argsttargettnametlibstcwdtenvtFalsetis_initializedtclosingtNonetnotifiertprocesstzmqtContexttcontextRtinstancet aboutToQuittconnecttcloseRttimerttimeoutt _heartbeat(tselfRR RRRRR((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR ,s          c Cs`|jjtjƒ|_|jjdtƒ|_t|ƒ|_|j r_|jj |j ƒnd|j t |jƒg}|j d k r™||j 7}ntƒ}|jjƒ}|jrÉd|jksØ|jd kratjtdƒƒ}x]|jD]R}y8tjtj|ƒdƒ}tjj||gƒ}Wq÷tk rHq÷Xq÷W|jd|ƒn|jr}|j|jƒnx6|D].}|jdƒ\}} } |j|| ƒq„W|jj|ƒ|jj |j!|ƒ|jj"j#|j$ƒ|jj%ƒ} | st&d|ƒd S|jj'tj(ƒ} t)| t)j*|ƒ|_+|j+j,j#|j-ƒd S( s/Handle the connection with the server. stcp://%ss-ut PYTHONPATHtspyderis PYTHONPATH=%st=sCould not start %sN(.RtsocketRtPAIRtbind_to_random_portt LOCALHOSTtportRRRtsetWorkingDirectoryRtstrRRRtsystemEnvironmentRtosptdirnameRRtimpt find_moduletpathseptjoint ImportErrortappendtupdatet partitiontinserttsetProcessEnvironmenttstartR tfinishedRt _on_finishedtwaitForStartedRt getsockopttFDRtReadRt activatedt_on_msg_received( R$tp_argstprocessEnvironmentRt python_pathtlibtpathtenvItemtenvNamet separatortenvValuetrunningtfid((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pytrunAsD  '   c OsN|js dStjƒj}td|d|d|d|ƒ}|j|ƒ|S(sùSend a request to the server. The response will be a dictionary the 'request_id' and the 'func_name' as well as a 'result' field with the object returned by the function call or or an 'error' field with a traceback. Nt func_nametargstkwargst request_id(Rtuuidtuuid4thextdictt_send(R$RQRRRSRTtrequest((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyRZts    cCs­t|_t|_|jjƒ|jdk r`|jjj |j ƒ|jj tƒd|_n|j dƒ|j dk rœ|j jdƒ|j jƒn|jjƒdS(s4Cleanly close the connection to the server. t server_quitièN(tTrueRRRR!tstopRRRCt disconnectRDt setEnabledRZRtwaitForFinishedR Rtdestroy(R$((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR …s     cCs»|jr dS|jrstd|jƒt|jjƒƒt|jjƒƒt|_|jj tƒ|j ƒnDtd|jƒt|jjƒƒt|jjƒƒ|j j ƒdS(s3Handle a finished signal from the process. Ns Restarting %ss Errored %s( RRRRRtreadAllStandardOutputtreadAllStandardErrorRRR_RPterroredtemit(R$((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR>˜s    cCsÂ|jjtƒx«y|jjdtjƒ}Wn%tjk rV|jjtƒdSX|j st|_ t d|j ƒ|j j ƒ|jjtƒqn|j |d<|jj |ƒqWdS(s2Handle a message trigger from the socket. tflagsNsInitialized %sR(RR_RR(t recv_pyobjRtNOBLOCKtZMQErrorR\RRRt initializedReR!R<t HEARTBEATtreceived(R$tresp((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyRDªs    cCs|jtddƒƒdS(s3Send a heartbeat to keep the server alive. RQtserver_heartbeatN(RYRX(R$((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR#½scCsQy|jj|tjƒWn0tk rL}t|ƒt|_|jƒnXdS(s&Send an object to the server. N( R(t send_pyobjRRht ExceptionRRRR>(R$tobjte((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyRYÂs   N(t__name__t __module__t__doc__RRjRdtobjectRlRR RPRZR R>RDR#RY(((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR s    3     t PluginClientcBseZdddd„ZRS(c CsYtjjtƒ}tt|ƒjdd|d|d|d|gd|gƒ||_dS(Nsplugin_server.pyR RRRR(tosRIR1t__file__R RwR R(R$t plugin_nameR Rt extra_pathR((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR Ïs N(RsRtRR (((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyRwÍst__main__tjedicCs3|GH|ddkr"tjƒn tjdƒdS(NRQtfoo(tapptquittpluginRZ(tvalue((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyt handle_returnÞs cCsdGHtjdƒdS(NRdi(R texit(((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pythandle_erroredåscCsdGHtjdƒdS(NR<tvalidate(RRZ(((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyR<és(%R2Rxtos.pathRIR0R RUt qtpy.QtCoreRRRRRRtqtpy.QtWidgetsRRtspyder.config.baseRRRkR+R RwRstargvRRRPRƒR…R<RdRRlRjtexec_(((sGlib/python2.7/site-packages/spyder/utils/introspection/plugin_client.pyts.    . °