-
?c       sG     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' B 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      s8   , t  Z . d Z 0 d   Z 4 d   Z 8 d   Z RS(   Ni    c    s1   0 1 t  i   |  _ 2 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'   4 5 t  i |   6 |  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    s4   8 9 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  B t  Z d  Z C E e i Z F e i Z G d Z H e	 Z
 I e	 Z J d Z K e Z M 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   M S T |  i   U t i d t i d |  i    V t i   |  _ W g  |  _	 X g  |  _
 Y g  |  _ Z 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 	   sU  _ ` a t  i d t  i d |  i    b x$ |  i Db ] } c t i |  q6 Wd t	 |  d t
  t
 j	 oa e |  i i   f t |  i d  o7 g t  i d t  i d |  i i  i |  i i   n n j x8 |  i Dj ]* } k | t
 j	 o l t i |  n q Wm t t d  o1 o x' |  i Do ] } p t i | d  q.Wn q x |  i Dq ] } r x d d f Dr ] } s d	 | | f } y d } z t i i |  ok { d } | xX t d
  D| ]G } } y ~ t i  |  Wn   t! i" d  n X d }  PqWn  | o  t i  |  n qx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	   localhostia  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    su     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   }  | | }  xY  | i   oG  t	 i
 d   t i   }  | | j o  |  i d  n qE 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    s     t  i    }  | | }  x[  |  i i   oG  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	 Wd   Z
 a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    s     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 } xa t d  D]P } y |  i   d } PWn& t
 j
 o t i d  n Xqt 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    sE   |  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    s}   |  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    s<   #'|  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   ,0|  i   1g  |  _ 3|  i d d d d d d  5|  i d d  |  _ 6|  i |  i i    8|  i t	 |  i
  9|  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   ?C|  i   |  _ E|  i   H|  i   Ig  |  _ K|  i   M|  i t |  i  P|  i	 d d  R|  i
   T|  i   U|  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    sd   W[|  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    s8  ab|  i   |  _ c|  i   dg  i } t d  Dd] } | |  i i    q9 ~ } et
   } f|  i i |  gxE | Dg]: } ht t |   } i|  i i | t | d |  q Wj|  i   k|  i t |  i i |  l|  i i |  m|  i d d  n|  i i   o|  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    s|  |  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  } x d oy y |  i | d | PWnQ t j
 oB t i	 d t i
 d	 d
 t i   t   i   n Xq Wt 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    sZ   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 } | |  _ | |  _ | |  _ | |  _ x= t d |  i  D]& } |  i   |  i	 d |  qR Wg  } z xM t |  i  D]9 } t |  d |  } | i |  | i   q WxD | D]9 } | 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    s  t  |  i    }  | i   } !| i   } #t d  | d <$t	   i
   &t  |  i    } '| i   i   } )|  i | d i d  +t d  | d <,t	   i
   /xX t d  D/]G } 0| i i   1| i i | i  o 2Pn 3t i d  q W4|  i | i i | i   7| i   8| i   i |  9| 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 Ad Z Cd   Z ]d   Z RS(   Ni   c    s4  CD|  i d d  } E|  i | i d  G|  i   |  _ H|  i i   } K|  i |  i i d  N|  i |  } O|  i | |  } Q| i
 | d  R| i   T|  i | |  } V|  i d d  } W|  i | i d  Y|  i | i
 | d  Z|  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  a|  i   |  _ b|  i i   } e|  i |  i i d  h|  i |  } i|  i | |  } k| i
 | d  l| i   ox, t d  Do] } p|  i | |  } q Wr|  i d d  } s|  i | i d  tt i   d } uxP u| i i   o; v| i   wt i   | j o x|  i d  n q(Wz|  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  	  ss   |  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  	  ss   |  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  xn t
 d  D]M } 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    sz  |  i d d  }  |  i | i d  "|  i   |  _ #|  i i   } &|  i |  i i d  )|  i |  } *|  i | |  ,| i
 | d  .|  i   0|  i   1t |  i _ 2t | _ 3t i d t i d  4|  i d d d	 d  5|  i   6|  i d
 |  9|  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      sP   >t  Z ?d Z Ad   Z Jd   Z Rd   Z Yd   Z vd   Z RS(   Ni   c    sx   AB|  i   } Ct   } D| i |  E| i |  Ft i d  G|  i	 t
 | i |  H| 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    s_   JK|  i   } Lt   } M| i |  N| i |  O| i |  P| 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    sO   RS|  i   } Tt   } U| i |  V| i |  W| 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 	   sX  YZ|  i } [|  i } \|  i   |  _ } ^| | i i	  `| i
   } at d  } bd d } dt   } e| i |  f| i | | t |  d |  } g| i |  it i d  j| i   k| | i    l| i   m| | i    o| t | i |  q| | i i	  t| 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  vw|  i }	 x|  i } y|  i } z|  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    s2   |  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  	  s  |  i   } |  i } |  i } x\ t t | i   D]B } | i	 d | i |  } d | | _ | i |  qC Wx2t | i  D]} x) | D] } g  | _ h  | _ q Wt   } x! | D] } | i |  q Wx t | i  D] } x | D] } | i   }
 | i i |
  t d | | i | | f  }	 t |	  }	 | i |
 t |	 d |  } | i i t |
 |   q0WqWx? | D]4 } | i |  } | i i t t  |   qWx! | D] } | i! |  qWx | D]u } x0 | i D]" }
 | i" | i i# |
   qZWx3 | i i$   D] }
 | i" |
 | i j  qWqD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    sE   x8 |  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    ^@|