6h]BSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r SSK J r JrJrJrJrJrJr SSKJrJr "SS5r"S S 5r"S S 5rS S0rSr"SS5rSSjr"SS5rSr Sr!"SS5r""SS5r#g)) annotationsN)_)encodingerror loggingutilpycompat repocacheutilvfs)cborutilprocutilc:\rSrSrSrSr\S5rSrSr Sr g) channeledoutput#zN Write data to out in the following format: data length (unsigned int), data cXlX lgN)outchannel)selfrrs 9/usr/lib/python3/dist-packages/mercurial/commandserver.py__init__channeledoutput.__init__+s  c SUR-$Ns <%c-channel>rrs rnamechanneledoutput.name/--rc U(dgURR[R"SUR[ U55U-5 URR 5 g)N>cI)rwritestructpackrlenflush)rdatas rr$channeledoutput.write3s@  v{{64<<TCdJK rcPUS;a [U5e[URU5$N)isattyfilenotellseek)AttributeErrorgetattrrrattrs r __getattr__channeledoutput.__getattr__:' 7 7 & &txx&&r)rrN) __name__ __module__ __qualname____firstlineno____doc__rpropertyrr$r5__static_attributes__rrrr#s*..'rrc.\rSrSrSrSrSrSrSrSr g) channeledmessage@z Write encoded message and metadata to out in the following format: data length (unsigned int), encoded message and metadata, as a flat key-value dict. Each message should have 'type' attribute. Messages of unknown type should be ignored. Tc<[X5UlX0lX@lgr)r_coutr _encodefn)rrr encodenameencodefns rrchanneledmessage.__init__Ns$S2 " !rc [R"U5nUbXS'URRUR U55 g)Nsdata)r byteskwargsrDr$rE)rr)optss rr$channeledmessage.writeSs:##D)   M -.rc.[URU5$r)r2rDr3s rr5channeledmessage.__getattr__Ystzz4((r)rDrErN) r8r9r:r;r< structuredrr$r5r>r?rrrArA@sJ" / )rrAcb\rSrSrSrSrSr\S5rSSjr Sr SSjr S r S r \ rS rS rg )channeledinput]a Read data from in_. Requests for input are written to out in the following format: channel identifier - 'I' for plain input, 'L' line based (1 byte) how many bytes to send at most (unsigned int), The client replies with: data length (unsigned int), 0 meaning EOF data ic(XlX lX0lgr)in_rr)rrTrrs rrchanneledinput.__init__ls rc SUR-$rrrs rrchanneledinput.nameqr!rcUS:aZURnURXR5nUnU(a(URXR5nX2- nU(aM(U$URXR5$Nr) maxchunksize_readrrsizesbufs rreadchanneledinput.readusj !8$$D 4.ACJJt\\2!J::dLL1 1rcfU(dgUS:deURR[R"SX!55 URR 5 UR R S5n[R"SU5SnU(dgUR R U5$)Nrrr#>I)rr$r%r&r(rTr`unpack)rr]rlengths rr[channeledinput._reads~axx v{{679: q!uf-a088==( (rcUS:atURnURUS5nUnU(aKURS5(d5URUS5nX2- nU(aURS5(dM5U$URUS5$)NrL )rZr[endswithr\s rreadlinechanneledinput.readlines~ !8$$D 4&ACAJJu--JJtT*AJJu--J::dD) )rcU$rr?rs r__iter__channeledinput.__iter__s rc@UR5nU(d[eU$r)rl StopIteration)rls rnextchanneledinput.nexts MMO rcPUS;a [U5e[URU5$r,)r1r2rTr3s rr5channeledinput.__getattr__r7r)rrTrN))r8r9r:r;r<rZrr=rr`r[rlrort__next__r5r>r?rrrQrQ]sL L .. 2) * H'rrQscborcLSR[R"U55$Nr)joinr streamencode)vs rrssxx 5 5a 89rcURSS5nUH$n[RU5nU(dM!X#4s $ [R"SSR U5-5e)N cmdserversmessage-encodingss"no supported message encodings: %s ) configlist_messageencodersgetrAbortr|)uiencnamesnfs r_selectmessageencoderrs]}}\+?@H    # 14K ++- (0CC rcb\rSrSrSrSSjrSrSrSrSr S r S r S r S r \ \ S .rSrSrg)serverza Listens for commands on fin, runs them and writes the output on a channel based stream to fout. Nc[R"5UlU(a)URUlX lURUlOXlS=UlUlXPl[US5Ul [US5Ul [US5Ul [X4S5Ul [US5UlURRSS5S:Xa>URR!5Ul[#URSURS 9 SUlURS S 5S :Xa['U5upg[)US Xg5UlX0lUR-SS5UlSUlUR.(d9[2R2"[2R4[2R65Ulgg)NdeoIrrlog-)repofpuismessage-outputschannelmsshutdown-on-interrupt)rgetcwdcwdbaseuirrrepoui_prereposetupsrcdebugcerrcoutrQcincresultconfigcopy setuploggingcmsgrrAclient configbool_shutdown_on_interrupt_old_inthandlersignalSIGINTSIG_IGN)rrrfinfout prereposetupsencnameencfns rrserver.__init__sU??$ kkDGI''DKG&* *DI +%dD1 #D$/ #D$/ !#T2&tT2 77>>, /4 7ggllnDG t < 99U- .* <226NG(tWDDI ')mm 2' # $**#)==#OD +rcUR(d0[R"[RUR5 gg)z9release and restore resources taken during server sessionN)rrrrrs rcleanupserver.cleanups(** MM&--)=)= >+rcfU(dgURRU5nU(d[eU$r{)rr`EOFError)rr]r)s rr[ server._reads+{{%N rc[R"SURS55SnU(dgURU5$)zCread a string from the channel format: data length (uint32), data rdrcrr)r%rer[)rrfs r_readstrserver._readstr s6 udjjm4Q7zz&!!rcVUR5nU(aURS5$/$)z6read a list of NULL separated strings from the channel)rsplit)rr^s r _readlistserver._readlists# MMO 775> !IrcSSKJn UR(aURU5$[R"[RUR 5 URU5[R"[R[R 5 $![Ra e[a Of=f[R"[R[R 5 O8![R"[R[R 5 f=fURR[S55 g)Nrdispatchs interrupted! rx) rrrrrrrSignalInterruptKeyboardInterruptrr)rreqrs r_dispatchcommandserver._dispatchcommands  & &$$S) ) 9 MM&--)=)= >$$S) MM&-- 8$$         MM&-- 8FMM&-- 8  Q()*s#?BB>;C6=B>>C665D+c FSSKJn UR5nURR 5nU/nUR (aX0R lURRUR5nURUlURU5 U=UR lUR Rl UR R5 UHDnUR5 [URS5(aM0UR!SSSS5 MF UR#USSUUR URUR$UR&UR(UR*S 9nUR-U5S -nUR.R1[2R4"S [7U555 S U;a![8R:"UR<5 gg!S U;a![8R:"UR<5 ff=f) zareads a list of terminated arguments, executes and writes the return code to the result channelrrr.rsnonttystrues commandserverNrs>is--cwd)rrrrrrrr __class__appenddirstate_ui invalidateall resetstatehasattrr setconfigrequestrrrrrrr$r%r&intoschdirr) rrargscopieduiuisrrrrets r runcommandserver.runcommand6s ~~77<<>j 99'II [[**4;;7F"--FK JJv 4: :DIIL499--1 II # # %B MMO488X.. UIw8HI  G  II HH II II II--   #'',s2C LL  v{{5#c(; <4" x4" s A G77)H cVURR[R5 g)z1writes the current encoding to the result channelN)rr$rrs r getencodingserver.getencodinghs 8,,-rcURR5SSnU(aQURRU5nU(a U"U5 US:g$[R "[ S5U-5eUS:g$)Nrxsunknown command %sr)rrl capabilitiesrrrr)rcmdhandlers rserveoneserver.serveonelspkk""$Sb) ''++C0G czkk!$9":S"@AAczr)s runcommands getencodingc@SSR[UR55-nUS- nUS[R-- nUS- nUR(aUSURR-- nUS[ R "5-- n[[S5(a!US- nUS[R"S 5-- nURRU5 UR5(aUR5(aMg ![a g f=f) Nscapabilities: rrjs encoding: smessage-encoding: %s spid: %dgetpgidspgid: %drr)r|sortedrrrrgetpidrrrrr$rr)rhellomsgs rserve server.serve{s$tyy8I8I1J'KKEMH$5$555E 99 1DII4F4FF FHJ!222 2y ! !  H  bjjm3 3H ! --//--//   s"+D DD)rrrrrrrrrrrrrrr)r8r9r:r;r<rrr[rrrrrrrrr>r?rrrrsH ,P\?  "40#d. $.{KLrrc(URSS5nU(dg[URSS55nUS:XaU(a[R"X$5nOUS:Xa"[R"UR U5nO[ R"[ R"U55nURSS5nURSS5n[R"[RRU55n[R "U[RR#U5UUUS9nU1n U(a6U R%UR&5 U R%UR(5 U Hn U R+SU5 M g) zSet up server logging facility If cmdserver.log is '-', log messages will be sent to the given fp. It should be the 'd' channel while a client is connected, and otherwise is the stderr of the server process. rrNs track-logrs max-log-filess max-log-size)maxfilesmaxsize)rsetrrfileobjectloggerferrr abspath expandpath configint configbytesvfsmodr rpathdirname fileloggerbasenameaddrr setlogger) rrrlogpathtrackedloggerrrr targetuisus rrrs*ii f-G "-- l;?..?jj12''  GG  W %   I  dkk" dgg  L&)rc&\rSrSrSrSrSrSrg) pipeserviceicXlX lgr)rr)rrrrKs rrpipeservice.__init__s  rcgrr?rs rinitpipeservice.inits rc URnUR5up#[XRX#5nUR 5UR 5 sSSS5 $!UR 5 f=f!,(df  g=fr)rprotectedfinoutrrrr)rrrrsvs rrunpipeservice.runsb WW   ![cIIs1B xxz " !  " !s"A5A A5 A22A55 B)rrN)r8r9r:r;rr rr>r?rrr r s  rr c\[R"SS5 [R"5 grY)rsetpgidrandomseedr?rr_initworkerprocessrsJJq! KKMrcURS5nURS5nSnU"XXVU5nUR5 UR5 UR!5 UR!5 g![Ra1nUR[ S5UR -5 SnANsSnAf[ a N[a Nf=f!UR5 f=f! U(a URn O [US5n U R[R"[R"555 e=f![ a gf=f!UR!5 UR!5 f![ a ff=f=f)Nrbwbs abort: %s r)makefilerrrrmessageBrokenPipeErrorrrrrr$r strtolocal traceback format_excclose) rrconncreatecmdserverrrrrinstrs r _serverequestr&s> -- C == D B TM B  HHJ JJL   JJL){{ 7 HHQ~&5 6 6       JJL 77D"4.D 8&&y';';'=>?       JJL   s C'A4C'#E4C'B4/C4 CC C CCCC$$C''AEE EEF'E87F8 FFFFc@\rSrSrSrSrSrSrSrSr Sr S r S r g) unixservicehandlerizSet of pluggable operations for unix-mode services Almost all methods except for createcmdserver() are called in the main process. You can't pass mutable resource back from createcmdserver(). NcXlgrr)rrs rrunixservicehandler.__init__src[R"X5 UR[R5 UR R [S5U-5 UR R5 g)Nslistening at %s ) r bindunixsocketlistensocket SOMAXCONNrstatusrr()rsockaddresss r bindsocketunixservicehandler.bindsocketsJ D* F$$% q-.89  rc0[R"U5 gr)runlink)rr3s r unlinksocketunixservicehandler.unlinksockets 'rcg)z9True if server should shut down; checked per pollintervalFr?rs r shouldexitunixservicehandler.shouldexitsrcg)z/Called when main process notices new connectionNr?rs r newconnection unixservicehandler.newconnection src0[URXXE5$)z`Create new command server instance; called in the process that serves for the current connection)rr)rrr#rrrs rr$"unixservicehandler.createcmdserver#sdggt$>>rr*) r8r9r:r;r< pollintervalrr4r8r;r>r$r>r?rrr(r(s, L >?rr(cd\rSrSrSrSSjrSrSrSrSr S r S r S r S r S rSrSrSrg)unixforkingservicei)z? Listens on unix domain socket and forks server per connection NcXlX lUSUl[[S5(d[ R "[S55eUR(d[ R "[S55eU=(d [U5Ul SUl SUl SUl SUl [5UlSUlUR#SS5nUS:a[ R "[S55e[$R&"X5Ul[*R,(a[.R0"5 gg) NsaddressAF_UNIXsunsupported platforms'no socket path specified with --addressrsmax-repo-cachers(negative max-repo-cache size not allowed)rrr3rr/rrrr(_servicehandler_sock_mainipc _workeripc_oldsigchldhandlerr _workerpids_socketunlinkedrr repoloader _repoloaderr isdarwinrgui)rrrrKrmaxlens rrunixforkingservice.__init__.s J' vy))++a 789 9||++a JKL L&@* A:++a KLM M$//;    LLN rcX[R"[R5Ul[R"[R[R5nUuUlUlURRURUR5 [[S5(a$[R"[R5 [R"[RUR5nXlSUlUR$R'5 g)N unblocksignalF)r/rFrH socketpair SOCK_DGRAMrIrJrGr4r3rrrUrSIGCHLD_sigchldhandlerrKrMrOstart)ros rr unixforkingservice.initGs]]6>>2    fnnf.?.? @)*& t '' DLLA 8_ - -  " "6>> 2 MM&..$*>*> ?"#$  rcUR(d-URRUR5 SUlgg)NT)rMrGr8r3rs r _unlinksocket unixforkingservice._unlinksocketVs0##  - -dll ;#'D $rct[R"[RUR5 URR 5 UR R 5 UR R 5 UR5 URR5 URS5 grY) rrXrKrHr"rIrJr^rOstop _reapworkersrs r_cleanupunixforkingservice._cleanup[sv fnnd&=&=>      !rcpUR5 UR5 g!UR5 f=fr) _mainlooprcrs rrunixforkingservice.runes$  NN  MMODMMOs#5cBSnURn[R"5nURUR[R UR 5 URUR[R UR5 U(d'UR5(aUR5 SnURURS9nU(d U(aO+MYUH!upVURURU5 M# MUR5 g)NFT)timeout)rG selectorsDefaultSelectorregisterrH EVENT_READ_acceptnewconnectionrI_handlemainipcr;r^selectrBr)fileobjr")rexitinghselectoreventskey_masks rrfunixforkingservice._mainloopks  ,,. JJ ,,d.G.G   MM9//1D1D q||~~ ""$__Q^^_r"rI _runworkerrJ_exitr )rr2rtrsr#_addrpids rrn'unixforkingservice._acceptnewconnections   kkm  ggi    "Es  $$S)!  "   ##%% %%'   ""GG%%D%1HHSMBHHSMs1AD"B D7"D47F:E+F+FFc\URS5nURRU5 g)z#Process messages sent from a workeriN)recvrOload)rr2rtrs rro!unixforkingservice._handlemainipcs$yy d#rcBUR[R5 gr)rbrWNOHANG)rrframes rrY"unixforkingservice._sigchldhandlers "**%rcTUR(am[R"SU5up#US:XagUR R SSU5 URRU5 UR(aMlgg![a URR 5 gf=f)Nrxrrsworker process exited (pid=%d) )rLrwaitpidChildProcessErrorclearrr}discard)roptionsr_statuss rrbunixforkingservice._reapworkerss !zz"g6  ax GGKK &I3 O    $ $S )%   &&( sB$B'&B'cZ[R"[RUR5 [5 URn[ UR URUURUR/S9 [R"5 g![R"5 f=f)Nr) rrXrKrrGr&rrr$ _reposetupgccollect)rr#rss rr~unixforkingservice._runworkersq fnnd&=&=>     !!#/   JJLBJJLs 6BB*cTUR5(dg"SSUR5nX2lURUlURR UR 5nUcgURRSSUR 5 [R"XB5 g)Nc(^\rSrSrU4SjrSrU=r$)8unixforkingservice._reposetup..unixcmdserverrepoic>[TU]5 URRUR5 g![ a UR RSS5 gf=f)Nrs#failed to send repo root to master )superr" _cmdserveripcsendrootOSErrorrr})rrs rr">unixforkingservice._reposetup..unixcmdserverrepo.closesN &&++DII6GGKK$&Ms%7&A A r?)r8r9r:r;r"r> __classcell__)rs@runixcmdserverrepors   rrs repocachesrepo from cache: %s ) localrrJrrOrrrr}r copycache)rrrr cachedrepos rrunixforkingservice._reposetups}zz||   +!__%%))$))4     L":DIIFJ-r) rIrKrOrGrHrMrJrLr3rrr)r8r9r:r;r<rr r^rcrrfrnrorYrbr~rr>r?rrrDrD)sD2 !(  :"B$ & * .rrD)NN)$ __future__rrrrrjrr/r%r i18nrrrrrr r r r rutilsr rrrArQrrrrr rr&r(rDr?rrrs#   '':)):T'T'p 9 NNb&*R($ F??Dz.z.r