iSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK Jr SSK Jr SSK Jr SS K Jr SS K Jr SS K Jr SS K Jr SS K Jr "SS\5r"SS\5r"SS\5r"SS\5r"SS\R4S9r"SS\5r"SS\5r"SS\5r"SS \5rScS!jr "S"S#5r!"S$S%5r"\#\$4r%\RLROS&5r(\RR"5r*\(S':XaSdS(jr+OQ\((aESSKrSSK,r,\RZR]\,R^"5S)\*-5r0\1"\0S*5r2SdS+jr+OS,=r3r+"S-S.5r4"S/S05r5"S1S2\65r7\Rp\%4SeS3jjr9"S4S5\65r:"S6S7\;5r<\="5r>"S8S95r?\="5r@S:rAS;rB"S<S=5rC"S>S?5rD"S@SA\D5rE"SBSC\D5rF"SDSE5rG"SFSG\G5rH"SHSI\65rI"SJSK\I5rJ"SLSM\I5rKSfSNjrL\L"SO5rMSPrNSQrO\R"\O5rQSRrR\R"\R5rS"SSST\65rT"SUSV5rU"SWSX5rVSgSYjrWShSZjrXSiSjS[jjrYSiSkS\jjrZSlSmS]jjr[SgS^jr\"S_S`5r]SnSajr^SoSbjr_g)pzBase execnet gateway code send to the other side for bootstrapping. :copyright: 2004-2015 :authors: - Holger Krekel - Armin Rigo - Benjamin Peterson - Ronny Pfannschmidt - many others ) annotationsN)interrupt_main)BytesIO)Any)Callable)Iterator)Literal) MutableSet)Protocol)cast)overloadc\rSrSrSSjrSrg)WriteIO cgNselfdatas S/var/www/html/ai-image-ml/venv/lib/python3.13/site-packages/execnet/gateway_base.pywrite WriteIO.write!SrNrbytesreturnNone)__name__ __module__ __qualname____firstlineno__r__static_attributes__rrrrr s0rrc\rSrSrSSjrSrg)ReadIO$cgrrrnumbytess rread ReadIO.read%srrNr*intrr)r r!r"r#r+r$rrrr&r&$s2rr&c\\rSrSr%S\S'S SjrS SjrSSjrSSjrSSjr SS jr S r g )IO( ExecModel execmodelcgrrr)s rr+IO.read+r-rcgrrrs rrIO.write-rrcgrrrs r close_read IO.close_read/#rcgrrr:s r close_writeIO.close_write1s3rcgrrr:s rwaitIO.wait3r=rcgrrr:s rkillIO.kill5sCrrNr.rrr)r int | None) r r!r"r#__annotations__r+rr;r?rBrEr$rrrr1r1(s20%&%rr1cD\rSrSrSrS SjrS SjrS SjrS S SjjrSr g) Event8z3Protocol for types which look like threading.Event.cgrrr:s ris_set Event.is_set;scrcgrrr:s rset Event.set=s3rcgrrr:s rclear Event.clear?sSrNcgrrrtimeouts rrB Event.waitAs#rrrboolrGrrX float | Nonerr[) r r!r"r#__doc__rNrQrTrBr$rrrrKrK8s=! ==rrKc\rSrSr\\R SSj55rSSjr\\R S55r \\R S55r \\R S55r \R SSSjj5r \R SS j5r \R SS j5r\R SS j5r\R S 5r\R S 5r\R SSj5rSrg)r3Dc[5erNotImplementedErrorr:s rbackendExecModel.backendE "##rc SUR-$)Nzrdr:s r__repr__ExecModel.__repr__Js$,,..rc[5errbr:s rqueueExecModel.queueMrfrc[5errbr:s r subprocessExecModel.subprocessRrfrc[5errbr:s rsocketExecModel.socketWrfrrc[5errb)rfuncargss rstartExecModel.start\ !##rc[5errbr:s r get_identExecModel.get_ident`ryrc[5errb)rdelays rsleepExecModel.sleepdryrc[5errb)rfdmodebufsizeclosefds rfdopenExecModel.fdopenhryrc[5errbr:s rLockExecModel.Locklryrc[5errbr:s rRLockExecModel.RLockpryrc[5errbr:s rrKExecModel.EventtryrNrstrrrGrr/r~floatrrT)rrK)r r!r"r#propertyabcabstractmethodrdrirlrorrrwr{rrrrrKr$rrrr3r3DsC $$/$$$$$$ $$ $$ $$ $$ $$ $$ $$rr3) metaclassc\rSrSrSr\S5r\S5r\S5rSSjr SSjr SSS jjr SS jr S r S rS rSrg)ThreadExecModelythreadcSSKnU$Nr)rl)rrls rrlThreadExecModel.queue|s  rcSSKnU$r)ro)rros rroThreadExecModel.subprocesss rcSSKnU$r)rr)rrrs rrrThreadExecModel.sockets  rc*SSKnUR5$r)_threadr{)rrs rr{ThreadExecModel.get_idents  ""rc.SSKnURU5 gr)timer)rr~rs rrThreadExecModel.sleeps 5rrc.SSKnURX5 gr)rstart_new_thread)rrurvrs rrwThreadExecModel.starts  ,rc0SSKnUR"XUSUS9$)Nrutf-8)encodingr)osr)rrrrrrs rrThreadExecModel.fdopensyy7WgNNrc*SSKnUR5$r threadingrrrs rrThreadExecModel.Lock  rc*SSKnUR5$rrrs rrThreadExecModel.RLockrrc*SSKnUR5$r)rrKrs rrKThreadExecModel.EventrrNrrrrGrr r!r"r#rdrrlrorrr{rrwrrrrKr$rrrrryseG    #  - O ! ! !rrc\rSrSrSrSrg)MainThreadOnlyExecModelmain_thread_onlyrN)r r!r"r#rdr$rrrrrs Grrc\rSrSrSr\S5r\S5r\S5rSSjr SSjr SSS jjr SS jr S r S rS rSrg)EventletExecModeleventletc"SSKnUR$r)rrlrrs rrlEventletExecModel.queues~~rc6SSKnURR$r)eventlet.green.subprocessgreenrors rroEventletExecModel.subprocesss(~~(((rc6SSKnURR$r)eventlet.green.socketrrrrs rrrEventletExecModel.sockets$~~$$$rcRSSKnURRR5$r)eventlet.green.threadrrr{rs rr{EventletExecModel.get_idents$~~$$..00rc.SSKnURU5 gr)rr)rr~rs rrEventletExecModel.sleepsurrc2SSKnUR"U/UQ76 gr)rspawn_n)rrurvrs rrwEventletExecModel.starts%%rcRSSKnURRRXX4S9$Nrr)eventlet.green.osrrr)rrrrrrs rrEventletExecModel.fdopens% ~~  ''''KKrcRSSKnURRR5$reventlet.green.threadingrrrrs rrEventletExecModel.Lock'~~''--//rcRSSKnURRR5$rrrs rrEventletExecModel.RLockrrcRSSKnURRR5$r)rrrrKrs rrKEventletExecModel.EventrrNrrrrGrrrrrrrseG  )) %% 1  & L 0 0 0rrc\rSrSrSr\S5r\S5r\S5rSSjr SSjr SSS jjr SS jr S r S rS rSrg)GeventExecModelgeventc"SSKnUR$r) gevent.queuerlrrs rrlGeventExecModel.queues||rc"SSKnUR$r)gevent.subprocessrors rroGeventExecModel.subprocesss    rc"SSKnUR$r)rrrrs rrrGeventExecModel.sockets}}rc>SSKnURR5$r) gevent.threadrr{rs rr{GeventExecModel.get_idents}}&&((rc.SSKnURU5 gr)rr)rr~rs rrGeventExecModel.sleep s Urrc2SSKnUR"U/UQ76 gr)rspawn)rrurvrs rrwGeventExecModel.starts T!D!rc>SSKnURRXX4S9$r)gevent.fileobject fileobjectFileObjectThread)rrrrrrs rrGeventExecModel.fdopens!   11"G1UUrc>SSKnURR5$r gevent.locklockrrs rrGeventExecModel.Lock{{  ""rc>SSKnURR5$rrrs rrGeventExecModel.RLockrrc>SSKnURR5$r) gevent.eventeventrKrs rrKGeventExecModel.Event#s||!!##rNrrrrGrrrrrrrseG  !!  )  " V # # $rrc[U[5(aU$US:Xa [5$US:Xa [5$US:Xa [ 5$US:Xa [ 5$[ SU<35e)Nrrrrzunknown execmodel ) isinstancer3rrrr ValueErrorrhs r get_execmodelr)sl'9%%(  & &&(( J  "" H   -g[9::rcH\rSrSrSrS SjrS S SjjrS S SjjrS SjrSr g)Replyi8zdProvide access to the result of a function execution that got dispatched through WorkerPool.spawn().cHXlUR5UlSUlgNT)taskrK _result_readyrunning)rr threadmodels r__init__Reply.__init__<s (..0 rNctURU5 UR$![a URSef=f)zget the result object from an asynchronous function execution. if the function execution raised an exception, then calling get() will reraise that exception including its traceback. N) waitfinish_resultAttributeError_excrWs rget Reply.getAs:   &<<  &)) % &s 7cvURRU5(d[SUR<35eg)Nztimeout waiting for )rrBOSErrorrrWs rrReply.waitfinishMs5!!&&w//0 >? ?0rcURupnU"U0UD6UlURR 5 SUlg![anX@lSnAN7SnAff=f!URR 5 SUlf=fNF)rr BaseExceptionr rrQr)rrurvkwargsexcs rrun Reply.runQs{!YYF ! #T4V4     " " $ DL !       " " $ DLs) A A AAAA#B)r rrrr)rr3rrr)rXr]rXr]rrrG) r r!r"r#r^rr!rr+r$rrrrr8s# &@ !rrc\rSrSr%SrS\S'SSSjjrSSjrSSjrSSjr SS jr SS jr SS jr SSS jjr SSSjjrSrg ) WorkerPooli]aA WorkerPool allows to spawn function executions to threads, returning a reply object on which you can ask for the result (and get exceptions reraised). This implementation allows the main thread to integrate itself into performing function execution through calling integrate_as_primary_thread() which will return when the pool received a trigger_shutdown(). By default allows unlimited number of spawns. z Reply | None_primary_thread_taskc.XlURR5Ul[5UlSUl/UlU(aEURRS;a [S5eURR5Ul gSUl g)NFrrz%hasprimary=True requires thread model) r4r _running_lockrQ_running _shuttingdown_waitall_eventsrdrrK_primary_thread_task_ready)rr4 hasprimarys rrWorkerPool.__init__lst"!^^002+.5 ",. ~~%%-KK !HII<@NNM!%%'***  s A9B!! B/c*URnUbUR5(dXlUR5 gURR S:Xa>URb1URR 5 XlUR5 gg)NTrF)r7rNr0rQr4rdr)rr=r<s r_try_send_to_primary_thread&WorkerPool._try_send_to_primary_threads%)$C$C! $ 0,3355,1))--/&&*<<--9))446,1) *--/rcl[XU4UR5nUR UR(a [ S5eUR R U5 URU5(d'URRURU45 SSS5 U$!,(df  U$=f)zAAsynchronously dispatch func(*args, **kwargs) and return a Reply.zpool is shutting downN) rr4r3r5rr4addrMrwr;)rrurvr)r=s rrWorkerPool.spawnst6*DNN;   !! !899 MM  e $33E::$$T%8%85(C      s A5B$$ B3Nc@UR5 URUS9$)z;Trigger shutdown and wait for completion of all executions.rX)rAwaitallrWs r terminateWorkerPool.terminates ||G|,,rc UR UR(d SSS5 gURR5nURR U5 SSS5 WR US9$!,(df  N=f)z5Wait until all active spawns have finished executing.NTrS)r3r4r4rKr6appendrB)rrXmy_waitall_events rrTWorkerPool.waitallsk   ==  $~~335   ' '(8 9  $$W$55 sA55A55 B)r0r7r4r3r5r6r4F)r4r3r8r[rrrGr)r=rrr)r=rrr[)rrrr\)r r!r"r#r^rIrr>rArEr;rMrrUrTr$rrrr/r/]sA '& 36.6"(2 - 6 6rr/ EXECNET_DEBUG2cSR[[U55n[RR S[ SUS35 [RR5 g![a gf=f)N [z]  ) joinmaprsysstderrrpidflush Exception)msglines rtracerks^ 88CSM*D JJ  qRvR0 1 JJ      sA'A** A76A7zexecnet-debug-%dwcJSR[[U55n[R US-5 [R 5 g![ aJn[RR S[SU<S35 SnAg![ a SnAgf=fSnAff=f)Nr_rar`z] exception during tracing: ) rbrcr debugfilerrgrhrdrerf)rirjr*s rrkrks 88CSM*D OOD4K ( OO      1SE)EcWB!OPP   s0A A B"+B  BBBBB"cgrr)ris rrps4rcP\rSrSr\\\4rS SjrS Sjr S Sjr S Sjr S Sjr Sr g) Popen2IOicXsUlUl[RS:XaaSSKnUR UR 5[R5 UR UR 5[R5 [USU5RUl [USU5RUlX0lg![[4a NQf=f)Nwin32rbuffer)outfileinfilerdplatformmsvcrtsetmodefilenorO_BINARYrr$getattrr+_readr_writer4)rrvrwr4rys rrPopen2IO.__init__s$+! dk <<7 "  v}} <w~~/=VXv6;; gx9?? " #G,  sACCCcSnU[U5:aRURU[U5- 5nU(d[SU[U54-5eX#- nU[U5:aMRU$)z,Read exactly 'numbytes' bytes from the pipe.rzexpected %d bytes, got %d)rDr~EOFError)rr*bufrs rr+ Popen2IO.readseS!::hS12D:hC=QQRR KC S!  rc[U[5(deURU5 URR 5 g)zWrite out all data bytes.N)rrrrvrgrs rrPopen2IO.writes1$&&&& D rc8URR5 gr)rwcloser:s rr;Popen2IO.close_read"s rc8URR5 gr)rvrr:s rr?Popen2IO.close_write%s r)r~rr4rwrvN)r4r3rrr.rrG)r r!r"r#IOErrorr$rerrorrr+rr;r?r$rrrrrrrs' gx (E #  rrrcH\rSrSr%Sr0rS\S'S$S%Sjjr\S&Sj5r S'Sjr S(S jr S)S jr S*S jr SrS \ 4\\'S*S jrSrS\4\\'S*SjrSrS\4\\'S*SjrSrS\4\\'S*SjrSrS\4\\'S*SjrSrS\4\\'S*SjrSrS\4\\'S*SjrS rS!\4\\'S"rg#)+Messagei)z.Encapsulates Messages and their wire protocol.z=dict[int, tuple[str, Callable[[Message, BaseGateway], None]]]_typesrc(XlX lX0lgr)msgcode channelidr)rrrrs rrMessage.__init__/s " rcURS5nU(d [S5e[R"SU5up4n[ X4URU55$![a!n[SURS-5SeSnAff=f)N z empty readzcouldn't load message header, r!bii)r+rrvstructunpackr)ioheaderemsgtypechannelpayloads rfrom_ioMessage.from_io4s SWWQZF|,,%+MM&&$A!'w)9:: S;affQiGHd R Ss#A B%BBc[R"SURUR[ UR 55nUR X R -5 g)Nr)rpackrrrDrr)rrrs rto_io Message.to_io?s9VT\\4>>3tyy>R ))#$rcLURURSnU"X5 g)Nr)rr)rgatewayhandlers rreceivedMessage.receivedCs!++dll+A.rcURURSnSUSURS[UR5S3$)Nrz )rrrrDr)rnames rriMessage.__repr__GsC{{4<<(+4& $..)93tyy>BRRSTTrc^[URR5URR 5UR R S.nUR[RUR[U55 UR[RUR5 g)N) numchannels numexecutingr4) rD_channelfactory _channels _execpoolrEr4rd_sendr CHANNEL_DATArdumps_internal CHANNEL_CLOSE)messagerds r_statusMessage._statusKs}w66@@A#--::< **22    g**G,=,=~a?PQ g++W->->?rSTATUSc[URU5n[U[5(deUnURS:XaX1lgX1R RUR5lgr)loads_internalrrtupler _strconfigrnew)rrr strconfigs r _reconfigureMessage._reconfigureZs[gllG4$&&&&'+    !!* HQ # # ' '(9(9 : Err RECONFIGUREc[U5er)GatewayReceivedTerminaterrs r_gateway_terminateMessage._gateway_terminatefs &w//rGATEWAY_TERMINATEcURRUR5nURX RS9 g)N)r sourcetask)rrr_local_schedulexecr)rrrs r _channel_execMessage._channel_execls3))--g.?.?@""7||"Lr CHANNEL_EXECcdURRURUR5 gr)r_local_receiverrrs r _channel_dataMessage._channel_datass"..w/@/@',,OrrcNURRUR5 grr _local_closerrs r_channel_closeMessage._channel_closeys,,W->->?rrc[UR5n[U[5(de[ U5nUR R URU5 gr)rrrr RemoteErrorrrr)rr error_message remote_errors r_channel_close_errorMessage._channel_close_errorsI&w||4 -----"=1 ,,W->-> MrCHANNEL_CLOSE_ERRORcLURRURSS9 gNT)sendonlyrrs r_channel_last_messageMessage._channel_last_messages!,,W->->,NrCHANNEL_LAST_MESSAGE)rrrNrrrr/rr/rrrr)rr&rr)rrrr)r BaseGatewayrrr)rrrrrr)r r!r"r#r^rrIr staticmethodrrrrirrrrrrrrrrrrrrrrr$rrrrr)s$8MOF IN ;;%U @F(F6NRK(,7F;0!46H IF ML*M:F<PL*M:F<@M,n=F=N #8:N"OF O$:-> ?GGAJ   3Cy))*"SE2 3s-1*AAcN^\rSrSrSrSU4SjjrS SjrS SjrS SjrSr U=r $) riz=Exception containing a stringified error from the other side.c.>[TU]5 Xlgr)superr formatted)rr __class__s rrRemoteError.__init__s "rcUR$rrr:s r__str__RemoteError.__str__s ~~rcLURRSUR3$)Nr)rr rr:s rriRemoteError.__repr__s#..))*"T^^,<==rcUR[:wa;[RR S[ R "5SU<S35 gg)Nr`z] Warning: unhandled ra)rINTERRUPT_TEXTrdrerrgetpidr:s rwarnRemoteError.warns; >>^ + JJ  q -B4("M N ,rr)rrrrrrG) r r!r"r#r^rrrirr$ __classcell__rs@rrrs!G#>OOrrc\rSrSrSrSrg) TimeoutErroriz0Exception indicating that a timeout was reached.rNrrrrrrs:rrc:\rSrSrSr\r\rSrSrSSjr SSjr \ 4SSjjr SSjr SS jrS rSS jr\SSS jj5r\S S!S jj5rS"S#SjjrS$SSjjrS$S%SjjrS&SjrS$S'SjjrS(SjrS)Sjr\rS*S+SjjrSrg),ChannelizFCommunication channel between two Python Interpreter execution points.iFcp[U[5(de[U[5(aeXl[ USS5UlX lURRRR5Ul SUl URRR5Ul /Ulg)z :private:rTFFN)rr/rrr}ridr4rlQueue_items_closedrK_receiveclosed _remoteerrors)rrrs rrChannel.__init__s"c""""gt,,,, !'<Gll,,2288:  "ll44::<02rcRURR"UR/UQ76 gr)r_tracerrris rr Channel._traces DGG*c*rcURRRnURR URc[ U<S35eURnSUlUR SS9nU[La#URU5 U[LaU"U5 O U"U5 MGSSS5 g!URRRRaN UR(d9URR5(dXUR 4X0R"'Mf=f!,(df  g=f)afSet a callback function for receiving items. All already-queued items will immediately trigger the callback. Afterwards the callback will execute in the receiver thread for each received data item and calls to ``receive()`` will raise an error. If an endmarker is specified the callback will eventually be called with the endmarker when the channel closes. Nz has callback already registeredF)block)rr _callbacks _receivelockrr$r! ENDMARKERputNO_ENDMARKER_WANTEDr4rlEmptyrrrNrr)rcallback endmarkerr%itemsolditems r setcallbackChannel.setcallbacks \\11<< \\ & &{{"(HIJJKKEDK *#iiei4G )+ '*$,??$Y/ ) ' &||--3399 LLD,?,?,F,F,H,H/7DOO.T 77+' &s01D7)B887D78A8D40D73D44D77 EchUR5=(a S=(d SnSURU4-$)Nclosedopenz)isclosedr)rflags rriChannel.__repr__s* ,H7#twwo55rcURcgURS5 UR(a$URHnUR 5 M gUR R 5(ag[bUURc[RnO[RnURRX R5 gg![[4a gf=f)Nzchannel.__del__)rr rrrrrNrrrrrrr$r)rrrs r__del__Channel.__del__s <<   %& <<++ ,  ' ' ) ) ";;&%::G%33GLL&&w8 # ,s+%CC%$C%cURRS5$![a, URRs$![ a Of=fgf=fr)rrI IndexErrorr_errorrr:s r_getremoteerrorChannel._getremoteerrorsW %%))!, ,  ||***!    s1 AAA A  A A  AAcUR$)zNReturn True if the channel is closed. A closed channel may still hold items. )rr:s rr4Channel.isclosed)s ||rcgrrrr proxycloses rmakefileChannel.makefile0s rcgrrrBs rrDrE4s rc^US:Xa [XS9$US:Xa [XS9$[SU<S35e)zReturn a file-like object. mode can be 'w' or 'r' for writeable/readable files. If proxyclose is true, file.close() will also close the channel. rl)rrCrzmode z not available)ChannelFileWriteChannelFileReadrrBs rrDrE<s< 3;#DH H S["4G G5788rNc0UR(a [S5eUR(aURR US5 UR(Gd;UR R 5(dwURRnUb,U"[RUR[U55 O!U"[RUR5 UR S5 [U[5(aURR!U5 SUlUR R#5 UR$nUbUR'[(5 URR*R-UR5 gg)zClose down this channel with an optional error message. Note that closing of a channel tied to remote_exec happens automatically at the end of execution and cannot be done explicitly. z2cannot explicitly close channel within remote_execz"ignoring redundant call to close()Nzsent channel close messageT) _executingr$rrr rrNrrrrrrrrrrXrQrr(r'r_no_longer_opened)rrr(rls rr Channel.closeLs ??NO O << LL  &J K||| &&--//ll(($33TWWnU>ST--tww7 89%--""))%0DL    # # %KKE  )$ LL ( ( : :477 C)rcURRUS9 URR5(dURSU-5eUR 5nU(aUeg)aWait until this channel is closed (or the remote side otherwise signalled that no more data was being sent). The channel may still hold receiveable items, but not receive any more after waitclose() has returned. Exceptions from executing code on the other side are reraised as local channel.RemoteErrors. EOFError is raised if the reading-connection was prematurely closed, which often indicates a dying process. self.TimeoutError is raised after the specified number of seconds (default is None, i.e. wait indefinitely). rSzTimeout after %r secondsN)rrBrNrr=)rrXrs r waitcloseChannel.waitclosemsb"    1""))++##$>$HI I$$& K rcUR5(a[SU<35eURR[R UR [U55 g)zSends the given item to the other side of the channel, possibly blocking if the sender queue is full. The item must be a simple Python type and will be copied to the other side by value. OSError is raised if the write pipe was prematurely closed. zcannot send to N)r4r$rrrrrr)ritems rsend Channel.sendsF ==??OD845 5 7//.:NOrc^URnUc [S5eURUS9nU[La2URU5 UR5=(d [5eU$!URRR R a URSU-5Sef=f)aReceive a data item that was sent from the other side. timeout: None [default] blocked waiting. A positive number indicates the number of seconds after which a channel.TimeoutError exception will be raised if no item was received. Note that exceptions from the remotely executing code will be reraised as channel.RemoteError exceptions containing a textual representation of the remote traceback. Nz/cannot receive(), channel has receiver callbackrSzno item after %r seconds) rr$r!rr4rlr*rr'r(r=r)rrX itemqueuexs rreceiveChannel.receivesKK  KL L T g .A > MM! &&(6HJ 6H ||%%++11 T##$>$HIt S Ts A((AB,cU$rrr:s r__iter__Channel.__iter__s rcNUR5$![a [Sef=fr)rYr StopIterationr:s rnext Channel.nexts* *<<> ! *T ) *s$cX4Ul[UR5nURR[R UR US9 g)zSet the string coercion for this channel. The default is to try to convert py2 str as py3 str, but not to try and convert py3 str to py2 str )rN)rrrrrrr)rpy2str_as_py3strpy3str_as_py2strrs r reconfigureChannel.reconfigures?,>doo. 7..dCr)rrrrrrr)rrrr/rrriobjectrr)r+zCallable[[Any], Any]r,rhrrrrGrZ).)rz Literal['r']rCr[rrJ)..)rz Literal['w']rCr[rrI)rlF)rzLiteral['r', 'w']rCr[rz"ChannelFileWrite | ChannelFileReadrr-)rSrhrr)rXr]rr)rz Iterator[Any])rrr)rcr[rdr[rr)r r!r"r#r^rr_INTERNALWAKEUPrLrr r)r/rir8r=r4r rDrrPrTrYr\r`__next__rer$rrrrrs)PKLOJ 3+ 0"*&"*"*  "*H6<  !       #& 999 , 9 DB0 P0* HGL D $ D?C D  D Drrzkeyboard-interruptedzJconcurrent remote_exec would cause deadlock for main_thread_only execmodelcf\rSrSrS S SjjrS SSjjrSSjrSSjrSSSjjrSSjr SS jr S r g)ChannelFactoryic[R"5Ul0UlURR 5UlXlX lSUl [Ul gr') weakrefWeakValueDictionaryrr%r4r _writelockrcountfinishedlist_list)rr startcounts rrChannelFactory.__init__sQ  ' ' )   "++002    rNcvUR UR(a[SUR35eUc!URnU=RS- slUR UnUsSSS5 $![ a' [URU5=o R U'N;f=f!,(df  g=f)z:Create a new Channel with 'id' (or create new id if None).zconnection already closed: Nr)rprrr$rrqrKeyErrorr)rrrs rrChannelFactory.news __}} ;DLL>JKKzZZ a  I..,_ I/6t||R/HH.., I_s0AB*A6+B*6.B'$B*&B''B** B8cTURURR55$r)rtrvaluesr:s rchannelsChannelFactory.channelsszz$..//122rcURU URRU5up#nU[La U"U5 gg![a N>f=f![a gf=fr)rrxr%rIr))rrr+r,rs rrM ChannelFactory._no_longer_openedsp r" $.2oo.A.A".E +H 33#4      s" AA A A AAcURRU5nUc)U(aUR5 URU5 gU(aURR U5 UR nUbUR[5 URU5 U(dSUl URR5 gr) rr!rrMrrXrr(r'rrrQ)rr remoteerrorrrrls rrChannelFactory._local_closes..$$R( ?  "  " "2 &%%,,[9NNE  )$  " "2 &"&  " " & & (rc8URRU5nURUupEn[X#U5nU"U5 g![anUR R SU-5 UR RU5nUR R[RU[U55 URX5 SnAgSnAff=f![a5 Ub UROSn U cg[X#5n U RU 5 gf=f)Nzexception during callback: %s)rr!r%rrhrr  _geterrortextrrrrrrxrr() rrrrr+ _endmarkerrr*rrlrSs rrChannelFactory._local_receive s..$$R( 1.2oob.A +H) 1%dY? 1 ##$Cc$IJ LL66s;  ""//^I5N!!"00  1 &-&9GNNtE}%d4 $  s/CA CA>CCD:DDc(UR SUlSSS5 URUR5HnUR USS9 M URUR 5HnUR U5 M g!,(df  Nt=fr)rprrrtrrr%rM)rrs r_finished_receiving"ChannelFactory._finished_receiving$sl __ DM**T^^,B   b4  0-**T__-B  " "2 &. _s B B)r%rrtrprqrrr)r)rrrur/rrr)rrHrr)rz list[Channel])rr/rrr')rr/rr[rrrG) r r!r"r#rrr|rMrrrr$rrrrlrls%  3 $)&10'rrlc@\rSrSrSS SjjrS SjrS SjrS SjrSrg) ChannelFilei-cXlX lgr)r _proxyclose)rrrCs rrChannelFile.__init__.s  %rcgr'rr:s risattyChannelFile.isatty2src\UR(aURR5 ggr)rrrr:s rrChannelFile.close5s    LL    rcURR5=(a S=(d SnSURRU4-$)Nr2r3z)rr4r)rstates rriChannelFile.__repr__9s6&&(5X@&$ '???r)rrNTrrrCr[rrrZrGr) r r!r"r#rrrrir$rrrrr-s&!@rrc(\rSrSrSSjrSSjrSrg)rIi>c:URRU5 gr)rrT)routs rrChannelFileWrite.write?s #rcgrrr:s rrgChannelFileWrite.flushB rrN)rrrrrG)r r!r"r#rrgr$rrrrIrI>s  rrIcD^\rSrSrSSU4SjjjrSSjrS SjrSrU=r$) rJiFc2>[TU]X5 SUlgr)rr_buffer)rrrCrs rrChannelFileRead.__init__Gs -#' rcURc-[[URR 55Ul[ UR5U:aVU=R[[URR 55- sl[ UR5U:aMVURcSnU$URSUnURUSUlU$![ a UR5 NRf=f)Nr)rr rrrYrDrr)rnrets rr+ChannelFileRead.readKs ||##C)=)=)?@ dll#a' S$,,*>*>*@ AA dll#a' << C ,,r"C<<+DL   JJL sB'C!!C>=C>c~URb]URRS5nUS:waURUS-5$UR[UR5S-5nOURS5nU(a:USS:wa1URS5nU(dU$X#- nU(a USS:waM1U$)Nrar)rfindr+rD)rirjcs rreadlineChannelFileRead.readlineZs << # !!$'ABwyyQ''99S.23D99QcFURUlXlX l[R[R 4Ul[X5UlURR5Ul [Ul [Ul[UR5Ulgr)r4_ior Unserializerrcrdrrlrrr&rk_BaseGateway__tracerrr/ _receivepool)rrr _startcounts rrBaseGateway.__init__nsq'88,:W:WX-d@ NN002 )&t~~6rc>UR"UR/UQ76 gr)rrr!s rr BaseGateway._tracezs TWW#s#rcNURRUR5 gr)rr_thread_receiverr:s r _initreceiveBaseGateway._initreceive}s  5 56rc^S U4SjjnU"S5 TRn[RU5nU"SU5 TR UR T5 ASSS5 MG!,(df  N=f![ [ 4a ON[anU"S5 UTlSnAO1SnAf[a!nU"TRU55 SnAOSnAff=fU"S5 TRR5 U"S5 TR5 U"S5 TRR5 U"S5 TRR5 U"S 5 TR R#5 g) Nc,>TR"S/UQ76 g)Nz[receiver-thread]r rirs rlog)BaseGateway._thread_receiver..logs KK+ 2c 2rzRECEIVERTHREAD: starting to runrz-EOF without prior gateway termination messagezfinishing receiving threadzterminating executionz closing readz closing writez#terminating our receive pseudo poolrg)rrrr&rKeyboardInterruptrrr<rhrrr_terminate_executionr;r?rrA)rrrrir*s` rrBaseGateway._thread_receivers5 3 -. XX )oob)J$&&LL&''&"#;<    ? @DKK ) ""3' ( ( ) () 002 #$ !!# N  O  12 **,sA+A8 A' A8' A51A88C CB'' C4CCcgrrr:s rr BaseGateway._terminate_executionrrc[XU5nURUR5 URSU5 g![[ 4a#nURSXE5 [ S5UeSnAff=f)Nsentzfailed to sendzcannot send (already closed?))rrrr r$r)rrrrrrs rrBaseGateway._sendsf'd3 B MM$(( # KK ($ B KK(' 59: A Bs-<A/ A**A/c&URS5 g)Nzexecution disallowed)r)rrrs rrBaseGateway._local_schedulexecs ,-rc6URR5$)z!Return a new independent channel.)rrr:s r newchannelBaseGateway.newchannels##''))rNc\URS5 URRU5 g)z%Wait for receiverthread to terminate.z%waiting for receiver thread to finishN)r rrTrWs rrbBaseGateway.joins# ;< !!'*r) __tracerr<rrr&rrr4r)r)rr1rr/rrrgrGrrrrrrrr)rrrr-)r r!r"r#r_sysexrrr rrrrrrrbr$rrrrrjs@ F B 7$7-@ B.*++rrcD\rSrSrSSjrS SjrS SjrS SjrSrg) WorkerGatewayicjURRRS:Xa]URceURR SS9(dUR [ 5 gURR5 [U5nURRURX45 g)NrrrS) rr4rd_executetask_completerBrMAIN_THREAD_ONLY_DEADLOCK_TEXTrTrr executetask)rrr sourcetask_s rr WorkerGateway._local_schedulexecs >> # # + +/A A--9 99--2212= <=  & & , , .$Z0  T--/EFrc2URS5 URR5 URRS5(dURS5 [R S:wa<URS5 [ R"[ R"5S5 O"[bURS5 [5 URRS5(d(URS 5 [ R"S 5 ggg) Nzshutting down execution poolg@z5execution ongoing after 5 secs, trying interrupt_mainrtzsending ourselves a SIGINTrzcalling interrupt_main()g$@z?execution did not finish in another 10 secs, calling os._exit()r) r rrArTrdrxrrEr r_exitr:s rr"WorkerGateway._terminate_executions 23 '')~~%%c** KKO P||w& 89 Q'+ 67 >>))$// U 0+rc^S U4SjjnTRRS;n[TRUS9TlSTlTRRS:Xa9TRR 5TlTRR 5 U"S5 TR5 U(a"U"S5 TRR5 U"S5 TR5 g![a U"S5 gf=f) Nc.>TRSU-5 g)Nz[serve] rrs rrk"WorkerGateway.serve..traces KK S( )rr2)r8rzspawning receiver threadzintegrating as primary threadzjoining receiver threadz,swallowing keyboardinterrupt, serve finished)rirrr) r4rdr/rrrKrQrr>rbr)rrkr8s` rserveWorkerGateway.serves *^^++/MM #DNNzJ%)" >> ! !%7 7)-)=)=)?D &  & & * * , ()  B56::< + , IIK  B @ A Bs/AC11DDcUunup4pVUSS.nURSURS[U5SS35 SUl[ US-U=(d SS 5n[ X5 U(a(URS U<S U<S S 35 Xun U "U40UD6 SUlURS5 WR5 UR bUR R#5 gg!SUlURS5 f=f![ a WR[5 e[an [U [5(daWRRR(d<URSU <35 URU 5n URU 5 Sn A gURS5 Sn A GN Sn A ff=f)N__channelexec__)rr zexecution starts[z]: 2Traz execzcalling z(**z>60)Fzexecution finishedzgot exception: z,ignoring EOFError because receiving finished)r rreprrLcompilerrrr r(rrrrrrrrrQ) rrSrsource file_name call_namer)loccofunctionr*rs rrWorkerGateway.executetasks H>B ;G;f.5CT"UC KK+GJJ num mappings.@ABCDEFGHIJKLMNOPQRSTrN)r r!r"r#r^ BUILDTUPLEBYTESCHANNELFALSEFLOAT FROZENSETINTLONGLONGINTLONGLONGNEWDICTNEWLISTNONE PY2STRING PY3STRINGSETSETITEMSTOPTRUEUNICODECOMPLEXr$rrrrrIsn-J EG E EI C DGHGG DII CG D DGGrrc\rSrSr%0rS\S'SrSrS S!SjjrS"S#Sjjr S$S jr \ \\ R'S$S jr \ \\ R'S$S jr\\\ R 'S$S jr\\\ R$'S$S jr\\\ R('\r\\\ R,'\r\\\ R0'S$Sjr\\\ R4'S$Sjr\\\ R8'S%SjrS&SjrS$Sjr\\\ R@'S$Sjr!\!\\ RD'S$Sjr#\#\\ RH'S$Sjr%\%\\ RL'S$Sjr'\'\\ RP'S$Sjr)\)\\ RT'S$Sjr+\+\\ RX'S'Sjr-S$Sjr.\.\\ R^'S$Sjr0\0\\ Rb'S$Sjr2\2\\ Rf'S$Sjr4\4\\ Rj'S$Sjr6\6\\ Rn'Sr8g)(ricz+dict[bytes, Callable[[Unserializer], None]]num2funcTFNc[U[5(a URnOUnUb URnU(aUuUlUlXlUcSUlgURUlgr) rrrrrcrdstreamchannelfactoryr)rr.channel_or_gatewayrgws rrUnserializer.__init__hsf (' 2 2%7%?%?B#B  )*55I ;D 8D !4#8 :"&D "$"4"4D rcU(a3URRS5nU[:wa[SU-5e/UlURRS5nU(d[ eUR UnU"U5 MB![a [SU<S35Sef=f![aC [UR5S:wa [S5SeURRS5s$f=f)Nrzwrong dumpformat version %rzunknown opcode z - wire protocol corruption?zinternal unserialization errorr) r.r+DUMPFORMAT_VERSIONrstackrr,rxrrDrI)r versionedverrloaders rloadUnserializer.load|s ++""1%C(( = CDD#%  /))!,"N !]]62F t    #)&3OP   %4::!# @AtK::>>!$ $ %s+)B%-B< B%B""B%%A C21C2c:URRS5 grr5rXr:s r load_noneUnserializer.load_none $rc:URRS5 grr<r:s r load_trueUnserializer.load_truer?rc:URRS5 gr'r<r:s r load_falseUnserializer.load_falses % rcZUR5nURRU5 gr _read_int4r5rXrrs rload_intUnserializer.load_ints OO  !rclUR5nURR[U55 gr)_read_byte_stringr5rXr/rss r load_longintUnserializer.load_longints&  " " $ #a&!rcURR[5nURR [ R "[U5S5 gr)r.r+FLOAT_FORMAT_SIZEr5rXrr FLOAT_FORMATrbinarys r load_floatUnserializer.load_floats9!!"34 &-- f=a@ArcURR[5nURR [ [ R"[U565 gr) r.r+COMPLEX_FORMAT_SIZEr5rXcomplexrrCOMPLEX_FORMATrUs r load_complexUnserializer.load_complexs9!!"56 '6==#HIJrcl[R"SURRS55SnU$)N!irr)rrr.r+)rvalues rrHUnserializer._read_int4s+]]4)9)9!)<=a@ rc\UR5nURRU5nU$r)rHr.r+)rlengthas_bytess rrMUnserializer._read_byte_strings'";;##F+rcUR5nUR(aURRU5 gURRUR S55 gNr)rMrdr5rXdecode)rres rload_py3stringUnserializer.load_py3stringsF))+  JJ  h ' JJ  hoog6 7rcUR5nUR(aURS5nOUnURR U5 g)Nzlatin-1)rMrcrir5rX)rrerOs rload_py2stringUnserializer.load_py2strings>))+  %__Y7AA !rcZUR5nURRU5 gr)rMr5rXrNs r load_bytesUnserializer.load_bytess"  " " $ !rctURRUR5RS55 grh)r5rXrMrir:s r load_unicodeUnserializer.load_unicodes( $00299'BCrcbUR5nURRS/U-5 grrG)rrds r load_newlistUnserializer.load_newlists&" 4&6/*rc[UR5S:a [S5eURR5nURR5nXRSU'g)Nrznot enough items for setitemr)rDr5rrI)rrakeys r load_setitemUnserializer.load_setitemsN tzz?Q :; ;  jjnn# 2src:URR05 grr<r:s r load_newdictUnserializer.load_newdicts "rcUR5nU(aBU"URU*S5nURU*S2 URRU5 gURRU"55 grrG)rtype_rdress r_load_collectionUnserializer._load_collections^"  F78,-C F78$ JJ  c " JJ  eg &rc.UR[5 gr)rrr:s rload_buildtupleUnserializer.load_buildtuples e$rc.UR[5 gr)rrQr:s rload_setUnserializer.load_set s c"rc.UR[5 gr)r frozensetr:s rload_frozensetUnserializer.load_frozensets i(rc[er)rr:s r load_stopUnserializer.load_stops rcUR5nURceURRU5nURR U5 gr)rHr/rr5rX)rrrs r load_channelUnserializer.load_channelsH __ ""...((,,R0  *%r)r/rcrdr5r.NN)r.r&r0zChannel | BaseGateway | Nonertuple[bool, bool] | Nonerrr[)r6r[rrrGr)rr)rrrr)9r r!r"r#r,rIrcrdrr9r=rr"rAr(rDrrJrrPr load_longr load_longlongrrWrr]r*rHrMrjr$rmr#rprrsr)rvr!rzr&r}r rrrrr%rrrr'rrr$rrrrrcs!<>H9> <@.2 5595, 5  5(/2 &HV[[ &HV[[!(HV\\$HVZZ" ,HV^^I%HV[[ M -HV__B(HV\\K ,HV^^ 8"0HV  "0HV  (HV\\D ,HV^^+ ,HV^^$ ,HV^^ ,HV^^'%#2HV  #$HVZZ)"0HV  &HV[[& ,HV^^rrc2[5RUSS9$)zSerialize the given obj to a bytestring. The obj and all contained objects must be of a builtin Python type (so nested dicts, sets, etc. are all OK but not user-level instances). Tr6 _Serializersaveobjs rdumpsr#s =  cT  22rcF[URS9RUSS9 g)zCwrite a serialized bytestring of the given obj to the given stream.)rTrN)rrr)byteiors rdumpr-sfll#(((=rc,[U5n[X1US9$)a0Deserialize the given bytestring to an object. py2str_as_py3str: If true then string (str) objects previously dumped on Python2 will be loaded as Python3 strings which really are text objects. py3str_as_py2str: If true then string (str) objects previously dumped on Python3 will be loaded as Python2 strings instead of unicode objects. If the bytestring was dumped with an incompatible protocol version or if the bytestring is corrupted, the ``execnet.DataFormatError`` will be raised. )rcrd)rr9) bytestringrcrdrs rloadsr2s!  B  @P rc4X4n[XS9RSS9$)zuDerserialize an object form the specified stream. Behaviour and parameters are otherwise the same as with ``loads`` )rTr)rr9)rrcrdrs rr9r9Hs%"4I  0 5 5 5 EErcL[U5n[X1U5R5$r)rrr9)rr/rrs rrrSs$  B I 6 ; ; ==rc4[5RU5$rrrs rrr\s =  c ""rc*\rSrSr%0rS\S'SSSjjrS S!SjjrS"SjrS#Sjr S$S jr S%S jr S&S jr S&S jr S%S jrS'SjrS(SjrS)SjrS*SjrS+SjrS\4-4S,SjjrS-SjrS.SjrS/SjrS0SjrS1SjrS2SjrS3SjrS4SjrSrg)5ri`z1dict[type, Callable[[_Serializer, object], None]] _dispatchNcPUc/UlURRnXlgr) _streamlistrXr)rrs rr_Serializer.__init__cs% =,.D $$++E rcU(aUR[5 URU5 UR[R5 UR nSRU5$![ a gf=f)Nr)rr4_saverr'rrrb)rrr6 streamlists rr_Serializer.saveisd  KK* + 3 FKK  ))Jxx ##  s A++ A87A8c[U5nURUnU"X5 g![aK SUR-n[ UR US5nUc[ SU35SeU=o0RU'N]f=f)Nsave_zcan't serialize )rrrxr r}rr)rrtpdispatch methodnamemeths rr_Serializer._savews #Y 1~~b)H  1 2;;.JAH DBD|"22$ 78dB,0 0H~~b) 1s%AA:9A:cBUR[R5 gr)rrr")rnons r save_NoneType_Serializer.save_NoneTypes FKK rcU(a UR[R5 gUR[R5 gr)rrr(r)rbooleans r save_bool_Serializer.save_bools%  KK $ KK %rcdUR[R5 URU5 gr)rrr_write_byte_sequencerbytes_s r save_bytes_Serializer.save_bytess  FLL! !!&)rcdUR[R5 URU5 gr)rrr$_write_unicode_stringrNs rsave_str_Serializer.save_strs" F$$% ""1%rcURS5nURU5 g![an[S5UeSnAff=f)Nrzstrings must be utf-8 encodable)encodeUnicodeEncodeErrorrr)rrOrers rr!_Serializer._write_unicode_stringsH Fxx(H !!(+" F=>A E Fs% A ;Ac\UR[U5S5 URU5 g)Nzstring is too long) _write_int4rDrrs rr _Serializer._write_byte_sequences# V&:; FrcU[::a#URU5 URU5 gURU5 UR[ U5R S5R S55 g)NLascii)FOUR_BYTE_INT_MAXrrrrrstripr)rrshort_oplong_ops r_save_integral_Serializer._save_integralsW ! ! KK !   Q  KK  % %c!fmmC&8&?&?&H IrcbURU[R[R5 gr)rrrrrIs rsave_int_Serializer.save_ints Avzz6>>:rcbURU[R[R5 gr)rrrr)rrs r save_long_Serializer.save_longs Av{{FOOAR@T#T** * *) $ , 8 4 '-%rrc[[S5(de[[R[R U5nSSKnUR"S5[lUR"S5[lU$[RnUR[R"S5SS5n[R"U[R5n[R"US5 [R "U5 UR[R"S5SS5n[R"U[R"5n[R"US5 [RS:XaGUR[R"S 5SS5[l[R"US 5 [R "U5 [XdU5nURSSSS S 9[lURSSSS S 9[lU$![a [RS:XaSnGNSnGNf=f) NduprrHrlntNULz /dev/nullrrFr)hasattrrrrrdstdoutstdintempfile TemporaryFiledevnullrrrr r3O_RDONLYdup2rO_WRONLYre)r4rrrrrrs r init_popen_iors 2u   cjj#))Y 7**3/ ++C0 < I9 &jjG  C3 WWWbkk * A  !!"&&)S!4 WWWbkk * A 77d?"))"&&)S! %%aa%? I5 &ww$%  &s<H IIIcR[SU<35 [XSS9R5 g)Nzcreating workergateway on r)rrr)rkrr)rrs rrr s% &rf -.RA.446r)rdzstr | ExecModelrr3rg)r*r(rztuple[type[BaseException], ...]rr)rr/rr)rrhrrr)FF)rrrcr[rdr[rr)rr&rcr[rdr[rrr)rrrrrr)r4r3rrr)rr1rr)`r^ __future__rrrrrd tracebackrnrrrrtypingrrrr r r r r rr&r1rKABCMetar3rrrrrrr/r SystemExitrenvironr!DEBUGr rfrkrpathrb gettempdirfnr3rnnotracerrrrhrrrrrrrhr)rr'r rrlrrIrJrrrrrrr4rrTcalcsizerSr\rZrrrrrrr9rrrrrrrrr$sp # "1h13X3    >H >2$#++2$j6!i6!r!o!60 60r7$i7$t ;"!"!Jy6y6x J' 'iikC<   h))+-?#-E FBR I ('Ge''TcScSL2y2 //-2  + "O)O&;7;hADADH H 'P a'a'H@@" { !k!HR+R+jd-Kd-X i --//!W OOL1oon5 I 4},},@3> QV)-IM.JOFF"&FBFFF*.>>(> >#B%B%J$N7r