[XMc@sdZddlZddlZddlZddlZddlmZddlmZedkrddl m Z ddl m Z ddl mZdd l mZdd l mZe Zn(dd l m Z m Z mZmZmZdd lmZmZmZdd lmZmZmZddlmZmZmZdejfdYZ dddYZ!de!e fdYZ"dS(sp Various asynchronous UDP classes. Please do not use this module directly. Maintainer: Itamar Shtull-Trauring iN(t implements(t platformTypetwin32(tWSAEWOULDBLOCK(tWSAEINTR(t WSAEMSGSIZE(tWSAECONNREFUSED(t WSAECONNRESET(t EWOULDBLOCKtEINTRtEMSGSIZEt ECONNREFUSEDtEAGAIN(tbasetdefertaddress(tlogtreflecttfailure(tabstractterrort interfacestPortcBseZdZeejejejej Z ej Z dZ dZddddZdZdZdZd Zd Zd Zdd Zd ZdZdZdZdZddZdZdZdZ RS(s* UDP port, listening for packets. iiti cCsNtjj||||_||_||_||_|jd|_ dS(s> Initialize with a numeric port to listen on. N( R tBasePortt__init__tporttprotocolt maxPacketSizet interfacet setLogStrtNonet_connectedAddr(tselfRtprotoRRtreactor((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR6s     cCs;|jdk r&d|jj|jfSd|jjfSdS(Ns <%s on %s>s<%s not connected>(t_realPortNumberRRt __class__(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt__repr__BscCs|jS(s) Return a socket object. (tsocket(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt getHandleHscCs|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!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytstartListeningNs cCsy)|j}|j|j|jfWn1tjk r\}tj|j|j|fnX|jd|_t j d|j j |jfd|_ ||_|jj|_dS(Nis%s starting on %s(tcreateInternetSockettbindRRR'RtCannotListenErrort getsocknameR$RtmsgRR%t connectedtfileno(R!tskttle((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR)Xs    cCs|jj||jdS(N(RtmakeConnectiont startReading(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR*iscCsd}x||jkry|jj|j\}}Wntjk r}|jd}|tttfkrrdS|t kst dkr|t kr|j r|j jqqq X|t|7}y|j j||Wq tjq Xq WdS(s= Called when my socket is ready for reading. iNR(t maxThroughputR'trecvfromRRtargsR R RR RRR RtconnectionRefusedtlentdatagramReceivedRterr(R!treadtdatataddrtsetno((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytdoReadns" $ cCs|jr|d |jfks$ty|jj|SWqtjk r}|jd}|tkrs|j|S|t krtj dq|t kr|j j qqXn|d kst|djddj r |ddkr tjdtddny|jj||SWnmtjk r}|jd}|tkra|j||S|t kr|tj 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 RtAssertionErrorR'tsendRR9R twriteR tMessageLengthErrorR RR:treplacetisdigittwarningstwarntDeprecationWarningtsendto(R!tdatagramR@RARB((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyRHs8       -     cCs|jdj||dS(NR(RHtjoin(R!tseqR@((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt writeSequencescCsY|jrtdntj|s0tdn||f|_|jj||fdS(s- 'Connect' to remote server. s\already connected, reconnecting is not currently supported (talk to itamar if you want this)s/please pass only IP addresses, not domain namesN(R t RuntimeErrorRt isIPAddresst ValueErrorR'tconnect(R!thostR((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyRWs    cCs=|j|jr9ddlm}|jd|jndS(Ni(R#i(t stopReadingR1ttwisted.internetR#t callLatertconnectionLost(R!R#((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt_loseConnections  cCs3|jrtj}|_nd}|j|S(N(R1RtDeferredtdRR](R!tresult((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt stopListenings   cCs$tjdtdd|jdS(Ns-Please use stopListening() to disconnect portREi(RLRMRNRa(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytloseConnectionscCstjd|jd|_tjj|||jjd|_ |j j |` |` t |dr|jjd|`ndS(s& Cleans up my socket. s(Port %s Closed)iR_N(RR0R$RR RR\RtdoStopR1R'tcloseR2thasattrR_tcallback(R!treason((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR\s    cCs tj|jjd|_dS(Ns (UDP)(RtqualRR%tlogstr(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyRscCs|jS(sK Returns the name of my class, to prefix log entries with. (Ri(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt logPrefixscCstjd|jjS(si Returns an IPv4Address. This indicates the address from which I am connecting. tUDP(Rt IPv4AddressR'R/(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytgetHostsiN(!t__name__t __module__t__doc__RRtIListeningPortt IUDPTransportt ISystemHandleR'tAF_INETt addressFamilyt SOCK_DGRAMt socketTypeR7RR$RR&R(R+R)R*RCRHRSRWR]RaRbR\RRjRm(((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR&s2          /       tMulticastMixincBsweZdZdZdZdZdZdZdZdZ dd Z d Z d Z dd Z RS( s, Implement multicast functionality. cCs4|jjtjtj}tjtjd|S(Ns@i(R't getsockoptt IPPROTO_IPtIP_MULTICAST_IFt inet_ntoatstructtpack(R!ti((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytgetOutgoingInterfacescCs|jj|j|jS(sReturns Deferred of success.(R#tresolvet addCallbackt _setInterface(R!R@((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytsetOutgoingInterfacescCs/tj|}|jjtjtj|dS(Ni(R't inet_atont setsockoptRzR{(R!R@R((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyRscCs|jjtjtjS(N(R'RyRztIP_MULTICAST_LOOP(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytgetLoopbackMode scCs;tjdtj|}|jjtjtj|dS(Ntb(R}R~toperatorttruthR'RRzR(R!tmode((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytsetLoopbackModescCs|jjtjtjS(N(R'RyRztIP_MULTICAST_TTL(R!((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytgetTTLscCs2tjd|}|jjtjtj|dS(NtB(R}R~R'RRzR(R!tttl((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pytsetTTLsRcCs"|jj|j|j|dS(s4Join a multicast group. Returns Deferred of success.i(R#RRt _joinAddr1(R!R@R((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt joinGroupscCs"|jj|j|j||S(N(R#RRt _joinAddr2(R!R@RRQ((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyRscCstj|}tj|}|r0tj}n tj}y!|jjtj|||Wn2tjk r}tjtj |||j SXdS(N( R'RtIP_ADD_MEMBERSHIPtIP_DROP_MEMBERSHIPRRzRRtFailuretMulticastJoinErrorR9(R!RR@RQtcmdte((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR s  !cCs"|jj|j|j|dS(s2Leave multicast group, return Deferred of success.i(R#RRR(R!R@R((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt leaveGroup,s(RnRoRpRRRRRRRRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyRxs          t MulticastPortcBs9eZdZeejdddedZdZ RS(s. UDP Port that supports multicasting. Ri cCs)tj||||||||_dS(sX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N(RRtlistenMultiple(R!RR"RRR#R((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR8scCsctj|}|jr_|jtjtjdttdr_|jtjtjdq_n|S(Nit SO_REUSEPORT( RR,RRR't SOL_SOCKETt SO_REUSEADDRReR(R!R3((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR,?s  N( RnRoRpRRtIMulticastTransportRtFalseRR,(((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyR1s ((#RpR'RR}RLtzope.interfaceRttwisted.python.runtimeRterrnoRRRR RR RR RR RZR RRttwisted.pythonRRRRRRRRRxR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/udp.pyt s(      (8