h5/SrSSKrSSKrSSKrSSKrSSKJr SSKJ r SSK J r J r SSK Jr SSKJr SSKJr SS KJr SS KJrJrJrJrJr SS KJr "S S \R:5r"SS\R>\R@5r \RB"\R@\ 5 "SS5r""SS\RF5r$"SS\RJ\RL5r'"SS\RF5r(g!\a SrNf=f)z Distributed web servers. This is going to have to be refactored so that argument parsing is done by each subprocess and not by the main web server (i.e. GET, POST etc.). N)BytesIO)getDOMImplementation)addressreactor)Logger)styles)pb) SIZE_LIMIT)httpresourceserverstaticutil)Headersc,\rSrSrSrSrSrSrSrg)_ReferenceableProducerWrapper cXlgNproducer)selfrs Z/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/web/distrib.py__init__&_ReferenceableProducerWrapper.__init__!s c8URR5 gr)rresumeProducingrs rremote_resumeProducing4_ReferenceableProducerWrapper.remote_resumeProducing$s %%'rc8URR5 gr)rpauseProducingrs rremote_pauseProducing3_ReferenceableProducerWrapper.remote_pauseProducing's $$&rc8URR5 gr)r stopProducingrs rremote_stopProducing2_ReferenceableProducerWrapper.remote_stopProducing*s ##%rrN) __name__ __module__ __qualname____firstlineno__rr r$r(__static_attributes__rrrr s!('&rrc6\rSrSrSrSrSrSrSrSr Sr g ) Request.zb A request which was received by a L{ResourceSubscription} and sent via PB to a distributed node. c^^SH,nXmSSS.TSmUU4SjU4SjS.T"5nX1U'M. [[US 55US '[RR X5 [ UR 5UlURRS 5Ul URRS 5Ul URRS 5Ul URRS 5Ul URRS5UlURRS5UlURRS5Ulg)z Initialize this L{twisted.web.distrib.Request} based on the copied state so that it closely resembles a L{twisted.web.server.Request}. )hostclientTCPUNIX)INETr7rc@>[R"TTSTS5$)N)r IPv4Address)addrdesctupsr*Request.setCopyableState..=sw228SVSVLrc6>[R"TS5$)Nr:)r UNIXAddress)r>srr?r@>s 3 3CF ;r)r6r7requestHeadersfinish setHeader addCookiesetETagsetResponseCodesetLastModifiedwriteN)rdictr RemoteCopysetCopyableStater content_datacontentremote remoteMethodrDrErFrGrHrI_write)rstatekaddrr=r>s @@rrMRequest.setCopyableState4s/ "A(C %v6s1v>HL;D!H"#*$u5E/F*G"H &&t3t001 kk..x8 11+>11+>{{// : #{{778IJ#{{778IJkk..w7 rcSn[nURXU5 U[- nU[- nU[U5:agM7)z Write the given bytes to the response body. @param bytes: The bytes to write. If this is longer than 640k, it will be split up into smaller pieces. rN)r rRlen)rbytesstartends rrJ Request.writePsJ KKC( ) Z E : CE " rcURRS[U5U5RUR5 g)NregisterProducer)rP callRemoter addErrbackfail)rr streamings rr^Request.registerProducer`s/   =h G *TYY rclURRS5RUR5 g)NunregisterProducer)rPr_r`rars rreRequest.unregisterProduceres$ 34?? Jrc8URRSUS9 g)N)failure)_logrirris rra Request.failhs "g.r)rRrFrOrDrGrErIrHN) r*r+r,r-__doc__rMrJr^rerar.r/rrr1r1.s! 88  K/rr1c4\rSrSr\"5rSrSrSrSr g)IssueocXlgrrequest)rrss rrIssue.__init__rs rcU[RLaR[U[5(dS5eURR U5 URR 5 gg)Nzreturn value not a string)r NOT_DONE_YET isinstancestrrsrJrD)rresults rfinishedIssue.finishedusP ,, ,fc** G,G G* LL  v & LL   ! -rc b[U5nURR[R"[ R SS[R"U5-5RUR55 URR5 URRU5 g)NzServer Connection Lostz&Connection to distributed server lost:) rxrsrJr _UnsafeErrorPager INTERNAL_SERVER_ERRORr_PRErenderrDrjinforks rfailed Issue.failed{szg,   % %**(8499W;MM   fT\\"    wrrrN) r*r+r,r-rrjrrzrr.r/rrroroos 8D"  rrocN\rSrSrSrSr\"5rSrSr Sr Sr Sr S r S rg ) ResourceSubscriptionr:rcv[RRU5 XlX l/UlSUlgr)r Resourcerr4portpending publisher)rr4rs rrResourceSubscription.__init__s.""4(   rcd[R"UR5nSUS'SUS'/US'U$)z3Get persistent state for this ResourceSubscription.Nrrwaitingr)copy__dict__)rrSs r __getstate__!ResourceSubscription.__getstate__s9 $--(!kii rcURRS5 URRUR5 XlSUlURHnURU5 M /Ulg)z=I've connected to a publisher; I'll now send all my requests.zconnected to publisherrN) rjrbrokernotifyOnDisconnectbootedrrrr)rrrss r connectedResourceSubscription.connectedsX /0++DKK8" ||G KK $ rcURRSUS9 SUlSUlURH$nUR S5 UR 5 M& /Ulg)zHI can't connect to a publisher; I'll now reply to all pending requests. z3could not connect to distributed web service: {msg})msgrNz(Unable to connect to distributed server.)rjrrrrrJrD)rrrss r notConnected!ResourceSubscription.notConnectedsV LRUV ||G MMD E NN $ rc&URS5 g)Nzconnection dropped)rrs rrResourceSubscription.booteds ./rcUR(dURRU5 UR(dSUl[R "5nSnUR S:Xa"[R"URX#5 O,[R"UR URX#5 UR5nURURUR5 [&R($[U5nURR!SU5RUR"UR$5 [&R($)aRender this request, from my server. This will always be asynchronous, and therefore return NOT_DONE_YET. It spins off a request to the pb client, and either adds it to the list of pending issues or requests it immediately, depending on if the client is already connected. r: unixrs)rrappendrr PBClientFactoryr4r connectUNIXr connectTCP getRootObject addCallbacksrrror_rzrr rv)rrsbftimeoutdis rrResourceSubscription.renders~~ LL   (<<  '')99&'' 2?&&tyy$))RI$$&t~~t/@/@A""" gA NN % %i 9 F F AHH """r)r4rrrrN)r*r+r,r-isLeafrrrjrrrrrrr.r/rrrrs1 FG 8D  0#rrcB\rSrSrSr\"5rSrSrSr Sr Sr Sr g ) ResourcePublisherz L{ResourcePublisher} exposes a remote API which can be used to respond to request. @ivar site: The site which will be used for resource lookup. @type site: L{twisted.web.server.Site} cXlgrsite)rrs rrResourcePublisher.__init__s rr;cURRRS5 URRUR U?U?U?g)Nweb) application authorizerremoveIdentityservices serviceNameperspectiveNamers rupgradeToVersion2#ResourcePublisher.upgradeToVersion2sH ##2259    % %d&6&6 7      rcU$rr/)rnames rgetPerspectiveNamed%ResourcePublisher.getPerspectiveNameds rcURRU5nURRU5 UR U5nU[ R La!URU5 UR5 [ R $)z; Look up the resource for the given request and render it. ) rgetResourceForrjrrr rvrJrD)rrsresrys rremote_request ResourcePublisher.remote_requestsfii&&w/ wG$ ,, , MM& ! NN """rrN) r*r+r,r-rmrrjrpersistenceVersionrrrr.r/rrrrs, 8D! #rrc@\rSrSrSrSrSrSrS SjrSr S r S r S r g) UserDirectoryz A resource which lists available user resources and serves them as children. @ivar _pwd: An object like L{pwd} which is used to enumerate users and their home directories. public_htmlz.twistd-web-pba twisted.web.distrib.UserDirectory

twisted.web.distrib.UserDirectory

%(users)s Nc`[RRU5 Uc[nXlgr)r rrpwd_pwd)r userDatabases rrUserDirectory.__init__5s&""4(  L rc&/nURR5HnUup4pVpxn URS5Sn U (dUn [RR [RR XR55(aURX:S-45 [RR XR5n [RR U 5(dMUS-n URXS-45 M U$)zd Return a list of two-tuples giving links to user resources and text to associate with those links. ,rz (file)z.twistdz (twistd)) rgetpwallsplitospathexistsjoin userDirNameruserSocketName) rusersuserrpasswduidgidgecosdirshellrealname twistdsocklinkNames r_usersUserDirectory._users;s II&&(D8< 5D#E{{3'*Hww~~bggll30@0@ABB dy$89:c+>+>?Jww~~j)))+ h;(>?@) rc[5nURSSS5nURnUR5HupVUR S5nUR SUS-5 UR U5nURU5 UR S5n U RU5 URU 5 M URSUR50-n U RS5$) zU Render as HTML a listing of all known users with links to their personal resources. Nulahref/lirzutf-8) rcreateDocumentdocumentElementr createElement setAttributecreateTextNode appendChildtemplatetoxmlencode) rrsdomImplnewDoclistinglinktext linkElementtextNodeitemhtmlDocs r render_GETUserDirectory.render_GETNs '(''dD9((++-JD ..s3K  $ $VTCZ 8,,T2H  # #H -''-D   [ )    %(--GW]]_#=>~~g&&rcUS:XaU$SnURU5(aUS[U5*nSnOUnSnURRUR [ R "555unnnn n n n U(aH[RRXR5n [SU 5nURX5 U$[RRXR 5n[RR#U5(d[R"5$[$R&"U5$![a [R"5s$f=f)Nrs.twistdr:rr)endswithrXrgetpwnamdecodesysgetfilesystemencodingKeyErrorr _UnsafeNoResourcerrrrrputChildrrrFile)rrrstdusernamesubpw_name pw_passwdpw_uidpw_gidpw_gecospw_dirpw_shellrrsrs rgetChildUserDirectory.getChildcs+ 3;K  ==  Js2wh'HCHC 0 ""8??33L3L3N#OP  f.A.ABJ%fj9B MM$ #I77<<(8(89D77>>$''1133;;t$ $ 0--/ / 0sAEE&%E&)rr) r*r+r,r-rmrrrrrrrr.r/rrrrs/ K%N(HT! &'*#%rr))rmrrrr ImportErroriorxml.dom.minidomrtwisted.internetrrtwisted.loggerrtwisted.persistedrtwisted.spreadr twisted.spread.bananar twisted.webr r r rrtwisted.web.http_headersr ReferenceablerrLr1setUnjellyableForClassrorrRoot Versionedrrr/rrr(s  0-!$,<<, &B$4$4 &;/bmmV^^;/|&..'2  6K#8,,K#\$#!1!1$#NG%H%%G%[ CsC;;DD