iiSrSSKJr SSKrSSKrSSKrSSKrSSKJr SSKJ r SSKJ r SSK J r SS K J r SS K Jr SS K Jr SS KJr SS KJr "SS\ R(5r"SS5r\rSSjrSSjrSSjrg)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)XSpecc^\rSrSr%SrS\S'SU4Sjjr\SSj5rSSjr SSjr SSS jjr SSS jjr SS jr SS jrSS jrSSSjjrSrU=r$)Gatewayz0Gateway to a local or remote Python Interpreter.r _groupcb>[TU]XRSS9 X lUR 5 g)z :private:r)ioid _startcountN)super__init__rspec _initreceive)selfrr __class__s N/var/www/html/ai-image-ml/venv/lib/python3.13/site-packages/execnet/gateway.pyrGateway.__init__s* B77:  c.URR$N)_io remoteaddressrs rr"Gateway.remoteaddress#sxx%%%rc RUR5=(a S=(d Sn[[URR 555nSUR RSUR<SUSURRS US 3 $![ a SnSnNUf=f) z.A string representing gateway type and status.z receive-livez not-receiving uninitializedno) hasreceiverstrlen_channelfactorychannelsAttributeErrorr__name__r execmodelbackend)rris r__repr__Gateway.__repr__(s &&(;^OAC,,55789A4>>**+4{!A3bAWAW@XX`ab`cctuu AA sABB&%B&cURS5 XR;aURS5 gURRU5 URS5 UR[R 5 URS5 UR R5 g![[[4a/nURS5 URSU-5 SnAgSnAff=f)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 rexit Gateway.exit2s +, {{ " KKA B  % 0 KK7 8 JJw00 1 KK, - HH "Hg. 0 KKG H KK(3. / / 0sAB++C/%C**C/cX4Ul[R"UR5nUR[R US9 g)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_internalr;r RECONFIGURE)rpy2str_as_py3strpy3str_as_py2strrEs r reconfigureGateway.reconfigureFs8,>**4??; 7&&T 2rcU(d[US5(dPUR[5n[UR 55UlUR 5 UR $UR $!UR 5 f=f)z,Return some sys/env information from remote. _cache_rinfo)hasattr remote_exec rinfo_sourceRInforeceiverN waitclose)rupdatechs r_rinfoGateway._rinfoRsf ~66!!,/B $)"**,$7!    t    s A55Bc<URR5S:$)z(Whether gateway is able to receive data.r) _receivepool active_countr#s rr+Gateway.hasreceiver\s  --/!33rcUR5nUR[RUR5 UR 5nUR RUR5 [U5$)z5Obtain information about the remote execution status.) newchannelr;r STATUSrrSr. _local_close RemoteStatus)rchannel statusdicts r remote_statusGateway.remote_status`sU//# 7>>7::.__&  ))'**5J''rc ~SnSn[U[R5(aC[R"U5n[ R "U5 [R"U5nOl[U[R5(a.URn[R"U5n[U5nO[R"[U55nU(dU(a [S5eUR5nUR!["R$UR&[(R*"XX2455 U$)aOReturn 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 FunctionTyper1_source_of_functiontextwrapdedentr, TypeErrorr^r;r CHANNEL_EXECrrrG)rsourcekwargs call_name file_namerbs rrPGateway.remote_execjs(  fe.. / /--f5I  ! !) ,&&v.F  2 2 3 3I--f5I(0F__S[1FVKL L//#  JJ  ' 'I(N O rc[S5 g)z1DEPRECATED. Is currently a NO-OPERATION already.z?WARNING: remote_init_threads() is a no-operation in execnet-1.2N)print)rnums rremote_init_threadsGateway.remote_init_threadss  OPr)rNrFr)rr rr returnNonerr,rr)TF)rIboolrJrrr)F)rUrrrR)rr)rra)ruzCstr | types.FunctionType | Callable[..., object] | types.ModuleTypervobjectrr r )r|z int | Nonerr)r1 __module__ __qualname____firstlineno____doc____annotations__rpropertyr"r6rBrKrWr+rdrPr}__static_attributes__ __classcell__)rs@rrrs: M &&v0*GL 3 $ 3?C 3  3!4(*S**  *XQQrrcF\rSrSrSSjrSSjr\(aS SjrSrgSrg) rRc:URRU5 gr )__dict__rU)rrvs rrRInfo.__init__s V$rc~SRS[URR5555nSU-$)Nr*c34# UHupUSU3v M g7f)=N).0kvs r !RInfo.__repr__..sN0MA3as0Msz )joinsortedritems)rinfos rr6RInfo.__repr__s3yyNt}}7J7J7L0MNNd""rcgr r)rnames r __getattr__RInfo.__getattr__srrNrr)rr,rr) r1rrrrr6rrrrrrrRrRs%#4rrRc SSKnSSKnUR[URUR SSUR UR5UR5S95 g)Nr) executable version_infoplatformcwdpid) ossyssenddictrrrgetcwdgetpid)rbrrs rrQrQsL  LL ~~))"1-\\   rcdSSKnSSKn[RUR5nUR UR U55Vs/sHYn[XRR5(dMURU;dM1URUR;dMMURPM[ sn$s snf)Nr) astbuiltinsrfromkeys co_varnameswalkparsergNamerr)rucodeobjrrvarsnodes r_find_non_builtin_globalsrs ==,, -DHHSYYv./ /D dHH %  GG4   GG8,, , /  s B-,B->B-B-cVURS:Xa [S5e[R"U5nURnU(a USS:wa [S5eURnURnUb [S5e[R"U5n[R"U5n[XT5nU(a [SU5eS URS - -nX-$![ a [R "U5SnNf=f![an[SU-5UeSnAff=f) Nzz can't evaluate lambda functions'rrbz0expected 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)r1r>rjgetfullargspecargsr0 getargspec __closure____code__rnr@rqrrrco_firstlineno) functionsigrclosurerrue used_globals leading_wss rrprps)J&;<<$$X.xx 47i'KLL""GGBCCL""8,__V $F,V=LI<XX//!34J  3 /!!(+A./ L88CD!KLs)C!D !#DD D(D##D(r)rur,rztypes.CodeTyperz list[str])rz*types.FunctionType | Callable[..., object]rr,)r __future__rrjrlrqrhtypingrrrrr r r multir xspecr BaseGatewayrrRrarQrrprrrrsm # !!@Ql&&@QF 5 5    r