[Zodb-checkins] CVS: Zope3/src/zodb/zeo - client.py:1.6 server.py:1.8

Albertas Agejevas alga@codeworks.lt
Thu, 13 Mar 2003 13:49:29 -0500


Update of /cvs-repository/Zope3/src/zodb/zeo
In directory cvs.zope.org:/tmp/cvs-serv1411/src/zodb/zeo

Modified Files:
	client.py server.py 
Log Message:
An unexpected raid by the Whitespace Police.

Other than fixes of nonconforming whitespace, just a couple of $Id$
docstrings has been added.



=== Zope3/src/zodb/zeo/client.py 1.5 => 1.6 ===
--- Zope3/src/zodb/zeo/client.py:1.5	Tue Feb 25 13:55:05 2003
+++ Zope3/src/zodb/zeo/client.py	Thu Mar 13 13:48:58 2003
@@ -99,7 +99,7 @@
     # connects to.  We know that every storage must implement IStorage,
     # but once connected we may change the instance's __implements__
     # to reflect features available on the storage.
-    
+
     __implements__ = IStorage
 
     def __init__(self, addr, storage='1', cache_size=20 * MB,
@@ -189,12 +189,12 @@
         # but _server is set only after cache verification has finished
         # and clients can safely use the server.  _pending_server holds
         # a server stub while it is being verified.
-        
+
         self._server = disconnected_stub
         self._connection = None
         self._pending_server = None
         self._ready = threading.Event()
-        
+
         self._is_read_only = read_only
         self._storage = storage
         self._read_only_fallback = read_only_fallback
@@ -204,7 +204,7 @@
         self._pickler = None
 
         self._info = {'length': 0, 'size': 0, 'name': 'ZEO Client'}
-        
+
         self._tbuf = self.TransactionBufferClass()
         self._db = None
 
@@ -325,7 +325,7 @@
         # If there is no connection, return immediately.  Technically,
         # there are no pending invalidations so they are all handled.
         # There doesn't seem to be much benefit to raising an exception.
-        
+
         cn = self._connection
         if cn is not None:
             cn.pending()
@@ -376,7 +376,7 @@
             # the storage was closed, but the connect thread called
             # this method before it was stopped.
             return
-        
+
         # XXX would like to report whether we get a read-only connection
         if self._connection is not None:
             reconnect = 1
@@ -449,7 +449,7 @@
         # If verify_cache() finishes the cache verification process,
         # it should set self._server.  If it goes through full cache
         # verification, then endVerify() should self._server.
-        
+
         last_inval_tid = self._cache.getLastTid()
         if last_inval_tid is not None:
             ltid = server.lastTransaction()


=== Zope3/src/zodb/zeo/server.py 1.7 => 1.8 ===
--- Zope3/src/zodb/zeo/server.py:1.7	Tue Feb 25 13:55:05 2003
+++ Zope3/src/zodb/zeo/server.py	Thu Mar 13 13:48:58 2003
@@ -601,7 +601,7 @@
         monitor_address -- The address at which the monitor server
             should listen.  If specified, a monitor server is started.
             The monitor server provides server statistics in a simple
-            text format. 
+            text format.
         """
 
         self.addr = addr
@@ -714,13 +714,13 @@
         if not self.invq:
             self.logger.warn("invq empty")
             return None, []
-        
+
         earliest_tid = self.invq[0][0]
         if earliest_tid > tid:
             self.logger.warn("tid to old for invq %s < %s",
                              u64(tid), u64(earliest_tid))
             return None, []
-        
+
         oids = {}
         for tid, L in self.invq:
             for key in L: