File: //proc/3/root/usr/lib/python2.4/site-packages/M2Crypto/SSL/TwistedProtocolWrapper.pyo
mò
üäìPc @ s5 d Z d k i i Z d k Z d k l Z d k l Z d k l
Z
d k Z d k l Z l
Z
d k l Z d Z d „ Z d d e i i e i ƒ d
„ Z d d e i i e i ƒ d „ Z d d
e i i e d „ Z d d
e i i d d „ Z d f d „ ƒ YZ d f d „ ƒ YZ d e f d „ ƒ YZ d S( sx
M2Crypto.SSL.TwistedProtocolWrapper
Copyright (c) 2004-2005 Open Source Applications Foundation.
All rights reserved.
N( s ProtocolWrapper( s
ITLSTransport( s
implements( s m2s X509( s Checkeri c C s d S( Ni ( ( t peerX509t expectedHost( ( tG /usr/lib/python2.4/site-packages/M2Crypto/SSL/TwistedProtocolWrapper.pyt" _alwaysSucceedsPostConnectionCheck s i c s: t i | ƒ } ‡ ‡ d † | _ | i | | | | | ƒ S( s~
A convenience function to start an SSL/TLS connection using Twisted.
See IReactorSSL interface in Twisted.
c s% t | | d d d d d ˆ d ˆ ƒS( Nt startPassThroughi t clienti t contextFactoryt postConnectionCheck( t TLSProtocolWrappert factoryt wrappedProtocolR R ( R R
( R R ( R t <lambda># s
N( t policiest WrappingFactoryR t wrappingFactoryt protocolt reactort
connectTCPt hostt portt timeoutt bindAddress( R R R R R R R R R ( ( R R R t
connectSSL s c s7 t i | ƒ } ‡ d † | _ | i | | | | | ƒ S( s¶
A convenience function to start a TCP connection using Twisted.
NOTE: You must call startTLS(ctx) to go into SSL/TLS mode.
See IReactorTCP interface in Twisted.
c s% t | | d d d d d d d ˆ ƒS( NR i R R R ( R R R
t NoneR ( R R
( R ( R R 8 s
N( R R
R R R R R R R R R ( R R R R R R R R ( ( R R R - s i t c s7 t i | ƒ } ‡ ‡ d † | _ | i | | | | ƒ S( s~
A convenience function to listen for SSL/TLS connections using Twisted.
See IReactorSSL interface in Twisted.
c s% t | | d d d d d ˆ d ˆ ƒS( NR i R R R ( R R R
R R ( R R
( R R ( R R K s
N(
R R
R R R R t listenTCPR t backlogt interface( R R R R R R R R ( ( R R R t listenSSLB s c s4 t i | ƒ } ‡ d † | _ | i | | | | ƒ S( s¾
A convenience function to listen for TCP connections using Twisted.
NOTE: You must call startTLS(ctx) to go into SSL/TLS mode.
See IReactorTCP interface in Twisted.
c s% t | | d d d d d d d ˆ ƒS( NR i R i R R ( R R R
R R ( R R
( R ( R R ` s
N(
R R
R R R R R R R R ( R R R R R R R ( ( R R R U s t _SSLBioProxyc B s2 t Z d Z e i Z d „ Z d „ Z d „ Z RS( s
The purpose of this class is to eliminate the __del__ method from
TLSProtocolWrapper, and thus letting it be garbage collected.
c C s
| | _ d S( N( t sslBiot self( R R ( ( R t __init__r s c C s | i S( N( R R ( R ( ( R t _ptru s c C s( | i d j o | i | i ƒ n d S( N( R R R t m2_bio_free_all( R ( ( R t __del__x s ( t __name__t
__module__t __doc__t m2t bio_free_allR" R R! R# ( ( ( R R j s
t _SSLProxyc B s2 t Z d Z e i Z d „ Z d „ Z d „ Z RS( s
The purpose of this class is to eliminate the __del__ method from
TLSProtocolWrapper, and thus letting it be garbage collected.
c C s
| | _ d S( N( t sslR ( R R* ( ( R R … s c C s | i S( N( R R* ( R ( ( R R! ˆ s c C s( | i d j o | i | i ƒ n d S( N( R R* R t m2_ssl_free( R ( ( R R# ‹ s ( R$ R% R& R' t ssl_freeR+ R R! R# ( ( ( R R) } s
R c B sº t Z d Z e e ƒ d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d d d „ Z d d „ Z RS( sä
A SSL/TLS protocol wrapper to be used with Twisted. Typically
you would not use this class directly. Use connectTCP,
connectSSL, listenTCP, listenSSL functions defined above,
which will hook in this class.
c C s t o d GHn | | _ | | _ d | _ d | _ d | _ d | _ | | _ d | _
| d j o
t
| _ n
| | _ | p | i | i ƒ ƒ n d S( sŽ
@param factory:
@param wrappedProtocol:
@param startPassThrough: If true we won't encrypt at all. Need to
call startTLS() later to switch to SSL/TLS.
@param client: True if this should be a client protocol.
@param contextFactory: Factory that creates SSL.Context objects.
The called function is getContext().
@param postConnectionCheck: The post connection check callback that
will be called just after connection has
been established but before any real data
has been exchanged. The first argument to
this function is an X509 object, the second
is the expected host name string.
s TwistedProtocolWrapper.__init__R i N( t debugR R R
t datat encryptedt
tlsStartedt checkedR t isClientt helloDoneR R R R t startTLSR t
getContext( R R R
R R R R ( ( R R š s
c C s… t o d GHn t | d d ƒ o( d | _ d | _ d | _ d | _ n d | _ d | _ d | _
d | _ d | _ d | _
d S( sI
Clear this instance, after which it is ready for reuse.
s TwistedProtocolWrapper.clearR0 i R i N( R- t getattrR R R R* t internalBiot
networkBioR. R/ R0 R1 R2 R3 ( R ( ( R t clearÉ s
c C s¨ | i o
t d ‚ n t o d GHn | | _ t i t i ƒ ƒ | _ t i | i d ƒ t i t i ƒ ƒ | _
t i | i
d ƒ t i | i | i
ƒ t t i t i
ƒ ƒ ƒ | _ t t i | i i ƒ ƒ | _ | i o t i | i i ƒ ƒ n t i | i i ƒ ƒ t i | i i ƒ | i | i ƒ t i | i i ƒ | i i ƒ t i ƒ t i | i i ƒ ƒ } t i | i i ƒ | t i Bt i Bƒ d | _ d S( sq
Start SSL/TLS. If this is not called, this instance just passes data
through untouched.
s TLS already starteds TwistedProtocolWrapper.startTLSi i N( R R0 t ExceptionR- t ctxR' t bio_newt bio_s_bioR7 t bio_set_write_buf_sizeR8 t bio_make_bio_pairR t bio_f_sslR R) t ssl_newR* R2 t ssl_set_connect_stateR! t ssl_set_accept_statet ssl_set_biot bio_set_sslt bio_nocloset ssl_get_modet modet ssl_set_modet SSL_MODE_ENABLE_PARTIAL_WRITEt# SSL_MODE_ACCEPT_MOVING_WRITE_BUFFER( R R; RH ( ( R R4 Ý s,
"(c C s$ t o d GHn t i | | ƒ d S( Ns% TwistedProtocolWrapper.makeConnection( R- t ProtocolWrappert makeConnectionR t transport( R RN ( ( R RM s c C s® t o d GHn | i p t i | | ƒ d Sn y, | i | ƒ } t i | | ƒ d | _ WnI t i
i j
o7 } t
i | i i ƒ ƒ | i d f | _ | ‚ n Xd S( Ns TwistedProtocolWrapper.writei i ( R- R R0 RL t writeR. t _encryptt
encryptedDataR3 t M2Cryptot BIOt BIOErrort eR' t ssl_get_verify_resultR* R! t args( R R. RU RQ ( ( R RO
s
(c C sU t o d GHn | i p! t i | d i | ƒ ƒ d Sn | i d i | ƒ ƒ d S( Ns$ TwistedProtocolWrapper.writeSequenceR ( R- R R0 RL t
writeSequencet joinR. RO ( R R. ( ( R RX s
c C s! t o d GHn t i | ƒ d S( Ns% TwistedProtocolWrapper.loseConnection( R- RL t loseConnectionR ( R ( ( R RZ ' s c C s' t o d GHn t i | | | ƒ d S( Ns' TwistedProtocolWrapper.registerProducer( R- RL t registerProducerR t producert streaming( R R\ R] ( ( R R[ - s c C s! t o d GHn t i | ƒ d S( Ns) TwistedProtocolWrapper.unregisterProducer( R- RL t unregisterProducerR ( R ( ( R R^ 2 s c C s! t o d GHn t i | ƒ d S( Ns$ TwistedProtocolWrapper.stopConsuming( R- RL t
stopConsumingR ( R ( ( R R_ 7 s c C sN t o d GHn t i | ƒ | i o# | i o | i o | i ƒ n d S( Ns% TwistedProtocolWrapper.connectionMade( R- RL t connectionMadeR R0 R2 R3 t _clientHello( R ( ( R R` < s
c C sþ t o d GHn | i p t i | | ƒ d Sn | i | 7_ ym xf | i ƒ } | i ƒ | i
ƒ } t i | | ƒ t i | | ƒ | d j o | d j o PqG qG WWnI t
i i j
o7 } t i | i i ƒ ƒ | i d f | _ | ‚ n Xd S( Ns# TwistedProtocolWrapper.dataReceivedi R i ( R- R R0 RL t dataReceivedR. R/ t _decryptt
decryptedDatat _checkRP RQ RO RR RS RT RU R' RV R* R! RW ( R R. RU Rd RQ ( ( R Rb C s&
(c C s. t o d GHn | i ƒ t i | | ƒ d S( Ns% TwistedProtocolWrapper.connectionLost( R- R R9 RL t connectionLostt reason( R Rg ( ( R Rf _ s
c C sÓ t o d GHn | i o´ t i | i i ƒ ƒ o› t i | i i ƒ ƒ } | o t i | d ƒ } n d } | i o | i
i d } n | i
i ƒ i } | i | | ƒ p t i d ‚ n d | _ n d S( Ns TwistedProtocolWrapper._checki i s post connection check( R- R R1 R' t ssl_is_init_finishedR* R! t ssl_get_peer_certt xt X509t x509R R2 RN t addrR t getPeerR t Checkert SSLVerificationError( R Rl R Rj ( ( R Re e s $
c C s t o d GHn y/ | i d d ƒ } t i | | ƒ d | _ WnI t i i j
o7 } t i | i
i ƒ ƒ | i d f | _ | ‚ n Xd S( Ns# TwistedProtocolWrapper._clientHellot clientHelloi i ( R- R RP RQ RL RO R3 RR RS RT RU R' RV R* R! RW ( R RU RQ ( ( R Ra w s
(R i c C sî | i | 7_ t i | i i ƒ ƒ } | d j o | i d j p | oC t i | i i ƒ | i ƒ } | d j o qŽ | i | | _ n d } xS t i | i ƒ } | o4 t i | i | ƒ } | d j o | | 7} qå q— Pq— W| S( Ni R i ( R R. R' t bio_ctrl_get_write_guaranteeR R! t gRq t bio_writet rRQ t bio_ctrl_pendingR8 t pendingt bio_readt dR ( R R. Rq Ry Rs Ru RQ Rw ( ( R RP ‡ s& $
c C sç | i | 7_ t i | i ƒ } | d j oM | i d j o= t i | i | i ƒ } | d j o q{ | i | | _ n d } x_ t i
| i i ƒ ƒ } | o: t i | i i ƒ | ƒ } | d j o | | 7} qÞ q„ Pq„ W| S( Ni R i ( R R/ R. R' Rr R8 Rs Rt Ru Rd Rv R R! Rw Rx Ry R ( R R. Ry Rs Rd Ru Rw ( ( R Rc ¡ s$
( R$ R% R& t
implementst
ITLSTransportR R9 R4 RM RO RX RZ R[ R^ R_ R` Rb Rf Re Ra RP Rc ( ( ( R R s&
/ + ( R& t twisted.protocols.policiest protocolsR t twisted.internet.reactort twistedRL t twisted.internet.interfacesR{ t zope.interfaceRz RR R' Rk t M2Crypto.SSLRo R- R R t internetR R R R R R R) R ( Rz R RR R R R Rk R{ R Ro RL R R R R' R- R R) ( ( R t ? s"
!!