[Zope3-checkins] CVS: Zope3/lib/python/ZEO - ClientCache.py:1.29
Guido van Rossum
guido@python.org
Thu, 19 Dec 2002 14:33:53 -0500
Update of /cvs-repository/Zope3/lib/python/ZEO
In directory cvs.zope.org:/tmp/cvs-serv18798
Modified Files:
ClientCache.py
Log Message:
Convert to using the logging module, using the sublogger machinery.
=== Zope3/lib/python/ZEO/ClientCache.py 1.28 => 1.29 ===
--- Zope3/lib/python/ZEO/ClientCache.py:1.28 Mon Nov 25 14:54:50 2002
+++ Zope3/lib/python/ZEO/ClientCache.py Thu Dec 19 14:33:52 2002
@@ -105,10 +105,10 @@
import tempfile
from struct import pack, unpack
from thread import allocate_lock
+import logging
from ZODB.utils import u64
-import zLOG
from ZEO.ICache import ICache
magic='ZEC0'
@@ -127,6 +127,10 @@
self._storage = storage
self._limit = size / 2
+ # Create a logger specific for this client cache
+ logger = logging.getLogger("ZEC.%s" % storage)
+ self.log = logger.warn
+
# Allocate locks:
L = allocate_lock()
self._acquire = L.acquire
@@ -182,8 +186,7 @@
f[0].write(magic)
current = 0
- self.log("%s: storage=%r, size=%r; file[%r]=%r" %
- (self.__class__.__name__, storage, size, current, p[current]))
+ self.log("size=%r; file[%r]=%r", size, current, p[current])
self._current = current
self._setup_trace()
@@ -240,14 +243,14 @@
h = f.read(27)
if len(h) != 27:
self.log("invalidate: short record for oid %16x "
- "at position %d in cache file %d"
- % (u64(oid), ap, p < 0))
+ "at position %d in cache file %d",
+ u64(oid), ap, p < 0)
del self._index[oid]
return None
if h[:8] != oid:
self.log("invalidate: oid mismatch: expected %16x read %16x "
- "at position %d in cache file %d"
- % (u64(oid), u64(h[:8]), ap, p < 0))
+ "at position %d in cache file %d",
+ u64(oid), u64(h[:8]), ap, p < 0)
del self._index[oid]
return None
f.seek(ap+8) # Switch from reading to writing
@@ -281,8 +284,8 @@
tlen = -1
if tlen <= 0 or vlen < 0 or dlen < 0 or vlen+dlen > tlen:
self.log("load: bad record for oid %16x "
- "at position %d in cache file %d"
- % (u64(oid), ap, p < 0))
+ "at position %d in cache file %d",
+ u64(oid), ap, p < 0)
del self._index[oid]
return None
@@ -452,8 +455,8 @@
tlen = -1
if tlen <= 0 or vlen < 0 or dlen < 0 or vlen+dlen > tlen:
self.log("modifiedInVersion: bad record for oid %16x "
- "at position %d in cache file %d"
- % (u64(oid), ap, p < 0))
+ "at position %d in cache file %d",
+ u64(oid), ap, p < 0)
del self._index[oid]
return None
@@ -480,7 +483,7 @@
current = not self._current
self._current = current
self._trace(0x70)
- self.log("flipping cache files. new current = %d" % current)
+ self.log("flipping cache files. new current = %d", current)
# Delete the half of the index that's no longer valid
index = self._index
for oid in index.keys():
@@ -562,9 +565,9 @@
self._trace(0x00)
except IOError, msg:
self._tracefile = None
- self.log("cannot write tracefile %s (%s)" % (tfn, msg))
+ self.log("cannot write tracefile %s (%s)", tfn, msg)
else:
- self.log("opened tracefile %s" % tfn)
+ self.log("opened tracefile %s", tfn)
if self._tracefile is None:
def notrace(*args):
pass
@@ -663,15 +666,12 @@
pass
if count:
- self.log("read_index: cache file %d has %d records and %d bytes"
- % (fileindex, count, pos))
+ self.log("read_index: cache file %d has %d records and %d bytes",
+ fileindex, count, pos)
return pos
def rilog(self, msg, pos, fileindex):
- # Helper to log messages from read_index
- self.log("read_index: %s at position %d in cache file %d"
- % (msg, pos, fileindex))
-
- def log(self, msg, level=zLOG.INFO):
- zLOG.LOG("ZEC:%s" % self._storage, level, msg)
+ # Helper to log certain messages from read_index
+ self.log("read_index: %s at position %d in cache file %d",
+ msg, pos, fileindex)