-
?c       sA     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" l# Z# l$ Z$ ) d d Z% + d e
 i& i' f d     YZ( 3 d e f d     YZ) G d f  d     YZ* K d e f d     YZ+  d e+ f d     YZ, Fd e+ f d     YZ- d e+ f d     YZ. Jd e+ f d     YZ/ d e i0 f d     YZ1 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_unpickles   handle_all_serialss   handle_serialss    i   s   TestServerStubc      s)   + t  Z , e i i i Z . d   Z RS(   Nc    s&   . 0 |  i |  |  _ 1 |  i Sd  S(   N(   s   selfs'   _TestServerStub__super_getInvalidationss   tids   _last_invals(   s   selfs   tid(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   getInvalidations. s   (   s   __name__s
   __module__s   ZEOs
   ServerStubs   StorageServers   getInvalidationss'   _TestServerStub__super_getInvalidations(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   TestServerStub+ s   	s   TestClientStoragec      sA   3 t  Z 5 e Z 7 e Z 9 d   Z = d   Z A d   Z RS(   Nc    s1   9 : 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_cache9 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	   endVerify= s   c    s4   A B z C t  i |  |  SWd  D E t |  _ Xd  S(   N(   s   ClientStorages   testConnections   selfs   conns   Trues   test_connection(   s   selfs   conn(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   testConnectionA s   (	   s   __name__s
   __module__s   Falses   test_connections   TestServerStubs   StorageServerStubClasss   verify_caches	   endVerifys   testConnection(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   TestClientStorage3 s
   			s   DummyDBc      s   G t  Z H d   Z RS(   Nc    s
   H I d  S(   N(    (   s   selfs   argss   kwargs(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys
   invalidateH s   (   s   __name__s
   __module__s
   invalidate(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   DummyDBG s   	s   CommonSetupTearDownc    	  s  K t  Z d  Z L N e i Z O e i Z P d Z Q e	 Z
 R e	 Z S d Z T e Z V d   Z h 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   V \ ] |  i   ^ t i d t i d |  i    _ t i   |  _ ` g  |  _	 a g  |  _
 b g  |  _ c g  |  _ d g  |  _ e |  i   f |  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   setUpV s   #c 	   sU  h i j t  i d t  i d |  i    k x$ |  i Dk ] } l t i |  q6 Wm t	 |  d t
  t
 j	 oa n |  i i   o t |  i d  o7 p t  i d t  i d |  i i  r |  i i   n n s x8 |  i Ds ]* } t | t
 j	 o u t i |  n q Wv t t d  o1 x x' |  i Dx ] } y t i | d  q.Wn z x |  i Dz ] } { x d d f D{ ] } | d	 | | f }  d }  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   tearDownh 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   CommonSetupTearDownK s(   					)	$s   ConnectionTestsc      s    t  Z d  Z   d   Z  d   Z d   Z d   Z ,d   Z 5d   Z Hd   Z	 `d   Z
 j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<   ,0|  i d d  |  _ 2|  i   3|  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   59|  i   :g  |  _ <|  i d d d d d d  >|  i d d  |  _ ?|  i |  i i    A|  i t	 |  i
  B|  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#   checkReadOnlyFallbackReadOnlyServer5s   c    s   HL|  i   |  _ N|  i   Q|  i   Rg  |  _ T|  i   V|  i t |  i  Y|  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   checkReconnectWritableHs   c    sd   `d|  i   e|  i d d d d |  _ f|  i t g|  i i d d  h|  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   checkDisconnectionError`s
   c    s8  jk|  i   |  _ l|  i   mg  i } t d  Dm] } | |  i i    q9 ~ } nt
   } o|  i i |  pxE | Dp]: } qt t |   } r|  i i | t | d |  q Ws|  i   t|  i t |  i i |  u|  i i |  v|  i d d  w|  i i   x|  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   checkDisconnectedAbortj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 o y |  i | d | PWnQ t j
 oB t i	 d t i
 d	 d
 t i   t   i   n Xt i d  q 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   errorf0.10000000000000001s   finished(   s   selfs   openClientStorages   _storages   new_oids   oids   MinPOs   objs   _dostores   zLOGs   LOGs   INFOs   shutdownServers   startServers   ClientDisconnecteds   syss   exc_infos   get_transactions   aborts   times   sleeps   close(   s   selfs   objs   oid(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkReconnections2   


 
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  1t d  | d <2t	   i
   5xX t d  D5]G } 6| i i   7| i i | i  o 8Pn 9t i d  q W:|  i | i i | i   =| i   >| i   i |  ?| i   i   @| i   A|  i | i | i  C| i   D| 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,   Ft  Z Gd Z Id   Z id   Z RS(   Ni   c    s  IJ|  i d d  } K|  i | i d  M|  i   |  _ N|  i i   } O|  i i   } R|  i |  i i d  U|  i	 |  } V|  i	 | |  } Y|  i	 |  } Z|  i	 | |  } \| i | d  ]| i   _|  i	 | |  } `|  i d d  } a|  i | i d  b|  i | i i c| | d f g f  e|  i | i | d  f|  i i | d   g| i   d  S(   Ns   caches   tests   full verifications    s   quick verification(   s   selfs   openClientStorages
   perstorages   assertEquals   verify_results   _storages   new_oids   oids   oid2s   _dostores   revids   revid2s   loads   closes   _servers   _last_invals(   s   selfs
   perstorages   oids   revid2s   revids   oid2(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys"   checkQuickVerificationWith2ClientsIs(   c    s  ij|  i d d  } k|  i | i d  m|  i   |  _ n|  i i   } q|  i |  i i d  t|  i |  } u|  i | |  } w| i
 | d  x| i   {x, t d  D{] } ||  i | |  } q W~|  i d d  } |  i | i d  t i   d } xP | i i   o; | 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)   checkVerificationWith2ClientsInvqOverflowis0    	 &(   s   __name__s
   __module__s   invqs"   checkQuickVerificationWith2Clientss)   checkVerificationWith2ClientsInvqOverflow(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys	   InvqTestsF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   } 2|  i |  i i d  5|  i |  } 6|  i | |  8| i
 | d  :|  i   <|  i   =t |  i _ >t | _ ?t i d t i d  @|  i d d d	 d  A|  i   B|  i d
 |  E|  i |  i i d  F|  i | i d  G| i   H|  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   Jt  Z Kd Z Md   Z Vd   Z ^d   Z ed   Z d   Z RS(   Ni   c    sx   MN|  i   } Ot   } P| i |  Q| i |  Rt i d  S|  i	 t
 | i |  T| 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   checkTimeoutMs   c    s_   VW|  i   } Xt   } Y| i |  Z| 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   checkTimeoutOnAbortVs   c    sO   ^_|  i   } `t   } a| i |  b| i |  c| 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   checkTimeoutOnAbortNoLock^s
   c    sK  ef|  i } g|  i } h|  i   |  _ } j| | i i	  l| i
   } mt d  } ot   } p| i |  q| i | t t |  d |  } r| i |  tt i d  u| i   v| | i    w| i   x| | i    z| t | i |  || | i i	  | t | i | d  d  S(   Ni   s    i   (   s   selfs   assertRaisess   raisess
   failUnlesss   unlesss   openClientStorages   _storages   storages   _caches   _indexs   new_oids   oids   MinPOs   objs   Transactions   ts	   tpc_begins   stores   ZEROs   zodb_pickles   revid1s   tpc_votes   times   sleeps   syncs   is_connecteds   _waits   ClientDisconnecteds
   tpc_finishs   KeyErrors   load(   s   selfs   unlesss   oids   storages   revid1s   raisess   objs   t(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutAfterVotees$   $c    s  |  i } |  i } |  i } |  i   |  _ } | | i
 i  | i   } t d  } t   } | i |  | i | t 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   i   i	   i
   i   (,   s   selfs   assertEquals   eqs   assertRaisess   raisess
   failUnlesss   unlesss   openClientStorages   _storages   storages   _caches   _indexs   new_oids   oids   MinPOs   objs   Transactions   ts	   tpc_begins   stores   ZEROs   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   raisess   revid2as   revid2bs   eqs   revid1as   revid1bs   objs   datas   revid2s   revid1s   t(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   checkTimeoutProvokingConflictssb   $$""$(   s   __name__s
   __module__s   timeouts   checkTimeouts   checkTimeoutOnAborts   checkTimeoutOnAbortNoLocks   checkTimeoutAfterVotes   checkTimeoutProvokingConflicts(    (    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   TimeoutTestsJ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(2   s   oss   syss   times   randoms   sockets   asyncores   tempfiles	   threadings   zLOGs   ZEO.ServerStubs   ZEOs   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   handle_serialss   ZEROs
   ServerStubs   StorageServers   TestServerStubs   TestClientStorages   DummyDBs   CommonSetupTearDowns   ConnectionTestss	   InvqTestss   ReconnectionTestss   TimeoutTestss   Threads	   MSTThread($   s   ConnectionTestss   Transactions   asyncores   TestClientStorages   TimeoutTestss	   MSTThreads   randoms   DBs   TestServerStubs   forkers   syss   ConflictErrors   get_transactions   StorageTestBases   handle_all_serialss   ReconnectionTestss   DummyDBs   MinPOs   ClientStorages   sockets   ClientDisconnecteds	   threadings   tempfiles   zodb_unpickles   zodb_pickles	   InvqTestss   ZEOs   CommonSetupTearDowns   DisconnectedErrors
   Marshallers   handle_serialss   ReadOnlyErrors   times   zLOGs   ZEROs   os(    (    sA   /usr/pkg/lib/python2.2/site-packages/ZEO/tests/ConnectionTests.pys   ? s>   " [Fz