[XMc@sdZddlmZmZddlZddlmZmZmZddl m Z m Z ddl m Z ddlmZddlmZdd lmZd d d d ddddgZde fdYZde fdYZd efdYZd efdYZdefdYZdefdYZdefdYZdefdYZdddZdded Zd!ddddd"Z!ied#6ed$6e!d%6Z"e#d&\Z$Z%d'Z&d(Z'ied)6ed*6ed+6Z(ied)6ed*6ed+6Z)eZ*dd,Z+d-Z,d.Z-d/Z.d0Z/d1Z0d2Z1d3Z2ie/d)6e1d*6e2d+6Z3d4Z4dS(5s7 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(t implementstdirectlyProvidesN(t interfacestdeferterror(t ClientFactorytProtocol(t getPlugins(t!IStreamServerEndpointStringParser(t!IStreamClientEndpointStringParser(tFilePathtclientFromStringtserverFromStringtTCP4ServerEndpointtTCP4ClientEndpointtUNIXServerEndpointtUNIXClientEndpointtSSL4ServerEndpointtSSL4ClientEndpointt_WrappingProtocolcBsDeZdZdZdZdZdZdZdZRS(s1 Wrap another protocol in order to notify my user when a connection has been made. @ivar _connectedDeferred: The L{Deferred} that will callback with the C{wrappedProtocol} when it is connected. @ivar _wrappedProtocol: An L{IProtocol} provider that will be connected. cCs>||_||_tjj|jr:t|tjndS(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_wrappedProtocolRtIHalfCloseableProtocolt providedByR(tselftconnectedDeferredtwrappedProtocol((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt__init__,s     cCs*|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(RtmakeConnectiont transportRtcallback(R((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pytconnectionMade;scCs|jj|S(sM Proxy C{dataReceived} calls to our C{self._wrappedProtocol} (Rt dataReceived(Rtdata((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR DscCs|jj|S(sO Proxy C{connectionLost} calls to our C{self._wrappedProtocol} (RtconnectionLost(Rtreason((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR"KscCs|jjdS(sl Proxy L{IHalfCloseableProtocol.readConnectionLost} to our C{self._wrappedProtocol} N(RtreadConnectionLost(R((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR$RscCs|jjdS(sm Proxy L{IHalfCloseableProtocol.writeConnectionLost} to our C{self._wrappedProtocol} N(RtwriteConnectionLost(R((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR%Zs( t__name__t __module__t__doc__RRR R"R$R%(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR s     t_WrappingFactorycBs/eZdZeZdZdZdZRS(sD 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: An L{Deferred} that fires when the protocol is connected cCs"||_tjd||_dS(s. @param wrappedFactory: A provider of I{IProtocolFactory} whose buildProtocol method will be called and whose resulting protocol will be wrapped. @param canceller: An object that will be called to cancel the L{self._onConnection} L{Deferred} t cancellerN(t_wrappedFactoryRtDeferredt _onConnection(RtwrappedFactoryR*((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRps cCsDy|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(R+t buildProtocolR-terrbacktprotocol(Rtaddrtproto((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR/|s cCs|jj|dS(si Errback the C{self._onConnection} L{Deferred} when the client connection fails. N(R-R0(Rt connectorR#((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pytclientConnectionFaileds(R&R'R(RR1RR/R5(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR)cs   cBs3eZdZeejdddZdZRS(sr TCP server endpoint with an IPv4 configuration @ivar _reactor: An L{IReactorTCP} provider. @type _port: int @ivar _port: The port number on which to listen for incoming connections. @type _backlog: int @ivar _backlog: size of the listen queue @type _interface: str @ivar _interface: the hostname to bind to, defaults to '' (all) i2tcCs@||_||_tdddd|_||_||_dS(s @param reactor: An L{IReactorTCP} provider. @param port: The port number used listening @param backlog: size of the listen queue @param interface: the hostname to bind to, defaults to '' (all) tbacklogi2t interfaceR6N(t_reactort_porttdictt _listenArgst_backlogt _interface(RtreactortportR7R8((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs    cCs.tj|jj|j|d|jd|jS(sU Implement L{IStreamServerEndpoint.listen} to listen on a TCP socket R7R8(RtexecuteR9t listenTCPR:R=R>(RtprotocolFactory((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pytlistens  (R&R'R(RRtIStreamServerEndpointRRD(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR s cBs3eZdZeejdddZdZRS(s TCP client endpoint with an IPv4 configuration. @ivar _reactor: An L{IReactorTCP} provider. @type _host: str @ivar _host: The hostname to connect to as a C{str} @type _port: int @ivar _port: The port to connect to as C{int} @type _timeout: int @ivar _timeout: number of seconds to wait before assuming the connection has failed. @type _bindAddress: tuple @type _bindAddress: a (host, port) tuple of local address to bind to, or None. icCs1||_||_||_||_||_dS(sx @param reactor: An L{IReactorTCP} provider @param host: A hostname, used when connecting @param port: The port number, used when connecting @param timeout: number of seconds to wait before assuming the connection has failed. @param bindAddress: a (host, port tuple of local address to bind to, or None. N(R9t_hostR:t_timeoutt _bindAddress(RR?thostR@ttimeoutt bindAddress((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs    csnfd}yJt||}|jj|j|j|d|jd|j|jSWntj SXdS(sP Implement L{IStreamClientEndpoint.connect} to connect via TCP. cs*j|jtjjdS(N(tstopConnectingR0RtConnectingCancelledErrortgetDestination(tdeferred(R4(s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt _cancellers RJRKN( R)R9t connectTCPRFR:RGRHR-Rtfail(RRCRPtwf((R4s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pytconnects  N( R&R'R(RRtIStreamClientEndpointtNoneRRT(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs cBs3eZdZeejdddZdZRS(sS SSL secured TCP server endpoint with an IPv4 configuration. @ivar _reactor: An L{IReactorSSL} provider. @type _host: str @ivar _host: The hostname to connect to as a C{str} @type _port: int @ivar _port: The port to connect to as C{int} @type _sslContextFactory: L{OpenSSLCertificateOptions} @var _sslContextFactory: SSL Configuration information as an L{OpenSSLCertificateOptions} @type _backlog: int @ivar _backlog: size of the listen queue @type _interface: str @ivar _interface: the hostname to bind to, defaults to '' (all) i2R6cCs1||_||_||_||_||_dS(s @param reactor: An L{IReactorSSL} provider. @param port: The port number used listening @param sslContextFactory: An instance of L{twisted.internet._sslverify.OpenSSLCertificateOptions}. @param timeout: number of seconds to wait before assuming the connection has failed. @param bindAddress: a (host, port tuple of local address to bind to, or None. N(R9R:t_sslContextFactoryR=R>(RR?R@tsslContextFactoryR7R8((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs    c Cs7tj|jj|j|d|jd|jd|jS(sf Implement L{IStreamServerEndpoint.listen} to listen for SSL on a TCP socket. tcontextFactoryR7R8(RRAR9t listenSSLR:RWR=R>(RRC((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRD%s   (R&R'R(RRRERRD(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs cBs3eZdZeejdddZdZRS(s SSL secured TCP client endpoint with an IPv4 configuration @ivar _reactor: An L{IReactorSSL} provider. @type _host: str @ivar _host: The hostname to connect to as a C{str} @type _port: int @ivar _port: The port to connect to as C{int} @type _sslContextFactory: L{OpenSSLCertificateOptions} @var _sslContextFactory: SSL Configuration information as an L{OpenSSLCertificateOptions} @type _timeout: int @ivar _timeout: number of seconds to wait before assuming the connection has failed. @type _bindAddress: tuple @ivar _bindAddress: a (host, port) tuple of local address to bind to, or None. icCs:||_||_||_||_||_||_dS(s @param reactor: An L{IReactorSSL} provider. @param host: A hostname, used when connecting @param port: The port number, used when connecting @param sslContextFactory: SSL Configuration information as An instance of L{OpenSSLCertificateOptions}. @param timeout: number of seconds to wait before assuming the connection has failed. @param bindAddress: a (host, port tuple of local address to bind to, or None. N(R9RFR:RWRGRH(RR?RIR@RXRJRK((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRLs     c stfd}yPt||}|jj|j|j||jd|jd|j|jSWnt j SXdS(sb Implement L{IStreamClientEndpoint.connect} to connect with SSL over TCP. cs*j|jtjjdS(N(RLR0RRMRN(RO(R4(s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRPfs RJRKN( R)R9t connectSSLRFR:RWRGRHR-RRR(RRCRPRS((R4s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRTas  N( R&R'R(RRRURVRRT(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR2s cBs6eZdZeejddddZdZRS(s- UnixSocket server endpoint. @type path: str @ivar path: a path to a unix socket on the filesystem. @type _listenArgs: dict @ivar _listenArgs: A C{dict} of keyword args that will be passed to L{IReactorUNIX.listenUNIX} @var _reactor: An L{IReactorTCP} provider. i2iicCs1||_||_||_||_||_dS(sC @param reactor: An L{IReactorUNIX} provider. @param address: The path to the Unix socket file, used when listening @param listenArgs: An optional dict of keyword args that will be passed to L{IReactorUNIX.listenUNIX} @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(R9t_addressR=t_modet_wantPID(RR?taddressR7tmodetwantPID((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs    c Cs7tj|jj|j|d|jd|jd|jS(sW Implement L{IStreamServerEndpoint.listen} to listen on a UNIX socket. R7R`Ra(RRAR9t listenUNIXR\R=R]R^(RRC((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRDs   (R&R'R(RRRERRD(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRvs  cBs3eZdZeejdddZdZRS(s UnixSocket client endpoint. @type _path: str @ivar _path: a path to a unix socket on the filesystem. @type _timeout: int @ivar _timeout: number of seconds to wait before assuming the connection has failed. @type _checkPID: bool @ivar _checkPID: if True, check for a pid file to verify that a server is listening. @var _reactor: An L{IReactorUNIX} provider. iicCs(||_||_||_||_dS(s\ @param reactor: An L{IReactorUNIX} provider. @param path: The path to the Unix socket file, used when connecting @param timeout: number of seconds to wait before assuming the connection has failed. @param checkPID: if True, check for a pid file to verify that a server is listening. N(R9t_pathRGt _checkPID(RR?tpathRJtcheckPID((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs   cshfd}yDt||}|jj|j|d|jd|j|jSWntjSXdS(sa Implement L{IStreamClientEndpoint.connect} to connect via a UNIX Socket cs*j|jtjjdS(N(RLR0RRMRN(RO(R4(s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRPs RJRfN( R)R9t connectUNIXRcRGRdR-RRR(RRCRPRS((R4s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRTs     (R&R'R(RRRURRT(((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyRs R6i2cCs*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}. R8R7(tint(tfactoryR@R8R7((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt _parseTCPst666cCs@||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}. iR`R7Ra(Rhtbool(RiR_R`R7tlockfile((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt _parseUNIXs  s server.pemc Csddlm}|dkr%|}ni}|dk rPt|j||d/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt _parseSSLs#   ttcptunixRoiccsd}d}idd6dd6}t|}xl|D]d}||krnt|fVt|fVd}||}q3|dkr||j7}q3||7}q3Wt|fVdS(s~ Tokenize a strports string and yield each token. @param description: a string as described by L{serverFromString} or L{clientFromString}. @return: an iterable of 2-tuples of (L{_OP} or L{_STRING}, string). Tuples starting with L{_OP} will contain a second element of either ':' (i.e. 'next parameter') or '=' (i.e. 'assign parameter value'). For example, the string 'hello:greet\=ing=world' would result in a generator yielding these values:: _STRING, 'hello' _OP, ':' _STRING, 'greet=ing' _OP, '=' _STRING, 'world' R6s:=t:t=s\N(titert_STRINGt_OPtnext(t descriptiontcurrenttopstnextOpstn((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt _tokenizeJs       csgifd}d}xUt|D]G\}}|tkrZ||f7}q2|dkr2||d}q2q2W||fS(s Convert a description string into a list of positional and keyword parameters, using logic vaguely like what Python does. @param description: a string as described by L{serverFromString} or L{clientFromString}. @return: a 2-tuple of C{(args, kwargs)}, where 'args' is a list of all ':'-separated C{str}s not containing an '=' and 'kwargs' is a map of all C{str}s which do contain an '='. For example, the result of C{_parse('a:b:d=1:c')} would be C{(['a', 'b', 'c'], {'d': '1'})}. cs<t|dkr&j|dn|d|d/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pytadd}sR|(((RR(RRRttypetvalue((RRws>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt_parseos      tTCPRstUNIXc Cs.t|\}}| s2t|dkr| rd|f}|d krmd}tj|dtddn|tkrt|n|g|dd+n|d}tj |}|d kr x4t t D]&}|j |kr||d|fSqWtd|fn|j f|||d|S( s Parse a stports description into a 2-tuple of arguments and keyword values. @param description: A description in the format explained by L{serverFromString}. @type description: C{str} @param factory: A 'factory' argument; this is left-over from twisted.application.strports, it's not really used. @type factory: L{IProtocolFactory} or L{None} @param default: Deprecated argument, specifying the default parser mode to use for unqualified description strings (those which do not have a ':' and prefix). @type default: C{str} or C{NoneType} @return: a 3-tuple of (plugin or name, arguments, keyword arguments) isoUnqualified strport description passed to 'service'.Use qualified endpoint descriptions; for example, 'tcp:%s'.Rztcategoryt stackleveliisUnknown endpoint type: '%s'N(RRRVtwarningstwarntDeprecationWarningt _NO_DEFAULTt ValueErrort_serverParserstgetRRtprefixtupper( RRitdefaultRRwtdeprecationMessaget endpointTypetparsertplugin((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt _parseServers&      cCsrt|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(RRVRtstrtparseStreamServert_endpointServerFactories(R?RRt nameOrPluginRRwRtname((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt_serverFromStringLegacyscCst||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 (RR(R?R((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR s/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pytquoteStringArgumentscKsDt|d|d/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt_parseClientTCP<s  cCsddlm}i}x|jD]}|jjddjdksTq#ny|j}Wntk rzq#nXy|jj |}Wn|j j k rq#X|j ||j /usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt_loadCAsFromDirNs % c Ks,ddlm}t|}|jdd }|jdd }|jdd }|d k r|jjt|jj }nd }|d k r|j jt|jj j }nd }|d k rt }t t|}n t}d }|jd|jjd|d|d|d ||d <|S( sX Perform any argument value coercion necessary for SSL client parameters. Valid keyword arguments to this function are all L{IReactorSSL.connectSSL} arguments except for C{contextFactory}. Instead, C{certKey} (the path name of the certificate file) C{privateKey} (the path name of the private key associated with the certificate) are accepted and used to construct a context factory. @param caCertsDir: The one parameter which is not part of L{IReactorSSL.connectSSL}'s signature, this is a path name used to construct a list of certificate authority certificates. The directory will be scanned for files ending in C{.pem}, all of which will be considered valid certificate authorities for this connection. @type caCertsDir: C{str} @return: The coerced values as a C{dict}. i(RoRvRut caCertsDirtmethodt certificatetverifyRRXN(RqRoRtpopRVRRR RRtPrivateCertificateRutTrueRtFalsetCertificateOptionsRst SSLv23_METHOD(RRoRvRuRtcertx509RR((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt_parseClientSSLms2         cKsgy#tt|jd|d/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt_parseClientUNIXs #  cCst|\}}|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, since even the simplest client endpoint (plain TCP) requires at least 2 arguments (host and port) to construct. 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 an SSL client endpoint with those arguments, plus the arguments used by the server SSL, for a client certificate:: clientFromString(reactor, "ssl:host=web.example.com:port=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") 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( RRRRR RtparseStreamClientt_clientParsersRt_endpointClientFactories(R?RRRtanameRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyR s(  (5R(tzope.interfaceRRRRqRRRttwisted.internet.protocolRRttwisted.pluginRttwisted.internet.interfacesRR ttwisted.python.filepathR t__all__RR)tobjectR RRRRRRjRRnRVRyRtrangeRRRRRRRRRR RRRRRRR (((s>/usr/lib/python2.7/dist-packages/twisted/internet/endpoints.pyt sh  C1+;8D.8 ,   %     -  @ !   4