CMc@s1dZddlZddlZddlZddlZddlZddlmZmZyddl m Z Wne k rdZ nXddl mZddlmZmZedkreZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZ ddlm!Z"ddlm#Z$ddlm%Z&ddlm'Z(eZ)eZ*eZ+dd lmZ,ddl-m.Z/nddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm"Z"ddlm$Z$ddlm&Z&ddlm(Z(ddlm)Z)ddlm*Z*dd lm+Z+dd!lm,Z,dd"lm/Z/dd#lm0Z0dd$l1m2Z2m3Z3m4Z4dd%l5m6Z6dd&lm7Z7m8Z8m9Z9dd'l:m;Z;dd(l<m=Z=dd)l1m>Z>m?Z?m@Z@mAZAd*efd+YZBd,d=d-YZCd.efd/YZDid0ZEd1e>jFeBfd2YZGe reeGe@jHnd3eGfd4YZId5eIfd6YZJd7eGfd8YZKd9e2jLeBfd:YZMd;e2jNfd<YZOdS(>s Various asynchronous TCP/IP classes. End users shouldn't use this module directly - use the reactor APIs instead. Maintainer: Itamar Shtull-Trauring iN(t implementstclassImplements(tSSL(t platformType(tversionst deprecatetwin32(t WSAEINVAL(tWSAEWOULDBLOCK(tWSAEINPROGRESS(t WSAEALREADY(t WSAECONNRESET(t WSAEISCONN(t WSAENOTCONN(tWSAEINTR(t WSAENOBUFS(t WSAEMFILE(t formatError(tEPERM(tEINVAL(t EWOULDBLOCK(t EINPROGRESS(tEALREADY(t ECONNRESET(tEISCONN(tENOTCONN(tEINTR(tENOBUFS(tEMFILE(tENFILE(tENOMEM(tEAGAIN(t ECONNABORTED(tstrerror(t errorcode(tbasetaddresstfdesc(t deferLater(tlogtfailuretreflect(t unsignedID(tCannotListenError(tabstracttmaint interfacesterrort _SocketClosercBseZdZdZRS(tshutdowncCsc|j}yt||jdWntjk r9nXy|jWntjk r^nXdS(Ni(tsockettgetattrt_socketShutdownMethodR/tclose(tselftskt((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt _closeSocketVs (t__name__t __module__R4R8(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyR0Sst _TLSMixincBseZdZdZdZeZZdZdZ dZ dZ dZ dZ dZd Zd Zd Zd Zd ZRS(t sock_shutdownicCs |jjS(N(R2tget_peer_certificate(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pytgetPeerCertificateoscCs|jrtjS|jr/d|_|jnytj|SWntjk rZtjStj k rndStj k rd|_ tj |tj |dStjk r\}}|dkr|dks|dkrtjStjtjStjk r}|SXdS(NiiisUnexpected EOF(t disconnectedR-tCONNECTION_DONEtwriteBlockedOnReadt_resetReadWritet ConnectiontdoReadRtZeroReturnErrort WantReadErrortWantWriteErrortreadBlockedOnWritet startWritingt stopReadingt SysCallErrortCONNECTION_LOSTR'terrtError(R6tretvaltdescte((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRDrs0         cCsR|jr|jS|jr&|jS|jrEd|_|jntj|S(Ni(R?t_postLoseConnectiont_writeDisconnectedt_closeWriteConnectionRHRBRCtdoWrite(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRUs      cCsytj||SWntjk r+dStjk rbd|_tj|tj|dStjk ryt j Stj k r}|ddkr|dkrdSt j Sntj k r}|SXdS(Niiit( RCt writeSomeDataRRGRFRAt stopWritingt startReadingRER-RLRKRN(R6tdataRQ((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRWs"    cCs;t|_t|jdr1|jjtjn|jS(s Gets called after loseConnection(), after buffered data is sent. We try to send an SSL shutdown alert, but if it doesn't work, retry when the socket is writable. t set_shutdown(tTrueR?thasattrR2R[RtRECEIVED_SHUTDOWNt_sendCloseAlert(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRRs cCs(ytj|jjdWn7tk rV}|jdtttfkrOdSt j SXyt |jdr|jj }|jj |tjB|jj}|tj@s|jj tjqn|jjt}Wntjk r}|SX|r |jt jS|j|jdSdS(NRViR[(tostwriteR2tfilenotOSErrortargsRRRR-RLR]t get_shutdownR[RR^R1t SENT_SHUTDOWNR\RNRXR@RIRYtNone(R6tset laststatetdoneRQ((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyR_s.     cCs,|j}|tjkr(tj|S|S(N(R_R-R@RCRT(R6tresult((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRT!s  cCs#t|_|jstj|SdS(N(R\t _userWantReadRHRCRY(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRY)s  cCs#t|_|jstj|SdS(N(tFalseRlRARCRJ(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRJ.s  cCs#t|_|jstj|SdS(N(R\t_userWantWriteRARCRI(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRI3s  cCs#t|_|jstj|SdS(N(RmRnRHRCRX(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRX8s  cCsD|jr|jn |j|jr6|jn |jdS(N(RnRIRXRlRYRJ(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRB=s      (R9R:R4RARHR\RlRnR>RDRURWRRR_RTRYRJRIRXRB(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyR;hs    *    A     t _TLSDelayedcBseZdZdZRS(s State tracking record for TLS startup parameters. Used to remember how TLS should be started when starting it is delayed to wait for the output buffer to be flushed. @ivar bufferedData: A C{list} which contains all the data which was written to the transport after an attempt to start TLS was made but before the buffers outstanding at that time could be flushed and TLS could really be started. This is appended to by the transport's write and writeSequence methods until it is possible to actually start TLS, then it is written to the TLS-enabled transport. @ivar context: An SSL context factory object to use to start TLS. @ivar extra: An extra argument to pass to the transport's C{startTLS} method. cCs||_||_||_dS(N(t bufferedDatatcontexttextra(R6RpRqRr((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt__init__^s  (R9R:t__doc__Rs(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRoLscCs:||kr2dt|fdY}|||(RRR*(R6R((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt__repr__sN(R9R:RtRgRsRRR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRs    tServercBs>eZdZdZdZddZdZdZRS(s Serverside socket-stream connection class. This is a serverside network connection transport; a socket which came from an accept() on a server. cCstj||||||_||_||_|d|_d|jjj||jf|_ d|jjj|j|jj f|_ |j d|_ dS(s  Server(sock, protocol, client, server, sessionno) Initialize it with a socket, a protocol, a descriptor for my peer (a tuple of host, port describing the other end of the connection), an instance of Port, and a session number. is%s,%s,%ss<%s #%s on %s>iN(RCRstserverRt sessionnothostnameR}RR9Rt_realPortNumbertrepstrRYR(R6tsockR}RRRRz((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRss     cCs|jS(s4A string representation of this connection. (R(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRsicCs?tj|||r;|r+|jjq;|jjndS(N(RCRR2RR(R6RR((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRscCstjd|jjS(sNReturns an IPv4Address. This indicates the server's address. R(R$RR2R(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyR scCstjd|jS(sNReturns an IPv4Address. This indicates the client's address. R(R$RR(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRs(R9R:RtRsRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRs     tPortcBseZdZeejejZej Z e Z dZ dZdZdZddddZdZdZdZdZd Zejejd ZeZd Zd Zd Z dZ!RS(s A TCP server port, listening for connections. When a connection is accepted, this will call a factory's buildProtocol with the incoming address as an argument, according to the specification described in L{twisted.internet.interfaces.IProtocolFactory}. If you wish to change the sort of transport that will be used, the C{transport} attribute will be called with the signature expected for C{Server.__init__}, so it can be replaced. @ivar deferred: a deferred created when L{stopListening} is called, and that will fire when connection is lost. This is not to be used it directly: prefer the deferred returned by L{stopListening} instead. @type deferred: L{defer.Deferred} @ivar disconnecting: flag indicating that the L{stopListening} method has been called and that no connections should be accepted anymore. @type disconnecting: C{bool} @ivar connected: flag set once the listen has successfully been called on the socket. @type connected: C{bool} iRVi2cCs>tjj|d|||_||_||_||_dS(s5Initialize with a numeric port to listen on. RzN(R#tBasePortRsRtfactorytbacklogt interface(R6RRRRRz((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRsBs    cCsG|jdk r,d|j|jj|jfSd|j|jjfSdS(Ns<%s of %s on %s>s<%s of %s (not listening)>(RRgRR(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRKs cCsMtjj|}tdkrItjdkrI|jtjtj dn|S(Ntposixtcygwini( R#RRRtsystplatformRR2Rt SO_REUSEADDR(R6R((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRRscCsy)|j}|j|j|jfWn.tjk rY}t|j|j|fnX|jd|_t j d|j j |jf|j j |j|jt|_||_|jj|_d|_|jdS(sCreate 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. is%s starting on %sidN(RRRRR2R/R+RRR'tmsgRRtdoStarttlistenRR\RRbt numberAcceptsRY(R6R7tle((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pytstartListeningYs      cCs|\}}tjd||S(NR(R$t_ServerFactoryIPv4Address(R6t.1RR((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt _buildAddrws c Csytdkr|j}nd}xxt|D]Z}|jrAdSy|jj\}}Wntjk r}|jdtt fkr||_Pn^|jdt krq.nE|jdt t t ttfkrtjdt|jdfPnnXtj|j|jj|j|}|dkrD|jq.n|j}|d|_|j||||||j}|j|q.W|jd|_WntjnXdS(sCalled when my socket is ready for reading. This accepts a connection and calls self.protocol() to handle the wire-level protocol. RiNis$Could not accept new connection (%s)i( RRtranget disconnectingR2tacceptR/RdRRRRRRRR R'RR"R%RRbRRRRgR5Rt transportRzRtdeferr( R6t numAcceptstiR7RRQR}RR((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRD{s@    "     !cCsEt|_|j|jrAt|jd|j||_|jSdS(s Stop accepting connections on this port. This will shut down the socket and call self.connectionLost(). It returns a deferred which will fire successfully when the port is actually closed, or with a failure if an error occurs shutting down. iN(R\RRJRR&RzRtdeferred(R6tconnDone((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pytloseConnections    cCstjd|jfdS(s. Log message for closing port s(TCP Port %s Closed)N(R'RR(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt_logConnectionLostMsgscCsg|jd|_tjj||t|_|j|` |` z|j j Wdt|_ XdS(s' Cleans up the socket. N(RRgRR#RRRmRR8R2RbRtdoStopR(R6R((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRs    cCstj|jjS(sBReturns the name of my class, to prefix log entries with. (R)tqualRR(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRscCstjd|jjS(sNReturns an IPv4Address. This indicates the server's address. R(R$RR2R(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRsN("R9R:RtRR.tIListeningPortR2RRRRRRRRRRgRRsRRRRRDR(RR-R@Rt stopListeningRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRs*        G   t ConnectorcBs&eZddZdZdZRS(cCs||_t|tjriytj|d}Wqitjk re}tjdd||fqiXn||_||_ t j j ||||dS(NttcpRs%s (%r)( Rt isinstancettypest StringTypesR2t getservbynameR/tServiceNameUnknownErrorRRR#t BaseConnectorRs(R6RRRttimeoutRRzRQ((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRss #  cCs"t|j|j|j||jS(N(RRRRRz(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt_makeTransportscCstjd|j|jS(NR(R$RRR(R6((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pytgetDestination sN(R9R:RgRsRR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyRs ((PRtR`RR2RRtzope.interfaceRRtOpenSSLRt ImportErrorRgttwisted.python.runtimeRttwisted.pythonRRtobjectRterrnoRRRRR RR RR RR RR RRRRRRRRRRR ttwisted.python.win32RR!R"ttwisted.internetR#R$R%ttwisted.internet.taskR&R'R(R)ttwisted.python.utilR*ttwisted.internet.errorR+R,R-R.R/R0R;RoRyR{RCt ITLSTransportRRRRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/internet/tcp.pyt s           " ,;