iidZddlmZddlZddlZddlZddlZddlmZddlm Z ddlm Z ddl m Z dd l m Z dd l mZdd l mZdd lmZdd lmZGdde jZGddZeZddZddZd dZdS)!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)XSpecceZdZUdZded<d%fd Zed&d Zd&d Zd'dZ d(d)dZ d*d+dZ d,dZ d-dZ d.d Zd/d0d$ZxZS)1Gatewayz0Gateway to a local or remote Python Interpreter.r _groupior specr returnNonect||jd||_|dS)z :private:r)rid _startcountN)super__init__rr _initreceive)selfrr __class__s V/home/ubuntu/.hermes/hermes-agent/venv/lib/python3.11/site-packages/execnet/gateway.pyrzGateway.__init__sC B47:::  strc|jjSN)_io remoteaddressrs rr#zGateway.remoteaddress#sx%%rc  |rdpd}tt|j}n#t $rd}d}YnwxYwd|jjd|jd|d|j j d |d S) z.A string representing gateway type and status.z receive-livez not-receiving uninitializedno) hasreceiverrlen_channelfactorychannelsAttributeErrorr__name__r execmodelbackend)rris r__repr__zGateway.__repr__(s &&((;^OAC,55778899AA   AAAA v4>*uuuuAuuAWuuabuuuusA AAAc|d||jvr|ddS|j| |d|tj|d|jdS#tttf$r8}|d|d|zYd}~dSd}~wwxYw)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) _tracer _unregister_sendr GATEWAY_TERMINATEr" close_write ValueErrorEOFErrorOSError)rexcs rexitz Gateway.exit2s +,,, t{ " " KKA B B B F %%% 0 KK7 8 8 8 JJw0 1 1 1 KK, - - - H " " " " "Hg. 0 0 0 KKG H H H KK(3. / / / / / / / / / 0sA"B55D -C??DTFpy2str_as_py3strboolpy3str_as_py2strc||f|_tj|j}|tj|dS)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) _strconfigrdumps_internalr9r RECONFIGURE)rrArCrEs r reconfigurezGateway.reconfigureFsB,-=>*4?;; 7&T 22222rupdateRInfoc|st|dso|t} t||_|n#|wxYw|jS)z,Return some sys/env information from remote. _cache_rinfo)hasattr remote_exec rinfo_sourcerKreceiverM waitclose)rrJchs r_rinfozGateway._rinfoRsu  ~66 !!,//B $)"**,,$7$7!    s &A))A?c<|jdkS)z(Whether gateway is able to receive data.r) _receivepool active_countr$s rr+zGateway.hasreceiver\s --//!33r RemoteStatusc|}|tj|j|}|j|jt|S)z5Obtain information about the remote execution status.) newchannelr9r STATUSrrQr- _local_closerX)rchannel statusdicts r remote_statuszGateway.remote_status`sa//## 7>7:...__&&  ))'*555J'''rsourceCstr | types.FunctionType | Callable[..., object] | types.ModuleTypekwargsobjectr c Nd}d}t|tjr=tj|}t j|tj|}nft|tjr+|j }tj|}t|}n!tj t|}|s|rtd|}|t"j|jt)j||||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 FunctionTyper0_source_of_functiontextwrapdedentr TypeErrorrZr9r CHANNEL_EXECrrrG)rr`rb call_name file_namer]s rrOzGateway.remote_execjs(  fe. / / 2-f55I  !) , , ,&v..FF  2 3 3 2I-f55I(00FF_S[[11F MV MKLL L//##  J  'Iv(N O O   rNnum int | Nonec$tddS)z1DEPRECATED. Is currently a NO-OPERATION already.z?WARNING: remote_init_threads() is a no-operation in execnet-1.2N)print)rrus rremote_init_threadszGateway.remote_init_threadss OPPPPPr)rr rr rrrrrr)TF)rArBrCrBrr)F)rJrBrrK)rrB)rrX)r`rarbrcrr r!)rurvrr)r0 __module__ __qualname____doc____annotations__rpropertyr#r5r@rIrTr+r_rOry __classcell__)rs@rrrs2::MMM &&&X&vvvv0000*GL 3 3 3 3 3!!!!!4444((((****XQQQQQQQQQrrc.eZdZd dZd dZerd dZd Sd S) rKrrc:|j|dSr!)__dict__rJ)rrbs rrzRInfo.__init__s V$$$$$rrcddt|jD}d|zS)Nr*c3*K|]\}}|d|VdS)=N).0kvs r z!RInfo.__repr__..s0NN1ANNNNNNrz )joinsortedritems)rinfos rr5zRInfo.__repr__sCyyNNt}7J7J7L7L0M0MNNNNNd""rnamercdSr!r)rrs r __getattr__zRInfo.__getattr__srNr{rz)rrrr)r0r|r}rr5rrrrrrKrKsX%%%%####544444455rrKrrc ddl}ddl}|t|j|jdd|j||dS)Nr) executable version_infoplatformcwdpid) ossyssenddictrrrgetcwdgetpid)r]rrs rrPrPsu IIIJJJ LL ~)"1"-\     rr`rcodeobjtypes.CodeType list[str]cddlddlt|jfd|DS)Nrcvg|]5}t|jr|jvr|jjv.|j6Sr)reNamerr)rnodeastbuiltinsvarss r z-_find_non_builtin_globals..sZ     dCH % %  G4   G8, , ,  - , ,r)rrrfromkeys co_varnameswalkparse)r`rrrrs @@@r_find_non_builtin_globalsrsxJJJOOO ==, - -D      HHSYYv..//   rfunction*types.FunctionType | Callable[..., object]cB|jdkrtd tj|}|j}n*#t $rtj|d}YnwxYw|r |ddkrtd|j}|j}|td tj |}n%#t$r}td|z|d}~wwxYwtj |}t||}|rtd|d |jd z z}||zS) Nzz can't evaluate lambda functions'rr]z0expected 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)r0r<rhgetfullargspecargsr/ getargspec __closure____code__rlr>rorprco_firstlineno) rsigrclosurerr`e used_globals leading_wss rrnrnsjJ&&;<<<$X..x ///!(++A./ M47i''KLLL"GGBCCCL"8,, LLL88CDD!KL_V $ $F,VW==LYI<XXX/!34J  s'8$AAB44 C>CCr{)r`rrrrr)rrrr)r~ __future__rrhrjrorftypingrrrrr r r multir xspecr BaseGatewayrrKrXrPrrnrrrrs #""""" !!!!!!!!!!!!@Q@Q@Q@Q@Ql&@Q@Q@QF 5 5 5 5 5 5 5 5               r