ó [³XMc@sºdZddlZddlZddlZddlZddlmZmZmZm Z m Z ddl m Z m Z mZeedƒs˜edƒ‚nddlmZmZmZmZmZmZmZddlmZdd lmZmZmZmZd ej fd „ƒYZ d „Z!d e"fd„ƒYZ#de#ej$fd„ƒYZ$dej%fd„ƒYZ&dej'fd„ƒYZ(de#ej$fd„ƒYZ)de)fd„ƒYZ*dS(s˜ Various asynchronous TCP/IP classes. End users shouldn't use this module directly - use the reactor APIs instead. Maintainer: Itamar Shtull-Trauring iÿÿÿÿN(tEINTRtEMSGSIZEtEAGAINt EWOULDBLOCKt ECONNREFUSED(t implementstimplementsOnlyt implementedBytAF_UNIXs+UNIX sockets not supported on this platform(tbasettcptudpterrort interfacestprotocoltaddress(tCannotListenError(tlockfiletlogtreflecttfailuretServercBs#eZd„Zd„Zd„ZRS(cCs,tjj||||df|||ƒdS(N(R Rt__init__tNone(tselftsockRtclienttservert sessionnotreactor((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRscCstj|jjƒƒS(N(Rt UNIXAddresstsockett getsockname(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pytgetHost!scCstj|jƒS(N(RRthostname(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pytgetPeer$s(t__name__t __module__RR!R#(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRs  cCs|d dkS(s› Determine whether the given unix socket path is in a filesystem namespace. While most PF_UNIX sockets are entries in the filesystem, Linux 2.2 and above support PF_UNIX sockets in an "abstract namespace" that does not correspond to any path. This function returns C{True} if the given socket path is stored in the filesystem and C{False} if the path is in this abstract namespace. it((tpath((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt_inFilesystemNamespace)s t _UNIXPortcBseZd„ZRS(cCsFtjdkst|jƒr0|jjƒ}n |j}tj|ƒS(sMReturns a UNIXAddress. This indicates the server's address. ii(ii(tsyst version_infoR(tportRR RR(RR'((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR!7s (R$R%R!(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR)6stPortcBsheZejZejZeZd Z ddd dd„Z d„Z d„Z d„Zd„Zd„ZRS( i2i¶icCs5tjj||||d|ƒ||_||_dS(NR(R R-RtmodetwantPID(RtfileNametfactorytbacklogR.RR/((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRMs cCsDtj|jjƒ}t|dƒr5d||jfSd|fSdS(NRs <%s on %r>s<%s (not listening)>(RtqualR1t __class__thasattrR,(Rt factoryName((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt__repr__RscCs tj|ƒS(N(RR(Rtname((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt _buildAddrYscCs‹tjd|jjt|jƒfƒ|jrÀtj|jdƒ|_ |j j ƒsot d|jdf‚qÀ|j j sÀy5tjtj|jƒjƒr¯tj|jƒnWq½q½XqÀn|jjƒy |jƒ}|j|jƒWn+tjk r}t d|j|f‚nmXt|jƒrCtj|j|jƒn|j|jƒt|_||_|jj|_d|_ |j!ƒdS(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. s%s starting on %rs.locksCannot acquire lockidN("RtmsgR1R4treprR,R/RtFilesystemLocktlockFiletlockRRtcleantstattS_ISSOCKtostst_modetremovetdoStarttcreateInternetSockettbindRR R(tchmodR.tlistenR2tTruet connectedtfilenot numberAcceptst startReading(Rtskttle((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pytstartListening\s2&        cCs!tjdt|jƒfƒdS(s0 Log message for closing socket s(UNIX Port %s Closed)N(RR:R;R,(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt_logConnectionLostMsg†scCsXt|jƒr"tj|jƒn|jdk rA|jjƒntjj ||ƒdS(N( R(R,RBtunlinkR=RtunlockR R-tconnectionLost(Rtreason((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRUs N(R$R%RRt addressFamilyt SOCK_STREAMt socketTypeRt transportRR=RR7R9RQRRRU(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR-Fs     * tClientcBsAeZdZejZejZddd„Z d„Z d„Z RS(sA client for Unix sockets.icCsx||_||_|_|rUtj|dƒ rU|jddtj|ƒ|ƒn|j|j |j ƒd|ƒdS(Ns.lock( t connectort realAddresstaddrRtisLockedt _finishInitRR t BadFileErrort doConnectRF(RtfilenameR\RtcheckPID((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR›s  "cCstj|jƒS(N(RRR^(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR#£scCs tjdƒS(N(RRR(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR!¦sN( R$R%t__doc__RRRWRXRYRRR#R!(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR[–s    t ConnectorcBs#eZd„Zd„Zd„ZRS(cCs/tjj||||ƒ||_||_dS(N(R t BaseConnectorRRRd(RRR1ttimeoutRRd((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR«s cCst|j||j|jƒS(N(R[RRRd(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt_makeTransport°scCstj|jƒS(N(RR(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pytgetDestination³s(R$R%RRiRj(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRfªs  t DatagramPortcBsfeZdZeejƒejZddd d„Z d„Z d„Z d„Z d d„Zd„ZRS( s*Datagram UNIX port, listening for packets.i i¶cCs/tjj|||d|d|ƒ||_dS(s.Initialize with address to listen on. t maxPacketSizeRN(R R-RR.(RR^tprotoRlR.R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR¾s"cCsDtj|jjƒ}t|dƒr5d||jfSd|fSdS(NRs <%s on %r>s<%s (not listening)>(RR3RR4R5R,(Rt protocolName((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR7ÅscCsÙtjd|jjt|jƒfƒy,|jƒ}|jrQ|j|jƒnWn.tj k r‚}t j d|j|f‚nX|jr´t |jƒr´t j|j|jƒnd|_||_|jj|_dS(Ns%s starting on %si(RR:RR4R;R,RFRGRR RRR(RBRHR.RKRL(RRORP((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt _bindSocketÍs&    cCsŠy|jj||ƒSWnltjk r…}|jd}|tkrU|j||ƒS|tkrptjd‚q†|tkrq†‚nXdS(sWrite a datagram.ismessage too longN( RtsendtoR targsRtwriteRtMessageLengthErrorR(RtdatagramRtsetno((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRrÜs    cCsštjdt|jƒƒtjj||ƒt|dƒrL|jj ƒnd|_ |j j ƒ|` |` t|dƒr–|jjdƒ|`ndS(sCleans up my socket. s(Port %s Closed)RitdN(RR:R;R,R tBasePortRUR5RtdoStopRKRtcloseRLRwtcallbackR(RRV((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRUîs  cCs tj|jjƒd|_dS(Ns (UDP)(RR3RR4tlogstr(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt setLogStrÿsN(R$R%ReRR tIUNIXDatagramTransportRRRWRRR7RoRrRUR}(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRk·s      tConnectedDatagramPortcBsieZdZeejeejƒŒddd d d„Z d„Z d„Z d„Z d„Zd„ZRS( s+ A connected datagram UNIX socket. i i¶cCsAt|tjƒst‚tj||||||ƒ||_dS(N(t isinstanceRtConnectedDatagramProtocoltAssertionErrorRkRt remoteaddr(RR^RmRlR.t bindAddressR((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR scCsLy+|jƒ|jj|jƒ|jƒWn|jtjƒƒnXdS(N(RoRtconnectRƒt_connectToProtocoltconnectionFailedRtFailure(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRQs  cCs$|jƒ|jj|ƒ|`dS(s£ Called when a connection fails. Stop listening on the socket. @type reason: L{Failure} @param reason: Why the connection failed. N(t stopListeningRR‡(RRV((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR‡s cCsÍd}xÀ||jkrÈy?|jj|jƒ\}}|t|ƒ7}|jj|ƒWq tjk r´}|jd}|t t t fkr’dS|t kr®|jj ƒqÅ‚q tjƒq Xq WdS(s= Called when my socket is ready for reading. iN(t maxThroughputRtrecvfromRltlenRtdatagramReceivedR RqRRRRtconnectionRefusedRtdeferr(RtreadtdataR^RuRv((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pytdoRead)s  cCs y|jj|ƒSWn…tjk r›}|jd}|tkrO|j|ƒS|tkrjtjd‚qœ|tkr†|j j ƒqœ|t kr•qœ‚nXdS(s# Write a datagram. ismessage too longN( RtsendR RqRRrRRsRRRŽR(RR‘RuRv((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRr?s      cCstj|jƒS(N(RRRƒ(R((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyR#VsN(R$R%ReRR tIUNIXDatagramConnectedTransportRR RxRRRQR‡R’RrR#(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyRs   (+ReRBR*R@RterrnoRRRRRtzope.interfaceRRRR5t ImportErrorttwisted.internetR R R R R RRttwisted.internet.errorRttwisted.pythonRRRRRR(tobjectR)R-t BaseClientR[RgRfRkR(((s9/usr/lib/python2.7/dist-packages/twisted/internet/unix.pyt s 0(4" P M