a &jg@sdZddlmZddlZddlZddlZddlZddlmZddlm Z ddlm Z ddl m Z dd l m Z dd l mZdd l mZdd lmZdd lmZGddde jZGdddZeZddddZddddddZdddddZdS) zhGateway code for initiating popen, socket and ssh connections. (c) 2004-2013, Holger Krekel and others ) annotationsN) TYPE_CHECKING)Any)Callable) gateway_base)IO)Channel)Message)Group)XSpeccseZdZUdZded<ddddfdd Zed d d d Zd d ddZdd ddZ d,ddddddZ d-dddddZ dd ddZ dd dd Z d!d"d#d$d%d&Zd.d(dd)d*d+ZZS)/Gatewayz0Gateway to a local or remote Python Interpreter.r _grouprr None)iospecreturncs&tj||jdd||_|dS)z :private:r)ridZ _startcountN)super__init__rrZ _initreceive)selfrr __class__5E:\soccer\ml_env\Lib\site-packages\execnet/gateway.pyrszGateway.__init__strrcCs|jjSN)_io remoteaddressrrrrr#szGateway.remoteaddressc Cspz&|rdpd}tt|j}Wnty@d}d}Yn0d|jjd|jd|d|j j d |d S) z.A string representing gateway type and status.z receive-livez not-receivingZ uninitializedno) hasreceiverrlen_channelfactoryZchannelsAttributeErrorr__name__rZ execmodelbackend)rrirrr__repr__(s  zGateway.__repr__c Cs|d||jvr"|ddS|j|z.|d|tj|d|jWnBtt t fy}z$|d|d|WYd}~n d}~00dS)zTrigger 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_writez-io-error: could not send termination sequencez exception: %r) Z_tracerZ _unregister_sendr ZGATEWAY_TERMINATErZ close_write ValueErrorEOFErrorOSError)rexcrrrexit2s        z Gateway.exitTFbool)py2str_as_py3strpy3str_as_py2strrcCs*||f|_t|j}|jtj|ddS)zSet 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 _strconfigrdumps_internalr.r Z RECONFIGURE)rr5r6r7rrr reconfigureFs  zGateway.reconfigureRInfo)updatercCsD|st|ds>|t}zt||_W|n |0|jS)z,Return some sys/env information from remote. _cache_rinfo)hasattr remote_exec rinfo_sourcer:receiver<Z waitclose)rr;chrrr_rinfoRs  zGateway._rinfocCs|jdkS)z(Whether gateway is able to receive data.r)Z _receivepool active_countr rrrr%\szGateway.hasreceiver RemoteStatuscCs6|}|tj|j|}|j|jt|S)z5Obtain information about the remote execution status.) newchannelr.r ZSTATUSrr@r'Z _local_closerD)rchannelZ statusdictrrr remote_status`s zGateway.remote_statuszCstr | types.FunctionType | Callable[..., object] | types.ModuleTypeobjectr )sourcekwargsrc Ksd}d}t|tjr4t|}t|t|}n4t|tjrZ|j }t|}t |}nt t |}|sx|rxtd|}|tj|jt||||f|S)aReturn 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) isinstancetypes ModuleTypeinspect getsourcefile linecache updatecache getsource FunctionTyper)_source_of_functiontextwrapdedentr TypeErrorrEr.r Z CHANNEL_EXECrrr8)rrIrJZ call_name file_namerFrrrr>js(       zGateway.remote_execNz int | None)numrcCs tddS)z1DEPRECATED. Is currently a NO-OPERATION already.z?WARNING: remote_init_threads() is a no-operation in execnet-1.2N)print)rrYrrrremote_init_threadsszGateway.remote_init_threads)TF)F)N)r) __module__ __qualname____doc____annotations__rpropertyrr-r3r9rBr%rGr>r[ __classcell__rrrrr s     ,r c@s<eZdZddddZddddZer8ddd d d Zd S) r:rrcCs|j|dSr)__dict__r;)rrJrrrrszRInfo.__init__rcCs&dddt|jD}d|S)Nr$css |]\}}|d|VqdS)=Nr).0kvrrr z!RInfo.__repr__..z )joinsortedrbitems)rinforrrr-szRInfo.__repr__r)namercCsdSrr)rrmrrr __getattr__rhzRInfo.__getattr__N)r)r\r]rr-rrnrrrrr:sr:rrc CsBddl}ddl}|t|j|jdd|j||ddS)Nr) executable version_infoplatformcwdpid) ossyssenddictrprqrrgetcwdgetpid)rFrurvrrrr?s r?rztypes.CodeTypez list[str])rIcodeobjrcs>ddlddlt|jfdd|DS)Nrcs4g|],}t|jr|jvr|jjvr|jqSr)rKNamerrb)rdnodeastbuiltinsvarsrr s    z-_find_non_builtin_globals..)rrrxfromkeys co_varnameswalkparse)rIr{rr~r_find_non_builtin_globalss  rz*types.FunctionType | Callable[..., object])functionrc Cs|jdkrtdzt|}Wn ty@t|d}Yn0|j}|rX|ddkr`td|j}|j}|dur|tdzt |}Wn2t y}ztd||WYd}~n d}~00t |}t ||}|rtd|d |jd }||S) Nzz can't evaluate lambda functions'rrFz0expected 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)r)r/rNgetfullargspecr( getargspecargs __closure____code__rRr1rUrVrco_firstlineno) rsigrclosurer{rIeZ used_globalsZ leading_wsrrrrTs.  $   rT)r^ __future__rrNrPrUrLtypingrrrrrr r multir Zxspecr Z BaseGatewayr r:rDr?rrTrrrrs*