-Rc@`sdZddlmZmZddlZddlZddlZddlmZm Z ddl Z ddl m Z ddl mZmZmZmZmZddlmZmZmZmZddlmZdd lmZdd lmZdd lmZdd lm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&m'Z'ddl(m)Z)ddlm*Z*m+Z+ddl,m-Z-e sddl.m/Z/m0Z0ddl m1Z1ddl2m3Z3ddl4m5Z5m6Z6n2ddlm7Z7de7fdYZ/e8Z5e8Z6ddddddd d!d"d#d$d%d&d'd(d)gZ9ddddd"d#d)d'gZ:d*efd+YZ;d,efd-YZ<eej=d%e8fd.YZ>eej?d/e)ej@d0fd1YZAd2efd3YZBd(e6fd4YZCeejDd&e8fd5YZEeej=d6e8fd7YZFdeFfd8YZGdeFfd9YZHeejDde8fd:YZIeejDde8fd;YZJeejDd'e8fd<YZKeej=d"e8fd=YZLeejDd#e8fd>YZMeej=d e8fd?YZNeejDd!e8fd@YZOeej=d$e8fdAYZPdBdCdDZQdEdCeRdFZSdGdddBdCddHZUee/edIe8fdJYZVee/edKe8fdLYZWee/edMe8fdNYZXieQdO6eSdP6eUdQ6ZYeZdR\Z[Z\dSZ]dTZ^ieGdU6eLdV6eNdW6Z_ieIdU6eMdV6eOdW6Z`e8ZaddXZbdYZcdZZdd[Zed\Zfd]Zgd^Zhd_ZiiefdU6ehdV6eidW6Zjd`ZkdaZle rx5e9D],Zmeme:krNe9jnemeoem=qNqNW[m[:ndS(bs7 Implementations of L{IStreamServerEndpoint} and L{IStreamClientEndpoint} that wrap the L{IReactorTCP}, L{IReactorSSL}, and L{IReactorUNIX} interfaces. This also implements an extensible mini-language for describing endpoints, parsed by the L{clientFromString} and L{serverFromString} functions. @since: 10.1 i(tdivisiontabsolute_importN(t implementertdirectlyProvides(t_PY3(t interfacestdeferterrortfdesctthreads(t ClientFactorytProtocoltProcessProtocoltFactory(t!IStreamServerEndpointStringParser(t!IStreamClientEndpointStringParser(tFilePath(t ListenFDs(t isIPv6Address(tFailure(tlog(t_ProcessAddresstHostnameAddress(tproxyForInterface(tAF_INET6tAF_INET(t LoopingCall(tIPlugint getPlugins(tstdio(t PipeAddress(t NamedConstanttNames(t InterfaceRcB`seZRS((t__name__t __module__(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR/stclientFromStringtserverFromStringtTCP4ServerEndpointtTCP6ServerEndpointtTCP4ClientEndpointtTCP6ClientEndpointtUNIXServerEndpointtUNIXClientEndpointtSSL4ServerEndpointtSSL4ClientEndpointtAdoptedStreamServerEndpointtStandardIOEndpointtProcessEndpointtHostnameEndpointtStandardErrorBehaviortconnectProtocolt_WrappingProtocolcB`sVeZdZdZdZdZdZdZdZdZ dZ RS( s_ Wrap another protocol in order to notify my user when a connection has been made. cC`sU||_||_x<tjtjgD](}|j|jr%t||q%q%WdS(s @param connectedDeferred: The L{Deferred} that will callback with the C{wrappedProtocol} when it is connected. @param wrappedProtocol: An L{IProtocol} provider that will be connected. N(t_connectedDeferredt_wrappedProtocolRtIHalfCloseableProtocoltIFileDescriptorReceivert providedByR(tselftconnectedDeferredtwrappedProtocoltiface((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt__init__Is    cC`s/tjj|jr"|jjS|jjjS(sO Transparently pass through the wrapped protocol's log prefix. (RtILoggingContextR9R6t logPrefixt __class__R"(R:((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR@Zs cC`s*|jj|j|jj|jdS(s Connect the C{self._wrappedProtocol} to our C{self.transport} and callback C{self._connectedDeferred} with the C{self._wrappedProtocol} N(R6tmakeConnectiont transportR5tcallback(R:((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytconnectionMadecscC`s|jj|S(sM Proxy C{dataReceived} calls to our C{self._wrappedProtocol} (R6t dataReceived(R:tdata((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRFlscC`s|jj|S(sW Proxy C{fileDescriptorReceived} calls to our C{self._wrappedProtocol} (R6tfileDescriptorReceived(R:t descriptor((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRHsscC`s|jj|S(sO Proxy C{connectionLost} calls to our C{self._wrappedProtocol} (R6tconnectionLost(R:treason((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRJzscC`s|jjdS(sl Proxy L{IHalfCloseableProtocol.readConnectionLost} to our C{self._wrappedProtocol} N(R6treadConnectionLost(R:((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRLscC`s|jjdS(sm Proxy L{IHalfCloseableProtocol.writeConnectionLost} to our C{self._wrappedProtocol} N(R6twriteConnectionLost(R:((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRMs( R"R#t__doc__R>R@RERFRHRJRLRM(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR4Cs     t_WrappingFactorycB`sSeZdZeZdZdZdZdZdZ dZ dZ RS(s Wrap a factory in order to wrap the protocols it builds. @ivar _wrappedFactory: A provider of I{IProtocolFactory} whose buildProtocol method will be called and whose resulting protocol will be wrapped. @ivar _onConnection: A L{Deferred} that fires when the protocol is connected @ivar _connector: A L{connector } that is managing the current or previous connection attempt. cC`s%||_tjd|j|_dS(s @param wrappedFactory: A provider of I{IProtocolFactory} whose buildProtocol method will be called and whose resulting protocol will be wrapped. t cancellerN(t_wrappedFactoryRtDeferredt _cancellert _onConnection(R:twrappedFactory((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s cC`s ||_dS(s~ A connection attempt was started. Remember the connector which started said attempt, for use later. N(t _connector(R:t connector((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytstartedConnectingscC`s0|jtj|jj|jjdS(s; The outgoing connection attempt was cancelled. Fail that L{Deferred} with an L{error.ConnectingCancelledError}. @param deferred: The L{Deferred } that was cancelled; should be the same as C{self._onConnection}. @type deferred: L{Deferred } @note: This relies on startedConnecting having been called, so it may seem as though there's a race condition where C{_connector} may not have been set. However, using public APIs, this condition is impossible to catch, because a connection API (C{connectTCP}/C{SSL}/C{UNIX}) is always invoked before a L{_WrappingFactory}'s L{Deferred } is returned to C{connect()}'s caller. @return: C{None} N(terrbackRtConnectingCancelledErrorRVtgetDestinationtstopConnecting(R:tdeferred((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRSscC`s|jjdS(sY Start notifications are passed straight through to the wrapped factory. N(RQtdoStart(R:((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR^scC`s|jjdS(sX Stop notifications are passed straight through to the wrapped factory. N(RQtdoStop(R:((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR_scC`sDy|jj|}Wn|jjnX|j|j|SdS(s Proxy C{buildProtocol} to our C{self._wrappedFactory} or errback the C{self._onConnection} L{Deferred}. @return: An instance of L{_WrappingProtocol} or C{None} N(RQt buildProtocolRTRYtprotocol(R:taddrtproto((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR`s cC`s#|jjs|jj|ndS(si Errback the C{self._onConnection} L{Deferred} when the client connection fails. N(RTtcalledRY(R:RWRK((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytclientConnectionFaileds ( R"R#RNR4RaR>RXRSR^R_R`Re(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyROs      cB`s eZdZdZdZRS(s* A Standard Input/Output endpoint cC`s ||_dS(s> @param reactor: The reactor for the endpoint N(t_reactor(R:treactor((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>scC`stjtj|jtS(sU Implement L{IStreamServerEndpoint.listen} to listen on stdin/stdout (RtexecuteRt StandardIOR`R(R:tstdioProtocolFactory((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytlistens (R"R#RNR>Rk(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR/s t_ProcessEndpointTransportt_processcB`s eZdZdZdZRS(s0 An L{ITransport} provider for the L{IProtocol} instance passed to the process endpoint. @ivar _process: An active process transport which will be used by write methods on this object to write data to a child process. @type _process: L{interfaces.IProcessTransport} provider cC`s|jjd|dS(sp Write to the child process's standard input. @param data: The data to write on stdin. iN(Rmt writeToChild(R:RG((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytwritescC`s(x!|D]}|jjd|qWdS(s Write a list of strings to child process's stdin. @param data: The list of chunks to write on stdin. iN(RmRn(R:RGtchunk((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt writeSequences (R"R#RNRoRq(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRl s  t_WrapIProtocolcB`s2eZdZdZdZdZdZRS(s An L{IProcessProtocol} provider that wraps an L{IProtocol}. @ivar transport: A L{_ProcessEndpointTransport} provider that is hooked to the wrapped L{IProtocol} provider. @see: L{protocol.ProcessProtocol} cC`s||_||_||_dS(s @param proto: An L{IProtocol} provider. @param errFlag: A constant belonging to L{StandardErrorBehavior} that determines if stderr is logged or dropped. @param executable: The file name (full path) to spawn. N(RaterrFlagt executable(R:RcRtRs((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>3s  cC`s"t||_|jj|jS(s Call L{IProtocol} provider's makeConnection method with an L{ITransport} provider. @param process: An L{IProcessTransport} provider. (RlRCRaRB(R:tprocess((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRB?sc C`si|dkr|jj|S|dkre|jtjkretjddd|jd|jd|ndS( s This is called with data from the process's stdout or stderr pipes. It checks the status of the errFlag to setermine if stderr should be logged (default) or dropped. iitformatsGProcess %(executable)r wrote stderr unhandled by %(protocol)s: %(data)sRtRaRGN(RaRFRsR2tLOGRtmsgRt(R:tchildFDRG((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytchildDataReceivedJs  cC`s]|jtjtjkrI|jjdkrI|jjttjS|jj|SdS(s If the process ends with L{error.ProcessDone}, this method calls the L{IProtocol} provider's L{connectionLost} with a L{error.ConnectionDone} @see: L{ProcessProtocol.processEnded} iN( tcheckRt ProcessDonetvaluetstatusRaRJRtConnectionDone(R:RK((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt processEndedZs  (R"R#RNR>RBRzR(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRr)s  cB`s eZdZeZeZRS(s Constants used in ProcessEndpoint to decide what to do with stderr. @cvar LOG: Indicates that stderr is to be logged. @cvar DROP: Indicates that stderr is to be dropped (and not logged). @since: 13.1 (R"R#RNRRwtDROP(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR2ks c B`s;eZdZdidddddejdZdZRS(s An endpoint for child processes @ivar _spawnProcess: A hook used for testing the spawning of child process. @since: 13.1 ic C`sm||_||_||_||_||_||_||_||_| |_| |_ |jj |_ dS(s See L{IReactorProcess.spawnProcess}. @param errFlag: Determines if stderr should be logged. @type errFlag: L{endpoints.StandardErrorBehavior} N( Rft _executablet_argst_envt_patht_uidt_gidt_usePTYt _childFDst_errFlagt spawnProcesst _spawnProcess( R:RgRttargstenvtpathtuidtgidtusePTYtchildFDsRs((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s          c C`s|jt}yS|jt||j|j|j|j|j|j|j |j |j |j Wnt jSXt j|SdS(s3 Implement L{IStreamClientEndpoint.connect} to launch a child process and connect it to a protocol created by C{protocolFactory}. @param protocolFactory: A factory for an L{IProtocol} provider which will be notified of all events related to the created process. N(R`RRRrRRRRRRRRRRtfailtsucceed(R:tprotocolFactoryRc((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytconnects (N(R"R#RNtNoneR2RwR>R(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR0ys   t_TCPServerEndpointcB`s eZdZdZdZRS(s) A TCP server endpoint interface cC`s(||_||_||_||_dS(s+ @param reactor: An L{IReactorTCP} provider. @param port: The port number used for listening @type port: int @param backlog: Size of the listen queue @type backlog: int @param interface: The hostname to bind to @type interface: str N(Rft_portt_backlogt _interface(R:Rgtporttbacklogt interface((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s   cC`s.tj|jj|j|d|jd|jS(s] Implement L{IStreamServerEndpoint.listen} to listen on a TCP socket RR(RRhRft listenTCPRRR(R:R((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRks  (R"R#RNR>Rk(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRs cB`seZdZdddZRS(sC Implements TCP server endpoint with an IPv4 configuration i2tcC`stj|||||dS(sA @param reactor: An L{IReactorTCP} provider. @param port: The port number used for listening @type port: int @param backlog: Size of the listen queue @type backlog: int @param interface: The hostname to bind to, defaults to '' (all) @type interface: str N(RR>(R:RgRRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s (R"R#RNR>(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR&scB`seZdZdddZRS(sC Implements TCP server endpoint with an IPv6 configuration i2s::cC`stj|||||dS(sA @param reactor: An L{IReactorTCP} provider. @param port: The port number used for listening @type port: int @param backlog: Size of the listen queue @type backlog: int @param interface: The hostname to bind to, defaults to '' (all) @type interface: str N(RR>(R:RgRRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s (R"R#RNR>(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR'scB`s&eZdZdddZdZRS(s9 TCP client endpoint with an IPv4 configuration. icC`s1||_||_||_||_||_dS(s @param reactor: An L{IReactorTCP} provider @param host: A hostname, used when connecting @type host: str @param port: The port number, used when connecting @type port: int @param timeout: The number of seconds to wait before assuming the connection has failed. @type timeout: int @param bindAddress: A (host, port) tuple of local address to bind to, or None. @type bindAddress: tuple N(Rft_hostRt_timeoutt _bindAddress(R:RgthostRttimeoutt bindAddress((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s     cC`sZyEt|}|jj|j|j|d|jd|j|jSWntj SXdS(sP Implement L{IStreamClientEndpoint.connect} to connect via TCP. RRN( RORft connectTCPRRRRRTRR(R:Rtwf((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRs   N(R"R#RNRR>R(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR(scB`s\eZdZejZeejZ dZ dZ dddZ dZdZdZRS( s TCP client endpoint with an IPv6 configuration. @ivar _getaddrinfo: A hook used for testing name resolution. @ivar _deferToThread: A hook used for testing deferToThread. @ivar _GAI_ADDRESS: Index of the address portion in result of getaddrinfo to be used. @ivar _GAI_ADDRESS_HOST: Index of the actual host-address in the 5-tuple L{_GAI_ADDRESS}. iiicC`s1||_||_||_||_||_dS(s @param host: An IPv6 address literal or a hostname with an IPv6 address @see: L{twisted.internet.interfaces.IReactorTCP.connectTCP} N(RfRRRR(R:RgRRRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>@s     c`sftjr'jj|}n;jj}|jfd|jj||S(s~ Implement L{IStreamClientEndpoint.connect} to connect via TCP, once the hostname resolution is done. c`s|djjS(Ni(t _GAI_ADDRESSt_GAI_ADDRESS_HOST(tresult(R:(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytWs(RRt_resolvedHostConnectt_nameResolutiont addCallback(R:Rtd((R:sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRNs cC`s|j|j|dtjS(sd Resolve the hostname string into a tuple containing the host IPv6 address. i(t_deferToThreadt _getaddrinfotsocketR(R:R((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR]scC`sWyBt|}|jj||j|d|jd|j|jSWntjSXdS(sD Connect to the server using the resolved hostname. RRN( RORfRRRRRTRR(R:t resolvedHostRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRfs  N(R"R#RNRt getaddrinfoRt staticmethodR t deferToThreadRRRRR>RRR(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR)+s   cB`sGeZdZejZeejZ dddZ dZ dZ RS(s A name-based endpoint that connects to the fastest amongst the resolved host addresses. @ivar _getaddrinfo: A hook used for testing name resolution. @ivar _deferToThread: A hook used for testing deferToThread. icC`s1||_||_||_||_||_dS(sN @param host: A hostname to connect to. @type host: L{bytes} @param timeout: For each individual connection attempt, the number of seconds to wait before assuming the connection has failed. @type timeout: L{int} @see: L{twisted.internet.interfaces.IReactorTCP.connectTCP} N(RfRRRR(R:RgRRRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s    c`s|gfdfd}fd}fd}jjj}|j||j||j||S(s Attempts a connection to each address returned by gai, and returns a connection which is established first. c`sE|jtjtjjxD]}|jq-WdS(s1 The outgoing connection attempt was cancelled. Fail that L{Deferred} with an L{error.ConnectingCancelledError}. @param d: The L{Deferred } that was cancelled @type d: L{Deferred } @return: C{None} N(RYRRZRRRtcancel(Rtp(tpendingR:(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRSs c`s tjtjdjfS(su Errback for when L{_nameResolution} returns a Deferred that fires with failure. sCouldn't find the hostname '%s'(RRRtDNSLookupErrorR(tfailure(R:(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt errbackForGais c3`sx|D]\}}}}}|tgkrVtj|d|djjVq|tgkrtj|d|djjVqqWdS(s This method matches the host address family with an endpoint for every address returned by GAI. @param gaiResult: A list of 5-tuples as returned by GAI. @type gaiResult: list iiN(RR)RfRRRR((t gaiResulttfamilytsocktypeRct canonnametsockaddr(R:(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt _endpointssc `sgggtjd  fd  fd  fdfd  f d}t| j_jd S(sc When L{endpoints} yields an endpoint, this method attempts to connect it. RPc`sj||S(N(tremove(t connResultt connAttempt(R(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytusedEndpointRemovals c`sPjrjnjtxD]}|jq+Wj|dS(N(trunningtstoptappendtTrueRRDR(RR(tlcRt successfultwinner(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytafterConnectionAttempts    c`s.r* r* r*jjndS(N(RYtpop((tendpointsListExhaustedtfailuresRRR(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt checkDonesc`sj|dS(N(RR(RK(RR(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt connectFaileds c`syt}Wn/tk rAjtjnGX|j}j||j||j|jdS(N( tnextt StopIterationRRRRtaddBothRt addErrback(tendpointtdconn( RRRt endpointsRRRRR(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytiterateEndpoints      g333333?(RRRRRftclocktstart(RR(RSRR:R( RRRRRRRRRRsL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pytattemptConnections  '   (RRRRR(R:RRRRR((RSRR:RsL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRs:   cC`s|j|j||dtjS(s^ Resolve the hostname string into a tuple containig the host address. i(RRRt SOCK_STREAM(R:RR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRsN(R"R#RNRRRRR RRRR>RR(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR1ts    pcB`s&eZdZdddZdZRS(sE SSL secured TCP server endpoint with an IPv4 configuration. i2RcC`s1||_||_||_||_||_dS(s @param reactor: An L{IReactorSSL} provider. @param port: The port number used for listening @type port: int @param sslContextFactory: An instance of L{twisted.internet.ssl.ContextFactory}. @param backlog: Size of the listen queue @type backlog: int @param interface: The hostname to bind to, defaults to '' (all) @type interface: str N(RfRt_sslContextFactoryRR(R:RgRtsslContextFactoryRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s     c C`s7tj|jj|j|d|jd|jd|jS(sf Implement L{IStreamServerEndpoint.listen} to listen for SSL on a TCP socket. tcontextFactoryRR(RRhRft listenSSLRRRR(R:R((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRk+s   (R"R#RNR>Rk(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR, scB`s&eZdZdddZdZRS(sD SSL secured TCP client endpoint with an IPv4 configuration icC`s:||_||_||_||_||_||_dS(sq @param reactor: An L{IReactorSSL} provider. @param host: A hostname, used when connecting @type host: str @param port: The port number, used when connecting @type port: int @param sslContextFactory: SSL Configuration information as an instance of L{twisted.internet.ssl.ContextFactory}. @param timeout: Number of seconds to wait before assuming the connection has failed. @type timeout: int @param bindAddress: A (host, port) tuple of local address to bind to, or None. @type bindAddress: tuple N(RfRRRRR(R:RgRRRRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>>s      c C`s`yKt|}|jj|j|j||jd|jd|j|jSWnt j SXdS(sb Implement L{IStreamClientEndpoint.connect} to connect with SSL over TCP. RRN( RORft connectSSLRRRRRRTRR(R:RR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR\s   N(R"R#RNRR>R(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR-8scB`s)eZdZddddZdZRS(s% UnixSocket server endpoint. i2iicC`s1||_||_||_||_||_dS(s @param reactor: An L{IReactorUNIX} provider. @param address: The path to the Unix socket file, used when listening @param backlog: number of connections to allow in backlog. @param mode: mode to set on the unix socket. This parameter is deprecated. Permissions should be set on the directory which contains the UNIX socket. @param wantPID: If True, create a pidfile for the socket. N(Rft_addressRt_modet_wantPID(R:RgtaddressRtmodetwantPID((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>qs    c C`s7tj|jj|j|d|jd|jd|jS(sW Implement L{IStreamServerEndpoint.listen} to listen on a UNIX socket. RRR(RRhRft listenUNIXRRRR(R:R((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRks   (R"R#RNR>Rk(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR*lscB`s&eZdZdddZdZRS(s% UnixSocket client endpoint. iicC`s(||_||_||_||_dS(s @param reactor: An L{IReactorUNIX} provider. @param path: The path to the Unix socket file, used when connecting @type path: str @param timeout: Number of seconds to wait before assuming the connection has failed. @type timeout: int @param checkPID: If True, check for a pid file to verify that a server is listening. @type checkPID: bool N(RfRRt _checkPID(R:RgRRtcheckPID((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s   cC`sTy?t|}|jj|j|d|jd|j|jSWntjSXdS(sa Implement L{IStreamClientEndpoint.connect} to connect via a UNIX Socket RRN( RORft connectUNIXRRRRTRR(R:RR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRs      (R"R#RNR>R(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR+scB`s8eZdZejZeejZ dZ dZ RS(s An endpoint for listening on a file descriptor initialized outside of Twisted. @ivar _used: A C{bool} indicating whether this endpoint has been used to listen with a factory yet. C{True} if so. cC`s(||_||_||_t|_dS(s @param reactor: An L{IReactorSocket} provider. @param fileno: An integer file descriptor corresponding to a listening I{SOCK_STREAM} socket. @param addressFamily: The address family of the socket given by C{fileno}. N(Rgtfilenot addressFamilytFalset_used(R:RgRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR>s   cC`s|jrtjtjSt|_yB|j|j|jj |j|j |}|j |jWntjSXtj |S(s{ Implement L{IStreamServerEndpoint.listen} to start listening on, and then close, C{self._fileno}. ( RRRRtAlreadyListenedRt_setNonBlockingRRgtadoptStreamPortRt_closeR(R:tfactoryR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRks    ( R"R#RNtostcloseRRRtsetNonBlockingRR>Rk(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR.s   Ri2cC`s*t||fi|d6t|d6fS(s Internal parser function for L{_parseServer} to convert the string arguments for a TCP(IPv4) stream endpoint into the structured arguments. @param factory: the protocol factory being parsed, or C{None}. (This was a leftover argument from when this code was in C{strports}, and is now mostly None and unused.) @type factory: L{IProtocolFactory} or C{NoneType} @param port: the integer port number to bind @type port: C{str} @param interface: the interface IP to listen on @param backlog: the length of the listen queue @type backlog: C{str} @return: a 2-tuple of (args, kwargs), describing the parameters to L{IReactorTCP.listenTCP} (or, modulo argument 2, the factory, arguments to L{TCP4ServerEndpoint}. RR(tint(RRRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt _parseTCPst666cC`s@||fit|dd6t|d6tt|d6fS(s Internal parser function for L{_parseServer} to convert the string arguments for a UNIX (AF_UNIX/SOCK_STREAM) stream endpoint into the structured arguments. @param factory: the protocol factory being parsed, or C{None}. (This was a leftover argument from when this code was in C{strports}, and is now mostly None and unused.) @type factory: L{IProtocolFactory} or C{NoneType} @param address: the pathname of the unix socket @type address: C{str} @param backlog: the length of the listen queue @type backlog: C{str} @param lockfile: A string '0' or '1', mapping to True and False respectively. See the C{wantPID} argument to C{listenUNIX} @return: a 2-tuple of (args, kwargs), describing the parameters to L{IReactorTCP.listenUNIX} (or, modulo argument 2, the factory, arguments to L{UNIXServerEndpoint}. iRRR(Rtbool(RRRRtlockfile((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt _parseUNIXs  s server.pemcC`sqddlm}|d kr%|}ni} |d k rPt|j|| dRtwarningstwarntDeprecationWarningt _NO_DEFAULTRt_serverParserstgetRRR&tupper( R8RtdefaultRRtdeprecationMessaget endpointTypetparsertplugin((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR#<s&      cC`srt|d|\}}}t|tk rF|}|j|||S|}|d |d}t||||S(s Underlying implementation of L{serverFromString} which avoids exposing the deprecated 'default' argument to anything but L{strports.service}. iiN(R#RRAtstrR%t_endpointServerFactories(RgR8RNt nameOrPluginRRRRtname((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt_serverFromStringLegacylscC`st||tS(s2 Construct a stream server endpoint from an endpoint description string. The format for server endpoint descriptions is a simple string. It is a prefix naming the type of endpoint, then a colon, then the arguments for that endpoint. For example, you can call it like this to create an endpoint that will listen on TCP port 80:: serverFromString(reactor, "tcp:80") Additional arguments may be specified as keywords, separated with colons. For example, you can specify the interface for a TCP server endpoint to bind to like this:: serverFromString(reactor, "tcp:80:interface=127.0.0.1") SSL server endpoints may be specified with the 'ssl' prefix, and the private key and certificate files may be specified by the C{privateKey} and C{certKey} arguments:: serverFromString(reactor, "ssl:443:privateKey=key.pem:certKey=crt.pem") If a private key file name (C{privateKey}) isn't provided, a "server.pem" file is assumed to exist which contains the private key. If the certificate file name (C{certKey}) isn't provided, the private key file is assumed to contain the certificate as well. You may escape colons in arguments with a backslash, which you will need to use if you want to specify a full pathname argument on Windows:: serverFromString(reactor, "ssl:443:privateKey=C\:/key.pem:certKey=C\:/cert.pem") finally, the 'unix' prefix may be used to specify a filesystem UNIX socket, optionally with a 'mode' argument to specify the mode of the socket file created by C{listen}:: serverFromString(reactor, "unix:/var/run/finger") serverFromString(reactor, "unix:/var/run/finger:mode=660") This function is also extensible; new endpoint types may be registered as L{IStreamServerEndpointStringParser} plugins. See that interface for more information. @param reactor: The server endpoint will be constructed with this reactor. @param description: The strports description to parse. @return: A new endpoint which can be used to listen with the parameters given by by C{description}. @rtype: L{IStreamServerEndpoint} @raise ValueError: when the 'description' string cannot be parsed. @since: 10.2 (RWRJ(RgR8((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR%}sRtKeyError(RR$((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt_parseClientTCPs(     cC`sddlm}i}x|jD]}|jjddjdksTq#ny|j}Wntk rzq#nXy|jj |}Wn|j j k rq#X|j ||j RRRR[(RR$((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt_parseClientUNIX[s #  cC`st|\}}|jd}|j}x9ttD]+}|jj|kr:|j||Sq:W|tkrtd|fnt|||}t |||S(s Construct a client endpoint from a description string. Client description strings are much like server description strings, although they take all of their arguments as keywords, aside from host and port. You can create a TCP client endpoint with the 'host' and 'port' arguments, like so:: clientFromString(reactor, "tcp:host=www.example.com:port=80") or, without specifying host and port keywords:: clientFromString(reactor, "tcp:www.example.com:80") Or you can specify only one or the other, as in the following 2 examples:: clientFromString(reactor, "tcp:host=www.example.com:80") clientFromString(reactor, "tcp:www.example.com:port=80") or an SSL client endpoint with those arguments, plus the arguments used by the server SSL, for a client certificate:: clientFromString(reactor, "ssl:web.example.com:443:" "privateKey=foo.pem:certKey=foo.pem") to specify your certificate trust roots, you can identify a directory with PEM files in it with the C{caCertsDir} argument:: clientFromString(reactor, "ssl:host=web.example.com:port=443:" "caCertsDir=/etc/ssl/certs") Both TCP and SSL client endpoint description strings can include a 'bindAddress' keyword argument, whose value should be a local IPv4 address. This fixes the client socket to that IP address:: clientFromString(reactor, "tcp:www.example.com:80:" "bindAddress=192.0.2.100") NB: Fixed client ports are not currently supported in TCP or SSL client endpoints. The client socket will always use an ephemeral port assigned by the operating system You can create a UNIX client endpoint with the 'path' argument and optional 'lockfile' and 'timeout' arguments:: clientFromString(reactor, "unix:path=/var/foo/bar:lockfile=1:timeout=9") or, with the path as a positional argument with or without optional arguments as in the following 2 examples:: clientFromString(reactor, "unix:/var/foo/bar") clientFromString(reactor, "unix:/var/foo/bar:lockfile=1:timeout=9") This function is also extensible; new endpoint types may be registered as L{IStreamClientEndpointStringParser} plugins. See that interface for more information. @param reactor: The client endpoint will be constructed with this reactor. @param description: The strports description to parse. @return: A new endpoint which can be used to connect with the parameters given by by C{description}. @rtype: L{IStreamClientEndpoint} @since: 10.2 isUnknown endpoint type: %r( RBRRMRRR&tparseStreamClientt_clientParsersRt_endpointClientFactories(RgR8RR$tanameRVRR((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR$|sF  c`s,dtffdY}|j|S(s Connect a protocol instance to an endpoint. This allows using a client endpoint without having to create a factory. @param endpoint: A client endpoint to connect to. @param protocol: A protocol instance. @return: The result of calling C{connect} on the endpoint, i.e. a L{Deferred} that will fire with the protocol when connected, or an appropriate error. @since: 13.1 tOneShotFactoryc`seZfdZRS(c`sS(N((R:Rb(Ra(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR`s(R"R#R`((Ra(sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyRus(R R(RRaRu((RasL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyR3s(pRNt __future__RRRRRtzope.interfaceRRRGttwisted.python.compatRR RRRRR ttwisted.internet.protocolR R R R ttwisted.internet.interfacesRRttwisted.python.filepathRttwisted.python.systemdRttwisted.internet.abstractRttwisted.python.failureRttwisted.pythonRttwisted.internet.addressRRttwisted.python.componentsRRRttwisted.internet.taskRttwisted.pluginRRRttwisted.internet.stdioRttwisted.python.constantsRR R!tobjectt__all__t__all3__R4ROtIStreamServerEndpointR/t ITransporttIProcessTransportRlRrR2tIStreamClientEndpointR0RR&R'R(R)R1R,R-R*R+R.RRRRR!R"R'R/RKtrangeR7R6R=RBRTRsRJR#RWR%RZR\RkRoRpRrR$R3RVRtglobals(((sL/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/endpoints.pyt s    ("  OaB3%-H*3!*/ L1$   %     0  @ ! (  6   S