[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: