ó iù™Nc@srdZddlZddlmZedkraddlmZddlmZddlm Z n0ddlmZdd lmZdd lm Z dd l m Z dd l mZdd lmZddlmZmZddlmZddlmZmZddlmZddd„ƒYZid„Zdefd„ƒYZdefd„ƒYZdefd„ƒYZ dS(sH This module implements OpenSSL socket BIO based TLS support. It is only used if memory BIO APIs are not available, which is when the version of pyOpenSSL installed is older than 0.10 (when L{twisted.protocols.tls} is not importable). This implementation is undesirable because of the complexity of working with OpenSSL's non-blocking socket-based APIs (which this module probably does about 99% correctly, but see #4455 for an example of a problem with it). Eventually, use of this module should emit a warning. See #4974 and 5014. @see: L{twisted.internet._newtls} @since: 11.1 iÿÿÿÿN(t platformTypetwin32(tWSAEINTR(tWSAEWOULDBLOCK(t WSAENOBUFS(tEINTR(t EWOULDBLOCK(tENOBUFS(tSSL(t implements(tlog(t ITLSTransportt ISSLTransport(tFileDescriptor(tCONNECTION_DONEtCONNECTION_LOST(t _TLSDelayedt _TLSMixincBseZdZdZdZeZZd„Zd„Z d„Z d„Z d„Z d„Z d„Zd „Zd „Zd „Zd „Zd „ZRS(t sock_shutdownicCs |jjƒS(N(tsockettget_peer_certificate(tself((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pytgetPeerCertificate1scCs|jr tS|jr,d|_|jƒny|jj|ƒSWnÊtjk rWtStjk rkdStj k r¨d|_ |jj |ƒ|jj |ƒdStj k rö\}}|dkrØ|dksä|dkrètStjƒtStjk r }|SXdS(NiiiÿÿÿÿsUnexpected EOF(t disconnectedRtwriteBlockedOnReadt_resetReadWritet_basetdoReadRtZeroReturnErrort WantReadErrortWantWriteErrortreadBlockedOnWritet startWritingt stopReadingt SysCallErrorRR terrtError(Rtretvaltdescte((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR4s0       cCsU|jr|jƒS|jr&|jƒS|jrEd|_|jƒn|jj|ƒS(Ni(Rt_postLoseConnectiont_writeDisconnectedt_closeWriteConnectionRRRtdoWrite(R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR+^s      cCsÓy|jj||ƒSWnµtjk r.dStjk rkd|_|jj|ƒ|jj|ƒdStjk rt Stj k r¸}|ddkr±|dkr±dSt Sntj k rÎ}|SXdS(Niiiÿÿÿÿt( Rt writeSomeDataRRRRt stopWritingt startReadingRRR"R$(RtdataR'((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR-us" cCs;t|_t|jdƒr1|jjtjƒn|jƒS(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(tTrueRthasattrRR1RtRECEIVED_SHUTDOWNt_sendCloseAlert(R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR(Œs cCs"ytj|jjƒdƒWn4tk rS}|jdtttfkrOdSt SXy„t |jdƒrÄ|jj ƒ}|jj |t jBƒ|jjƒ}|t j@s×|jj t jƒq×n|jjƒt}Wnt jk rñ}|SX|r|jƒtS|jƒ|jƒdSdS(NR,iR1(tostwriteRtfilenotOSErrortargsRRRRR3t get_shutdownR1RR4tshutdownt SENT_SHUTDOWNR2R$R.RR R/tNone(Rtset laststatetdoneR'((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR5¢s.     cCs,|jƒ}|tkr(|jj|ƒS|S(N(R5RRR*(Rtresult((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR*ãs  cCs&t|_|js"|jj|ƒSdS(N(R2t _userWantReadRRR/(R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR/ës  cCs0t|_|js|j r,|jj|ƒSdS(N(tFalseRCRRRR!(R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR!ñs cCs&t|_|js"|jj|ƒSdS(N(R2t_userWantWriteRRR (R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR ús  cCs0t|_|js|j r,|jj|ƒSdS(N(RDRERRRR.(R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR.s cCsD|jr|jƒn |jƒ|jr6|jƒn |jƒdS(N(RER R.RCR/R!(R((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR s      (t__name__t __module__t_socketShutdownMethodRRR2RCRERRR+R-R(R5R*R/R!R R.R(((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR*s    *    A    cs@ˆ|kr8dtˆf‡fd†ƒY}||ˆt bufferedDatatappendR R7(Rtbytes((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR7@scCs9|jdk r%|jjj|ƒntj||ƒdS(N(RRR>RZtextendR t writeSequence(Rtiovec((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR^GscCsttj|ƒ}|jdk rp|j rp|j rp|j}d|_|j|j|jƒ|j |j ƒqpn|S(N( R R+RRR>RPRQRXtcontextRWR^RZ(RRBtwaiting((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyR+Ns  N( RFRGt__doc__RNR>RRR2RXRSR7R^R+(((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyRM!s    t ClientMixincBs$eZdZeeƒdd„ZRS(sh Mixin for L{twisted.internet.tcp.Client} to implement the client part of L{ITLSTransport}. icCsB|jj|||ƒr>|r.|jjƒq>|jjƒndS(N(RRXRtset_connect_statetset_accept_state(RRVtclient((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyRXas(RFRGRbR R RX(((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyRcZs t ServerMixincBs$eZdZeeƒdd„ZRS(sh Mixin for L{twisted.internet.tcp.Client} to implement the server part of L{ITLSTransport}. icCsB|jj|||ƒr>|r.|jjƒq>|jjƒndS(N(RRXRReRd(RRVtserver((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyRXqs(RFRGRbR R RX(((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyRgjs ((!RbR6ttwisted.python.runtimeRterrnoRRRRRRtOpenSSLRtzope.interfaceR ttwisted.pythonR ttwisted.internet.interfacesR R ttwisted.internet.abstractR ttwisted.internet.mainRRttwisted.internet._sslRRRLtobjectRMRcRg(((s</usr/lib/python2.7/dist-packages/twisted/internet/_oldtls.pyts*  î 9