m๒
LใธEc @ sๅ d Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k
Z
d k l Z d k
l Z d k l Z l Z l Z l Z l Z l Z l Z l Z l Z l Z l Z d k l Z d k l Z d k Z d k! l" Z" l# Z# l$ Z$ l% Z% d k& Z e i' d Z( d f d
YZ) d e i* f d YZ+ d
f d YZ, d Z- d e i e i e i e i. e i e i e$ i/ e% i% e, f d YZ0 d e0 e# i1 e# i2 e$ i3 e i4 e i5 e i6 e i e i e i e i f d YZ7 d e7 f d YZ8 d e0 f d YZ9 d e i: i; i< f d YZ= d e i: i; i< f d YZ> d e i: i; i< f d YZ? d e f d YZ@ e+ e8 e9 e@ e= e> e? g ZA d ZB eC d! j o e iD d" d# n d S($ s' Test suite for ZEO based on ZODB.tests.N( s MinPO( s
zodb_unpickle( s StorageTestBases BasicStorages VersionStorages TransactionalUndoStorages TransactionalUndoVersionStorages PackableStorages Synchronizations ConflictResolutions RevisionStorages MTStorages ReadOnlyStorage( s DemoStorageWrappedBase( s
ClientStorage( s forkers Caches CommitLockTestss ThreadTestss ZEO.tests.testZEOt DummyDBc B s t Z d Z RS( Nc G s d S( N( ( t selft args( ( t0 /data/zmath/zope/lib/python/ZEO/tests/testZEO.pyt
invalidate3 s ( t __name__t
__module__R ( ( ( R R 2 s t OneTimeTestsc B s t Z d Z RS( Nc C s# d k } | i t i | i d S( N( t ZEOR t assertEqualt ZODBt __version__t version( R R ( ( R t checkZEOVersionNumber8 s ( R R R
( ( ( R R 6 s t MiscZEOTestsc B s t Z d Z d Z d Z RS( s& ZEO tests that don't fit in elsewhere.c C s, t d d d d } | i d | d S( Nt Xi
i i t data( t MinPOt objR t _dostore( R R ( ( R t checkLargeUpdateA s c
C sB | i i } t | d d d d } z | i i } t d } | i
| d | } | i | d \ } } | i t | t d | i | | | i
| d t d d | } xp t d
D]V } t i d | i | d \ } } | | j o t | t d j o Pqษ qษ Wt d Wd | i Xd S( Nt waiti t min_disconnect_pollf0.10000000000000001t firstR t t secondt revidi s" Invalidation message was not sent!( R t _storaget _addrt addrt
ClientStoraget storage2t new_oidt oidR t obR t revid1t loadR t serialR t
zodb_unpicklet revid2t ranget nt timet sleept AssertionErrort close(
R R R! R' R" R# R) R% R R ( ( R t checkZEOInvalidationE s& !
& ( R R t __doc__R R. ( ( ( R R > s c C s x t d D]v } t i d d } t i t i t i } z8 y | i d | f Wn t i
j
o | Sn XWd | i Xq
Wt d d S( sษ Return a port that is not in use.
Checks if a port is in use by trying to connect to it. Assumes it
is not in use if connect raises an exception.
Raises RuntimeError after 10 tries.
i
i N i0u t localhostNs Can't find port(
R( t it randomt randranget portt sockett AF_INETt SOCK_STREAMt st connectt errorR- t RuntimeError( R1 R8 R4 ( ( R t get_port` s
t GenericTestsc B s> t Z d Z d Z d Z d d Z d Z d Z RS( s0 Combine tests from various origins in one class.c C sภ t i d | i t } t i d | f } t i | i
| | \ } } } } | g | _ | g | _ | | _ t | d d d d d d d d
d | _ | i i t d d S( Ns
setUp() %sR t 1t
cache_sizei -1R f0.5R i t wait_timeouti< ( t loggert infoR t idR< R4 t forkert ZEOConfigt zconft start_zeo_servert getConfigt zportt adminaddrt pidt patht _pidst _serverst
_conf_pathR R t
registerDBR t None( R RF RI RJ RK RL R4 ( ( R t setUp s c C sz | i i t i | i x | i D] } t i | q' Wt
t d o( x% | i D] } t i
| d qX Wn d S( Nt waitpidi ( R R R- t ost removeRO RN t serverRD t shutdown_zeo_servert hasattrRM RK RS ( R RK RV ( ( R t tearDown s
i c C s8 | i i } | i i t | d | d d | _ d S( Nt read_onlyR i ( R R R R R- R RZ ( R RZ R ( ( R t open s
c C s( t t d o t i i | n d S( NR ( RX R
t ReadOnlyStoraget checkWriteMethodsR ( R ( ( R R] ฆ s c C s9 d | i i | i i f } | i | i i | d S( Ns %s:%s( R R t _server_addrt keyR t sortKey( R R_ ( ( R t checkSortKeyฐ s ( R R R/ RR RY R[ R] Ra ( ( ( R R= u s
t FullGenericTestsc B s t Z d Z RS( s> Extend GenericTests with tests that MappingStorage can't pass.( R R R/ ( ( ( R Rb ด s
t FileStorageTestsc B s t Z d Z d Z d Z RS( s! Test ZEO backed by a FileStorage.i c C s t i } | _ d | S( NsG
path %s
( t tempfilet mktempt filenameR t _FileStorageTests__fs_base( R Rf ( ( R RH ว s ( R R R/ t levelRH ( ( ( R Rc ร s t MappingStorageTestsc B s t Z d Z d Z RS( s ZEO backed by a Mapping storage.c C s d S( Ns ( ( R ( ( R RH า s ( R R R/ RH ( ( ( R Ri ฯ s t HeartbeatTestsc B s; t Z d Z d Z d Z d Z d Z d Z RS( s๚ Make sure a heartbeat is being sent and that it does no harm
This is really hard to test properly because we can't see the data
flow between the client and server and we can't really tell what's
going on in the server very well. :(
c C sN t i i i | _ d t i i _ t i i i i t i i i
i | d S( Nf0.10000000000000001( R t zrpct
connectiont client_timeoutR t# _HeartbeatTests__old_client_timeoutt client_triggert pull_triggert testst ConnectionTestst CommonSetupTearDownRR ( R ( ( R RR ฿ s c C s? | i t i i _ t i i i i t i i i
i | d S( N( R Rn R Rk Rl Rm Ro Rp Rq Rr Rs RY ( R ( ( R RY ๆ s c C s d S( Ns ( ( R RL t createRZ ( ( R RH ๋ s c C s฿ t i i i } | i | _ t i d | i t i i i | j | i
t t d o+ t i
| i d t i d | i d ( ( R RL Rt RZ ( ( R RH s c s> | i | _ d f d Y} g d t i i i _ | t i i i
d # s f0.10000000000000001i i s The ZEO cient loop failed.t exc_infos Couldn't close a dispatcher.( R Rw R R R R Rk Rl t
client_loggert criticalt
client_mapRQ Ro Rp t DisconnectedErrorR* R+ t failIfR| R t lenRx ( R R R ( ( R R t" checkCatastrophicClientLoopFailure s"
( R R R/ RH R ( ( ( R R s t! ConnectionInvalidationOnReconnectc B s t Z d Z d Z d Z RS( s6 Test what happens when the client loop falls over
c C s d S( Ns ( ( R RL Rt RZ ( ( R RH ; s c C s t | i d d d d } | | _ x? t d D]% } | i o Pn t i d q1 Wt
d d f d Y} | } | i
| d | i } | i i x? t d D]% } | i o Pn t i d qต Wt
d | i | i | d d S( NR i R f0.10000000000000001id s Couldn't connect to serverR c B s t Z d Z d Z d Z RS( Ni c C s | i d 7_ d S( Ni ( R t _invalidatedCache( R ( ( R t invalidateCacheM s c O s d S( N( ( R t k( ( R R O s ( R R R R R ( ( ( R R K s ( R R R t storageR R( R1 R| R* R+ R, R t dbRP RQ R t baset _connectionR- R ( R R1 R R R R ( ( R t& checkConnectionInvalidationOnReconnect> s(
( R R R/ RH R ( ( ( R R 6 s t% DemoStorageWrappedAroundClientStoragec B s# t Z d Z d Z d Z RS( Nc C s d S( Ns ( ( R ( ( R RH h s c C sบ t i d | i t } t i d | f } t i | i
| | \ } } } } | g | _ | g | _ | | _ t | d d d d d d d d
d } | i t d | S( Ns
setUp() %sR R> R? i -1R f0.5R i R@ i< ( RA RB R RC R< R4 RD RE RF RG RH RI RJ RK RL RM RN RO R t _baseRP R RQ ( R RF RI RJ RK R RL R4 ( ( R t _makeBaseStoragek s c C sz t i | t i | i x | i D] } t i | q' Wt
t d o( x% | i D] } t i
| d qX Wn d S( NRS i ( t DemoStorageWrappedBaseRY R RT RU RO RN RV RD RW RX RM RK RS ( R RK RV ( ( R RY z s
( R R RH R RY ( ( ( R R f s c C s@ t i } x- t D]% } t i | d } | i | q W| S( Nt check( t unittestt TestSuitet suitet test_classest klasst makeSuitet subt addTest( Rก Rฅ Rฃ ( ( R t
test_suite s t __main__t defaultTestRง (E R/ t asyncoret loggingRT R2 Ry R5 Rd R* R R
t ZODB.tests.MinPOR t ZODB.tests.StorageTestBaseR& t
ZODB.testst StorageTestBaset BasicStoraget VersionStoraget TransactionalUndoStoraget TransactionalUndoVersionStoraget PackableStoraget Synchronizationt ConflictResolutiont RevisionStoraget MTStorageR\ t ZODB.tests.testDemoStorageR t ZEO.ClientStorageR t ZEO.zrpc.connectionR t ZEO.testsRD t Cachet CommitLockTestst ThreadTestst ZEO.tests.ConnectionTestst getLoggerRA R t TestCaseR R R< t SynchronizedStoraget CommitLockVoteTestsR= t StorageWithCachet TransUndoStorageWithCachet CommitLockUndoTestst ConflictResolvingStoraget! ConflictResolvingTransUndoStoraget PackableUndoStorageRb Rc Ri Rq Rr Rs Rj R R R Rข Rง R t main(- R= Rช R R2 Rฐ Ri Rด R Rj Rถ Rท R Rฒ Rd Rb Rธ Rต R< R R& R Rฝ Rพ Rฑ RD Rฏ Rc R Rง RA R Rซ R5 R\ R R Ry Rฟ R R Rณ R
Rข R* RT ( ( R t ? sF
I
" F?R < $ 0