h#SSKrSSKJr SSKJrJr SSKJrJr SSK J r SSK J r "SS5r \"\R5"S S 55rg) N) implementer)error interfaces)clientdns) DNSNameError) nativeStringc2\rSrSrSrSrSrSrSrSr g) "_SRVConnector_ClientFactoryWrappercXlX lgN)-_SRVConnector_ClientFactoryWrapper__connector2_SRVConnector_ClientFactoryWrapper__wrappedFactory)self connectorwrappedFactorys _/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/names/srvconnect.py__init__+_SRVConnector_ClientFactoryWrapper.__init__s$ .cNURRUR5 gr)rstartedConnectingr)rrs rr4_SRVConnector_ClientFactoryWrapper.startedConnectings //0@0@Arc:URRU5 gr)rconnectionFailedrrreasons rclientConnectionFailed9_SRVConnector_ClientFactoryWrapper.clientConnectionFaileds ))&1rc:URRU5 gr)rconnectionLostrs rclientConnectionLost7_SRVConnector_ClientFactoryWrapper.clientConnectionLosts ''/rc.[URU5$r)getattrr)rkeys r __getattr__._SRVConnector_ClientFactoryWrapper.__getattr__st,,c22r) __connector__wrappedFactoryN) __name__ __module__ __qualname____firstlineno__rrrr#r(__static_attributes__rrr r s/B203rr cr\rSrSrSrSrSSS0S4SjrS rS rS r S r S r Sr Sr SrSrSrSrSrg) SRVConnector"a A connector that looks up DNS SRV records. RFC 2782 details how SRV records should be interpreted and selected for subsequent connection attempts. The algorithm for using the records' priority and weight is implemented in L{pickServer}. @ivar servers: List of candidate server records for future connection attempts. @type servers: L{list} of L{dns.Record_SRV} @ivar orderedServers: List of server records that have already been tried in this round of connection attempts. @type orderedServers: L{list} of L{dns.Record_SRV} rtcp connectTCPr1Nc XlX lUcSO[R"U5UlX@lXPlX`lXplXl Xl SUl SUl SUl g)a @param domain: The domain to connect to. If passed as a text string, it will be encoded using C{idna} encoding. @type domain: L{bytes} or L{str} @param defaultPort: Optional default port number to be used when SRV lookup fails and the service name is unknown. This should be the port number associated with the service name as defined by the IANA registry. @type defaultPort: L{int} N)reactorservicer domainStringdomainfactoryprotocolconnectFuncNameconnectFuncArgsconnectFuncKwArgs _defaultPortrserversorderedServers) rr8r9r;r<r=r>r?r@ defaultPorts rrSRVConnector.__init__6s^.  $nd#2B2B62J   ..!2' "rc $URR5 URRU5 UR(GdURc&UR [ R"S55 g[R"S[UR5<S[UR5<S[UR5<35nURURUR5 UR!U4Sj5 UR"(aUR%UR&5 UR%UR 5 gUR(cUR+5 gUR(R-5 g)z"Start connection to remote server.NzDomain is not defined._z._.c"UR5$r)_reallyConnect)xrs r&SRVConnector.connect..qs t/B/B/Dr)r<doStartrrBr;rrDNSLookupErrorr lookupServicer r9r= addCallbacks _cbGotServers _ebGotServers addCallbackrA addErrback_ebServiceUnknownrrJconnect)rds rrWSRVConnector.connect]s  &&t,|||{{"%%(()AB$$!. / - A NN4--t/A/A B MMD E   T334 LL.. / ^^ #    ! NN " " $rcJUR[5 /Ul/Ulgr)traprrBrCrfailures rrSSRVConnector._ebGotServerszs \"   rc\Uup#n[U5S:XaUSR[R:XaUSR(avUSRR [R "S5:XaE[R"S[UR5<S[UR5<S35e/Ul /Ul UHYnUR[R:wdUR(dM4URRUR5 M[ g)Nr.zService z not available for domain rH)lentyperSRVpayloadtargetNamerrOreprr9r;rBrCappend)rresultanswersauthaddas rrRSRVConnector._cbGotServerss#s LA  377* "" ""))SXXd^;&& %tDKK'8:    Avv      & &qyy 1 rcUR[R5 [R"SSUR UR 5/Ul/UlUR5 g)z Connect to the default port when the service name is unknown. If no SRV records were found, the service name will be passed as the port. If resolving the name fails with L{error.ServiceNameUnknownError}, a final attempt is done using the default port. rN) r[rServiceNameUnknownErrorr Record_SRVrAr;rBrCrWr\s rrVSRVConnector._ebServiceUnknownsJ  U223q!T->-> LM   rcURceURceUR(d2UR(d![UR5UR4$UR(d)UR(aURUl/UlUR(deURR SS9 URSR nSnSn/nURH:nUR U:XdMX5R- nURX#45 US- nM< [R"SU5nUHdup'Xv:dM URUnURU URRU5 [UR5UR4s $ [SURR S35e)a Pick the next server. This selects the next server from the list of SRV records according to their priority and weight values, as set out by the default algorithm specified in RFC 2782. At the beginning of a round, L{servers} is populated with L{orderedServers}, and the latter is made empty. L{servers} is the list of candidates, and L{orderedServers} is the list of servers that have already been tried. First, all records are ordered by priority and weight in ascending order. Then for each priority level, a running sum is calculated over the sorted list of records for that priority. Then a random value between 0 and the final sum is compared to each record in order. The first record that is greater than or equal to that random value is chosen and removed from the list of candidates for this round. @return: A tuple of target hostname and port from the chosen DNS SRV record. @rtype: L{tuple} of native L{str} and L{int} c2URUR4$r)priorityweight)records rrL)SRVConnector.pickServer..sfoov}}-Mr)r'rr`z Impossible z pickServer result.)rBrCr r;r9sortrvrwrirandomrandintstrrfport RuntimeError __class__r,) r minPriorityindex weightSum weightIndexrKrandrwchosens r pickServerSRVConnector.pickServers0||'''""...||D$7$7 ,dll: :|| 3 3..DL"$D ||| MNll1o..   Azz[(XX% ""E#56   ~~a+(ME~e,LL'##**626==)6;;66 )[)@)@(AATUVVrcUR(aSUlgUR5uUlUlURcS5eURcS5e[ UR UR 5nU"URUR[XR5/URQ70URD6Ul g)NrzMust have a host to connect to.zMust have a port to connect to.) stopAfterDNSrhostr~r&r8r>r r<r?r@r)r connectFuncs rrJSRVConnector._reallyConnects    !D  #0 49yy$G&GG$yy$G&GG$dllD,@,@A $ II II .t\\ B  ! !  $$  rcjUR(aURR5 gSUlg)zStop attempting to connect.r`N)rstopConnectingrrs rrSRVConnector.stopConnectings! >> NN ) ) + !D rctURbURR5 gUR5 g)z%Disconnect whatever our are state is.N)r disconnectrrs rrSRVConnector.disconnects( >> % NN % % '    !rc\UR(deURR5$r)rgetDestinationrs rrSRVConnector.getDestinations!~~~~~,,..rcnURRX5 URR5 gr)r<rdoStoprrs rrSRVConnector.connectionFailed s$ ++D9 rcnURRX5 URR5 gr)r<r#rrs rr"SRVConnector.connectionLost s$ ))$7 r)rAr?r@r>rr;r<rrCr~r=r8rBr9r)r,r-r.r/__doc__rrrWrSrRrVrrJrrrrr"r0r1rrr3r3"s^ L$%#N%:!2, ;Wz $""/rr3)r{zope.interfacertwisted.internetrr twisted.namesrrtwisted.names.errorrtwisted.python.compatr r IConnectorr3r1rrrsJ &.%,.33$ Z " "#ll$lr