B pjÆ`½ã@sªdZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ej   ej   ej ¡¡ZGdd„de jƒZGdd „d ƒZeZd d „Zd d „Zdd„ZdS)zh gateway code for initiating popen, socket and ssh connections. (c) 2004-2013, Holger Krekel and others éNé)Ú gateway_base)ÚMessagecsreZdZdZ‡fdd„Zedd„ƒZdd„Zdd „Zdd d „Z ddd„Z dd„Z dd„Z dd„Z ddd„Z‡ZS)ÚGatewayz/Gateway to a local or remote Python Intepreter.cs*tt|ƒj||jdd||_| ¡dS)Nr)ÚioÚidZ _startcount)ÚsuperrÚ__init__rÚspecZ _initreceive)Úselfrr )Ú __class__©ú.lib/python3.7/site-packages/execnet/gateway.pyr szGateway.__init__cCs|jjS)N)Ú_ioÚ remoteaddress)r r r rrszGateway.remoteaddresscCs\y"| ¡rdpd}t|j ¡ƒ}Wntk r>d}d}YnXd |jj|j||j j |¡S)z3return string representing gateway type and status.z receive-livez not-receivingZ uninitializedÚnoz-<{} id={!r} {}, {} model, {} active channels>) Ú hasreceiverÚlenÚ_channelfactoryZchannelsÚAttributeErrorÚformatr Ú__name__rZ execmodelZbackend)r ÚrÚir r rÚ__repr__!s zGateway.__repr__c Cs | d¡||jkr"| d¡dS|j |¡y.| d¡| tj¡| d¡|j ¡Wn>tt t fk ršt   ¡d}| d¡| d|¡YnXdS) z›trigger gateway exit. Defer waiting for finishing of receiver-thread and subprocess activity to when group.terminate() is called. zgateway.exit() calledz'gateway already unregistered with groupNz--> sending GATEWAY_TERMINATEz--> io.close_writerz-io-error: could not send termination sequencez exception: %r) Z_traceÚ_groupZ _unregisterÚ_sendrZGATEWAY_TERMINATErZ close_writeÚ ValueErrorÚEOFErrorÚIOErrorÚsysÚexc_info)r Úvr r rÚexit-s         z Gateway.exitTFcCs*||f|_t |j¡}|jtj|ddS)z­ set the string coercion for this gateway the default is to try to convert py2 str as py3 str, but not to try and convert py3 str to py2 str )ÚdataN)Z _strconfigrÚdumps_internalrrZ RECONFIGURE)r Zpy2str_as_py3strZpy3str_as_py2strr$r r rÚ reconfigureAs  zGateway.reconfigurecCs<|st|dƒs6| t¡}zt| ¡ƒ|_Wd| ¡X|jS)z,return some sys/env information from remote.Ú _cache_rinfoN)ÚhasattrÚ remote_execÚ rinfo_sourceÚRInfoÚreceiver'Z waitclose)r ÚupdateZchr r rÚ_rinfoKs   zGateway._rinfocCs|j ¡dkS)z/return True if gateway is able to receive data.r)Z _receivepoolZ active_count)r r r rrUszGateway.hasreceivercCs6| ¡}| tj|j¡| ¡}|j |j¡t|ƒS)z8return information object about remote execution status.) Ú newchannelrrZSTATUSrr,rZ _local_closeÚ RemoteStatus)r ÚchannelZ statusdictr r rÚ remote_statusYs zGateway.remote_statusc Ks¤d}d}t|tjƒr4t |¡}t |¡t |¡}n4t|tjƒrZ|j }t |¡}t |ƒ}nt   t |ƒ¡}|sx|rxtdƒ‚| ¡}| tj|jt ||||f¡¡|S)a®return channel object and connect it to a remote execution thread where the given ``source`` executes. * ``source`` is a string: execute source string remotely with a ``channel`` put into the global namespace. * ``source`` is a pure function: serialize source and call function with ``**kwargs``, adding a ``channel`` object to the keyword arguments. * ``source`` is a pure module: execute source of module with a ``channel`` in its global namespace In all cases the binding ``__name__='__channelexec__'`` will be available in the global namespace of the remotely executing code. Nz-can't pass kwargs to non-function remote_exec)Ú isinstanceÚtypesÚ ModuleTypeÚinspectZ getsourcefileÚ linecacheÚ updatecacheÚ getsourceÚ FunctionTyperÚ_source_of_functionÚtextwrapÚdedentÚstrÚ TypeErrorr/rrZ CHANNEL_EXECrrr%)r ÚsourceÚkwargsZ call_nameÚ file_namer1r r rr)cs&       zGateway.remote_execNcCs tdƒdS)z1DEPRECATED. Is currently a NO-OPERATION already.z?WARNING: remote_init_threads() is a no-operation in execnet-1.2N)Úprint)r Znumr r rÚremote_init_threads‹szGateway.remote_init_threads)TF)F)N)rÚ __module__Ú __qualname__Ú__doc__r Úpropertyrrr#r&r.rr2r)rDÚ __classcell__r r )r rrs     (rc@seZdZdd„Zdd„ZdS)r+cCs|j |¡dS)N)Ú__dict__r-)r rAr r rr ‘szRInfo.__init__cCs&d dd„t|j ¡ƒDƒ¡}d|S)Nz, css|]}d|VqdS)z%s=%sNr )Ú.0Úitemr r rú •sz!RInfo.__repr__..z )ÚjoinÚsortedrJÚitems)r Úinfor r rr”szRInfo.__repr__N)rrErFr rr r r rr+sr+c CsBddl}ddl}| t|j|jdd…|j| ¡| ¡d¡dS)Nré)Ú executableÚ version_infoÚplatformÚcwdÚpid) r ÚosÚsendÚdictrSrTrUÚgetcwdÚgetpid)r1r rXr r rr*œs r*cs`ddl‰y ddl‰Wntk r0ddl‰YnXt |j¡‰‡‡‡fdd„ˆ ˆ |¡¡DƒS)Nrcs4g|],}t|ˆjƒr|jˆkr|jˆjkr|j‘qSr )r3ÚNamerrJ)rKZnode)Ú __builtin__ÚastÚvarsr rú µs  z-_find_non_builtin_globals..) r_r^Ú ImportErrorÚbuiltinsrZÚfromkeysÚ co_varnamesÚwalkÚparse)r@Úcodeobjr )r^r_r`rÚ_find_non_builtin_globals«s  ricCsú|jdkrtdƒ‚yt |¡}Wn"tk rBt |¡d}YnX|j}|rZ|ddkrbtdƒ‚tjrv|j }|j }n |j }|j }|dk r’tdƒ‚yt  |¡}Wn tk rÀtd|ƒ‚YnXt |¡}t||ƒ}|rätd|ƒ‚d |jd }||S) Nzz can't evaluate lambda functions'rr1z0expected first function argument to be `channel`z'functions with closures can't be passedzcan't find source file for %sz.the use of non-builtin globals isn't supportedÚ r)rrr6ZgetfullargspecrZ getargspecÚargsrZISPY3Ú __closure__Ú__code__Z func_closureZ func_coder9rr<r=riÚco_firstlineno)ZfunctionZsigrkZclosurerhr@Z used_globalsZ leading_wsr r rr;½s4    r;)rGr6r7rXr r<r4ZexecnetÚrrÚpathÚdirnameÚ__file__Z importdirZ BaseGatewayrr+r0r*rir;r r r rÚs   {