-í Û„?csâdkZdkZdklZlZdklZdklZdk l Z dk l Z l Z lZ*defd„ƒYZZdefd „ƒYZ¥d efd „ƒYZðd fd „ƒYZdS(N(schecksdisplay(sOOBTree(s TestThread(sDB(sReadConflictErrors ConflictErrorsVersionLockErrors StressThreadcs)*tZ0ded„Z<d„ZRS(Nic sz02ti||ƒ3||_4||_5||_6||_7||_8||_ 9g|_ :||_ dS(N( s TestThreads__init__sselfstestcasesdbsstops threadnumsstartnumsstepssleeps added_keyss commitdict( sselfstestcasesdbsstops threadnums commitdictsstartnumsstepssleep((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pys__init__0s       cs<=|iiƒ}>xs>|iiƒ o^?y@|iƒd}APWn9Btt fj o$Ct ƒi ƒD|i ƒnXqWE|i }FxìF|iiƒ o×GyoH|i||<It ƒid|ƒJt ƒiƒKd|i|<L|ioMti|iƒnWn;Nttfj o&}Ot ƒi ƒT|i ƒnXV|ii|ƒW||i7}q WX|iƒdS(Nstrees add key %si(sselfsdbsopenscnsstopsisSetsrootstrees ConflictErrorsKeyErrorsget_transactionsabortssyncsstartnumskeys threadnumsnotescommits commitdictssleepstimesReadConflictErrorsmsgs added_keyssappendsstepsclose(sselfscnskeysmsgstree((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pystestrun<s2  (s__name__s __module__sNones__init__stestrun(((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pys StressThread*s  sLargeUpdatesThreadcs)ZtZ`ded„Zld„ZRS(Nic sz`bti||ƒc||_d||_e||_f||_g||_h||_ ig|_ j||_ dS(N( s TestThreads__init__sselfstestcasesdbsstops threadnumsstartnumsstepssleeps added_keyss commitdict( sselfstestcasesdbsstops threadnums commitdictsstartnumsstepssleep((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pys__init__`s       c sëlm|iiƒ}nxsn|iiƒ o^oyp|iƒd}qPWn9rtt fj o$tt ƒi ƒu|i ƒnXqWwh}xg}yx"y|iiƒ o t|ƒ} €| djo.t|id|iƒ}‚t|ƒ} nƒtt| dƒdƒ}„gi} td| |ƒD„]}| ||ƒq@~ }…x]|D…]_}†y‡|i||t|ƒ} ?ti ƒ}A|i ƒ}Bt ƒ}|iƒd<CtƒiƒFh}G|i|||d|dƒ}H|i|| |d|dƒ} I|i|||| ƒK|iƒL|i||ƒM|i||| ƒO|iƒP|iƒQ| iƒdS(Nstreeii(sselfsopenClientStorages_storagesstorage1sstorage2sDBsdb1sdb2s threadingsEventsstopsopenscnsOOBTreestreesrootsget_transactionscommitscds StressThreadst1st2sgossyncs _check_trees_check_threadssclose( sselfsstorage2scnst1sstopstreescdsstorage1sdb1st2sdb2((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pyscheckConcurrentUpdates2Storages:s$ !!   c s4ST|iƒ|_}Ut|ƒ}Vtiƒ}X|i ƒ}Yt ƒ}|i ƒd<Ztƒiƒ]h}^|i|||d|dddƒ}_|i|||d|dddƒ}`|i||||ƒb|iƒc|i||ƒd|i|||ƒf|iƒg|iƒdS(Nstreeissleepf0.01i(sselfsopenClientStorages_storagesstorage1sDBsdb1s threadingsEventsstopsopenscnsOOBTreestreesrootsget_transactionscommitscds StressThreadst1st2sgossyncs _check_trees_check_threadssclose( sselfscnsstopstreescdsstorage1sdb1st2st1((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pyscheckConcurrentUpdates1StorageSs ''  c s€ij|iƒ|_}kt|ƒ}lt|iƒƒ} mtiƒ}o|i ƒ}pt ƒ}|iƒd<qtƒiƒxh}y|i|||d|ddƒ}z|i|| |d|dddƒ} {|i|| |d|dddƒ}||i|||| |ƒ~|iƒ|i||ƒ€|i||| |ƒ‚|iƒƒ|iƒ„| iƒdS(Nstreeiiif0.01(sselfsopenClientStorages_storagesstorage1sDBsdb1sdb2s threadingsEventsstopsopenscnsOOBTreestreesrootsget_transactionscommitscds StressThreadst1st2st3sgossyncs _check_trees_check_threadssclose( sselfscnst1sstopst3streescdsstorage1sdb1st2sdb2((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pys!checkConcurrentUpdates2StoragesMTis$ $''   c sw†‡|iƒ|_}ˆt|ƒ}‰t|iƒƒ} Štiƒ}Œ|i ƒ}t ƒ}|iƒd<Žtƒiƒ•h}–t|||d|ddƒ}—t|| |d|dddƒ} ˜t|| |d|dddƒ}™|i|||| |ƒ›|iƒœ|i||ƒ|i||| |ƒŸ|iƒ |iƒ¡| iƒdS(Nstreeiiif0.01(sselfsopenClientStorages_storagesstorage1sDBsdb1sdb2s threadingsEventsstopsopenscnsOOBTreestreesrootsget_transactionscommitscdsVersionStressThreadst1st2st3sgossyncs _check_trees_check_threadssclose( sselfscnst1sstopstreescdst3sstorage1sdb1st2sdb2((sC/usr/pkg/lib/python2.2/site-packages/ZEO/tests/InvalidationTests.pys checkConcurrentUpdatesInVersions†s$ !$$   c s(£¥|iƒ|_} ¦t| ƒ}§t|iƒƒ}¨tiƒ}ª|i ƒ}«t ƒ}|iƒd<¬x*tdddƒD¬]}­d||