-í
Û„?c       sá  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 Z d  k
 Z
 d k l Z d k l Z d k l Z d k l Z d k l Z d k l Z d k l Z l Z d k l Z l Z d	 k l Z d
 k l  Z  d k l! Z! l" Z" d k l# Z# l$ Z$ d k l% Z% d e f d „  ƒ  YZ& d f  d „  ƒ  YZ' d e f d „  ƒ  YZ( d e( f d „  ƒ  YZ) d e( f d „  ƒ  YZ* d e( f d „  ƒ  YZ+ d e( f d „  ƒ  YZ, d e	 i- f d „  ƒ  YZ. d  S(   N(   s   ClientStorage(   s   ClientDisconnected(   s
   Marshaller(   s   DisconnectedError(   s   forker(   s   DB(   s   get_transactions   Transaction(   s   ReadOnlyErrors   ConflictError(   s   StorageTestBase(   s   MinPO(   s   zodb_pickles   zodb_unpickle(   s   handle_all_serialss   ZERO(   s   handle_serialss   TestClientStoragec      s)   t  Z d Z d „  Z d „  Z d „  Z RS(   Ni    c    s(   t  i ƒ  |  _ t i |  | ƒ |  _ d  S(   N(   s	   threadings   Events   selfs
   end_verifys   ClientStorages   verify_caches   stubs   verify_result(   s   selfs   stub(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   verify_cache0 s    c    s   t  i |  ƒ |  i i ƒ  d  S(   N(   s   ClientStorages	   endVerifys   selfs
   end_verifys   set(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys	   endVerify4 s    c    s%   z t  i |  | ƒ SWd  d |  _ Xd  S(   Ni   (   s   ClientStorages   testConnections   selfs   conns   test_connection(   s   selfs   conn(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   testConnection8 s     (   s   __name__s
   __module__s   test_connections   verify_caches	   endVerifys   testConnection(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   TestClientStorage, s   		s   DummyDBc      s   t  Z d „  Z RS(   Nc    s   d  S(   N(    (   s   selfs   argss   kwargs(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys
   invalidate? s    (   s   __name__s
   __module__s
   invalidate(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   DummyDB> s   s   CommonSetupTearDownc    	  sÚ   t  Z d  Z e i Z e i Z d Z e	 Z
 e	 Z d Z e Z d „  Z d „  Z d „  Z d „  Z d „  Z d Z e	 d d d d e	 e	 e	 d	 „ Z d
 „  Z d d d d e	 d „ Z d d „ Z d e	 d „ Z d d „ Z RS(   s   Common boilerplatei    c    s~   |  i ƒ  t i d t i d |  i ƒ  ƒ t i ƒ  |  _ g  |  _	 g  |  _
 g  |  _ g  |  _ g  |  _ |  i ƒ  |  i ƒ  d S(   sÎ   Test setup for connection tests.

        This starts only one server; a test may start more servers by
        calling self._newAddr() and then self.startServer(index=i)
        for i in 1, 2, ...
        s   testZEOs
   setUp() %sN(   s   selfs!   _CommonSetupTearDown__super_setUps   zLOGs   LOGs   INFOs   ids   tempfiles   mktemps   files   addrs   _pidss   _serverss
   conf_pathss   cachess   _newAddrs   startServer(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   setUpM s     
 					
c 	   sã  t  i d t  i d |  i ƒ  ƒ x |  i D] } t i | ƒ q* Wt	 |  d t
 ƒ t
 j	 oU |  i i ƒ  t |  i d ƒ o1 t  i d t  i d |  i i ƒ |  i i ƒ  n n x/ |  i D]$ } | t
 j	 o t i | ƒ n q¹ Wt t d ƒ o( x! |  i D] } t i | d ƒ qû Wn x¹ |  i D]® } x¥ d d f D]— } d	 | | f } d } t i i | ƒ oP d } xC t d
 ƒ D]5 } y t i  | ƒ Wn t! i" d ƒ n Xd } PqxWn | o t i  | ƒ n q6Wq#W|  i# ƒ  d S(   s   Try to cause the tests to halts   testZEOs   tearDown() %ss   _storages   cleanups   cleanup storage %ss   waitpidi    i   s   c1-%s-%d.zeci   f0.5N($   s   zLOGs   LOGs   INFOs   selfs   ids
   conf_pathss   ps   oss   removes   getattrs   Nones   _storages   closes   hasattrs   DEBUGs   __name__s   cleanups   _serverss	   adminaddrs   forkers   shutdown_zeo_servers   _pidss   pids   waitpids   cachess   cs   is   paths   need_to_deletes   existss   ranges   dummys   unlinks   times   sleeps$   _CommonSetupTearDown__super_tearDown(	   s   selfs   dummys   cs   need_to_deletes   is	   adminaddrs   pids   ps   path(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   tearDown_ sJ      
  
 
 
   	c    s   |  i i |  i ƒ  ƒ d  S(   N(   s   selfs   addrs   appends   _getAddr(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   _newAddrˆ s    c    s   d t  i d d d ƒ f Sd  S(   Ns	   localhosti¨a  i0u  i   (   s   randoms	   randrange(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   _getAddr‹ s    c    s
   t  ‚ d  S(   N(   s   NotImplementedError(   s   selfs   paths   creates	   read_only(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys	   getConfig s    i   i@ c	 
   s¥   | t j o( t |  i i ƒ } |  i i d 7_ n |  i i | ƒ t |  i	 d | d | d | d d d | d | d	 | d
 | d | ƒ	}	 |	 i t ƒ  t ƒ |	 Sd  S(   Ni   s   clients
   cache_sizes   waits   min_disconnect_pollf0.10000000000000001s	   read_onlys   read_only_fallbacks   usernames   passwords   realm(   s   caches   Nones   strs   selfs	   __class__s   cache_ids   cachess   appends   TestClientStorages   addrs
   cache_sizes   waits	   read_onlys   read_only_fallbacks   usernames   passwords   realms   storages
   registerDBs   DummyDB(
   s   selfs   caches
   cache_sizes   waits	   read_onlys   read_only_fallbacks   usernames   passwords   realms   storage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   openClientStorage” s     	c    s|   t  i | ƒ } | o d | _ n |  i o d d f | _ n |  i	 o |  i	 | _
 n |  i o |  i | _ n | Sd  S(   Ni   s    i¤  (   s   forkers	   ZEOConfigs   addrs   zconfs   ro_svrs	   read_onlys   selfs   monitors   monitor_addresss   invqs   invalidation_queue_sizes   timeouts   transaction_timeout(   s   selfs   addrs   ro_svrs   zconf(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   getServerConfig¨ s    


c    sã   |  i | } t i d t i d | | | | f ƒ d |  i | f }
 |  i
 |
 | | ƒ } |  i | | ƒ } | t j o |  i } n t i | | | d | ƒ \ } } }	 }
 |  i i |
 ƒ |  i i |	 ƒ |  i i | ƒ d  S(   Ns   testZEOs3   startServer(create=%d, index=%d, read_only=%d) @ %ss   %s.%di   (   s   selfs   addrs   indexs   zLOGs   LOGs   INFOs   creates	   read_onlys   files   paths	   getConfigs   sconfs   getServerConfigs   ro_svrs   zconfs   keeps   Nones   forkers   start_zeo_servers   zeoports	   adminaddrs   pids
   conf_pathss   appends   _pidss   _servers(   s   selfs   creates   indexs	   read_onlys   ro_svrs   keeps   sconfs   zconfs	   adminaddrs   pids   paths   zeoports   addr(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   startServer´ s    (c    sc   t  i d t  i d | |  i | f ƒ |  i | } | t j	 o t i	 | ƒ t |  i | <n d  S(   Ns   testZEOs   shutdownServer(index=%d) @ %s(
   s   zLOGs   LOGs   INFOs   indexs   selfs   _serverss	   adminaddrs   Nones   forkers   shutdown_zeo_server(   s   selfs   indexs	   adminaddr(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   shutdownServerÄ s
    'f30.0c    s   | t j o |  i } n t i ƒ  } | | } xJ | i ƒ  o; t	 i
 d ƒ t i ƒ  } | | j o |  i d ƒ n q3 Wd  S(   Nf0.10000000000000001s(   timed out waiting for storage to connect(   s   storages   Nones   selfs   _storages   times   nows   timeouts   giveups   is_connecteds   asyncores   polls   fail(   s   selfs   timeouts   storages   nows   giveup(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   pollUpÌ s    
 c    si   t  i  ƒ  } | | } xL |  i i ƒ  o; t i d ƒ t  i  ƒ  } | | j o |  i	 d ƒ n q Wd  S(   Nf0.10000000000000001s+   timed out waiting for storage to disconnect(
   s   times   nows   timeouts   giveups   selfs   _storages   is_connecteds   asyncores   polls   fail(   s   selfs   timeouts   giveups   now(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   pollDownØ s    
 (   s   __name__s
   __module__s   __doc__s   StorageTestBases   setUps!   _CommonSetupTearDown__super_setUps   tearDowns$   _CommonSetupTearDown__super_tearDowns   keeps   Nones   invqs   timeouts   monitors   DummyDBs   db_classs   _newAddrs   _getAddrs	   getConfigs   cache_ids   openClientStorages   getServerConfigs   startServers   shutdownServers   pollUps   pollDown(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   CommonSetupTearDownB s(    				)			!	s   ConnectionTestsc      s§   t  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 „  Z d „  Z d „  Z d „  Z RS(   s¡   Tests that explicitly manage the server process.

    To test the cache or re-connection, these test cases explicit
    start and stop a ZEO storage server.
    c    su   x t  d ƒ D] } |  i ƒ  q W|  i d d ƒ |  _ |  i i ƒ  } t d ƒ } |  i
 | d | ƒ|  i i ƒ  d  S(   Ni   s   testi † i   s   data(   s   ranges   is   selfs   _newAddrs   openClientStorages   _storages   new_oids   oids   MinPOs   objs   _dostores   close(   s   selfs   objs   is   oid(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkMultipleAddressesê s     c    s¼   |  i ƒ  |  i d d ƒ |  _ |  i ƒ  |  i d d ƒ |  i d d ƒ d } xL t d ƒ D]> } y |  i ƒ  d } PWn  t
 j
 o t i d ƒ n Xq\ W|  i | ƒ |  i i ƒ  d  S(   Ns   testi † s   indexi    i   i
   f0.5(   s   selfs   _newAddrs   openClientStorages   _storages   _dostores   shutdownServers   startServers   did_a_stores   ranges   is   ClientDisconnecteds   times   sleeps   assert_s   close(   s   selfs   is   did_a_store(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkMultipleServersó s     

 
c    s9   |  i d d ƒ |  _ |  i t |  i ƒ |  i i ƒ  d  S(   Ns	   read_onlyi   (   s   selfs   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostores   close(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReadOnlyClients    c    sh   |  i ƒ  g  |  _ |  i d d d d d d ƒ |  i d d ƒ |  _ |  i t |  i ƒ |  i i	 ƒ  d  S(   Ns   createi    s   indexs   ro_svri   s	   read_only(
   s   selfs   shutdownServers   _serverss   startServers   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostores   close(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReadOnlyServers    
	c    s0   |  i d d ƒ |  _ |  i ƒ  |  i i ƒ  d  S(   Ns   read_only_fallbacki   (   s   selfs   openClientStorages   _storages   _dostores   close(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReadOnlyFallbackWritable#s    
c    s~   |  i ƒ  g  |  _ |  i d d d d d d ƒ |  i d d ƒ |  _ |  i |  i i ƒ  ƒ |  i t	 |  i
 ƒ |  i i ƒ  d  S(   Ns   createi    s   indexs   ro_svri   s   read_only_fallback(   s   selfs   shutdownServers   _serverss   startServers   openClientStorages   _storages   assert_s
   isReadOnlys   assertRaisess   ReadOnlyErrors   _dostores   close(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys#   checkReadOnlyFallbackReadOnlyServer,s    
	c    s~   |  i ƒ  |  _ |  i ƒ  |  i ƒ  g  |  _ |  i ƒ  |  i t |  i ƒ |  i	 d d ƒ |  i
 ƒ  |  i ƒ  |  i i ƒ  d  S(   Ns   createi    (   s   selfs   openClientStorages   _storages   _dostores   shutdownServers   _serverss   pollDowns   assertRaisess   ClientDisconnecteds   startServers   pollUps   close(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnectWritable?s    

	


c    sR   |  i ƒ  |  i d d d d ƒ|  _ |  i t |  i i d d ƒ |  i i ƒ  d  S(   Ns   testiè  s   waiti    s   fredwashs    (   s   selfs   shutdownServers   openClientStorages   _storages   assertRaisess   ClientDisconnecteds   loads   close(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkDisconnectionErrorWs
    
	c    s  |  i ƒ  |  _ |  i ƒ  g  i } t d ƒ D] } | |  i i ƒ  ƒ q- ~ } t
 ƒ  } |  i i | ƒ x< | D]4 } t t | ƒ ƒ } |  i i | t | d | ƒ qo W|  i ƒ  |  i t |  i i | ƒ |  i i | ƒ |  i d d ƒ |  i i ƒ  |  i ƒ  d  S(   Ni   s    s   createi    (   s   selfs   openClientStorages   _storages   _dostores   appends   _[1]s   ranges   is   new_oids   oidss   Transactions   txns	   tpc_begins   oids   zodb_pickles   MinPOs   datas   stores   Nones   shutdownServers   assertRaisess   ClientDisconnecteds   tpc_votes	   tpc_aborts   startServers   _wait(   s   selfs   txns   is   oids   oidss   _[1]s   data(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkDisconnectedAbortas     
 "	  
c    sÏ   |  i d d ƒ |  _ |  i i ƒ  } t d ƒ } |  i | d | ƒ} |  i i	 ƒ  |  i
 ƒ  |  i d d d d ƒ|  _ |  i i | d ƒ \ } } |  i t | ƒ t d ƒ ƒ |  i | | ƒ |  i i	 ƒ  d  S(   Ns   testi † i   s   datas   waiti    s    (   s   selfs   openClientStorages   _storages   new_oids   oids   MinPOs   objs   _dostores   revid1s   closes   shutdownServers   loads   datas   revid2s   assertEquals   zodb_unpickle(   s   selfs   objs   revid2s   oids   datas   revid1(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkBasicPersistence„s    
c    sâ   |  i d d ƒ |  _ |  i i ƒ  } t d d ƒ } |  i | d | ƒ|  i i ƒ  } t d d ƒ } |  i | d | ƒ|  i i
 ƒ  |  i ƒ  |  i d d d d ƒ|  _ |  i i | d	 ƒ |  i i | d	 ƒ |  i i
 ƒ  d  S(
   Ns   testiè  s   1iô  s   datas   2s   waiti    s    (   s   selfs   openClientStorages   _storages   new_oids   oid1s   MinPOs   obj1s   _dostores   oid2s   obj2s   closes   shutdownServers   load(   s   selfs   obj1s   obj2s   oid1s   oid2(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkRollover—s    
c    s1  |  i ƒ  |  _ |  i i ƒ  } t d ƒ } |  i | d | ƒt i	 d t i
 d ƒ |  i ƒ  t i	 d t i
 d ƒ |  i d d ƒ |  i i ƒ  } t d ƒ } xi d oa y |  i | d | ƒPWnB t j
 o6 t i	 d t i
 d	 d
 t i ƒ  ƒt ƒ  i ƒ  n Xq¡ Wt i	 d t i
 d ƒ |  i i ƒ  d  S(   Ni   s   datas   checkReconnections   About to shutdown servers   About to restart servers   createi    i   s%   Error after server restart; retrying.s   errors   finished(   s   selfs   openClientStorages   _storages   new_oids   oids   MinPOs   objs   _dostores   zLOGs   LOGs   INFOs   shutdownServers   startServers   ClientDisconnecteds   syss   exc_infos   get_transactions   aborts   close(   s   selfs   objs   oid(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnection«s0    

 c    s   |  i d ƒ d  S(   Ns   salty(   s   selfs   _bad_message(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkBadMessage1Ós    c    sH   d f  d „  ƒ  Ya  t ƒ  i d d d t  ƒ  f ƒ } |  i | ƒ b  d  S(   Ns   Hackc      s   t  Z RS(   N(   s   __name__s
   __module__(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   HackÚs   i   i    s   foo(   s   Hacks
   Marshallers   encodes   msgs   selfs   _bad_message(   s   selfs   msg(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkBadMessage2×s
     !c    sª   |  i ƒ  |  _ |  i ƒ  |  i i i } | i | ƒ y |  i ƒ  Wn t	 j
 o n X|  i i
 ƒ  |  i d ƒ |  i i
 ƒ  |  i ƒ  |  _ |  i ƒ  |  i i
 ƒ  d  S(   Ns-   Server did not disconnect after bogus message(   s   selfs   openClientStorages   _storages   _dostores   _servers   rpcs	   zrpc_conns   message_outputs   msgs   ClientDisconnecteds   closes   fail(   s   selfs   msgs	   zrpc_conn(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   _bad_messageás    

c    s  d } | |  _ | |  _ | |  _ | |  _ x4 t d |  i ƒ D]  } |  i ƒ  |  i	 d | ƒ q= Wg  } z† xA t |  i ƒ D]0 } t |  d | ƒ } | i | ƒ | i ƒ  qz Wx; | D]3 } | i d ƒ |  i | i ƒ  d | i ƒ  ƒ qµ WWd  x | D] } | i ƒ  q÷ WXd  S(   Ni   i   s   indexs   T%di<   s   %s didn't die(   s   Ns   selfs   nserverss   nthreadss   ntranss   nobjs   ranges   is   _newAddrs   startServers   threadss	   MSTThreads   ts   appends   starts   joins   failIfs   isAlives   getNames   closeclients(   s   selfs   threadss   ts   is   N(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   NOcheckMultiStorageTransactions0    				 
  (  c    sl  t  |  i ƒ  ƒ } | i ƒ  } | i ƒ  } t d ƒ | d <t	 ƒ  i
 ƒ  t  |  i ƒ  ƒ } | i ƒ  i ƒ  } |  i | d i d ƒ t d ƒ | d <t	 ƒ  i
 ƒ  xI t d ƒ D]; } | i i ƒ  | i i | i ƒ o Pn t i d ƒ q¬ W|  i | i i | i ƒ ƒ | i ƒ  | i ƒ  i | ƒ | i ƒ  i ƒ  | i ƒ  |  i | i | i ƒ | i ƒ  | i ƒ  d  S(   Ns   as   bi
   f0.10000000000000001(    s   DBs   selfs   openClientStorages   db1s   opens   c1s   roots   r1s   MinPOs   get_transactions   commits   db2s   r2s   assertEquals   values   ranges   is   _storages   syncs   _invalidateds   has_keys   _p_oids   times   sleeps   assert_s   setLocalTransactions   getTransactions   registers   aborts   keyss	   _p_serials   close(   s   selfs   r1s   r2s   is   db1s   c1s   db2(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkCrossDBInvalidationss0     


(   s   __name__s
   __module__s   __doc__s   checkMultipleAddressess   checkMultipleServerss   checkReadOnlyClients   checkReadOnlyServers   checkReadOnlyFallbackWritables#   checkReadOnlyFallbackReadOnlyServers   checkReconnectWritables   checkDisconnectionErrors   checkDisconnectedAborts   checkBasicPersistences   checkRollovers   checkReconnections   checkBadMessage1s   checkBadMessage2s   _bad_messages   NOcheckMultiStorageTransactions   checkCrossDBInvalidations(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   ConnectionTestsã s$    											
	#			(		
	 	s	   InvqTestsc      s    t  Z d Z d „  Z d „  Z RS(   Ni   c    s  |  i d d ƒ } |  i | i d ƒ |  i ƒ  |  _ |  i i ƒ  } |  i |  i i d ƒ |  i | ƒ } |  i | | ƒ } | i
 | d ƒ | i ƒ  |  i | | ƒ } |  i d d ƒ } |  i | i d ƒ |  i | i
 | d ƒ |  i i
 | d ƒ ƒ | i ƒ  d  S(   Ns   caches   tests   full verifications    s   quick verification(   s   selfs   openClientStorages
   perstorages   assertEquals   verify_results   _storages   new_oids   oids   _dostores   revids   loads   close(   s   selfs   oids   revids
   perstorage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys"   checkQuickVerificationWith2ClientsCs    
c    s•  |  i d d ƒ } |  i | i d ƒ |  i ƒ  |  _ |  i i ƒ  } |  i |  i i d ƒ |  i | ƒ } |  i | | ƒ } | i
 | d ƒ | i ƒ  x& t d ƒ D] } |  i | | ƒ } q¡ W|  i d d ƒ } |  i | i d ƒ t i ƒ  d } xD | i i ƒ  o2 | i ƒ  t i ƒ  | j o |  i d ƒ n qõ W|  i |  i i
 | d ƒ d | ƒ |  i | i
 | d ƒ |  i i
 | d ƒ ƒ | i ƒ  d  S(	   Ns   caches   tests   full verifications    i   i   s   timed out waiting for endVerifyi   (   s   selfs   openClientStorages
   perstorages   assertEquals   verify_results   _storages   new_oids   oids   _dostores   revids   loads   closes   ranges   is   times   ts
   end_verifys   isSets   syncs   fail(   s   selfs   ts   is   oids   revids
   perstorage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys)   checkVerificationWith2ClientsInvqOverflow]s0    
  
#(   s   __name__s
   __module__s   invqs"   checkQuickVerificationWith2Clientss)   checkVerificationWith2ClientsInvqOverflow(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys	   InvqTests@s   	s   ReconnectionTestsc      s\   t  Z d Z d Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d	 „  Z
 d
 „  Z RS(   Ni   i   c  	  sa   |  i ƒ  g  |  _ |  i d d d d d d d d ƒ |  i d d ƒ |  _ |  i t |  i ƒ d  S(   Ns   createi    s   indexs	   read_onlyi   s   keep(	   s   selfs   shutdownServers   _serverss   startServers   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostore(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReadOnlyStorageˆs
    
	"c  	  sa   |  i ƒ  g  |  _ |  i d d d d d d d d ƒ |  i d d ƒ |  _ |  i t |  i ƒ d  S(   Ns   createi    s   indexs	   read_onlyi   s   keeps   read_only_fallback(	   s   selfs   shutdownServers   _serverss   startServers   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostore(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys$   checkReadOnlyFallbackReadOnlyStorage•s
    
	"c    s•   |  i d d ƒ |  _ |  i t |  i ƒ |  i ƒ  g  |  _ |  i ƒ  |  i t |  i ƒ |  i	 d d d d d d ƒ |  i
 ƒ  |  i t |  i ƒ d  S(   Ns	   read_onlyi   s   createi    s   keep(   s   selfs   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostores   shutdownServers   _serverss   pollDowns   startServers   pollUp(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnectReadOnly¢s    
	

c    sŒ   |  i d d ƒ |  _ |  i ƒ  |  i ƒ  g  |  _ |  i ƒ  |  i t |  i ƒ |  i	 d d d d d d ƒ |  i
 ƒ  |  i t |  i ƒ d  S(   Ns   read_only_fallbacki   s   createi    s	   read_onlys   keep(   s   selfs   openClientStorages   _storages   _dostores   shutdownServers   _serverss   pollDowns   assertRaisess   ClientDisconnecteds   startServers   pollUps   ReadOnlyError(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnectFallbackºs    

	

c    s¯   |  i ƒ  g  |  _ |  i d d d d ƒ |  i d d ƒ |  _ |  i t |  i ƒ |  i ƒ  g  |  _ |  i	 ƒ  |  i t
 |  i ƒ |  i d d d d ƒ |  i ƒ  |  i ƒ  d  S(   Ns   createi    s	   read_onlyi   s   read_only_fallbacks   keep(   s   selfs   shutdownServers   _serverss   startServers   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostores   pollDowns   ClientDisconnecteds   pollUp(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnectUpgradeÒs    
	
	

c  	  sã   |  i ƒ  g  |  _ |  i ƒ  |  i d d d d d d d d ƒ |  i d d ƒ |  _ |  i t |  i	 ƒ |  i d d d d d d ƒ xY t
 d ƒ D]> } y |  i	 ƒ  PWn& t t f j
 o t i d	 ƒ n Xq W|  i d
 ƒ d  S(   Ns   createi    s   indexs	   read_onlyi   s   keeps   read_only_fallbacki,  f0.10000000000000001s1   Couldn't store after starting a read-write server(   s   selfs   shutdownServers   _serverss   _newAddrs   startServers   openClientStorages   _storages   assertRaisess   ReadOnlyErrors   _dostores   ranges   is   ClientDisconnecteds   times   sleeps   fail(   s   selfs   i(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnectSwitchïs    
	
" 
c    s‰   |  i ƒ  |  _ |  i |  i i d ƒ |  i ƒ  |  i ƒ  |  i ƒ  t |  i _ |  i	 d d d d ƒ |  i
 ƒ  |  i |  i i d ƒ d  S(   Ns   full verifications   createi    s   keeps   no verification(   s   selfs   openClientStorages   _storages   assertEquals   verify_results   _dostores   shutdownServers   pollDowns   Nones   startServers   pollUp(   s   self(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys"   checkNoVerificationOnServerRestarts    



c    s;  |  i d d ƒ } |  i | i d ƒ |  i ƒ  |  _ |  i i ƒ  } |  i |  i i d ƒ |  i | ƒ } |  i | | ƒ | i
 | d ƒ |  i ƒ  |  i ƒ  t |  i _ t | _ t i d t i d ƒ |  i d d d	 d ƒ |  i ƒ  |  i d
 | ƒ |  i |  i i d ƒ |  i | i d ƒ | i ƒ  |  i i ƒ  d  S(   Ns   caches   tests   full verifications    s   testZEOs   2ALLBEEFs   createi    s   keeps   storages   no verification(   s   selfs   openClientStorages
   perstorages   assertEquals   verify_results   _storages   new_oids   oids   _dostores   revids   loads   shutdownServers   pollDowns   Nones   zLOGs   LOGs   INFOs   startServers   pollUps   close(   s   selfs   oids   revids
   perstorage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys.   checkNoVerificationOnServerRestartWith2Clientss(    

	

(   s   __name__s
   __module__s   keeps   invqs   checkReadOnlyStorages$   checkReadOnlyFallbackReadOnlyStorages   checkReconnectReadOnlys   checkReconnectFallbacks   checkReconnectUpgrades   checkReconnectSwitchs"   checkNoVerificationOnServerRestarts.   checkNoVerificationOnServerRestartWith2Clients(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   ReconnectionTests€s   						 	s   TimeoutTestsc      s;   t  Z d Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   Ni   c    s`   |  i ƒ  } t ƒ  } | i | ƒ | i | ƒ t i d ƒ |  i	 t
 | i | ƒ | i ƒ  d  S(   Ni   (   s   selfs   openClientStorages   storages   Transactions   txns	   tpc_begins   tpc_votes   times   sleeps   assertRaisess   ClientDisconnecteds
   tpc_finishs   close(   s   selfs   txns   storage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutAs    	c    sJ   |  i ƒ  } t ƒ  } | i | ƒ | i | ƒ | i | ƒ | i ƒ  d  S(   N(	   s   selfs   openClientStorages   storages   Transactions   txns	   tpc_begins   tpc_votes	   tpc_aborts   close(   s   selfs   txns   storage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutOnAbortJs    	c    s=   |  i ƒ  } t ƒ  } | i | ƒ | i | ƒ | i ƒ  d  S(   N(   s   selfs   openClientStorages   storages   Transactions   txns	   tpc_begins	   tpc_aborts   close(   s   selfs   txns   storage(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutOnAbortNoLockRs
    	c 	   s  |  i } |  i } |  i ƒ  |  _ } | | i i	 ƒ | i
 ƒ  } t d ƒ } d d } t ƒ  } | i | ƒ | i | | t | ƒ d | ƒ } | i | ƒ t i d ƒ | i ƒ  | | i ƒ  ƒ | i ƒ  | | i ƒ  ƒ | t | i | ƒ | | i i	 ƒ | t | i | d ƒ d  S(   Ni   s    i   s    i   (   s   selfs   assertRaisess   raisess
   failUnlesss   unlesss   openClientStorages   _storages   storages   _caches   _indexs   new_oids   oids   MinPOs   objs   ZEROs   Transactions   ts	   tpc_begins   stores   zodb_pickles   revid1s   tpc_votes   times   sleeps   syncs   is_connecteds   _waits   ClientDisconnecteds
   tpc_finishs   KeyErrors   load(	   s   selfs   unlesss   oids   storages   revid1s   ZEROs   raisess   objs   t(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutAfterVoteYs&    		
	!

c    s  |  i }	 |  i } |  i } |  i ƒ  |  _ } | | i
 i ƒ | i ƒ  } t d ƒ } d d } t ƒ  } | i | ƒ | i | | t | ƒ d | ƒ }
 | i | ƒ } t | |
 | ƒ } | i | ƒ d | _ t ƒ  } | i | ƒ | i | | t | ƒ d | ƒ } | i | ƒ } t | | | ƒ } t  i! d ƒ | i" ƒ  | | i# ƒ  ƒ | i$ ƒ  | | i# ƒ  ƒ | t% | i | ƒ d | _ t ƒ  } | i | ƒ | i | | t | ƒ d | ƒ | t& | i | ƒ | i' | ƒ | i | ƒ d | _ t ƒ  } | i | ƒ | i | | t | ƒ d | ƒ | t& | i | ƒ | i' | ƒ | i | ƒ d | _ t ƒ  } | i | ƒ | i | | t | ƒ d | ƒ } | i | ƒ } t | | | ƒ } | i | ƒ | i( | d ƒ \ } } |	 t+ | ƒ t d ƒ ƒ |	 | | ƒ d  S(	   Ni   s    i   s    i   i	   i
   i   (,   s   selfs   assertEquals   eqs   assertRaisess   raisess
   failUnlesss   unlesss   openClientStorages   _storages   storages   _caches   _indexs   new_oids   oids   MinPOs   objs   ZEROs   Transactions   ts	   tpc_begins   stores   zodb_pickles   revid1as   tpc_votes   revid1bs   handle_serialss   revid1s
   tpc_finishs   values   revid2as   revid2bs   revid2s   times   sleeps   syncs   is_connecteds   _waits   ClientDisconnecteds   ConflictErrors	   tpc_aborts   loads   datas   revids   zodb_unpickle(   s   selfs   unlesss   storages   oids   revids   ZEROs   raisess   revid2as   revid2bs   eqs   revid1as   revid1bs   objs   datas   revid2s   revid1s   t(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutProvokingConflictsvsd    			
	!		!

						!(   s   __name__s
   __module__s   timeouts   checkTimeouts   checkTimeoutOnAborts   checkTimeoutOnAbortNoLocks   checkTimeoutAfterVotes   checkTimeoutProvokingConflicts(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   TimeoutTests>s   					s	   MSTThreadc      s/   t  Z e i i Z d „  Z d „  Z d „  Z RS(   Nc    s&   |  i d | ƒ | |  _ g  |  _ d  S(   Ns   name(   s   selfs   _MSTThread__super_inits   names   testcases   clients(   s   selfs   testcases   name(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   __init__¾s    	c  	  sD  |  i ƒ  } |  i } |  i } xP t t | i ƒ ƒ D]9 } | i	 d | i | ƒ } d | | _ | i | ƒ q4 WxÌt | i ƒ D]»} x  | D] } g  | _ h  | _ qŽ Wt ƒ  } x | D] } | i | ƒ qº Wx£ t | i ƒ D]’ } x‰ | D] } | i ƒ  }
 | i i |
 ƒ t d | | i | | f ƒ }	 t |	 ƒ }	 | i |
 t |	 d | ƒ } | i i t |
 | ƒ ƒ qî Wqá Wx6 | D]. } | i | ƒ } | i i t t  | ƒ ƒ q~Wx | D] } | i! | ƒ q·Wxk | D]c } x* | i D] }
 | i" | i i# |
 ƒ ƒ qåWx- | i i$ ƒ  D] }
 | i" |
 | i j ƒ qWqÕWq Wd  S(   Ns   addrs   C%ds   %s.%s.t%d.o%ds    (%   s   selfs   getNames   tnames   testcases   clientss   ranges   lens   addrs   is   openClientStorages   cs   _MSTThread__names   appends   ntranss   _MSTThread__oidss   _MSTThread__serialss   Transactions   ts	   tpc_begins   nobjs   js   new_oids   oids   MinPOs   datas   zodb_pickles   stores   ZEROs   ss   updates   handle_all_serialss   tpc_votes   Nones
   tpc_finishs
   failUnlesss   has_keys   keys(   s   selfs   cs   is   clientss   ss   js   testcases   ts   tnames   datas   oid(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   runÃsV    		   		   !   
  c    s0   x) |  i D] } y | i ƒ  Wn n Xq
 Wd  S(   N(   s   selfs   clientss   cs   close(   s   selfs   c(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   closeclientsüs    
 (   s   __name__s
   __module__s	   threadings   Threads   __init__s   _MSTThread__super_inits   runs   closeclients(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys	   MSTThreadºs   		9(/   s   oss   syss   times   randoms   selects   sockets   asyncores   tempfiles   threads	   threadings   zLOGs   ZEO.ClientStorages   ClientStorages   ZEO.Exceptionss   ClientDisconnecteds   ZEO.zrpc.marshals
   Marshallers   ZEO.zrpc.errors   DisconnectedErrors	   ZEO.testss   forkers   ZODB.DBs   DBs   ZODB.Transactions   get_transactions   Transactions   ZODB.POSExceptions   ReadOnlyErrors   ConflictErrors   ZODB.tests.StorageTestBases   StorageTestBases   ZODB.tests.MinPOs   MinPOs   zodb_pickles   zodb_unpickles   handle_all_serialss   ZEROs   handle_serialss   TestClientStorages   DummyDBs   CommonSetupTearDowns   ConnectionTestss	   InvqTestss   ReconnectionTestss   TimeoutTestss   Threads	   MSTThread($   s   ConnectionTestss   Transactions   asyncores   TestClientStorages   TimeoutTestss	   MSTThreads   randoms   DBs   forkers   syss   ConflictErrors   get_transactions   StorageTestBases   handle_all_serialss   ReconnectionTestss   MinPOs   DummyDBs   selects   ClientStorages   sockets   threads	   threadings   tempfiles   zodb_unpickles   zodb_pickles	   InvqTestss   ZEROs   CommonSetupTearDowns   DisconnectedErrors
   Marshallers   handle_serialss   ClientDisconnecteds   times   zLOGs   oss   ReadOnlyError(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   ? sB   												¡ÿ ^@¾|