-ํ \&“=csidZdkZdkZdkZdkZdkZdkZdklZdk Z dk Z dk Z dk Z dk Z dZdZdZdZ dZ!dZ#deifd „ƒYZ,d eifd „ƒYZ4d „ZAd „ZFed„ZXd„Z€ed„ZedjožeƒndS(s-A multi-client test of the ZEO storage serverN(sforkeriiidf0.10000000000000001ssRecordcs)#tZ$eed„Z)d„ZRS(Ncs+$%||_&t|_'t|_dS(N(sclientsselfsNonesvaluesnext(sselfsclientsvalue((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pys__init__$s  cs)*||_dS(N(snextsself(sselfsnext((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pysset_next)s(s__name__s __module__sNones__init__sset_next(((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pysRecord#s sStatscs#,tZ-d„Z1d„ZRS(Ncs%-.tiƒ|_/t|_dS(N(stimesselfsbeginsNonesend(sself((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pys__init__-scs12tiƒ|_dS(N(stimesselfsend(sself((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pysdone1s(s__name__s __module__s__init__sdone(((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pysStats,s  cs–45tiƒ}6to7dG|GHn8tii|ƒ}:ti|ƒ};|i ƒi ƒ}<t i ƒ|d<=t ƒi ƒ?|SdS(NsFileStorage path:smulti(stempfilesmktempspathsVERBOSEsZODBs FileStoragesfssDBsdbsopensrootsPersistentMappingsget_transactionscommit(srootspathsdbsfs((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pys init_storage4s cs;ABtƒ}Cti||ƒ\}}D||fSdS(N(s init_storagesstoragesforkersstart_zeo_serversaddrspidsexit(saddrsexitsstoragespid((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pys start_serverAs csัFGtiƒ}H|djoคIz†Jdk}KtoLdGtiƒGHnM|ii|dt ƒ}N|t joOt |ƒnQ||ƒR|iƒWdSTtidƒXnV|SdS(NisClient process started:sclient(sossforkspidsZEO.ClientStoragesZEOsVERBOSEsgetpids ClientStoragesaddrs CLIENT_CACHEsclis client_funcsNonesrunscloses_exit(saddrs client_funcspidsZEOscli((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pys start_clientFs   c scXYt|dƒo0Zx&Z|iƒ o[titƒqWn\tiƒ}]dG|G|GH^t i |ƒ}_|i ƒi ƒ}`x}`doray(btƒ}||<ctƒiƒWn<dt iij o'etƒiƒftitƒnXhPq’Wj|d} kt} ld}mxm|tjo๑ny[ot| ƒ}pt||ƒ}| |<q| or| i|ƒnstƒiƒWn>tt iij o)}utƒiƒvtitƒnPXx|d}yt!o|djp|ddjozd||tfGHnq4W{|i"ƒ|tƒiƒ~d G|GHdS( Ns is_connectedsClient process connected:ismultiiii sClient %s: %s of %ssClient completed:(#shasattrsstorages is_connectedstimessleeps CONNECT_DELAYsossgetpidspidsZODBsDBsdbsopensrootsStatssssget_transactionscommits POSExceptions ConflictErrorsabortsCONFLICT_DELAYsdictsNonesprevsisRECORDS_PER_CLIENTslenssizesRecordsrsset_nextserrsVERBOSEsdone( sstoragesdbspidsrssizeserrsisrootsssdictsprev((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pysrunXsJ       ( c sฮ€to‚dGtiƒGHnƒtiƒ}„tiƒ}…t|ƒ\}}†tiƒ} ‡g}ˆx0t tƒDˆ]} ‰|it||ƒƒq~WŠxม|DŠ]ถ}‹to6t|ƒtijp tdt|ƒt|ƒf‚y7Žtodt|ƒGHnti|dƒWn3‘tij o!}’dt|ƒ|fGHnXqฎW“tiƒ}”|iƒ•ti|dƒ™dG||GHšdG| |GH›dG|| GHdS( Ns Main process:sinvalid pid type: %s (%s)s waitpid(%s)iswaitpid(%s) failed: %ss Total time:sServer start times Client time:(sVERBOSEsossgetpidstempfilesmktempsaddrstimest0s start_servers server_pidsserverst1spidssrangesCLIENTSsisappends start_clients client_funcspids __debug__stypestypessIntTypesAssertionErrorsreprswaitpidserrorserrst2sclose( s client_funcspids server_pidspidssserversaddrserrst2st0st1si((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pysmain€s2    @ ! s__main__(s__doc__sZODBsZODB.DBsZODB.FileStoragesZODB.POSExceptions PersistencesPersistentMappings ZEO.testssforkersasyncoresosstempfilestimestypessVERBOSEsCLIENTSsRECORDS_PER_CLIENTsCONFLICT_DELAYs CONNECT_DELAYs CLIENT_CACHEs PersistentsRecordsStatss init_storages start_serversNones start_clientsrunsmains__name__(s CLIENT_CACHEsasyncoresRECORDS_PER_CLIENTsStatssCLIENTSsCONFLICT_DELAYsforkersRecordsZODBsPersistentMappingsruns PersistencesVERBOSEs start_serverstempfiles start_clients CONNECT_DELAYstypesstimes init_storagesmainsos((s7/usr/pkg/lib/python2.2/site-packages/ZEO/tests/multi.pys?s0 '                (