>Mc@s?dZddlmZmZmZmZddlmZddlm Z m Z m Z ddl m Z ddlZddlZddlZddlZddlZddlmZddlmZdd lmZdd lmZdd lmZmZd ejfd YZdfdYZdeefdYZ dS(s UDP support for IOCP reactor i(tdefertaddressterrort interfaces(t isIPAddress(tlogtreflecttfailure(t implementsN(tERROR_IO_PENDING(tERROR_CONNECTION_REFUSED(tERROR_PORT_UNREACHABLE(tIReadWriteHandle(t iocpsupporttabstracttPortcBs eZdZeeejejeje j Z e j Z eZdZddddZdZdZdZdZdZd Zd Zd Zd Zdd ZdZdZdZdZ dZ!ddZ"dZ#dZ$dZ%RS(s* UDP port, listening for packets. ti cCs||_||_||_||_|jd|_tjj ||t j |j |j }t j|j}t j||_t jtjd|_dS(s> Initialize with a numeric port to listen on. tiN(tporttprotocoltreadBufferSizet interfacet setLogStrtNonet_connectedAddrRt FileHandlet__init__tsockett addressFamilyt socketTypet_iocpt maxAddrLentfilenotAllocateReadBuffert addressBuffertstructtcalcsizetaddressLengthBuffer(tselfRtprotoRt maxPacketSizetreactortskttaddrLen((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR(s      cCs;|jdk r&d|jj|jfSd|jjfSdS(Ns <%s on %s>s<%s not connected>(t_realPortNumberRRt __class__(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt__repr__>scCs|jS(s) Return a socket object. (R(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt getHandleFscCs|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&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytstartListeningMs cCs|jj|j|jS(N(R)t createSocketRR(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR3XscCsy)|j}|j|j|jfWn1tjk r\}tj|j|j|fnX|jd|_t j d|j j |jft |_||_|jj|_dS(Nis%s starting on %s(R3tbindRRRRtCannotListenErrort getsocknameR,RtmsgRR-tTruet connectedR t getFileHandle(R&R*tle((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR0\s    cCs.|jj||j|jj|dS(N(RtmakeConnectiont startReadingR)taddActiveHandle(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR1os cCs-|jr)|j||||jndS(N(treadingt handleReadtdoRead(R&trctbytestevt((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytcbReadus cCs|tjtjttfkr:|jr|jjqns|ritj dtj j |d|fnDy0|jj t |j| tj|jWntjnXdS(Nserror in recvfrom -- %s (%s)s unknown error(terrnotWSAECONNREFUSEDt WSAECONNRESETR R RRtconnectionRefusedRR7t errorcodetgettdatagramReceivedtstrtbuffRt makesockaddrt addr_buffterr(R&RBRCRD((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR@{s   cCstj|j|}|jd|_}|j|_}|j|_}tj |j ||||\}}|r|t kr|j |||ndS(Ni( RtEventREt _readBuffersRNR"RPR%t addr_len_bufftrecvfromR:R R@(R&RDRNRPRTRBRC((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRAscCs|jr|d|jfks$ty|jj|SWqtjk r}|jd}|tjkrv|j |S|tj krtj dq|tj tj ttfkr|jjqqXn|dkst|djddjstjdtddny|jj||SWntjk r}|jd}|tjkrk|j ||S|tj krtj dq|tj tj ttfkrdSnXdS( s~ Write a datagram. @param addr: should be a tuple (ip, port), can be None in connected mode. ismessage too longt.Rs.Please only pass IPs to write(), not hostnamest stackleveliN(RRtAssertionErrorRtsendRtargsRFtWSAEINTRtwritet WSAEMSGSIZEtMessageLengthErrorRGRHR R RRItreplacetisdigittwarningstwarntDeprecationWarningtsendto(R&tdatagramtaddrtsetno((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR\s<      cCs|jdj||dS(NR(R\tjoin(R&tseqRf((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt writeSequencescCsY|jrtdnt|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(Rt RuntimeErrorRt ValueErrorRtconnect(R&thostR((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRns    cCsM|j|jj||jrIddlm}|jd|jndS(Ni(R)i(t stopReadingR)tremoveActiveHandleR9ttwisted.internett callLatertconnectionLost(R&R)((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt_loseConnections   cCs3|jrtj}|_nd}|j|S(N(R9RtDeferredtdRRu(R&tresult((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt stopListenings   cCs$tjdtdd|jdS(Ns-Please use stopListening() to disconnect portRWi(RaRbRcRy(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytloseConnections  cCstjd|jd|_|jt|drF|jjnt|_ t |_ |j j |` |`t|dr|jjd|`ndS(s& Cleans up my socket. s(Port %s Closed)RRwN(RR7R,RRpthasattrRtdoStoptFalseR9R8t disconnectedRtcloseR:Rwtcallback(R&treason((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRts     cCs tj|jjd|_dS(Ns (UDP)(RtqualRR-tlogstr(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRscCs|jS(sK Returns the name of my class, to prefix log entries with. (R(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt logPrefixscCstjd|jjS(si Returns an IPv4Address. This indicates the address from which I am connecting. tUDP(Rt IPv4AddressRR6(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytgetHostsN(&t__name__t __module__t__doc__RR RtIListeningPortt IUDPTransportt ISystemHandleRtAF_INETRt SOCK_DGRAMRR}tdynamicReadBuffersRR,RR.R/R2R3R0R1RER@RAR\RkRnRuRyRzRtRRR(((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRs:            -       tMulticastMixincBsweZdZdZdZdZdZdZdZdZ dd Z d Z d Z dd Z RS( s, Implement multicast functionality. cCs4|jjtjtj}tjtjd|S(Ns@i(Rt getsockoptt IPPROTO_IPtIP_MULTICAST_IFt inet_ntoaR#tpack(R&R((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytgetOutgoingInterfacescCs|jj|j|jS(s. Returns Deferred of success. (R)tresolvet addCallbackt _setInterface(R&Rf((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytsetOutgoingInterface#scCs/tj|}|jjtjtj|dS(Ni(Rt inet_atont setsockoptRR(R&RfR((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR*scCs|jjtjtjS(N(RRRtIP_MULTICAST_LOOP(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytgetLoopbackMode0scCs;tjdtj|}|jjtjtj|dS(Ntb(R#RtoperatorttruthRRRR(R&tmode((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytsetLoopbackMode5scCs|jjtjtjS(N(RRRtIP_MULTICAST_TTL(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytgetTTL;scCs2tjd|}|jjtjtj|dS(NtB(R#RRRRR(R&tttl((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pytsetTTL@sRcCs"|jj|j|j|dS(sF Join a multicast group. Returns Deferred of success. i(R)RRt _joinAddr1(R&RfR((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt joinGroupEscCs"|jj|j|j||S(N(R)RRt _joinAddr2(R&RfRRi((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRMscCstj|}tj|}|r0tj}n tj}y!|jjtj|||Wn2tjk r}tjtj |||j SXdS(N( RRtIP_ADD_MEMBERSHIPtIP_DROP_MEMBERSHIPRRRRtFailuretMulticastJoinErrorRZ(R&RRfRitcmdte((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRRs  !cCs"|jj|j|j|dS(sD Leave multicast group, return Deferred of success. i(R)RRR(R&RfR((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyt leaveGroup`s(RRRRRRRRRRRRRR(((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRs          t MulticastPortcBs9eZdZeejdddedZdZ RS(s. UDP Port that supports multicasting. Ri cCs)tj||||||||_dS(N(RRtlistenMultiple(R&RR'RR(R)R((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRqscCsctj|}|jr_|jtjtjdttdr_|jtjtjdq_n|S(Nit SO_REUSEPORT( RR3RRRt SOL_SOCKETt SO_REUSEADDRR{R(R&R*((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyR3ws  N( RRRRRtIMulticastTransportRR}RR3(((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyRis  (!RRrRRRRttwisted.internet.abstractRttwisted.pythonRRRtzope.interfaceRRRR#RaRFt"twisted.internet.iocpreactor.constR R R t'twisted.internet.iocpreactor.interfacesR ttwisted.internet.iocpreactorR RRRRRR(((sD/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/udp.pyts"<Q