'Qc@`sdZddlmZmZddlZddlZddlZddlZddlm Z ddl m Z e dkrddl m Z ddl mZmZmZdd l mZmZmZdd l mZee eegZeeeegZeZeZe ZeZn@dd l mZmZmZmZmZeeegZegZdd lmZmZmZdd l m!Z!m"Z"ddlm#Z#m$Z$m%Z%e e%j&e%j'e%j(dej)fdYZ*dfdYZ+e e%j,de+e*fdYZ-dS(s Various asynchronous UDP classes. Please do not use this module directly. @var _sockErrReadIgnore: list of symbolic error constants (from the C{errno} module) representing socket errors where the error is temporary and can be ignored. @var _sockErrReadRefuse: list of symbolic error constants (from the C{errno} module) representing socket errors that indicate connection refused. i(tdivisiontabsolute_importN(t implementer(t platformTypetwin32(tWSAEWOULDBLOCK(tWSAEINTRt WSAEMSGSIZEt WSAETIMEDOUT(tWSAECONNREFUSEDt WSAECONNRESETt WSAENETRESET(tWSAEINPROGRESS(t EWOULDBLOCKtEINTRtEMSGSIZEt ECONNREFUSEDtEAGAIN(tbasetdefertaddress(tlogtfailure(tabstractterrort interfacestPortcB`seZdZejZejZdZdZ dZ ddddZ e dZdZdZd Zd Zd Zd Zdd ZdZdZdZdZdZddZdZdZdZRS(s  UDP port, listening for packets. @ivar maxThroughput: Maximum number of bytes read in one event loop iteration. @ivar _realPortNumber: Actual port number being listened on. The value will be C{None} until this L{Port} is listening. @ivar _preexistingSocket: If not C{None}, a L{socket.socket} instance which was created and initialized outside of the reactor and will be used to listen for connections (instead of a new socket being created by this L{Port}). iiti cC`sNtjj||||_||_||_||_|jd|_ dS(s @param port: A port number on which to listen. @type port: C{int} @param proto: A C{DatagramProtocol} instance which will be connected to the given C{port}. @type proto: L{twisted.internet.protocol.DatagramProtocol} @param interface: The local IPv4 or IPv6 address to which to bind; defaults to '', ie all IPv4 addresses. @type interface: C{str} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: C{int} @param reactor: A reactor which will notify this C{Port} when its socket is ready for reading or writing. Defaults to C{None}, ie the default global reactor. @type reactor: L{interfaces.IReactorFDSet} N( RtBasePortt__init__tporttprotocolt maxPacketSizet interfacet setLogStrtNonet_connectedAddr(tselfRtprotoR!R treactor((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRSs     c C`sVtj|||j}|jd}|d|d|d|d|}||_|S(s Create a new L{Port} based on an existing listening I{SOCK_DGRAM} socket. @param reactor: A reactor which will notify this L{Port} when its socket is ready for reading or writing. Defaults to C{None}, ie the default global reactor. @type reactor: L{interfaces.IReactorFDSet} @param fd: An integer file descriptor associated with a listening socket. The socket must be in non-blocking mode. Any additional attributes desired, such as I{FD_CLOEXEC}, must also be set already. @type fd: C{int} @param addressFamily: The address family (sometimes called I{domain}) of the existing socket. For example, L{socket.AF_INET}. @param addressFamily: C{int} @param protocol: A C{DatagramProtocol} instance which will be connected to the C{port}. @type proto: L{twisted.internet.protocol.DatagramProtocol} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: C{int} @return: A new instance of C{cls} wrapping the socket given by C{fd}. @rtype: L{Port} iR!R'R N(tsockettfromfdt socketTypet getsocknameR#t_preexistingSocket( tclsR'tfdt addressFamilyRR RR!R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt_fromListeningDescriptorqs   cC`s;|jdk r&d|jj|jfSd|jjfSdS(Ns <%s on %s>s<%s not connected>(t_realPortNumberR#Rt __class__(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt__repr__scC`s|jS(s) Return a socket object. (R((R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt getHandlescC`s|j|jdS(s Create and bind my socket, and begin listening on it. This is called on unserialization, and must be called after creating a server to begin listening on the specified port. N(t _bindSockett_connectToProtocol(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytstartListenings cC`s|jdkroy)|j}|j|j|jfWqtjk rk}tj|j|j|qXn|j}d|_|j d|_ t j d|j |j|j fd|_||_|jj|_dS(sJ Prepare and assign a L{socket.socket} instance to C{self.socket}. Either creates a new SOCK_DGRAM L{socket.socket} bound to C{self.interface} and C{self.port} or takes an existing L{socket.socket} provided via the L{interfaces.IReactorSocket.adoptDatagramPort} interface. is%s starting on %sN(R,R#tcreateInternetSockettbindR!RR(RtCannotListenErrorR+R1Rtmsgt _getLogPrefixRt connectedtfileno(R%tskttle((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyR5s  "     cC`s|jj||jdS(N(RtmakeConnectiont startReading(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyR6scC`sd}x||jkry|jj|j\}}Wn_tjk r}|jd}|tkridS|tkr|jr|j j ndSq X|t |7}y|j j ||Wq t jq Xq WdS(s= Called when my socket is ready for reading. iN(t maxThroughputR(trecvfromR Rtargst_sockErrReadIgnoret_sockErrReadRefuseR$RtconnectionRefusedtlentdatagramReceivedRterr(R%treadtdatataddrtsetno((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytdoReads$    cC`s|jr|d |jfks$ty|jj|SWqtjk r}|jd}|tkrs|j|S|t krtj dq|t kr|j j qqXn|d kst|djddj r|ddkrtjdtddny|jj||SWnptjk r}|jd}|tkrd|j||S|t krtj dq|t krd SnXd S( sz Write a datagram. @type datagram: C{str} @param datagram: The datagram to be sent. @type addr: C{tuple} containing C{str} as first element and C{int} as second element, or C{None} @param addr: A tuple of (I{stringified dotted-quad IP address}, I{integer port number}); can be C{None} in connected mode. ismessage too longt.Rs s.Please only pass IPs to write(), not hostnamest stackleveliN(R$R#tAssertionErrorR(tsendRRERtwriteRtMessageLengthErrorRRRHtreplacetisdigittwarningstwarntDeprecationWarningtsendto(R%tdatagramRNRORP((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRVs8       -     cC`s|jdj||dS(NR(RVtjoin(R%tseqRN((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt writeSequencescC`s_|jrtdntj|s6tdn||f|_|jj||fdS(s- 'Connect' to remote server. s:already connected, reconnecting is not currently supporteds/please pass only IP addresses, not domain namesN(R$t RuntimeErrorRt isIPAddresst ValueErrorR(tconnect(R%thostR((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRe!s  cC`s0|j|jr,|jjd|jndS(Ni(t stopReadingR=R't callLatertconnectionLost(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt_loseConnection,s  cC`s3|jrtj}|_nd}|j|S(N(R=RtDeferredtdR#Rj(R%tresult((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt stopListening1s   cC`s$tjdtdd|jdS(Ns-Please use stopListening() to disconnect portRSi(RZR[R\Rn(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytloseConnection9scC`stjd|jd|_tjj|||jj|j j |` |` t |dr~|j jd|` ndS(s& Cleans up my socket. s(UDP Port %s Closed)RlN(RR;R1R#RRRiRtdoStopR(tcloseR>thasattrRltcallback(R%treason((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRi=s   cC`s#|j|j}d||_dS(sP Initialize the C{logstr} attribute to be used by C{logPrefix}. s%s (UDP)N(R<Rtlogstr(R%t logPrefix((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyR"MscC`s|jS(s0 Return the prefix to log with. (Ru(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRvUscC`stjd|jjS(si Returns an IPv4Address. This indicates the address from which I am connecting. tUDP(Rt IPv4AddressR(R+(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytgetHost\siN(t__name__t __module__t__doc__R(tAF_INETR/t SOCK_DGRAMR*RCR#R1R,Rt classmethodR0R3R4R7R5R6RQRVRaReRjRnRoRiR"RvRy(((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyR9s0  '   "   /       tMulticastMixincB`sweZdZdZdZdZdZdZdZdZ dd Z d Z d Z dd Z RS( s, Implement multicast functionality. cC`s4|jjtjtj}tjtjd|S(Ns@i(R(t getsockoptt IPPROTO_IPtIP_MULTICAST_IFt inet_ntoatstructtpack(R%ti((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytgetOutgoingInterfacekscC`s|jj|j|jS(sReturns Deferred of success.(R'tresolvet addCallbackt _setInterface(R%RN((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytsetOutgoingInterfaceoscC`s/tj|}|jjtjtj|dS(Ni(R(t inet_atont setsockoptRR(R%RNR((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRsscC`s|jjtjtjS(N(R(RRtIP_MULTICAST_LOOP(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytgetLoopbackModexscC`s;tjdtj|}|jjtjtj|dS(Ntb(RRtoperatorttruthR(RRR(R%tmode((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytsetLoopbackMode{scC`s|jjtjtjS(N(R(RRtIP_MULTICAST_TTL(R%((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytgetTTLscC`s2tjd|}|jjtjtj|dS(NtB(RRR(RRR(R%tttl((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytsetTTLsRcC`s"|jj|j|j|dS(s4Join a multicast group. Returns Deferred of success.i(R'RRt _joinAddr1(R%RNR!((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt joinGroupscC`s"|jj|j|j||S(N(R'RRt _joinAddr2(R%RNR!R_((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRscC`stj|}tj|}|r0tj}n tj}y!|jjtj|||Wn2tjk r}tjtj |||j SXdS(N( R(RtIP_ADD_MEMBERSHIPtIP_DROP_MEMBERSHIPRRRRtFailuretMulticastJoinErrorRE(R%R!RNR_tcmdte((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRs  !cC`s"|jj|j|j|dS(s2Leave multicast group, return Deferred of success.i(R'RRR(R%RNR!((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyt leaveGroups(RzR{R|RRRRRRRRRRR(((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRfs          t MulticastPortcB`s,eZdZdddedZdZRS(s. UDP Port that supports multicasting. Ri cC`s)tj||||||||_dS(sX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N(RRtlistenMultiple(R%RR&R!R R'R((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRscC`sctj|}|jr_|jtjtjdttdr_|jtjtjdq_n|S(Nit SO_REUSEPORT( RR8RRR(t SOL_SOCKETt SO_REUSEADDRRrR(R%R?((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyR8s  N(RzR{R|R#tFalseRR8(((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pyRs(.R|t __future__RRR(RRRZtzope.interfaceRttwisted.python.runtimeRterrnoRRRRR R R R RFRGRRRRR ttwisted.internetRRRttwisted.pythonRRRRRtIListeningPortt IUDPTransportt ISystemHandleRRRtIMulticastTransportR(((sF/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/udp.pytsB        (   +8